Skip to content

Commit 90a8a0d

Browse files
author
Glendon Solsberry
committed
Handle all triggers on tables
1 parent 41cce83 commit 90a8a0d

File tree

1 file changed

+15
-12
lines changed

1 file changed

+15
-12
lines changed

mysql2pgsql/lib/mysql_reader.py

Lines changed: 15 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -185,18 +185,21 @@ def _load_indexes(self):
185185
continue
186186

187187
def _load_triggers(self):
188-
explain = self.reader.db.query('SHOW TRIGGERS WHERE `table` = \'%s\'' % self.name, one=True)
189-
if type(explain) is tuple:
190-
trigger = {}
191-
trigger['name'] = explain[0]
192-
trigger['event'] = explain[1]
193-
trigger['statement'] = explain[3]
194-
trigger['timing'] = explain[4]
195-
196-
trigger['statement'] = re.sub('^BEGIN', '', trigger['statement'])
197-
trigger['statement'] = re.sub('^END', '', trigger['statement'], flags=re.MULTILINE)
198-
199-
self._triggers.append(trigger)
188+
explain = self.reader.db.query('SHOW TRIGGERS WHERE `table` = \'%s\'' % self.name)
189+
for row in explain:
190+
pprint(row)
191+
if type(row) is tuple:
192+
trigger = {}
193+
trigger['name'] = row[0]
194+
trigger['event'] = row[1]
195+
trigger['statement'] = row[3]
196+
trigger['timing'] = row[4]
197+
198+
trigger['statement'] = re.sub('^BEGIN', '', trigger['statement'])
199+
trigger['statement'] = re.sub('^END', '', trigger['statement'], flags=re.MULTILINE)
200+
trigger['statement'] = re.sub('`', '', trigger['statement'])
201+
202+
self._triggers.append(trigger)
200203

201204
@property
202205
def name(self):

0 commit comments

Comments
 (0)