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