diff --git a/source-dynamodb/.snapshots/TestDiscovery-additional_table_without_stream_enabled b/source-dynamodb/.snapshots/TestDiscovery-additional_table_without_stream_enabled index f686bdf4b3..1311f8f54b 100644 --- a/source-dynamodb/.snapshots/TestDiscovery-additional_table_without_stream_enabled +++ b/source-dynamodb/.snapshots/TestDiscovery-additional_table_without_stream_enabled @@ -22,8 +22,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-dynamodb/.snapshots/TestDiscovery-multiple_tables_with_various_types b/source-dynamodb/.snapshots/TestDiscovery-multiple_tables_with_various_types index c0ba3b621c..4ac7deca8e 100644 --- a/source-dynamodb/.snapshots/TestDiscovery-multiple_tables_with_various_types +++ b/source-dynamodb/.snapshots/TestDiscovery-multiple_tables_with_various_types @@ -22,8 +22,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -141,8 +147,14 @@ Binding 1: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -262,8 +274,14 @@ Binding 2: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-dynamodb/.snapshots/TestDiscovery-single_table_with_a_partition_key b/source-dynamodb/.snapshots/TestDiscovery-single_table_with_a_partition_key index f686bdf4b3..1311f8f54b 100644 --- a/source-dynamodb/.snapshots/TestDiscovery-single_table_with_a_partition_key +++ b/source-dynamodb/.snapshots/TestDiscovery-single_table_with_a_partition_key @@ -22,8 +22,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-dynamodb/discovery.go b/source-dynamodb/discovery.go index ae02cecba1..0be795b61c 100644 --- a/source-dynamodb/discovery.go +++ b/source-dynamodb/discovery.go @@ -175,9 +175,11 @@ func (driver) Discover(ctx context.Context, req *pc.Request_Discover) (*pc.Respo }, Required: []string{"_meta"}, If: &jsonschema.Schema{ + Required: []string{"_meta"}, Extras: map[string]interface{}{ "properties": map[string]*jsonschema.Schema{ "_meta": { + Required: []string{"op"}, Extras: map[string]interface{}{ "properties": map[string]*jsonschema.Schema{ "op": { diff --git a/source-kafka/src/discover.rs b/source-kafka/src/discover.rs index 879758faa0..6334d3102a 100644 --- a/source-kafka/src/discover.rs +++ b/source-kafka/src/discover.rs @@ -96,8 +96,10 @@ fn topic_schema_to_collection_spec( let doc_schema_json = json!({ "x-infer-schema": true, "if": { + "required": ["_meta"], "properties": { "_meta": { + "required": ["op"], "properties": { "op": { "const": "d" diff --git a/source-kafka/src/snapshots/source_kafka__discover__tests__avro record with scalar compound key.snap b/source-kafka/src/snapshots/source_kafka__discover__tests__avro record with scalar compound key.snap index 2141b2b5a8..78c8e54f12 100644 --- a/source-kafka/src/snapshots/source_kafka__discover__tests__avro record with scalar compound key.snap +++ b/source-kafka/src/snapshots/source_kafka__discover__tests__avro record with scalar compound key.snap @@ -6,8 +6,14 @@ expression: snap { "type": "object", "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-kafka/src/snapshots/source_kafka__discover__tests__nested avro record with scalars.snap b/source-kafka/src/snapshots/source_kafka__discover__tests__nested avro record with scalars.snap index 292c8fcb35..08bf4f0291 100644 --- a/source-kafka/src/snapshots/source_kafka__discover__tests__nested avro record with scalars.snap +++ b/source-kafka/src/snapshots/source_kafka__discover__tests__nested avro record with scalars.snap @@ -6,8 +6,14 @@ expression: snap { "type": "object", "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-kafka/src/snapshots/source_kafka__discover__tests__nested json object.snap b/source-kafka/src/snapshots/source_kafka__discover__tests__nested json object.snap index 33c6fd545f..6816e26dff 100644 --- a/source-kafka/src/snapshots/source_kafka__discover__tests__nested json object.snap +++ b/source-kafka/src/snapshots/source_kafka__discover__tests__nested json object.snap @@ -6,8 +6,14 @@ expression: snap { "type": "object", "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-kafka/src/snapshots/source_kafka__discover__tests__no key.snap b/source-kafka/src/snapshots/source_kafka__discover__tests__no key.snap index 20a6bd1550..d5b5d009a8 100644 --- a/source-kafka/src/snapshots/source_kafka__discover__tests__no key.snap +++ b/source-kafka/src/snapshots/source_kafka__discover__tests__no key.snap @@ -6,8 +6,14 @@ expression: snap { "type": "object", "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-kafka/src/snapshots/source_kafka__discover__tests__single non-scalar avro key.snap b/source-kafka/src/snapshots/source_kafka__discover__tests__single non-scalar avro key.snap index 20a6bd1550..d5b5d009a8 100644 --- a/source-kafka/src/snapshots/source_kafka__discover__tests__single non-scalar avro key.snap +++ b/source-kafka/src/snapshots/source_kafka__discover__tests__single non-scalar avro key.snap @@ -6,8 +6,14 @@ expression: snap { "type": "object", "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-kafka/src/snapshots/source_kafka__discover__tests__single nullable scalar avro key.snap b/source-kafka/src/snapshots/source_kafka__discover__tests__single nullable scalar avro key.snap index 20a6bd1550..d5b5d009a8 100644 --- a/source-kafka/src/snapshots/source_kafka__discover__tests__single nullable scalar avro key.snap +++ b/source-kafka/src/snapshots/source_kafka__discover__tests__single nullable scalar avro key.snap @@ -6,8 +6,14 @@ expression: snap { "type": "object", "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-kafka/src/snapshots/source_kafka__discover__tests__single nullable scalar json key.snap b/source-kafka/src/snapshots/source_kafka__discover__tests__single nullable scalar json key.snap index 20a6bd1550..d5b5d009a8 100644 --- a/source-kafka/src/snapshots/source_kafka__discover__tests__single nullable scalar json key.snap +++ b/source-kafka/src/snapshots/source_kafka__discover__tests__single nullable scalar json key.snap @@ -6,8 +6,14 @@ expression: snap { "type": "object", "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-kafka/src/snapshots/source_kafka__discover__tests__single scalar avro key.snap b/source-kafka/src/snapshots/source_kafka__discover__tests__single scalar avro key.snap index 6910a9d4b2..6ab97436ed 100644 --- a/source-kafka/src/snapshots/source_kafka__discover__tests__single scalar avro key.snap +++ b/source-kafka/src/snapshots/source_kafka__discover__tests__single scalar avro key.snap @@ -6,8 +6,14 @@ expression: snap { "type": "object", "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-kafka/src/snapshots/source_kafka__discover__tests__single scalar json key.snap b/source-kafka/src/snapshots/source_kafka__discover__tests__single scalar json key.snap index 6910a9d4b2..6ab97436ed 100644 --- a/source-kafka/src/snapshots/source_kafka__discover__tests__single scalar json key.snap +++ b/source-kafka/src/snapshots/source_kafka__discover__tests__single scalar json key.snap @@ -6,8 +6,14 @@ expression: snap { "type": "object", "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-kafka/tests/snapshots/test__discover.snap b/source-kafka/tests/snapshots/test__discover.snap index 8013c50531..6e27b4dadc 100644 --- a/source-kafka/tests/snapshots/test__discover.snap +++ b/source-kafka/tests/snapshots/test__discover.snap @@ -11,9 +11,15 @@ expression: snap "op": { "const": "d" } - } + }, + "required": [ + "op" + ] } - } + }, + "required": [ + "_meta" + ] }, "properties": { "_meta": { @@ -97,9 +103,15 @@ expression: snap "op": { "const": "d" } - } + }, + "required": [ + "op" + ] } - } + }, + "required": [ + "_meta" + ] }, "properties": { "_meta": { @@ -167,9 +179,15 @@ expression: snap "op": { "const": "d" } - } + }, + "required": [ + "op" + ] } - } + }, + "required": [ + "_meta" + ] }, "properties": { "_meta": { @@ -254,9 +272,15 @@ expression: snap "op": { "const": "d" } - } + }, + "required": [ + "op" + ] } - } + }, + "required": [ + "_meta" + ] }, "properties": { "_meta": { @@ -327,9 +351,15 @@ expression: snap "op": { "const": "d" } - } + }, + "required": [ + "op" + ] } - } + }, + "required": [ + "_meta" + ] }, "properties": { "_meta": { diff --git a/source-mongodb/.snapshots/TestDiscover b/source-mongodb/.snapshots/TestDiscover index 9a67be9e50..c278f4c641 100644 --- a/source-mongodb/.snapshots/TestDiscover +++ b/source-mongodb/.snapshots/TestDiscover @@ -8,8 +8,14 @@ Binding 0: }, "document_schema_json": { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -95,8 +101,14 @@ Binding 1: }, "document_schema_json": { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mongodb/.snapshots/TestDiscoverAllDatabases b/source-mongodb/.snapshots/TestDiscoverAllDatabases index e867e037bf..47745f01bb 100644 --- a/source-mongodb/.snapshots/TestDiscoverAllDatabases +++ b/source-mongodb/.snapshots/TestDiscoverAllDatabases @@ -8,8 +8,14 @@ Binding 0: }, "document_schema_json": { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -95,8 +101,14 @@ Binding 1: }, "document_schema_json": { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -182,8 +194,14 @@ Binding 2: }, "document_schema_json": { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -269,8 +287,14 @@ Binding 3: }, "document_schema_json": { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -356,8 +380,14 @@ Binding 4: }, "document_schema_json": { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -443,8 +473,14 @@ Binding 5: }, "document_schema_json": { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mongodb/.snapshots/TestDiscoverBatchCollections b/source-mongodb/.snapshots/TestDiscoverBatchCollections index a93ecec107..d2a3a2d728 100644 --- a/source-mongodb/.snapshots/TestDiscoverBatchCollections +++ b/source-mongodb/.snapshots/TestDiscoverBatchCollections @@ -8,8 +8,14 @@ Binding 0: }, "document_schema_json": { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -97,8 +103,14 @@ Binding 1: }, "document_schema_json": { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -185,8 +197,14 @@ Binding 2: }, "document_schema_json": { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mongodb/.snapshots/TestDiscoverMultipleDatabases b/source-mongodb/.snapshots/TestDiscoverMultipleDatabases index f3f79e83ed..4473458934 100644 --- a/source-mongodb/.snapshots/TestDiscoverMultipleDatabases +++ b/source-mongodb/.snapshots/TestDiscoverMultipleDatabases @@ -8,8 +8,14 @@ Binding 0: }, "document_schema_json": { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -95,8 +101,14 @@ Binding 1: }, "document_schema_json": { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -182,8 +194,14 @@ Binding 2: }, "document_schema_json": { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -269,8 +287,14 @@ Binding 3: }, "document_schema_json": { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mongodb/discovery.go b/source-mongodb/discovery.go index 44443f9cf2..0cd165fb8e 100644 --- a/source-mongodb/discovery.go +++ b/source-mongodb/discovery.go @@ -87,9 +87,11 @@ func generateMinimalSchema() json.RawMessage { "x-infer-schema": true, }, If: &jsonschema.Schema{ + Required: []string{"_meta"}, Extras: map[string]interface{}{ "properties": map[string]*jsonschema.Schema{ "_meta": { + Required: []string{"op"}, Extras: map[string]interface{}{ "properties": map[string]*jsonschema.Schema{ "op": { diff --git a/source-mysql/.snapshots/TestAlterTable_AddEnumColumn-discover1 b/source-mysql/.snapshots/TestAlterTable_AddEnumColumn-discover1 index 2dab340d7b..a62558f136 100644 --- a/source-mysql/.snapshots/TestAlterTable_AddEnumColumn-discover1 +++ b/source-mysql/.snapshots/TestAlterTable_AddEnumColumn-discover1 @@ -31,8 +31,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestAlterTable_AddEnumColumn-discover2 b/source-mysql/.snapshots/TestAlterTable_AddEnumColumn-discover2 index f5106a8d14..505f8e6764 100644 --- a/source-mysql/.snapshots/TestAlterTable_AddEnumColumn-discover2 +++ b/source-mysql/.snapshots/TestAlterTable_AddEnumColumn-discover2 @@ -45,8 +45,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestAlterTable_AddUnsignedColumn-discover1 b/source-mysql/.snapshots/TestAlterTable_AddUnsignedColumn-discover1 index 87c1418e68..ed9c49f4b5 100644 --- a/source-mysql/.snapshots/TestAlterTable_AddUnsignedColumn-discover1 +++ b/source-mysql/.snapshots/TestAlterTable_AddUnsignedColumn-discover1 @@ -31,8 +31,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestAlterTable_AddUnsignedColumn-discover2 b/source-mysql/.snapshots/TestAlterTable_AddUnsignedColumn-discover2 index e1b03d8fda..0c3568eb6c 100644 --- a/source-mysql/.snapshots/TestAlterTable_AddUnsignedColumn-discover2 +++ b/source-mysql/.snapshots/TestAlterTable_AddUnsignedColumn-discover2 @@ -38,8 +38,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestAlterTable_RenameColumnCaseInsensitive-discover b/source-mysql/.snapshots/TestAlterTable_RenameColumnCaseInsensitive-discover index be03824f7c..e3e4997a9b 100644 --- a/source-mysql/.snapshots/TestAlterTable_RenameColumnCaseInsensitive-discover +++ b/source-mysql/.snapshots/TestAlterTable_RenameColumnCaseInsensitive-discover @@ -31,8 +31,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestEmptyBlobs-Discovery b/source-mysql/.snapshots/TestEmptyBlobs-Discovery index b4dba88ec9..cba2762a0f 100644 --- a/source-mysql/.snapshots/TestEmptyBlobs-Discovery +++ b/source-mysql/.snapshots/TestEmptyBlobs-Discovery @@ -35,8 +35,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestEnumDecodingFix-discovery b/source-mysql/.snapshots/TestEnumDecodingFix-discovery index 9726827dfd..8f8fffb465 100644 --- a/source-mysql/.snapshots/TestEnumDecodingFix-discovery +++ b/source-mysql/.snapshots/TestEnumDecodingFix-discovery @@ -39,8 +39,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestEnumEmptyString-discovery b/source-mysql/.snapshots/TestEnumEmptyString-discovery index 116e6b677b..dba8a28c43 100644 --- a/source-mysql/.snapshots/TestEnumEmptyString-discovery +++ b/source-mysql/.snapshots/TestEnumEmptyString-discovery @@ -39,8 +39,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestEnumPrimaryKey-discovery b/source-mysql/.snapshots/TestEnumPrimaryKey-discovery index ad2f493b6a..5d0b54ad4f 100644 --- a/source-mysql/.snapshots/TestEnumPrimaryKey-discovery +++ b/source-mysql/.snapshots/TestEnumPrimaryKey-discovery @@ -43,8 +43,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestFeatureFlagTinyintAsBool-Default-Discovery b/source-mysql/.snapshots/TestFeatureFlagTinyintAsBool-Default-Discovery index 31f416b7c9..d514f3968d 100644 --- a/source-mysql/.snapshots/TestFeatureFlagTinyintAsBool-Default-Discovery +++ b/source-mysql/.snapshots/TestFeatureFlagTinyintAsBool-Default-Discovery @@ -38,8 +38,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestFeatureFlagTinyintAsBool-Disabled-Discovery b/source-mysql/.snapshots/TestFeatureFlagTinyintAsBool-Disabled-Discovery index 31f416b7c9..d514f3968d 100644 --- a/source-mysql/.snapshots/TestFeatureFlagTinyintAsBool-Disabled-Discovery +++ b/source-mysql/.snapshots/TestFeatureFlagTinyintAsBool-Disabled-Discovery @@ -38,8 +38,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestFeatureFlagTinyintAsBool-Enabled-Discovery b/source-mysql/.snapshots/TestFeatureFlagTinyintAsBool-Enabled-Discovery index 9437bf4fc2..169fb53897 100644 --- a/source-mysql/.snapshots/TestFeatureFlagTinyintAsBool-Enabled-Discovery +++ b/source-mysql/.snapshots/TestFeatureFlagTinyintAsBool-Enabled-Discovery @@ -38,8 +38,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestGeneric-KeylessDiscovery b/source-mysql/.snapshots/TestGeneric-KeylessDiscovery index b9a32084ce..cfb0645f78 100644 --- a/source-mysql/.snapshots/TestGeneric-KeylessDiscovery +++ b/source-mysql/.snapshots/TestGeneric-KeylessDiscovery @@ -45,8 +45,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestGeneric-SimpleDiscovery b/source-mysql/.snapshots/TestGeneric-SimpleDiscovery index 7e32599997..51d241e7b1 100644 --- a/source-mysql/.snapshots/TestGeneric-SimpleDiscovery +++ b/source-mysql/.snapshots/TestGeneric-SimpleDiscovery @@ -44,8 +44,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestMariaDBTypeUUID-discovery b/source-mysql/.snapshots/TestMariaDBTypeUUID-discovery index a653935b0a..8dffddc5bc 100644 --- a/source-mysql/.snapshots/TestMariaDBTypeUUID-discovery +++ b/source-mysql/.snapshots/TestMariaDBTypeUUID-discovery @@ -32,8 +32,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestPartitionedTable-Discovery b/source-mysql/.snapshots/TestPartitionedTable-Discovery index fbd034322b..0762084657 100644 --- a/source-mysql/.snapshots/TestPartitionedTable-Discovery +++ b/source-mysql/.snapshots/TestPartitionedTable-Discovery @@ -36,8 +36,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestSchemaWhitelist-Default b/source-mysql/.snapshots/TestSchemaWhitelist-Default index ceb2a7dcdb..c9a9b870f0 100644 --- a/source-mysql/.snapshots/TestSchemaWhitelist-Default +++ b/source-mysql/.snapshots/TestSchemaWhitelist-Default @@ -31,8 +31,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestSchemaWhitelist-Included b/source-mysql/.snapshots/TestSchemaWhitelist-Included index ceb2a7dcdb..c9a9b870f0 100644 --- a/source-mysql/.snapshots/TestSchemaWhitelist-Included +++ b/source-mysql/.snapshots/TestSchemaWhitelist-Included @@ -31,8 +31,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestSecondaryIndexDiscovery-index_and_fk b/source-mysql/.snapshots/TestSecondaryIndexDiscovery-index_and_fk index c8a70f5a44..9d18f44746 100644 --- a/source-mysql/.snapshots/TestSecondaryIndexDiscovery-index_and_fk +++ b/source-mysql/.snapshots/TestSecondaryIndexDiscovery-index_and_fk @@ -31,8 +31,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestSecondaryIndexDiscovery-index_only b/source-mysql/.snapshots/TestSecondaryIndexDiscovery-index_only index 3e7bce031a..19d24b7f4d 100644 --- a/source-mysql/.snapshots/TestSecondaryIndexDiscovery-index_only +++ b/source-mysql/.snapshots/TestSecondaryIndexDiscovery-index_only @@ -43,8 +43,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestSecondaryIndexDiscovery-nonunique_index b/source-mysql/.snapshots/TestSecondaryIndexDiscovery-nonunique_index index 006a65a6d2..e7390f63a1 100644 --- a/source-mysql/.snapshots/TestSecondaryIndexDiscovery-nonunique_index +++ b/source-mysql/.snapshots/TestSecondaryIndexDiscovery-nonunique_index @@ -40,8 +40,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestSecondaryIndexDiscovery-nothing b/source-mysql/.snapshots/TestSecondaryIndexDiscovery-nothing index 5e1b6ea3fd..5972cd05f1 100644 --- a/source-mysql/.snapshots/TestSecondaryIndexDiscovery-nothing +++ b/source-mysql/.snapshots/TestSecondaryIndexDiscovery-nothing @@ -40,8 +40,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestSecondaryIndexDiscovery-nullable_index b/source-mysql/.snapshots/TestSecondaryIndexDiscovery-nullable_index index 43334a02b9..1048f70987 100644 --- a/source-mysql/.snapshots/TestSecondaryIndexDiscovery-nullable_index +++ b/source-mysql/.snapshots/TestSecondaryIndexDiscovery-nullable_index @@ -46,8 +46,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestSecondaryIndexDiscovery-pk_and_index b/source-mysql/.snapshots/TestSecondaryIndexDiscovery-pk_and_index index e5bdff9570..dcab9e4ce5 100644 --- a/source-mysql/.snapshots/TestSecondaryIndexDiscovery-pk_and_index +++ b/source-mysql/.snapshots/TestSecondaryIndexDiscovery-pk_and_index @@ -39,8 +39,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestSpatialTypes-Discovery b/source-mysql/.snapshots/TestSpatialTypes-Discovery index 0a103b3f54..5ce1d90071 100644 --- a/source-mysql/.snapshots/TestSpatialTypes-Discovery +++ b/source-mysql/.snapshots/TestSpatialTypes-Discovery @@ -52,8 +52,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestTableNamesIdenticalUnderCapitalization-Discover b/source-mysql/.snapshots/TestTableNamesIdenticalUnderCapitalization-Discover index b4580fbaee..a245aac50d 100644 --- a/source-mysql/.snapshots/TestTableNamesIdenticalUnderCapitalization-Discover +++ b/source-mysql/.snapshots/TestTableNamesIdenticalUnderCapitalization-Discover @@ -38,8 +38,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -167,8 +173,14 @@ Binding 1: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestTrickyColumnNames-discover b/source-mysql/.snapshots/TestTrickyColumnNames-discover index a68d1ef62c..96481ed879 100644 --- a/source-mysql/.snapshots/TestTrickyColumnNames-discover +++ b/source-mysql/.snapshots/TestTrickyColumnNames-discover @@ -31,8 +31,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -163,8 +169,14 @@ Binding 1: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestTrickyEnumValues b/source-mysql/.snapshots/TestTrickyEnumValues index b308325155..bbbb8e5f79 100644 --- a/source-mysql/.snapshots/TestTrickyEnumValues +++ b/source-mysql/.snapshots/TestTrickyEnumValues @@ -45,8 +45,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestTrickyTableNames-Discover b/source-mysql/.snapshots/TestTrickyTableNames-Discover index f53e996b88..48d857129a 100644 --- a/source-mysql/.snapshots/TestTrickyTableNames-Discover +++ b/source-mysql/.snapshots/TestTrickyTableNames-Discover @@ -28,8 +28,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-mysql/.snapshots/TestUnsignedIntegers-discovery b/source-mysql/.snapshots/TestUnsignedIntegers-discovery index a8db8f348d..6b17692353 100644 --- a/source-mysql/.snapshots/TestUnsignedIntegers-discovery +++ b/source-mysql/.snapshots/TestUnsignedIntegers-discovery @@ -59,8 +59,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-oracle/.snapshots/TestAllTypes-discover b/source-oracle/.snapshots/TestAllTypes-discover index 176fac913e..5d9603f79e 100644 --- a/source-oracle/.snapshots/TestAllTypes-discover +++ b/source-oracle/.snapshots/TestAllTypes-discover @@ -195,8 +195,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-oracle/.snapshots/TestBareNumberKey-discover b/source-oracle/.snapshots/TestBareNumberKey-discover index f5c39d1e64..9e5b1e9fab 100644 --- a/source-oracle/.snapshots/TestBareNumberKey-discover +++ b/source-oracle/.snapshots/TestBareNumberKey-discover @@ -25,8 +25,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-oracle/.snapshots/TestCapitalizedTables-Discover b/source-oracle/.snapshots/TestCapitalizedTables-Discover index cb957883c5..0f60bc0b1a 100644 --- a/source-oracle/.snapshots/TestCapitalizedTables-Discover +++ b/source-oracle/.snapshots/TestCapitalizedTables-Discover @@ -29,8 +29,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-oracle/.snapshots/TestGeneric-KeylessDiscovery b/source-oracle/.snapshots/TestGeneric-KeylessDiscovery index 25f667cbf6..794c29af71 100644 --- a/source-oracle/.snapshots/TestGeneric-KeylessDiscovery +++ b/source-oracle/.snapshots/TestGeneric-KeylessDiscovery @@ -45,8 +45,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-oracle/.snapshots/TestGeneric-SimpleDiscovery b/source-oracle/.snapshots/TestGeneric-SimpleDiscovery index 241cfba769..ad579bd3f8 100644 --- a/source-oracle/.snapshots/TestGeneric-SimpleDiscovery +++ b/source-oracle/.snapshots/TestGeneric-SimpleDiscovery @@ -44,8 +44,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-oracle/.snapshots/TestIntegerKey-discover b/source-oracle/.snapshots/TestIntegerKey-discover index f82d54eb82..8925a52a51 100644 --- a/source-oracle/.snapshots/TestIntegerKey-discover +++ b/source-oracle/.snapshots/TestIntegerKey-discover @@ -25,8 +25,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-oracle/.snapshots/TestNullValues-discover b/source-oracle/.snapshots/TestNullValues-discover index 1c838933e7..fc25d773b0 100644 --- a/source-oracle/.snapshots/TestNullValues-discover +++ b/source-oracle/.snapshots/TestNullValues-discover @@ -182,8 +182,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-oracle/.snapshots/TestStringKey-discover b/source-oracle/.snapshots/TestStringKey-discover index 2483078e61..96fe0c7ed5 100644 --- a/source-oracle/.snapshots/TestStringKey-discover +++ b/source-oracle/.snapshots/TestStringKey-discover @@ -26,8 +26,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-oracle/.snapshots/TestTrickyColumnNames-discover b/source-oracle/.snapshots/TestTrickyColumnNames-discover index 854785bf79..a13aac829a 100644 --- a/source-oracle/.snapshots/TestTrickyColumnNames-discover +++ b/source-oracle/.snapshots/TestTrickyColumnNames-discover @@ -32,8 +32,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -175,8 +181,14 @@ Binding 1: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-oracle/.snapshots/TestUnsupportedTypes-discover b/source-oracle/.snapshots/TestUnsupportedTypes-discover index 4d8fa29a5d..e4a7113345 100644 --- a/source-oracle/.snapshots/TestUnsupportedTypes-discover +++ b/source-oracle/.snapshots/TestUnsupportedTypes-discover @@ -25,8 +25,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestCIText b/source-postgres/.snapshots/TestCIText index ec3dc8f751..4a926a884e 100644 --- a/source-postgres/.snapshots/TestCIText +++ b/source-postgres/.snapshots/TestCIText @@ -45,8 +45,14 @@ sql> CREATE TABLE test.citext_675587 (id INTEGER PRIMARY KEY, data CITEXT, arr C "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestCaptureAsPartitions b/source-postgres/.snapshots/TestCaptureAsPartitions index caa6029e12..f9310508e8 100644 --- a/source-postgres/.snapshots/TestCaptureAsPartitions +++ b/source-postgres/.snapshots/TestCaptureAsPartitions @@ -37,8 +37,14 @@ sql> CREATE TABLE test.captureaspartitions_274513_2023q4 PARTITION OF test.captu "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -173,8 +179,14 @@ sql> CREATE TABLE test.captureaspartitions_274513_2023q4 PARTITION OF test.captu "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -309,8 +321,14 @@ sql> CREATE TABLE test.captureaspartitions_274513_2023q4 PARTITION OF test.captu "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -445,8 +463,14 @@ sql> CREATE TABLE test.captureaspartitions_274513_2023q4 PARTITION OF test.captu "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestCaptureAsPartitionsMixed b/source-postgres/.snapshots/TestCaptureAsPartitionsMixed index 2d3246c87e..1f6191ba43 100644 --- a/source-postgres/.snapshots/TestCaptureAsPartitionsMixed +++ b/source-postgres/.snapshots/TestCaptureAsPartitionsMixed @@ -36,8 +36,14 @@ sql> CREATE TABLE test.captureaspartitionsmixed_611041_parted_h2 PARTITION OF te "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -172,8 +178,14 @@ sql> CREATE TABLE test.captureaspartitionsmixed_611041_parted_h2 PARTITION OF te "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -307,8 +319,14 @@ sql> CREATE TABLE test.captureaspartitionsmixed_611041_parted_h2 PARTITION OF te "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestCaptureAsPartitionsSubpartitioned b/source-postgres/.snapshots/TestCaptureAsPartitionsSubpartitioned index 973255a033..f381b55b5f 100644 --- a/source-postgres/.snapshots/TestCaptureAsPartitionsSubpartitioned +++ b/source-postgres/.snapshots/TestCaptureAsPartitionsSubpartitioned @@ -44,8 +44,14 @@ sql> CREATE TABLE test.captureaspartitionssubpartitioned_416337_h2_west PARTITIO "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -186,8 +192,14 @@ sql> CREATE TABLE test.captureaspartitionssubpartitioned_416337_h2_west PARTITIO "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -328,8 +340,14 @@ sql> CREATE TABLE test.captureaspartitionssubpartitioned_416337_h2_west PARTITIO "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" @@ -470,8 +488,14 @@ sql> CREATE TABLE test.captureaspartitionssubpartitioned_416337_h2_west PARTITIO "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestDiscoveryComplex b/source-postgres/.snapshots/TestDiscoveryComplex index 3f83263f0c..a152509516 100644 --- a/source-postgres/.snapshots/TestDiscoveryComplex +++ b/source-postgres/.snapshots/TestDiscoveryComplex @@ -70,8 +70,14 @@ sql> COMMENT ON COLUMN test.discoverycomplex_934635.k1 IS 'I think this is a key "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestDiscoveryWithoutPermissions b/source-postgres/.snapshots/TestDiscoveryWithoutPermissions index aa41b5e9ac..0d4c9a1db9 100644 --- a/source-postgres/.snapshots/TestDiscoveryWithoutPermissions +++ b/source-postgres/.snapshots/TestDiscoveryWithoutPermissions @@ -32,8 +32,14 @@ sql> CREATE TABLE public.tbl419033 (id INTEGER PRIMARY KEY, data TEXT) "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestFeatureFlagFlattenArrays-Disabled b/source-postgres/.snapshots/TestFeatureFlagFlattenArrays-Disabled index ad95f55da6..2b3ef8b3ff 100644 --- a/source-postgres/.snapshots/TestFeatureFlagFlattenArrays-Disabled +++ b/source-postgres/.snapshots/TestFeatureFlagFlattenArrays-Disabled @@ -117,8 +117,14 @@ sql> INSERT INTO test.featureflagflattenarrays_disabled_688545 VALUES "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestFeatureFlagFlattenArrays-Enabled b/source-postgres/.snapshots/TestFeatureFlagFlattenArrays-Enabled index 8416bca02b..e127a28517 100644 --- a/source-postgres/.snapshots/TestFeatureFlagFlattenArrays-Enabled +++ b/source-postgres/.snapshots/TestFeatureFlagFlattenArrays-Enabled @@ -69,8 +69,14 @@ sql> INSERT INTO test.featureflagflattenarrays_enabled_602988 VALUES "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestFloatKeyDiscovery b/source-postgres/.snapshots/TestFloatKeyDiscovery index 03745ca543..d88ddd7145 100644 --- a/source-postgres/.snapshots/TestFloatKeyDiscovery +++ b/source-postgres/.snapshots/TestFloatKeyDiscovery @@ -35,8 +35,14 @@ sql> CREATE TABLE test.floatkeydiscovery_109173 (id DOUBLE PRECISION PRIMARY KEY "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestGeneratedColumn b/source-postgres/.snapshots/TestGeneratedColumn index da288e1645..e0f854680a 100644 --- a/source-postgres/.snapshots/TestGeneratedColumn +++ b/source-postgres/.snapshots/TestGeneratedColumn @@ -41,8 +41,14 @@ sql> CREATE TABLE test.generatedcolumn_136230 (id INTEGER PRIMARY KEY, a VARCHAR "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestKeylessDiscovery b/source-postgres/.snapshots/TestKeylessDiscovery index 0ab71d322f..842043fe68 100644 --- a/source-postgres/.snapshots/TestKeylessDiscovery +++ b/source-postgres/.snapshots/TestKeylessDiscovery @@ -50,8 +50,14 @@ sql> CREATE TABLE test.keylessdiscovery_729953 (a INTEGER, b VARCHAR(2000), c RE "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestMultidimensionalArrays b/source-postgres/.snapshots/TestMultidimensionalArrays index d18219d0fd..0dba27eec5 100644 --- a/source-postgres/.snapshots/TestMultidimensionalArrays +++ b/source-postgres/.snapshots/TestMultidimensionalArrays @@ -32,8 +32,14 @@ sql> CREATE TABLE test.multidimensionalarrays_911995 (id INTEGER PRIMARY KEY, ar "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestPartitionedTableDiscovery b/source-postgres/.snapshots/TestPartitionedTableDiscovery index e2cc7870b7..f6e5493dc5 100644 --- a/source-postgres/.snapshots/TestPartitionedTableDiscovery +++ b/source-postgres/.snapshots/TestPartitionedTableDiscovery @@ -37,8 +37,14 @@ sql> CREATE TABLE test.partitionedtablediscovery_242722_2023q4 PARTITION OF test "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestSecondaryIndexDiscovery-index_only b/source-postgres/.snapshots/TestSecondaryIndexDiscovery-index_only index a4d8649ac3..7caa9c6b80 100644 --- a/source-postgres/.snapshots/TestSecondaryIndexDiscovery-index_only +++ b/source-postgres/.snapshots/TestSecondaryIndexDiscovery-index_only @@ -45,8 +45,14 @@ sql> CREATE UNIQUE INDEX idx693037_k23 ON test.tbl693037 (k2, k3) "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestSecondaryIndexDiscovery-nonunique_index b/source-postgres/.snapshots/TestSecondaryIndexDiscovery-nonunique_index index 6a6d2a847f..859e63b71b 100644 --- a/source-postgres/.snapshots/TestSecondaryIndexDiscovery-nonunique_index +++ b/source-postgres/.snapshots/TestSecondaryIndexDiscovery-nonunique_index @@ -42,8 +42,14 @@ sql> CREATE INDEX idx591008_k23 ON test.tbl591008 (k2, k3) "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestSecondaryIndexDiscovery-nothing b/source-postgres/.snapshots/TestSecondaryIndexDiscovery-nothing index 2f4dad9642..5c02e2be73 100644 --- a/source-postgres/.snapshots/TestSecondaryIndexDiscovery-nothing +++ b/source-postgres/.snapshots/TestSecondaryIndexDiscovery-nothing @@ -41,8 +41,14 @@ sql> CREATE TABLE test.tbl237250 (k1 INTEGER, k2 INTEGER NOT NULL, k3 INTEGER NO "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestSecondaryIndexDiscovery-nullable_index b/source-postgres/.snapshots/TestSecondaryIndexDiscovery-nullable_index index 2ad76697d3..cdd46c5ade 100644 --- a/source-postgres/.snapshots/TestSecondaryIndexDiscovery-nullable_index +++ b/source-postgres/.snapshots/TestSecondaryIndexDiscovery-nullable_index @@ -48,8 +48,14 @@ sql> CREATE UNIQUE INDEX idx892285_k23 ON test.tbl892285 (k2, k3) "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestSecondaryIndexDiscovery-pk_and_index b/source-postgres/.snapshots/TestSecondaryIndexDiscovery-pk_and_index index 63867e0fef..8507c980b8 100644 --- a/source-postgres/.snapshots/TestSecondaryIndexDiscovery-pk_and_index +++ b/source-postgres/.snapshots/TestSecondaryIndexDiscovery-pk_and_index @@ -41,8 +41,14 @@ sql> CREATE UNIQUE INDEX idx954884_k23 ON test.tbl954884 (k2, k3) "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestSimpleDiscovery b/source-postgres/.snapshots/TestSimpleDiscovery index 6bccd5439f..d12bbc8084 100644 --- a/source-postgres/.snapshots/TestSimpleDiscovery +++ b/source-postgres/.snapshots/TestSimpleDiscovery @@ -49,8 +49,14 @@ sql> CREATE TABLE test.simplediscovery_838908 (a INTEGER PRIMARY KEY, b VARCHAR( "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestUserTypes-Domain b/source-postgres/.snapshots/TestUserTypes-Domain index cdeee9aef7..5ab0fbbfbf 100644 --- a/source-postgres/.snapshots/TestUserTypes-Domain +++ b/source-postgres/.snapshots/TestUserTypes-Domain @@ -33,8 +33,14 @@ sql> CREATE TABLE test.usertypes_domain_245097 (id INTEGER PRIMARY KEY, value Us "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestUserTypes-Enum b/source-postgres/.snapshots/TestUserTypes-Enum index 7cf1051a5d..7578882c7a 100644 --- a/source-postgres/.snapshots/TestUserTypes-Enum +++ b/source-postgres/.snapshots/TestUserTypes-Enum @@ -33,8 +33,14 @@ sql> CREATE TABLE test.usertypes_enum_211653 (id INTEGER PRIMARY KEY, value User "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestUserTypes-Range b/source-postgres/.snapshots/TestUserTypes-Range index ca72affdbf..d5101c107e 100644 --- a/source-postgres/.snapshots/TestUserTypes-Range +++ b/source-postgres/.snapshots/TestUserTypes-Range @@ -33,8 +33,14 @@ sql> CREATE TABLE test.usertypes_range_933528 (id INTEGER PRIMARY KEY, value Use "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-postgres/.snapshots/TestUserTypes-Tuple b/source-postgres/.snapshots/TestUserTypes-Tuple index 79e057e9cb..cbb7fe223a 100644 --- a/source-postgres/.snapshots/TestUserTypes-Tuple +++ b/source-postgres/.snapshots/TestUserTypes-Tuple @@ -29,8 +29,14 @@ sql> CREATE TABLE test.usertypes_tuple_223541 (id INTEGER PRIMARY KEY, value Use "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-snowflake/.snapshots/TestBasicDatatypes-discover b/source-snowflake/.snapshots/TestBasicDatatypes-discover index 11cf0b47b6..4dccaa841f 100644 --- a/source-snowflake/.snapshots/TestBasicDatatypes-discover +++ b/source-snowflake/.snapshots/TestBasicDatatypes-discover @@ -60,8 +60,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-snowflake/.snapshots/TestDiscoveryMultiplePrimaryKeys b/source-snowflake/.snapshots/TestDiscoveryMultiplePrimaryKeys index bc881959b1..6dd3454eaa 100644 --- a/source-snowflake/.snapshots/TestDiscoveryMultiplePrimaryKeys +++ b/source-snowflake/.snapshots/TestDiscoveryMultiplePrimaryKeys @@ -37,8 +37,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-snowflake/.snapshots/TestDiscoveryWithPrimaryKey b/source-snowflake/.snapshots/TestDiscoveryWithPrimaryKey index f6f02ce8ec..f2fb745ef5 100644 --- a/source-snowflake/.snapshots/TestDiscoveryWithPrimaryKey +++ b/source-snowflake/.snapshots/TestDiscoveryWithPrimaryKey @@ -38,8 +38,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-snowflake/.snapshots/TestDiscoveryWithoutPrimaryKey b/source-snowflake/.snapshots/TestDiscoveryWithoutPrimaryKey index 09fd38aced..66162357a5 100644 --- a/source-snowflake/.snapshots/TestDiscoveryWithoutPrimaryKey +++ b/source-snowflake/.snapshots/TestDiscoveryWithoutPrimaryKey @@ -38,8 +38,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-snowflake/.snapshots/TestDynamicTable-discovery b/source-snowflake/.snapshots/TestDynamicTable-discovery index 1cc26fd8ad..29dbfb3447 100644 --- a/source-snowflake/.snapshots/TestDynamicTable-discovery +++ b/source-snowflake/.snapshots/TestDynamicTable-discovery @@ -26,8 +26,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-snowflake/.snapshots/TestTimestampDatatypes-discover b/source-snowflake/.snapshots/TestTimestampDatatypes-discover index e50a9bb4bc..623025f228 100644 --- a/source-snowflake/.snapshots/TestTimestampDatatypes-discover +++ b/source-snowflake/.snapshots/TestTimestampDatatypes-discover @@ -45,8 +45,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-snowflake/.snapshots/TestVariantDatatypes-discover b/source-snowflake/.snapshots/TestVariantDatatypes-discover index 60a67710b2..cdf52d1e24 100644 --- a/source-snowflake/.snapshots/TestVariantDatatypes-discover +++ b/source-snowflake/.snapshots/TestVariantDatatypes-discover @@ -30,8 +30,14 @@ Binding 0: "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-snowflake/discovery.go b/source-snowflake/discovery.go index 8985e65ad3..6abe311560 100644 --- a/source-snowflake/discovery.go +++ b/source-snowflake/discovery.go @@ -341,9 +341,11 @@ func schemaFromDiscovery(info *snowflakeDiscoveryInfo) (json.RawMessage, error) }, Required: []string{metadataProperty}, If: &jsonschema.Schema{ + Required: []string{"_meta"}, Extras: map[string]interface{}{ "properties": map[string]*jsonschema.Schema{ "_meta": { + Required: []string{"op"}, Extras: map[string]interface{}{ "properties": map[string]*jsonschema.Schema{ "op": { diff --git a/source-sqlserver-ct/.snapshots/TestBasics-SimpleDiscovery b/source-sqlserver-ct/.snapshots/TestBasics-SimpleDiscovery index 284a38476a..cbdaeb252f 100644 --- a/source-sqlserver-ct/.snapshots/TestBasics-SimpleDiscovery +++ b/source-sqlserver-ct/.snapshots/TestBasics-SimpleDiscovery @@ -45,8 +45,14 @@ sql> CREATE TABLE dbo.Basics_SimpleDiscovery_891380 (a INTEGER PRIMARY KEY, b VA "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver-ct/.snapshots/TestCapture-ComputedColumn b/source-sqlserver-ct/.snapshots/TestCapture-ComputedColumn index 304f48fc35..9bed3699e0 100644 --- a/source-sqlserver-ct/.snapshots/TestCapture-ComputedColumn +++ b/source-sqlserver-ct/.snapshots/TestCapture-ComputedColumn @@ -46,8 +46,14 @@ sql> CREATE TABLE dbo.Capture_ComputedColumn_345410 (id INTEGER PRIMARY KEY, a V "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver-ct/.snapshots/TestCapture-ComputedPrimaryKey b/source-sqlserver-ct/.snapshots/TestCapture-ComputedPrimaryKey index 9d8e9892b6..3add2a8026 100644 --- a/source-sqlserver-ct/.snapshots/TestCapture-ComputedPrimaryKey +++ b/source-sqlserver-ct/.snapshots/TestCapture-ComputedPrimaryKey @@ -37,8 +37,14 @@ sql> CREATE TABLE dbo.Capture_ComputedPrimaryKey_812546 (actual_id INTEGER NOT N "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver-ct/.snapshots/TestCapture-DiscoveryIrrelevantConstraints b/source-sqlserver-ct/.snapshots/TestCapture-DiscoveryIrrelevantConstraints index ae21506f0a..3775d4bca0 100644 --- a/source-sqlserver-ct/.snapshots/TestCapture-DiscoveryIrrelevantConstraints +++ b/source-sqlserver-ct/.snapshots/TestCapture-DiscoveryIrrelevantConstraints @@ -40,8 +40,14 @@ sql> CREATE TABLE dbo.Capture_DiscoveryIrrelevantConstraints_771648 (id VARCHAR( "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver-ct/.snapshots/TestCollation-VarcharKeyDiscovery b/source-sqlserver-ct/.snapshots/TestCollation-VarcharKeyDiscovery index 5754178f33..ad316f72cc 100644 --- a/source-sqlserver-ct/.snapshots/TestCollation-VarcharKeyDiscovery +++ b/source-sqlserver-ct/.snapshots/TestCollation-VarcharKeyDiscovery @@ -33,8 +33,14 @@ sql> CREATE TABLE dbo.Collation_VarcharKeyDiscovery_989577 (id VARCHAR(32) PRIMA "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver-ct/.snapshots/TestDatatypes-RowversionTypes-rowversion b/source-sqlserver-ct/.snapshots/TestDatatypes-RowversionTypes-rowversion index 84b7cc6044..ff4237625c 100644 --- a/source-sqlserver-ct/.snapshots/TestDatatypes-RowversionTypes-rowversion +++ b/source-sqlserver-ct/.snapshots/TestDatatypes-RowversionTypes-rowversion @@ -38,8 +38,14 @@ sql> CREATE TABLE dbo.Datatypes_RowversionTypes_rowversion_318641 (id INTEGER PR "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver-ct/.snapshots/TestDatatypes-RowversionTypes-timestamp b/source-sqlserver-ct/.snapshots/TestDatatypes-RowversionTypes-timestamp index 8f94d73850..8e2bddfea4 100644 --- a/source-sqlserver-ct/.snapshots/TestDatatypes-RowversionTypes-timestamp +++ b/source-sqlserver-ct/.snapshots/TestDatatypes-RowversionTypes-timestamp @@ -38,8 +38,14 @@ sql> CREATE TABLE dbo.Datatypes_RowversionTypes_timestamp_404369 (id INTEGER PRI "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver/.snapshots/TestBasics-SimpleDiscovery b/source-sqlserver/.snapshots/TestBasics-SimpleDiscovery index b349676f0f..e190258642 100644 --- a/source-sqlserver/.snapshots/TestBasics-SimpleDiscovery +++ b/source-sqlserver/.snapshots/TestBasics-SimpleDiscovery @@ -45,8 +45,14 @@ sql> CREATE TABLE dbo.Basics_SimpleDiscovery_891380 (a INTEGER PRIMARY KEY, b VA "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver/.snapshots/TestCapture-ComputedColumn b/source-sqlserver/.snapshots/TestCapture-ComputedColumn index 54ba4c58fb..5787e709a8 100644 --- a/source-sqlserver/.snapshots/TestCapture-ComputedColumn +++ b/source-sqlserver/.snapshots/TestCapture-ComputedColumn @@ -41,8 +41,14 @@ sql> CREATE TABLE dbo.Capture_ComputedColumn_345410 (id INTEGER PRIMARY KEY, a V "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver/.snapshots/TestCapture-ComputedPrimaryKey b/source-sqlserver/.snapshots/TestCapture-ComputedPrimaryKey index f506ef7b82..1fec23a572 100644 --- a/source-sqlserver/.snapshots/TestCapture-ComputedPrimaryKey +++ b/source-sqlserver/.snapshots/TestCapture-ComputedPrimaryKey @@ -31,8 +31,14 @@ sql> CREATE TABLE dbo.Capture_ComputedPrimaryKey_812546 (actual_id INTEGER NOT N "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver/.snapshots/TestCapture-DiscoveryIrrelevantConstraints b/source-sqlserver/.snapshots/TestCapture-DiscoveryIrrelevantConstraints index 68bb0841c1..894cb8a75a 100644 --- a/source-sqlserver/.snapshots/TestCapture-DiscoveryIrrelevantConstraints +++ b/source-sqlserver/.snapshots/TestCapture-DiscoveryIrrelevantConstraints @@ -40,8 +40,14 @@ sql> CREATE TABLE dbo.Capture_DiscoveryIrrelevantConstraints_771648 (id VARCHAR( "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver/.snapshots/TestCollation-VarcharKeyDiscovery b/source-sqlserver/.snapshots/TestCollation-VarcharKeyDiscovery index a7cad6caf9..e262c7abf4 100644 --- a/source-sqlserver/.snapshots/TestCollation-VarcharKeyDiscovery +++ b/source-sqlserver/.snapshots/TestCollation-VarcharKeyDiscovery @@ -33,8 +33,14 @@ sql> CREATE TABLE dbo.Collation_VarcharKeyDiscovery_989577 (id VARCHAR(32) PRIMA "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver/.snapshots/TestDatatypes-RowversionTypes-rowversion b/source-sqlserver/.snapshots/TestDatatypes-RowversionTypes-rowversion index 763c7281aa..4806cf7fd8 100644 --- a/source-sqlserver/.snapshots/TestDatatypes-RowversionTypes-rowversion +++ b/source-sqlserver/.snapshots/TestDatatypes-RowversionTypes-rowversion @@ -38,8 +38,14 @@ sql> CREATE TABLE dbo.Datatypes_RowversionTypes_rowversion_318641 (id INTEGER PR "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver/.snapshots/TestDatatypes-RowversionTypes-timestamp b/source-sqlserver/.snapshots/TestDatatypes-RowversionTypes-timestamp index 54de755c62..01a1ab4efe 100644 --- a/source-sqlserver/.snapshots/TestDatatypes-RowversionTypes-timestamp +++ b/source-sqlserver/.snapshots/TestDatatypes-RowversionTypes-timestamp @@ -38,8 +38,14 @@ sql> CREATE TABLE dbo.Datatypes_RowversionTypes_timestamp_404369 (id INTEGER PRI "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver/.snapshots/TestIndexIncludedDiscovery b/source-sqlserver/.snapshots/TestIndexIncludedDiscovery index e65048ee36..5d6e26f173 100644 --- a/source-sqlserver/.snapshots/TestIndexIncludedDiscovery +++ b/source-sqlserver/.snapshots/TestIndexIncludedDiscovery @@ -45,8 +45,14 @@ sql> CREATE UNIQUE INDEX UX_312546_k23 ON dbo.IndexIncludedDiscovery_312546 (k2, "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver/.snapshots/TestKeylessDiscovery b/source-sqlserver/.snapshots/TestKeylessDiscovery index faf917260f..6002d32a6f 100644 --- a/source-sqlserver/.snapshots/TestKeylessDiscovery +++ b/source-sqlserver/.snapshots/TestKeylessDiscovery @@ -46,8 +46,14 @@ sql> CREATE TABLE dbo.KeylessDiscovery_729953 (a INTEGER, b VARCHAR(2000), c REA "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-index_only b/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-index_only index 89684e325c..71f58c24b4 100644 --- a/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-index_only +++ b/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-index_only @@ -45,8 +45,14 @@ sql> CREATE UNIQUE INDEX UX_693037_k23 ON dbo.SecondaryIndexDiscovery_index_only "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-nonunique_index b/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-nonunique_index index ac0c1e4667..dbf136bfb8 100644 --- a/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-nonunique_index +++ b/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-nonunique_index @@ -42,8 +42,14 @@ sql> CREATE INDEX UX_591008_k23 ON dbo.SecondaryIndexDiscovery_nonunique_index_5 "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-nothing b/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-nothing index a0e34e16b7..bdfb744be8 100644 --- a/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-nothing +++ b/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-nothing @@ -41,8 +41,14 @@ sql> CREATE TABLE dbo.SecondaryIndexDiscovery_nothing_237250 (k1 INTEGER, k2 INT "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-nullable_index b/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-nullable_index index cb4580192d..8b76089c25 100644 --- a/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-nullable_index +++ b/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-nullable_index @@ -48,8 +48,14 @@ sql> CREATE UNIQUE INDEX UX_892285_k23 ON dbo.SecondaryIndexDiscovery_nullable_i "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-pk_and_index b/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-pk_and_index index 49f8997061..0aa1288e82 100644 --- a/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-pk_and_index +++ b/source-sqlserver/.snapshots/TestSecondaryIndexDiscovery-pk_and_index @@ -41,8 +41,14 @@ sql> CREATE UNIQUE INDEX UX_954884_k23 ON dbo.SecondaryIndexDiscovery_pk_and_ind "allOf": [ { "if": { + "required": [ + "_meta" + ], "properties": { "_meta": { + "required": [ + "op" + ], "properties": { "op": { "const": "d" diff --git a/sqlcapture/discovery.go b/sqlcapture/discovery.go index 64fd55158a..f6a263ea27 100644 --- a/sqlcapture/discovery.go +++ b/sqlcapture/discovery.go @@ -238,9 +238,11 @@ func generateCollectionSchema(db Database, table *DiscoveryInfo, fullWriteSchema // behavior which expresses how deletions work. We don't want that in a SourcedSchema update. if fullWriteSchema { metadataSchema.If = &jsonschema.Schema{ + Required: []string{"_meta"}, Extras: map[string]any{ "properties": map[string]*jsonschema.Schema{ "_meta": { + Required: []string{"op"}, Extras: map[string]any{ "properties": map[string]*jsonschema.Schema{ "op": {