Skip to content

Commit cdf96cf

Browse files
authored
feat: ensure sync schema and table exist before GetSyncJobConfig processing (#105)
Call targetConn.EnsureSyncSchemaAndTableExists for config/{id}/{area}/schema so the target has the required schema and table before table schema resolution.
1 parent 6ffe754 commit cdf96cf

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

src/SqlBulkSyncFunction/Functions/GetSyncJobConfig.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,7 @@ string area
145145
SourceTableChangeTrackingInfo[]
146146
sourceTableChangeTrackingInfos = [.. await sourceConn.QueryAsync<SourceTableChangeTrackingInfo>(SchemaExtensions.SourceTableChangeTrackingInfoQuery)];
147147

148-
148+
targetConn.EnsureSyncSchemaAndTableExists($"config/{id}/{area}/schema", logger);
149149

150150
var tableSchemas = (
151151
syncJob.Tables ?? []

0 commit comments

Comments
 (0)