googleapis
diff --git a/Collapse file
‎packages/sqlalchemy-bigquery/sqlalchemy_bigquery/base.py‎
Copy file name to clipboardExpand all lines: packages/sqlalchemy-bigquery/sqlalchemy_bigquery/base.py
+3Lines changed: 3 additions & 0 deletions b/Collapse file
‎packages/sqlalchemy-bigquery/sqlalchemy_bigquery/base.py‎
Copy file name to clipboardExpand all lines: packages/sqlalchemy-bigquery/sqlalchemy_bigquery/base.py
+3Lines changed: 3 additions & 0 deletions
diff --git a/Collapse file
‎packages/sqlalchemy-bigquery/tests/unit/test_table_options.py‎
Copy file name to clipboardExpand all lines: packages/sqlalchemy-bigquery/tests/unit/test_table_options.py
+12Lines changed: 12 additions & 0 deletions b/Collapse file
‎packages/sqlalchemy-bigquery/tests/unit/test_table_options.py‎
Copy file name to clipboardExpand all lines: packages/sqlalchemy-bigquery/tests/unit/test_table_options.py
+12Lines changed: 12 additions & 0 deletions
@@ -622,6 +622,9 @@ def visit_BINARY(self, type_, **kw):
 
     visit_VARBINARY = visit_BLOB = visit_BINARY
 
+    def visit_JSON(self, type_, **kw):
+        return "JSON"
+
     def visit_NUMERIC(self, type_, **kw):
         if (type_.precision is not None) and isinstance(
             kw.get("type_expression"), Column
 
@@ -62,6 +62,18 @@ def test_table_default_rounding_mode_dialect_option(faux_conn):
     )
 
 
+def test_table_with_json_columns(faux_conn):
+    setup_table(
+        faux_conn,
+        "some_table",
+        sqlalchemy.Column("some_stuff", sqlalchemy.JSON),
+    )
+
+    assert " ".join(faux_conn.test_data["execute"][-1][0].strip().split()) == (
+        "CREATE TABLE `some_table` ( `some_stuff` JSON )"
+    )
+
+
 def test_table_clustering_fields_dialect_option_no_such_column(faux_conn):
     with pytest.raises(sqlalchemy.exc.NoSuchColumnError):
         setup_table(