refactor: replace specific extractor implementations with a generic extractor; remove mssql and postgres extractor files

This commit is contained in:
2026-04-26 19:33:59 -05:00
parent 33af391986
commit 9a00d6af04
5 changed files with 138 additions and 372 deletions

View File

@@ -39,7 +39,7 @@ func processMigrationJob(
targetDbWrapper dbwrapper.DbWrapper,
sourceTableAnalyzer etl.TableAnalyzer,
targetTableAnalyzer etl.TableAnalyzer,
extractor etl.Extractor,
extractor extractors.GenericExtractor,
azureClient *azure.Client,
loader etl.Loader,
job config.Job,
@@ -155,9 +155,8 @@ func processMigrationJob(
for range maxExtractors {
wgExtractors.Go(func() {
extractors.Consume(
extractor.Consume(
localCtx,
extractor,
job.SourceTable,
sourceColTypes,
job.BatchSize,