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

DBZ-7880 Make schema backward compatible

Browse Source
This commit is contained in:
Jiri Pechanec 2024-05-22 09:31:40 +02:00
parent 083fbcf163
commit b052d8a472
5 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/SourceInfoTest.java
View File

@ -248,8 +248,8 @@ public void schemaIsCorrect() {
.field("snapshot", AbstractSourceInfoStructMaker.SNAPSHOT_RECORD_SCHEMA)
.field("db", Schema.STRING_SCHEMA)
.field("sequence", Schema.OPTIONAL_STRING_SCHEMA)
.field("ts_us", Schema.INT64_SCHEMA)
.field("ts_ns", Schema.INT64_SCHEMA)
.field("ts_us", Schema.OPTIONAL_INT64_SCHEMA)
.field("ts_ns", Schema.OPTIONAL_INT64_SCHEMA)
.field("collection", Schema.STRING_SCHEMA)
.field("ord", Schema.INT32_SCHEMA)
.field("lsid", Schema.OPTIONAL_STRING_SCHEMA)

4
debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/SourceInfoTest.java
View File

@ -57,8 +57,8 @@ public void schemaIsCorrect() {
.field("snapshot", AbstractSourceInfoStructMaker.SNAPSHOT_RECORD_SCHEMA)
.field("db", Schema.STRING_SCHEMA)
.field("sequence", Schema.OPTIONAL_STRING_SCHEMA)
.field("ts_us", Schema.INT64_SCHEMA)
.field("ts_ns", Schema.INT64_SCHEMA)
.field("ts_us", Schema.OPTIONAL_INT64_SCHEMA)
.field("ts_ns", Schema.OPTIONAL_INT64_SCHEMA)
.field("schema", Schema.STRING_SCHEMA)
.field("table", Schema.STRING_SCHEMA)
.field("txId", Schema.OPTIONAL_STRING_SCHEMA)

4
debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/SourceInfoTest.java
View File

@ -70,8 +70,8 @@ public void schemaIsCorrect() {
.field("snapshot", AbstractSourceInfoStructMaker.SNAPSHOT_RECORD_SCHEMA)
.field("db", Schema.STRING_SCHEMA)
.field("sequence", Schema.OPTIONAL_STRING_SCHEMA)
.field("ts_us", Schema.INT64_SCHEMA)
.field("ts_ns", Schema.INT64_SCHEMA)
.field("ts_us", Schema.OPTIONAL_INT64_SCHEMA)
.field("ts_ns", Schema.OPTIONAL_INT64_SCHEMA)
.field("schema", Schema.STRING_SCHEMA)
.field("table", Schema.STRING_SCHEMA)
.field("txId", Schema.OPTIONAL_INT64_SCHEMA)

4
debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SourceInfoTest.java
View File

@ -97,8 +97,8 @@ public void schemaIsCorrect() {
.field("snapshot", AbstractSourceInfoStructMaker.SNAPSHOT_RECORD_SCHEMA)
.field("db", Schema.STRING_SCHEMA)
.field("sequence", Schema.OPTIONAL_STRING_SCHEMA)
.field("ts_us", Schema.INT64_SCHEMA)
.field("ts_ns", Schema.INT64_SCHEMA)
.field("ts_us", Schema.OPTIONAL_INT64_SCHEMA)
.field("ts_ns", Schema.OPTIONAL_INT64_SCHEMA)
.field("schema", Schema.STRING_SCHEMA)
.field("table", Schema.STRING_SCHEMA)
.field("change_lsn", Schema.OPTIONAL_STRING_SCHEMA)

4
debezium-core/src/main/java/io/debezium/connector/AbstractSourceInfoStructMaker.java
View File

@ -46,8 +46,8 @@ protected SchemaBuilder commonSchemaBuilder() {
.field(AbstractSourceInfo.SNAPSHOT_KEY, SNAPSHOT_RECORD_SCHEMA)
.field(AbstractSourceInfo.DATABASE_NAME_KEY, Schema.STRING_SCHEMA)
.field(AbstractSourceInfo.SEQUENCE_KEY, Schema.OPTIONAL_STRING_SCHEMA)
.field(AbstractSourceInfo.TIMESTAMP_US_KEY, Schema.INT64_SCHEMA)
.field(AbstractSourceInfo.TIMESTAMP_NS_KEY, Schema.INT64_SCHEMA);
.field(AbstractSourceInfo.TIMESTAMP_US_KEY, Schema.OPTIONAL_INT64_SCHEMA)
.field(AbstractSourceInfo.TIMESTAMP_NS_KEY, Schema.OPTIONAL_INT64_SCHEMA);
}
protected Struct commonStruct(T sourceInfo) {