Skip to content

Commit

Permalink
Clean up.
Browse files Browse the repository at this point in the history
  • Loading branch information
Tang8330 committed Sep 27, 2024
1 parent 7589af6 commit d50ee30
Showing 1 changed file with 5 additions and 7 deletions.
12 changes: 5 additions & 7 deletions clients/mssql/store.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,6 @@ import (
"github.com/artie-labs/transfer/lib/kafkalib"
"github.com/artie-labs/transfer/lib/optimization"
"github.com/artie-labs/transfer/lib/sql"
"github.com/artie-labs/transfer/lib/typing"
)

type Store struct {
Expand All @@ -32,6 +31,10 @@ func getSchema(schema string) string {
}

func (s *Store) Dialect() sql.Dialect {
return s.dialect()
}

func (s *Store) dialect() dialect.MSSQLDialect {
return dialect.MSSQLDialect{}
}

Expand Down Expand Up @@ -59,12 +62,7 @@ func (s *Store) Sweep() error {
return err
}

mssqlDialect, err := typing.AssertType[dialect.MSSQLDialect](s.Dialect())
if err != nil {
return err
}

return shared.Sweep(s, tcs, mssqlDialect.BuildSweepQuery)
return shared.Sweep(s, tcs, s.dialect().BuildSweepQuery)
}

func (s *Store) Dedupe(_ sql.TableIdentifier, _ []string, _ bool) error {
Expand Down

0 comments on commit d50ee30

Please sign in to comment.