diff --git a/clients/mssql/store.go b/clients/mssql/store.go index 66704e93e..f76809e0a 100644 --- a/clients/mssql/store.go +++ b/clients/mssql/store.go @@ -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 { @@ -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{} } @@ -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 {