From 56a1ff1ba38622fbc1814b654da0d22aa3686fbd Mon Sep 17 00:00:00 2001 From: Roshan Bhalla Date: Mon, 29 Apr 2019 13:32:46 +0100 Subject: [PATCH] correctly discover columns for given table --- tap_redshift/__init__.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/tap_redshift/__init__.py b/tap_redshift/__init__.py index 85305f5..0e45dbd 100644 --- a/tap_redshift/__init__.py +++ b/tap_redshift/__init__.py @@ -86,7 +86,9 @@ def discover_catalog(conn, db_schema): SELECT c.table_name, c.ordinal_position, c.column_name, c.udt_name, c.is_nullable FROM INFORMATION_SCHEMA.Tables t - JOIN INFORMATION_SCHEMA.Columns c ON c.table_name = t.table_name + JOIN INFORMATION_SCHEMA.Columns c + ON c.table_name = t.table_name AND + c.table_schema = t.table_schema WHERE t.table_schema = '{}' ORDER BY c.table_name, c.ordinal_position """.format(db_schema))