DBZ-7693 Correctly enable row-query events
This commit is contained in:
parent
0cde7e664e
commit
dc5b496c28
@ -256,7 +256,7 @@ public void updates() throws Exception {
|
|||||||
final int batchSize = 10;
|
final int batchSize = 10;
|
||||||
try (JdbcConnection connection = databaseConnection()) {
|
try (JdbcConnection connection = databaseConnection()) {
|
||||||
connection.setAutoCommit(false);
|
connection.setAutoCommit(false);
|
||||||
((BinlogTestConnection) connection).setBinlogCompressionOn();
|
((BinlogTestConnection) connection).setBinlogRowQueryEventsOn();
|
||||||
for (int i = 0; i < ROW_COUNT; i++) {
|
for (int i = 0; i < ROW_COUNT; i++) {
|
||||||
connection.executeWithoutCommitting(
|
connection.executeWithoutCommitting(
|
||||||
String.format("UPDATE %s SET aa = aa + 2000 WHERE pk > %s AND pk <= %s", tableName(),
|
String.format("UPDATE %s SET aa = aa + 2000 WHERE pk > %s AND pk <= %s", tableName(),
|
||||||
|
Loading…
Reference in New Issue
Block a user