Skip to content

Commit

Permalink
Showing 2 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
@@ -49,7 +49,7 @@ protected Map<String, List<String>> discoverPrimaryKeys(final JdbcDatabase datab
final List<TableInfo<CommonField<JDBCType>>> tableInfos) {
return tableInfos.stream()
.collect(Collectors.toMap(
tableInfo -> sourceOperations.getFullyQualifiedTableName(tableInfo.getNameSpace(), tableInfo.getName()),
tableInfo -> JdbcUtils.getFullyQualifiedTableName(tableInfo.getNameSpace(), tableInfo.getName()),
tableInfo -> {
try {
return database.queryStrings(connection -> {
Original file line number Diff line number Diff line change
@@ -511,16 +511,16 @@ void testDiscoverWithMultipleSchemas() throws Exception {
database.execute(connection -> {
connection.createStatement().execute(
String.format("CREATE TABLE " + dbName + ".%s(id VARCHAR(200), name VARCHAR(200))",
sourceOperations.getFullyQualifiedTableName(SCHEMA_NAME2, TABLE_NAME)));
JdbcUtils.getFullyQualifiedTableName(SCHEMA_NAME2, TABLE_NAME)));
connection.createStatement()
.execute(String.format("INSERT INTO " + dbName + ".%s(id, name) VALUES ('1','picard')",
sourceOperations.getFullyQualifiedTableName(SCHEMA_NAME2, TABLE_NAME)));
JdbcUtils.getFullyQualifiedTableName(SCHEMA_NAME2, TABLE_NAME)));
connection.createStatement()
.execute(String.format("INSERT INTO " + dbName + ".%s(id, name) VALUES ('2', 'crusher')",
sourceOperations.getFullyQualifiedTableName(SCHEMA_NAME2, TABLE_NAME)));
JdbcUtils.getFullyQualifiedTableName(SCHEMA_NAME2, TABLE_NAME)));
connection.createStatement()
.execute(String.format("INSERT INTO " + dbName + ".%s(id, name) VALUES ('3', 'vash')",
sourceOperations.getFullyQualifiedTableName(SCHEMA_NAME2, TABLE_NAME)));
JdbcUtils.getFullyQualifiedTableName(SCHEMA_NAME2, TABLE_NAME)));
});

final AirbyteCatalog actual = source.discover(config);

0 comments on commit 59c06ab

Please sign in to comment.