From fd1a7a669fdaa072b326b1eca11d907a70fe683a Mon Sep 17 00:00:00 2001 From: Ken Payne Date: Thu, 20 Oct 2022 15:19:41 +0100 Subject: [PATCH] fix merge duplicates --- singer_sdk/sinks/sql.py | 41 ----------------------------------------- 1 file changed, 41 deletions(-) diff --git a/singer_sdk/sinks/sql.py b/singer_sdk/sinks/sql.py index eafe2de20..3b9ad0d34 100644 --- a/singer_sdk/sinks/sql.py +++ b/singer_sdk/sinks/sql.py @@ -228,47 +228,6 @@ def key_properties(self) -> List[str]: """ return [self.conform_name(key, "column") for key in super().key_properties] - def process_batch(self, context: dict) -> None: - """Process a batch with the given batch context. - - Writes a batch to the SQL target. Developers may override this method - in order to provide a more efficient upload/upsert process. - - Returns: - The fully qualified table name. - """ - return self.connector.get_fully_qualified_name( - table_name=self.table_name, - schema_name=self.schema_name, - db_name=self.database_name, - ) - - @property - def full_schema_name(self) -> str: - """Return the fully qualified schema name. - - Returns: - The fully qualified schema name. - """ - return self.connector.get_fully_qualified_name( - schema_name=self.schema_name, db_name=self.database_name - ) - - def setup(self) -> None: - """Set up Sink. - - This method is called on Sink creation, and creates the required Schema and - Table entities in the target database. - """ - if self.schema_name: - self.connector.prepare_schema(self.schema_name) - self.connector.prepare_table( - full_table_name=self.full_table_name, - schema=self.schema, - primary_keys=self.key_properties, - as_temp_table=False, - ) - def process_batch(self, context: dict) -> None: """Process a batch with the given batch context.