alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-8073: Fixed tests

Browse Source
This commit is contained in:
Rajendra Dangwal 2024-08-07 15:59:31 +05:30 committed by Jiri Pechanec
parent 733ef0d8b4
commit c193d7091d
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/connection/ReplicationConnectionIT.java
View File

@ -125,10 +125,10 @@ public void shouldNotAllowRetryWhenConfigured() throws Exception {
@Test(expected = SQLException.class)
public void shouldNotRetryIfSlotCreationFailsWithoutTimeoutError() throws Exception {
LogInterceptor interceptor = new LogInterceptor(PostgresReplicationConnection.class);
try (ReplicationConnection conn1 = TestHelper.createForReplication("test1", false)) {
try (ReplicationConnection conn1 = TestHelper.createForReplication("testslot1", false)) {
conn1.createReplicationSlot();
// try to create the replication slot with same name again
try (ReplicationConnection conn2 = TestHelper.createForReplication("test1", false)) {
try (ReplicationConnection conn2 = TestHelper.createForReplication("testslot1", false)) {
conn2.createReplicationSlot();
fail("Should not be able to create 2 replication slots on same db and plugin");
}
@ -148,7 +148,7 @@ public void shouldRetryAndFailIfSlotCreationFailsWithTimeoutErrorOnLimitedRetrie
"CREATE TABLE table_with_pk (a SERIAL, b VARCHAR(30), c TIMESTAMP NOT NULL, PRIMARY KEY(a, c));" +
"INSERT INTO table_with_pk (b, c) VALUES('val1', now()); ";
PostgresConnection connection = TestHelper.executeWithoutCommit(statement);
try (ReplicationConnection conn1 = TestHelper.createForReplication("test1", false,
try (ReplicationConnection conn1 = TestHelper.createForReplication("testslot2", false,
new PostgresConnectorConfig(TestHelper.defaultConfig()
.with(PostgresConnectorConfig.MAX_RETRIES, 1)
.with(PostgresConnectorConfig.RETRY_DELAY_MS, 10)
@ -175,7 +175,7 @@ public void shouldSucceedIfSlotCreationSucceedsAfterTimeoutErrors() throws Excep
"CREATE TABLE table_with_pk (a SERIAL, b VARCHAR(30), c TIMESTAMP NOT NULL, PRIMARY KEY(a, c));" +
"INSERT INTO table_with_pk (b, c) VALUES('val1', now()); ";
PostgresConnection connection = TestHelper.executeWithoutCommit(statement);
try (ReplicationConnection conn1 = TestHelper.createForReplication("test1", false,
try (ReplicationConnection conn1 = TestHelper.createForReplication("testslot3", false,
new PostgresConnectorConfig(TestHelper.defaultConfig()
.with(PostgresConnectorConfig.MAX_RETRIES, 1)
.with(PostgresConnectorConfig.RETRY_DELAY_MS, 10)
@ -192,7 +192,7 @@ public void shouldSucceedIfSlotCreationSucceedsAfterTimeoutErrors() throws Excep
connection.commit();
}
// slot creation should be successful as there are no open transactions now
try (ReplicationConnection conn2 = TestHelper.createForReplication("test1", false,
try (ReplicationConnection conn2 = TestHelper.createForReplication("testslot3", false,
new PostgresConnectorConfig(TestHelper.defaultConfig()
.with(PostgresConnectorConfig.MAX_RETRIES, 1)
.with(PostgresConnectorConfig.RETRY_DELAY_MS, 10)