Fix reflection bug for case-sensitive schemas

see snowflakedb#458
pvcy · Nov 27, 2023 · 920aee0 · 920aee0
1 parent 333d966
commit 920aee0
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/snowflake/sqlalchemy/snowdialect.py b/src/snowflake/sqlalchemy/snowdialect.py
@@ -801,7 +801,7 @@ def get_schema_names(self, connection, **kw):
     @reflection.cache
     def get_sequence_names(self, connection, schema=None, **kw):
         sql_command = "SHOW SEQUENCES {}".format(
-            f"IN SCHEMA {self.normalize_name(schema)}" if schema else ""
+            f" IN SCHEMA \"{self.denormalize_name(schema)}\"" if schema else "",
         )
         try:
             cursor = connection.execute(text(sql_command))
@@ -819,7 +819,7 @@ def _get_table_comment(self, connection, table_name, schema=None, **kw):
             "SHOW /* sqlalchemy:_get_table_comment */ "
             "TABLES LIKE '{}'{}".format(
                 table_name,
-                f" IN SCHEMA {self.normalize_name(schema)}" if schema else "",
+                f" IN SCHEMA \"{self.denormalize_name(schema)}\"" if schema else "",
             )
         )
         cursor = connection.execute(text(sql_command))
@@ -833,7 +833,7 @@ def _get_view_comment(self, connection, table_name, schema=None, **kw):
             "SHOW /* sqlalchemy:_get_view_comment */ "
             "VIEWS LIKE '{}'{}".format(
                 table_name,
-                f" IN SCHEMA {self.normalize_name(schema)}" if schema else "",
+                f" IN SCHEMA \"{self.denormalize_name(schema)}\"" if schema else "",
             )
         )
         cursor = connection.execute(text(sql_command))