#3453 refactor: Insert then delete
Pull request opened by
edgarrmondragon on <!date^1768505009^{date_short}|2026-01-15T19:23:29Z>
• On top of
#3450
Summary by Sourcery
Refactor SQL hard-delete handling to upsert then delete based on the soft delete column for LOG_BASED replication.
New Features:
• Introduce a generic bulk_upsert_records method on SQLSink for database-specific bulk upsert implementations using the table schema.
Bug Fixes:
• Ensure hard delete processing works even when records already exist by upserting before deleting rows marked as deleted.
Enhancements:
• Simplify SQLSink hard delete flow by removing record-splitting logic and delegating deletion to a connector-level method using the soft delete column.
• Replace key-based deletion with a connector method that deletes all rows where the soft delete column is set, improving consistency and reducing required inputs.
meltano/sdk