File tree 1 file changed +4
-3
lines changed
1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -1314,6 +1314,8 @@ def test_sync_drop_table_map_event_table_schema(self):
1314
1314
self .execute (insert_query )
1315
1315
1316
1316
self .execute ("COMMIT" )
1317
+ drop_query = "DROP TABLE test_sync;"
1318
+ self .execute (drop_query )
1317
1319
select_query = """
1318
1320
SELECT
1319
1321
COLUMN_NAME, COLLATION_NAME, CHARACTER_SET_NAME,
@@ -1326,13 +1328,12 @@ def test_sync_drop_table_map_event_table_schema(self):
1326
1328
ORDER BY ORDINAL_POSITION
1327
1329
"""
1328
1330
column_schemas = self .execute (select_query ).fetchall ()
1329
- drop_query = "DROP TABLE test_sync;"
1330
- self .execute (drop_query )
1331
1331
1332
1332
event = self .stream .fetchone ()
1333
1333
self .assertIsInstance (event , TableMapEvent )
1334
- self .assertEqual (event .table_obj .data ['column_schemas' ][0 ]['COLUMN_NAME' ], column_schemas [ 0 ][ 0 ] )
1334
+ self .assertEqual (event .table_obj .data ['column_schemas' ][0 ]['COLUMN_NAME' ], 'name' )
1335
1335
self .assertEqual (event .table_obj .data ['column_schemas' ][0 ]['COLUMN_COMMENT' ], "" )
1336
+ self .assertEqual (len (column_schemas ), 0 )
1336
1337
1337
1338
def test_sync_column_drop_event_table_schema (self ):
1338
1339
create_query = "CREATE TABLE test_sync (drop_column1 VARCHAR(50) , drop_column2 VARCHAR(50) , drop_column3 VARCHAR(50));"
You can’t perform that action at this time.
0 commit comments