Skip to content

Commit 3d59c4f

Browse files
committed
modify test to correspond to inserting data to es in bulk
1 parent 8f4fade commit 3d59c4f

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

test/test_basic.py

+5-1
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ def setUp(self):
2626
"passwd": self.config['mysql']['password'],
2727
"port": self.config['mysql']['port'],
2828
"use_unicode": True,
29-
"charset": "utf8", #utf8mb4
29+
"charset": "utf8", # regarded as utf8mb4
3030
}
3131

3232
self.conn_control = pymysql.connect(**mysql_config)
@@ -51,13 +51,17 @@ def test_basic_replication(self):
5151
t TIMESTAMP)
5252
"""
5353
)
54+
5455
self.execute("INSERT INTO basic_replication(id, f, t) VALUES(1, 12.34, '2023-09-25 00:00:00')")
56+
self.execute("INSERT INTO basic_replication(id, f, t) VALUES(2, 12.34, '2023-09-25 00:00:00')")
5557
self.conn_control.commit()
5658

5759
self.execute("UPDATE basic_replication SET f=56.78 WHERE id=1")
60+
self.execute("UPDATE basic_replication SET f=56.78 WHERE id=2")
5861
self.conn_control.commit()
5962

6063
self.execute("DELETE FROM basic_replication WHERE id=1")
64+
self.execute("DELETE FROM basic_replication WHERE id=2")
6165
self.conn_control.commit()
6266

6367
self.pymyelarepl.run()

0 commit comments

Comments
 (0)