Skip to content

Commit

Permalink
sqlcapture: update test snapshots for new collection names
Browse files Browse the repository at this point in the history
  • Loading branch information
mdibaiee committed Sep 11, 2024
1 parent 52e1a7d commit 6aa784d
Show file tree
Hide file tree
Showing 301 changed files with 829 additions and 967 deletions.
2 changes: 1 addition & 1 deletion source-bigquery-batch/main_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -195,7 +195,7 @@ func testCaptureSpec(t testing.TB) *st.CaptureSpec {
}

var sanitizers = make(map[string]*regexp.Regexp)
sanitizers[`"<TIMESTAMP>"`] = regexp.MustCompile(`"[0-9]{4}-[0-9]{2}-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}(\.[0-9]+)?(Z|-[0-9]+:[0-9]+)"`)
sanitizers[`"<TIMESTAMP>"`] = regexp.MustCompile(`"[0-9]{4}-[0-9]{2}-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}(\.[0-9]+)?(Z|[+-][0-9]+:[0-9]+)"`)
sanitizers[`"index":999`] = regexp.MustCompile(`"index":[0-9]+`)

return &st.CaptureSpec{
Expand Down
2 changes: 1 addition & 1 deletion source-dynamodb/discovery_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ func TestDiscovery(t *testing.T) {
})

