def parse_sql()

in gremlin/glue-neptune/glue-jobs/common/load_mysql.py [0:0]


def parse_sql(filename):
    
    DELIMITER = ';'
    statements = []
    statement = ''
    
    data = open(filename, 'r').readlines()
    
    for lineno, line in enumerate(data):
        if not line.strip():
            continue

        if line.startswith('--'):
            continue

        if 'DELIMITER' in line:
            DELIMITER = line.split()[1]
            continue

        if (DELIMITER not in line):
            statement += line.replace(DELIMITER, ';')
            continue

        if statement:
            statement += line
            statements.append(statement.strip())
            statement = ''
        else:
            statements.append(line.strip())
    return statements