Skip to content

Commit 37a9de5

Browse files
committed
Remove generate_insert_statement
The override of generate_insert_statement is no longer used.
1 parent 711d9af commit 37a9de5

File tree

1 file changed

+0
-18
lines changed

1 file changed

+0
-18
lines changed

target_postgres/sinks.py

Lines changed: 0 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -280,24 +280,6 @@ def generate_copy_statement(
280280

281281
return sql
282282

283-
def generate_insert_statement(
284-
self,
285-
full_table_name: str,
286-
columns: List[sa.Column], # type: ignore[override]
287-
) -> Union[str, Executable]:
288-
"""Generate an insert statement for the given records.
289-
290-
Args:
291-
full_table_name: the target table name.
292-
columns: the target table columns.
293-
294-
Returns:
295-
An insert statement.
296-
"""
297-
metadata = sa.MetaData()
298-
table = sa.Table(full_table_name, metadata, *columns)
299-
return sa.insert(table)
300-
301283
def conform_name(self, name: str, object_type: Optional[str] = None) -> str:
302284
"""Conforming names of tables, schemas, column names."""
303285
return name

0 commit comments

Comments
 (0)