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

DBZ-2607 Query param must not be in string

Browse Source
This commit is contained in:
Jiri Pechanec 2020-10-01 06:39:52 +02:00 committed by Gunnar Morling
parent d1d9e3c6fe
commit 57017140b4
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnection.java
View File

@ -36,6 +36,7 @@
import io.debezium.relational.Tables.ColumnNameFilter;
import io.debezium.relational.Tables.TableFilter;
import io.debezium.util.Strings;
import oracle.jdbc.OracleTypes;
public class OracleConnection extends JdbcConnection {
@ -115,14 +116,14 @@ protected Set<TableId> getAllTableIds(String catalogName, String schemaNamePatte
query = "select table_name, owner from all_tables where table_name NOT LIKE 'MDRT_%' AND table_name not LIKE 'MDXT_%' ";
if (filterBySchema) {
query += " and owner like '%?%'";
query += " and owner like ?";
}
}
else {
query = "select view_name, owner from all_views";
if (filterBySchema) {
query += " where owner like '%?%'";
query += " where owner like ?";
}
}
@ -130,10 +131,10 @@ protected Set<TableId> getAllTableIds(String catalogName, String schemaNamePatte
try (PreparedStatement statement = connection().prepareStatement(query)) {
if (filterBySchema) {
statement.setString(1, schemaNamePattern.toUpperCase());
statement.setString(1, '%' + schemaNamePattern.toUpperCase() + '%');
}
try(ResultSet result = statement.executeQuery()) {
try (ResultSet result = statement.executeQuery()) {
while (result.next()) {
String tableName = result.getString(1);
final String schemaName = result.getString(2);

1
debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorIT.java
View File

@ -34,7 +34,6 @@
import io.debezium.connector.oracle.OracleConnectorConfig.SnapshotMode;
import io.debezium.connector.oracle.junit.SkipTestDependingOnAdapterNameRule;
import io.debezium.connector.oracle.junit.SkipWhenAdapterNameIs;
import io.debezium.connector.oracle.junit.SkipWhenAdapterNameIsNot;
import io.debezium.connector.oracle.util.TestHelper;
import io.debezium.data.Envelope;
import io.debezium.data.VerifyRecord;

2
pom.xml
View File

@ -4,7 +4,7 @@
<parent>
<groupId>io.debezium</groupId>
<artifactId>debezium-parent</artifactId>
<version>1.3.0.CR1</version>
<version>1.3.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>