Display bigquery subfield of record as schema.

getredash · Oct 15, 2023 · bef6304 · bef6304
1 parent eafe30d
commit bef6304
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/redash/query_runner/big_query.py b/redash/query_runner/big_query.py
@@ -301,8 +301,8 @@ def get_schema(self, get_stats=False):
         datasets = self._get_project_datasets(project_id)
 
         query_base = """
-        SELECT table_schema, table_name, column_name
-        FROM `{dataset_id}`.INFORMATION_SCHEMA.COLUMNS
+        SELECT table_schema, table_name, field_path
+        FROM `{dataset_id}`.INFORMATION_SCHEMA.COLUMN_FIELD_PATHS
         WHERE table_schema NOT IN ('information_schema')
         """
 
@@ -323,7 +323,7 @@ def get_schema(self, get_stats=False):
             table_name = "{0}.{1}".format(row["table_schema"], row["table_name"])
             if table_name not in schema:
                 schema[table_name] = {"name": table_name, "columns": []}
-            schema[table_name]["columns"].append(row["column_name"])
+            schema[table_name]["columns"].append(row["field_path"])
 
         return list(schema.values())