remove drop tables logic

hotgluexyz · Nov 25, 2024 · 91e74eb · 91e74eb
1 parent 06e5318
commit 91e74eb
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/target_mssql/connector.py b/target_mssql/connector.py
@@ -40,10 +40,10 @@ def prepare_table(
         """
         # NOTE: Force create the table
         # TODO: remove this
-        if not self.dropped_tables.get(full_table_name, False):
-            self.logger.info("Force dropping the table!")
-            self.connection.execute(f"DROP TABLE IF EXISTS {full_table_name};")
-            self.dropped_tables[full_table_name] = True
+        # if not self.dropped_tables.get(full_table_name, False):
+        #     self.logger.info("Force dropping the table!")
+        #     self.connection.execute(f"DROP TABLE IF EXISTS {full_table_name};")
+        #     self.dropped_tables[full_table_name] = True
 
         if not self.table_exists(full_table_name=full_table_name):
             self.create_empty_table(

diff --git a/target_mssql/sinks.py b/target_mssql/sinks.py
@@ -167,10 +167,10 @@ def prepare_table(
         """
         # NOTE: Force create the table
         # TODO: remove this
-        if not self.dropped_tables.get(self.stream_name, False):
-            self.logger.info("Force dropping the table!")
-            self.connector.connection.execute(f"DROP TABLE IF EXISTS {self.full_table_name};")
-            self.dropped_tables[self.stream_name] = True
+        # if not self.dropped_tables.get(self.stream_name, False):
+        #     self.logger.info("Force dropping the table!")
+        #     self.connector.connection.execute(f"DROP TABLE IF EXISTS {self.full_table_name};")
+        #     self.dropped_tables[self.stream_name] = True
 
         if not self.table_exists(full_table_name=full_table_name):
             self.create_empty_table(