Skip to content

Commit 379eb84

Browse files
Update join in parse_sql.
1 parent 281561d commit 379eb84

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

datajoint/utils.py

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -99,15 +99,15 @@ def safe_copy(src, dest, overwrite=False):
9999

100100
def parse_sql(filepath):
101101
DELIMITER = ';'
102-
statement = ''
102+
statement = []
103103
with open(filepath, 'rt') as f:
104104
for line in f:
105105
line = line.strip()
106106
if not line.startswith('--') and len(line) > 1:
107-
if not line.startswith('DELIMITER'):
108-
statement += ' ' + line
109-
if line.endswith(DELIMITER):
110-
yield statement[1:]
111-
statement = ''
107+
if line.startswith('DELIMITER'):
108+
DELIMITER = line.split()[1]
112109
else:
113-
DELIMITER = line.split()[1]
110+
statement.append(line)
111+
if line.endswith(DELIMITER):
112+
yield ' '.join(statement)
113+
statement = []

0 commit comments

Comments
 (0)