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

DBZ-1089 Database is no longer part of schema name

Browse Source
This commit is contained in:
Jiri Pechanec 2019-01-18 06:51:56 +01:00
parent 1451349ae2
commit 2d198a8674
2 changed files with 22 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/CaseSensitivenessIT.java
View File

@ -86,7 +86,7 @@ private void testDatabase() throws Exception {
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.MyTableOne.Value")
.name("server1.dbo.MyTableOne.Value")
.field("Id", Schema.INT32_SCHEMA)
.field("ColA", Schema.OPTIONAL_STRING_SCHEMA)
.build()
@ -94,7 +94,7 @@ private void testDatabase() throws Exception {
assertSchemaMatchesStruct(
(Struct)record.key(),
SchemaBuilder.struct()
.name("server1.testDB.dbo.MyTableOne.Key")
.name("server1.dbo.MyTableOne.Key")
.field("Id", Schema.INT32_SCHEMA)
.build()
);
@ -108,7 +108,7 @@ record = records.recordsForTopic("server1.dbo.MyTableOne").get(0);
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.MyTableOne.Value")
.name("server1.dbo.MyTableOne.Value")
.field("Id", Schema.INT32_SCHEMA)
.field("ColA", Schema.OPTIONAL_STRING_SCHEMA)
.build()
@ -116,7 +116,7 @@ record = records.recordsForTopic("server1.dbo.MyTableOne").get(0);
assertSchemaMatchesStruct(
(Struct)record.key(),
SchemaBuilder.struct()
.name("server1.testDB.dbo.MyTableOne.Key")
.name("server1.dbo.MyTableOne.Key")
.field("Id", Schema.INT32_SCHEMA)
.build()
);
@ -134,7 +134,7 @@ record = records.recordsForTopic("server1.dbo.MyTableTwo").get(0);
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.MyTableTwo.Value")
.name("server1.dbo.MyTableTwo.Value")
.field("Id", Schema.INT32_SCHEMA)
.field("ColB", Schema.OPTIONAL_STRING_SCHEMA)
.build()
@ -142,7 +142,7 @@ record = records.recordsForTopic("server1.dbo.MyTableTwo").get(0);
assertSchemaMatchesStruct(
(Struct)record.key(),
SchemaBuilder.struct()
.name("server1.testDB.dbo.MyTableTwo.Key")
.name("server1.dbo.MyTableTwo.Key")
.field("Id", Schema.INT32_SCHEMA)
.build()
);

32
debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerChangeTableSetIT.java
View File

@ -105,7 +105,7 @@ public void addTable() throws Exception {
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.tablec.Value")
.name("server1.dbo.tablec.Value")
.field("id", Schema.INT32_SCHEMA)
.field("colc", Schema.OPTIONAL_STRING_SCHEMA)
.build()
@ -116,7 +116,7 @@ public void addTable() throws Exception {
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.tabled.Value")
.name("server1.dbo.tabled.Value")
.field("id", Schema.INT32_SCHEMA)
.field("cold", Schema.OPTIONAL_STRING_SCHEMA)
.build()
@ -210,7 +210,7 @@ private void addColumnToTable(boolean pauseAfterCaptureChange) throws Exception
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.tableb.Value")
.name("server1.dbo.tableb.Value")
.field("id", Schema.INT32_SCHEMA)
.field("colb", Schema.OPTIONAL_STRING_SCHEMA)
.build()
@ -238,7 +238,7 @@ private void addColumnToTable(boolean pauseAfterCaptureChange) throws Exception
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.tableb.Value")
.name("server1.dbo.tableb.Value")
.field("id", Schema.INT32_SCHEMA)
.field("colb", Schema.OPTIONAL_STRING_SCHEMA)
.build()
@ -268,7 +268,7 @@ private void addColumnToTable(boolean pauseAfterCaptureChange) throws Exception
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.tableb.Value")
.name("server1.dbo.tableb.Value")
.field("id", Schema.INT32_SCHEMA)
.field("colb", Schema.OPTIONAL_STRING_SCHEMA)
.field("newcol", Schema.INT32_SCHEMA)
@ -293,7 +293,7 @@ private void addColumnToTable(boolean pauseAfterCaptureChange) throws Exception
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.tableb.Value")
.name("server1.dbo.tableb.Value")
.field("id", Schema.INT32_SCHEMA)
.field("colb", Schema.OPTIONAL_STRING_SCHEMA)
.field("newcol", Schema.INT32_SCHEMA)
@ -334,7 +334,7 @@ public void removeColumnFromTable() throws Exception {
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.tableb.Value")
.name("server1.dbo.tableb.Value")
.field("id", Schema.INT32_SCHEMA)
.field("colb", Schema.OPTIONAL_STRING_SCHEMA)
.build()
@ -363,7 +363,7 @@ public void removeColumnFromTable() throws Exception {
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.tableb.Value")
.name("server1.dbo.tableb.Value")
.field("id", Schema.INT32_SCHEMA)
.build()
);
@ -386,7 +386,7 @@ public void removeColumnFromTable() throws Exception {
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.tableb.Value")
.name("server1.dbo.tableb.Value")
.field("id", Schema.INT32_SCHEMA)
.build()
);
@ -459,7 +459,7 @@ public void readHistoryAfterRestart() throws Exception {
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.tableb.Value")
.name("server1.dbo.tableb.Value")
.field("id", Schema.INT32_SCHEMA)
.build()
);
@ -498,7 +498,7 @@ public void renameColumn() throws Exception {
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.tableb.Value")
.name("server1.dbo.tableb.Value")
.field("id", Schema.INT32_SCHEMA)
.field("colb", Schema.OPTIONAL_STRING_SCHEMA)
.build()
@ -529,7 +529,7 @@ public void renameColumn() throws Exception {
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.tableb.Value")
.name("server1.dbo.tableb.Value")
.field("id", Schema.INT32_SCHEMA)
.field("newcolb", Schema.OPTIONAL_STRING_SCHEMA)
.build()
@ -553,7 +553,7 @@ public void renameColumn() throws Exception {
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.tableb.Value")
.name("server1.dbo.tableb.Value")
.field("id", Schema.INT32_SCHEMA)
.field("newcolb", Schema.OPTIONAL_STRING_SCHEMA)
.build()
@ -593,7 +593,7 @@ public void changeColumn() throws Exception {
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.tableb.Value")
.name("server1.dbo.tableb.Value")
.field("id", Schema.INT32_SCHEMA)
.field("colb", Schema.OPTIONAL_STRING_SCHEMA)
.build()
@ -626,7 +626,7 @@ public void changeColumn() throws Exception {
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.tableb.Value")
.name("server1.dbo.tableb.Value")
.field("id", Schema.INT32_SCHEMA)
.field("colb", Schema.OPTIONAL_INT32_SCHEMA)
.build()
@ -654,7 +654,7 @@ public void changeColumn() throws Exception {
(Struct)((Struct)record.value()).get("after"),
SchemaBuilder.struct()
.optional()
.name("server1.testDB.dbo.tableb.Value")
.name("server1.dbo.tableb.Value")
.field("id", Schema.INT32_SCHEMA)
.field("colb", Schema.OPTIONAL_INT32_SCHEMA)
.build()