Adding DropTable scaffold

clients/bigquery/bigquery.go

@@ -47,6 +47,10 @@ type Store struct {
 	db.Store
 }
 
+func (s *Store) DropTable(_ context.Context, _ sql.TableIdentifier) error {
+	return fmt.Errorf("not supported")
+}
+
 func (s *Store) Append(ctx context.Context, tableData *optimization.TableData, useTempTable bool) error {
 	if !useTempTable {
 		return shared.Append(ctx, s, tableData, types.AdditionalSettings{

clients/databricks/store.go

@@ -32,6 +32,10 @@ type Store struct {
 	configMap *types.DwhToTablesConfigMap
 }
 
+func (s Store) DropTable(_ context.Context, _ sql.TableIdentifier) error {
+	return fmt.Errorf("not supported")
+}
+
 func (s Store) Merge(ctx context.Context, tableData *optimization.TableData) error {
 	return shared.Merge(ctx, s, tableData, types.MergeOpts{})
 }

clients/mssql/store.go

@@ -2,6 +2,7 @@ package mssql
 
 import (
 	"context"
+	"fmt"
 	"strings"
 
 	_ "github.com/microsoft/go-mssqldb"
@@ -31,6 +32,10 @@ func getSchema(schema string) string {
 	return schema
 }
 
+func (s *Store) DropTable(_ context.Context, _ sql.TableIdentifier) error {
+	return fmt.Errorf("not supported")
+}
+
 func (s *Store) Dialect() sql.Dialect {
 	return s.dialect()
 }

clients/redshift/redshift.go

@@ -27,6 +27,10 @@ type Store struct {
 	db.Store
 }
 
+func (s *Store) DropTable(_ context.Context, _ sql.TableIdentifier) error {
+	return fmt.Errorf("not supported")
+}
+
 func (s *Store) Append(ctx context.Context, tableData *optimization.TableData, _ bool) error {
 	return shared.Append(ctx, s, tableData, types.AdditionalSettings{})
 }

clients/snowflake/snowflake.go

@@ -26,6 +26,10 @@ func (s *Store) IdentifierFor(topicConfig kafkalib.TopicConfig, table string) sq
 	return dialect.NewTableIdentifier(topicConfig.Database, topicConfig.Schema, table)
 }
 
+func (s *Store) DropTable(_ context.Context, _ sql.TableIdentifier) error {
+	return fmt.Errorf("not supported")
+}
+
 func (s *Store) GetTableConfig(tableID sql.TableIdentifier, dropDeletedColumns bool) (*types.DwhTableConfig, error) {
 	return shared.GetTableCfgArgs{
 		Dwh:                   s,

lib/destination/dwh.go

@@ -27,6 +27,9 @@ type DataWarehouse interface {
 	// Helper functions for merge
 	GetTableConfig(tableID sqllib.TableIdentifier, dropDeletedColumns bool) (*types.DwhTableConfig, error)
 	PrepareTemporaryTable(ctx context.Context, tableData *optimization.TableData, tableConfig *types.DwhTableConfig, tempTableID sqllib.TableIdentifier, parentTableID sqllib.TableIdentifier, additionalSettings types.AdditionalSettings, createTempTable bool) error
+
+	// Helper function for multi-step merge
+	DropTable(ctx context.Context, tableID sqllib.TableIdentifier) error
 }
 
 type Baseline interface {