Skip to content

Commit b199bfa

Browse files
committed
fix(Cursor, __has_valid_columns): replace table_schema by schema_name. resolves unknown column error seen in insert_data_bulk
1 parent f8b2e0c commit b199bfa

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

redshift_connector/cursor.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -353,9 +353,9 @@ def insert_data_bulk(
353353

354354
def __has_valid_columns(self: "Cursor", table: str, columns: typing.List[str]) -> bool:
355355
split_table_name: typing.List[str] = table.split(".")
356-
q: str = "select 1 from information_schema.columns where table_name = ? and column_name = ?"
356+
q: str = "select 1 from pg_catalog.svv_all_columns where table_name = ? and column_name = ?"
357357
if len(split_table_name) == 2:
358-
q += " and table_schema = ?"
358+
q += " and schema_name = ?"
359359
param_list = [[split_table_name[1], c, split_table_name[0]] for c in columns]
360360
else:
361361
param_list = [[split_table_name[0], c] for c in columns]

0 commit comments

Comments
 (0)