Skip to content

Commit 959bb84

Browse files
committed
feat: oracle logminer support double active
1 parent 10deffb commit 959bb84

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

connectors-common/sql-core/src/main/java/io/tapdata/common/CommonDbConnector.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -221,7 +221,8 @@ protected CreateTableOptions createTableV3(TapConnectorContext connectorContext,
221221

222222
protected void createDoubleActiveTempTable() throws SQLException {
223223
if (jdbcContext.queryAllTables(Collections.singletonList("_tap_double_active")).size() < 1) {
224-
jdbcContext.execute(String.format("create table %s (c1 int primary key, c2 varchar(50))", getSchemaAndTable("_tap_double_active")));
224+
jdbcContext.execute(String.format("create table %s (%s int primary key, %s varchar(50))", getSchemaAndTable("_tap_double_active"),
225+
commonDbConfig.getEscapeChar() + "c1" + commonDbConfig.getEscapeChar(), commonDbConfig.getEscapeChar() + "c2" + commonDbConfig.getEscapeChar()));
225226
jdbcContext.execute(String.format("insert into %s values (1, null)", getSchemaAndTable("_tap_double_active")));
226227
}
227228
}

0 commit comments

Comments
 (0)