var sanitizers = make(map[string]*regexp.Regexp)
sanitizers[`"<TIMESTAMP>"`] = regexp.MustCompile(`"[0-9]{4}-[0-9]{2}-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}(\.[0-9]+)?(Z|-[0-9]+:[0-9]+)"`)
sanitizers[`"<TIMESTAMP>"`] = regexp.MustCompile(`"[0-9]{4}-[0-9]{2}-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}(\.[0-9]+)?(Z|[+-][0-9]+:[0-9]+)"`)
cs := &st.CaptureSpec{
Driver: driver{},
EndpointSpec: &cfg,
Expand Down
2 changes: 1 addition & 1 deletion source-dynamodb/main_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -302,7 +302,7 @@ func TestCaptureOperations(t *testing.T) {

func commonSanitizers() map[string]*regexp.Regexp {
sanitizers := make(map[string]*regexp.Regexp)
sanitizers[`"<TIMESTAMP>"`] = regexp.MustCompile(`"[0-9]{4}-[0-9]{2}-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}(\.[0-9]+)?(Z|-[0-9]+:[0-9]+)"`)
sanitizers[`"<TIMESTAMP>"`] = regexp.MustCompile(`"[0-9]{4}-[0-9]{2}-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}(\.[0-9]+)?(Z|[+-][0-9]+:[0-9]+)"`)
sanitizers[`"<SHARD_ID>"`] = regexp.MustCompile(`"shardId\-\d+\-\w+"`)
sanitizers[`"<STREAM_ARN>"`] = regexp.MustCompile(`"arn:aws:dynamodb:\w+:\d+:.+?\.\d+"`)
sanitizers[`<UUID>`] = regexp.MustCompile(`[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}`)
Expand Down
2 changes: 1 addition & 1 deletion source-firestore/main_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ func TestMain(m *testing.M) {
DataKey: "data",
FieldMap: log.FieldMap{log.FieldKeyTime: "@ts"},
})
DefaultSanitizers[`"<TIMESTAMP>"`] = regexp.MustCompile(`"[0-9]{4}-[0-9]{2}-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}(\.[0-9]+)?(Z|-[0-9]+:[0-9]+)"`)
DefaultSanitizers[`"<TIMESTAMP>"`] = regexp.MustCompile(`"[0-9]{4}-[0-9]{2}-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}(\.[0-9]+)?(Z|[+-][0-9]+:[0-9]+)"`)
DefaultSanitizers["project-id-123456"] = regexp.MustCompile(regexp.QuoteMeta(*testProjectID))
os.Exit(m.Run())
}
Expand Down
2 changes: 1 addition & 1 deletion source-hello-world/main_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -54,5 +54,5 @@ func TestCapture(t *testing.T) {
}

var testSanitizers = map[string]*regexp.Regexp{
`"<TIMESTAMP>"`: regexp.MustCompile(`"[0-9]{4}-[0-9]{2}-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}(\.[0-9]+)?(Z|-[0-9]+:[0-9]+)"`),
`"<TIMESTAMP>"`: regexp.MustCompile(`"[0-9]{4}-[0-9]{2}-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}(\.[0-9]+)?(Z|[+-][0-9]+:[0-9]+)"`),
}
2 changes: 1 addition & 1 deletion source-mysql-batch/main_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -154,7 +154,7 @@ func testCaptureSpec(t testing.TB) *st.CaptureSpec {
}

var sanitizers = make(map[string]*regexp.Regexp)
sanitizers[`"<TIMESTAMP>"`] = regexp.MustCompile(`"[0-9]{4}-[0-9]{2}-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}(\.[0-9]+)?(Z|-[0-9]+:[0-9]+)"`)
sanitizers[`"<TIMESTAMP>"`] = regexp.MustCompile(`"[0-9]{4}-[0-9]{2}-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}(\.[0-9]+)?(Z|[+-][0-9]+:[0-9]+)"`)
sanitizers[`"index":999`] = regexp.MustCompile(`"index":[0-9]+`)

return &st.CaptureSpec{
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addcolumnbasic_68678323": 2 Documents
# Collection "acmeCo/test/test/altertable_addcolumnbasic_68678323": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnBasic_68678323","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"eee","extra_end":"extra_end_3","id":3}
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnBasic_68678323","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"fff","extra_end":"extra_end_4","id":4}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addcolumnbasic_68678323": 2 Documents
# Collection "acmeCo/test/test/altertable_addcolumnbasic_68678323": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnBasic_68678323","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"ggg","extra_end":"extra_end_5","id":5}
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnBasic_68678323","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"hhh","extra_end":"extra_end_6","id":6}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addcolumnbasic_68678323": 2 Documents
# Collection "acmeCo/test/test/altertable_addcolumnbasic_68678323": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnBasic_68678323","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"iii","extra_end":"extra_end_7","extra_start":"extra_start_7","id":7}
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnBasic_68678323","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"jjj","extra_end":"extra_end_8","extra_start":"extra_start_8","id":8}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addcolumnbasic_68678323": 2 Documents
# Collection "acmeCo/test/test/altertable_addcolumnbasic_68678323": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnBasic_68678323","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"kkk","extra_end":"extra_end_9","extra_start":"extra_start_9","id":9}
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnBasic_68678323","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"lll","extra_end":"extra_end_10","extra_start":"extra_start_10","id":10}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addcolumnbasic_68678323": 2 Documents
# Collection "acmeCo/test/test/altertable_addcolumnbasic_68678323": 2 Documents
# ================================
{"Extra_MIDDLE":"extra_middle_1","_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnBasic_68678323","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"mmm","extra_end":"extra_end_11","extra_start":"extra_start_11","id":11}
{"Extra_MIDDLE":"extra_middle_2","_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnBasic_68678323","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"nnn","extra_end":"extra_end_12","extra_start":"extra_start_12","id":12}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addcolumnbasic_68678323": 2 Documents
# Collection "acmeCo/test/test/altertable_addcolumnbasic_68678323": 2 Documents
# ================================
{"Extra_MIDDLE":"extra_middle_13","_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnBasic_68678323","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"ooo","extra_end":"extra_end_13","extra_start":"extra_start_13","id":13}
{"Extra_MIDDLE":"extra_middle_14","_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnBasic_68678323","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"ppp","extra_end":"extra_end_14","extra_start":"extra_start_14","id":14}
Expand Down
2 changes: 1 addition & 1 deletion source-mysql/.snapshots/TestAlterTable_AddColumnBasic-init
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addcolumnbasic_68678323": 2 Documents
# Collection "acmeCo/test/test/altertable_addcolumnbasic_68678323": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"schema":"test","snapshot":true,"table":"AlterTable_AddColumnBasic_68678323","cursor":"backfill:0"}},"data":"aaa","id":1}
{"_meta":{"op":"c","source":{"schema":"test","snapshot":true,"table":"AlterTable_AddColumnBasic_68678323","cursor":"backfill:1"}},"data":"bbb","id":2}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addcolumnsetenum_enum_76927424": 2 Documents
# Collection "acmeCo/test/test/altertable_addcolumnsetenum_enum_76927424": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"schema":"test","snapshot":true,"table":"AlterTable_AddColumnSetEnum_enum_76927424","cursor":"backfill:0"}},"data":"aaa","id":1}
{"_meta":{"op":"c","source":{"schema":"test","snapshot":true,"table":"AlterTable_AddColumnSetEnum_enum_76927424","cursor":"backfill:1"}},"data":"bbb","id":2}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addcolumnsetenum_enum_76927424": 2 Documents
# Collection "acmeCo/test/test/altertable_addcolumnsetenum_enum_76927424": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnSetEnum_enum_76927424","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"eee","enumCol":"someValue","id":5}
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnSetEnum_enum_76927424","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"fff","enumCol":"someValue","id":6}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addcolumnsetenum_enum_76927424": 2 Documents
# Collection "acmeCo/test/test/altertable_addcolumnsetenum_enum_76927424": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnSetEnum_enum_76927424","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"ccc","enumCol":"anotherValue","id":3}
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnSetEnum_enum_76927424","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"ddd","enumCol":"someValue","id":4}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addcolumnsetenum_set_14622082": 2 Documents
# Collection "acmeCo/test/test/altertable_addcolumnsetenum_set_14622082": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"schema":"test","snapshot":true,"table":"AlterTable_AddColumnSetEnum_set_14622082","cursor":"backfill:0"}},"data":"aaa","id":1}
{"_meta":{"op":"c","source":{"schema":"test","snapshot":true,"table":"AlterTable_AddColumnSetEnum_set_14622082","cursor":"backfill:1"}},"data":"bbb","id":2}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addcolumnsetenum_set_14622082": 2 Documents
# Collection "acmeCo/test/test/altertable_addcolumnsetenum_set_14622082": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnSetEnum_set_14622082","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"eee","id":5,"setCol":"a,c"}
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnSetEnum_set_14622082","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"fff","id":6,"setCol":"b,c"}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addcolumnsetenum_set_14622082": 2 Documents
# Collection "acmeCo/test/test/altertable_addcolumnsetenum_set_14622082": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnSetEnum_set_14622082","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"ccc","id":3,"setCol":"a,b"}
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddColumnSetEnum_set_14622082","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"ddd","id":4,"setCol":"b,c"}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
Binding 0:
{
"recommended_name": "test_altertable_addenumcolumn_30213486",
"recommended_name": "test/altertable_addenumcolumn_30213486",
"resource_config_json": {
"namespace": "test",
"stream": "AlterTable_AddEnumColumn_30213486"
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
Binding 0:
{
"recommended_name": "test_altertable_addenumcolumn_30213486",
"recommended_name": "test/altertable_addenumcolumn_30213486",
"resource_config_json": {
"namespace": "test",
"stream": "AlterTable_AddEnumColumn_30213486"
Expand Down
2 changes: 1 addition & 1 deletion source-mysql/.snapshots/TestAlterTable_AddEnumColumn-init
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addenumcolumn_30213486": 2 Documents
# Collection "acmeCo/test/test/altertable_addenumcolumn_30213486": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"schema":"test","snapshot":true,"table":"AlterTable_AddEnumColumn_30213486","cursor":"backfill:0"}},"data":"aaa","id":1}
{"_meta":{"op":"c","source":{"schema":"test","snapshot":true,"table":"AlterTable_AddEnumColumn_30213486","cursor":"backfill:1"}},"data":"bbb","id":2}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addenumcolumn_30213486": 3 Documents
# Collection "acmeCo/test/test/altertable_addenumcolumn_30213486": 3 Documents
# ================================
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddEnumColumn_30213486","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"eee","enumcol":"med","id":3}
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddEnumColumn_30213486","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"fff","enumcol":"lg","id":4}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addenumcolumn_30213486": 5 Documents
# Collection "acmeCo/test/test/altertable_addenumcolumn_30213486": 5 Documents
# ================================
{"_meta":{"op":"c","source":{"schema":"test","snapshot":true,"table":"AlterTable_AddEnumColumn_30213486","cursor":"backfill:0"}},"data":"aaa","enumcol":null,"id":1}
{"_meta":{"op":"c","source":{"schema":"test","snapshot":true,"table":"AlterTable_AddEnumColumn_30213486","cursor":"backfill:1"}},"data":"bbb","enumcol":null,"id":2}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
Binding 0:
{
"recommended_name": "test_altertable_addunsignedcolumn_57413089",
"recommended_name": "test/altertable_addunsignedcolumn_57413089",
"resource_config_json": {
"namespace": "test",
"stream": "AlterTable_AddUnsignedColumn_57413089"
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
Binding 0:
{
"recommended_name": "test_altertable_addunsignedcolumn_57413089",
"recommended_name": "test/altertable_addunsignedcolumn_57413089",
"resource_config_json": {
"namespace": "test",
"stream": "AlterTable_AddUnsignedColumn_57413089"
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addunsignedcolumn_57413089": 2 Documents
# Collection "acmeCo/test/test/altertable_addunsignedcolumn_57413089": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"schema":"test","snapshot":true,"table":"AlterTable_AddUnsignedColumn_57413089","cursor":"backfill:0"}},"data":"aaa","id":1}
{"_meta":{"op":"c","source":{"schema":"test","snapshot":true,"table":"AlterTable_AddUnsignedColumn_57413089","cursor":"backfill:1"}},"data":"bbb","id":2}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addunsignedcolumn_57413089": 2 Documents
# Collection "acmeCo/test/test/altertable_addunsignedcolumn_57413089": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddUnsignedColumn_57413089","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"eee","id":3,"uintval":17777777777777777777}
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_AddUnsignedColumn_57413089","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"fff","id":4,"uintval":18000000000000000000}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_addunsignedcolumn_57413089": 4 Documents
# Collection "acmeCo/test/test/altertable_addunsignedcolumn_57413089": 4 Documents
# ================================
{"_meta":{"op":"c","source":{"schema":"test","snapshot":true,"table":"AlterTable_AddUnsignedColumn_57413089","cursor":"backfill:0"}},"data":"aaa","id":1,"uintval":null}
{"_meta":{"op":"c","source":{"schema":"test","snapshot":true,"table":"AlterTable_AddUnsignedColumn_57413089","cursor":"backfill:1"}},"data":"bbb","id":2,"uintval":null}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_changecolumn_27484562": 2 Documents
# Collection "acmeCo/test/test/altertable_changecolumn_27484562": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_ChangeColumn_27484562","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"ccc","id":3}
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_ChangeColumn_27484562","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data_two":"ddd","id":4}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_changecolumn_27484562": 2 Documents
# Collection "acmeCo/test/test/altertable_changecolumn_27484562": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_ChangeColumn_27484562","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data_three":"fff","id":6}
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_ChangeColumn_27484562","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data_two":"eee","id":5}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_changecolumn_27484562": 2 Documents
# Collection "acmeCo/test/test/altertable_changecolumn_27484562": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_ChangeColumn_27484562","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data":"hhh","id":8}
{"_meta":{"op":"c","source":{"ts_ms":1111111111111,"schema":"test","table":"AlterTable_ChangeColumn_27484562","cursor":"binlog.000123:56789:123","txid":"11111111-1111-1111-1111-111111111111:111"}},"data_three":"ggg","id":7}
Expand Down
2 changes: 1 addition & 1 deletion source-mysql/.snapshots/TestAlterTable_ChangeColumn-init
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# ================================
# Collection "acmeCo/test/test_altertable_changecolumn_27484562": 2 Documents
# Collection "acmeCo/test/test/altertable_changecolumn_27484562": 2 Documents
# ================================
{"_meta":{"op":"c","source":{"schema":"test","snapshot":true,"table":"AlterTable_ChangeColumn_27484562","cursor":"backfill:0"}},"data":"aaa","id":1}
{"_meta":{"op":"c","source":{"schema":"test","snapshot":true,"table":"AlterTable_ChangeColumn_27484562","cursor":"backfill:1"}},"data":"bbb","id":2}
Expand Down
Loading

0 comments on commit 6aa784d

Please sign in to comment.