r1b
diff --git a/‎sqlalchemy_bigquery/_json.py
Copy file name to clipboardExpand all lines: sqlalchemy_bigquery/_json.py
+15-2Lines changed: 15 additions & 2 deletions b/‎sqlalchemy_bigquery/_json.py
Copy file name to clipboardExpand all lines: sqlalchemy_bigquery/_json.py
+15-2Lines changed: 15 additions & 2 deletions
diff --git a/‎sqlalchemy_bigquery/base.py
Copy file name to clipboardExpand all lines: sqlalchemy_bigquery/base.py
+10Lines changed: 10 additions & 0 deletions b/‎sqlalchemy_bigquery/base.py
Copy file name to clipboardExpand all lines: sqlalchemy_bigquery/base.py
+10Lines changed: 10 additions & 0 deletions
diff --git a/‎tests/unit/test__json.py
Copy file name to clipboardExpand all lines: tests/unit/test__json.py
+33-1Lines changed: 33 additions & 1 deletion b/‎tests/unit/test__json.py
Copy file name to clipboardExpand all lines: tests/unit/test__json.py
+33-1Lines changed: 33 additions & 1 deletion
@@ -37,13 +37,26 @@ def _format_value(self, value):
         if isinstance(value, int):
             value = "$[%s]" % value
         else:
-            value = '$.%s' % value
+            value = '$."%s"' % value
         return value
 
-
 class JSONIntIndexType(JSONIndexType):
     __visit_name__ = "json_int_index"
 
 
 class JSONStrIndexType(JSONIndexType):
     __visit_name__ = "json_str_index"
+
+
+class JSONPathType(_FormatTypeMixin, sqltypes.JSON.JSONPathType):
+    def _format_value(self, value):
+        return "$%s" % (
+            "".join(
+                [
+                    "[%s]" % elem if isinstance(elem, int) else '."%s"' % elem
+                    for elem in value
+                ]
+            )
+        )
+
+
@@ -588,6 +588,12 @@ def visit_json_getitem_op_binary(self, binary, operator_, **kw):
             self.process(binary.right, **kw),
         )
 
+    def visit_json_path_getitem_op_binary(self, binary, operator, **kw):
+        return "JSON_QUERY(%s, %s)" % (
+            self.process(binary.left, **kw),
+            self.process(binary.right, **kw),
+        )
+
     def _get_regexp_args(self, binary, kw):
         string = self.process(binary.left, **kw)
         pattern = self.process(binary.right, **kw)
@@ -661,6 +667,9 @@ def visit_NUMERIC(self, type_, **kw):
     def visit_JSON(self, type_, **kw):
         return "JSON"
 
+    def visit_json_path(self, type_, **kw):
+        return "STRING"
+
     def visit_json_int_index(self, type_, **kw):
         return "STRING"
 
@@ -1104,6 +1113,7 @@ class BigQueryDialect(DefaultDialect):
         sqlalchemy.sql.sqltypes.Enum: sqlalchemy.sql.sqltypes.Enum,
         sqlalchemy.sql.sqltypes.JSON: _json.JSON,
         sqlalchemy.sql.sqltypes.JSON.JSONIndexType: _json.JSONIndexType,
+        sqlalchemy.sql.sqltypes.JSON.JSONPathType: _json.JSONPathType,
         sqlalchemy.sql.sqltypes.JSON.JSONIntIndexType: _json.JSONIntIndexType,
         sqlalchemy.sql.sqltypes.JSON.JSONStrIndexType: _json.JSONStrIndexType,
     }
 
@@ -56,8 +56,13 @@ def test_json_insert_type_info(faux_conn, metadata, json_table, json_data):
         (
             ["name"],
             "JSON_QUERY(`json_table`.`cart`, %(cart_1:STRING)s)",
-            "JSON_QUERY(`json_table`.`cart`, '$.name')",
+            "JSON_QUERY(`json_table`.`cart`, '$.\"name\"')",
         ),
+        # (
+        #     ["items", 0],
+        #     "JSON_QUERY(`json_table`.`cart`, %(cart_1:STRING)s)",
+        #     "JSON_QUERY(`json_table`.`cart`, '$.items[0]')",
+        # ),
     ),
 )
 def test_json_index(faux_conn, json_column, index_values, sql, literal_sql):
@@ -75,6 +80,33 @@ def test_json_index(faux_conn, json_column, index_values, sql, literal_sql):
     assert expected_sql == actual_sql
     assert expected_literal_sql == actual_literal_sql
 
+@pytest.mark.parametrize(
+    "index_values,sql,literal_sql",
+    (
+        (
+            ["name"],
+            "JSON_QUERY(`json_table`.`cart`, %(cart_1:STRING)s)",
+            "JSON_QUERY(`json_table`.`cart`, '$.\"name\"')",
+        ),
+        # (
+        #     ["items", 0],
+        #     "JSON_QUERY(`json_table`.`cart`, %(cart_1:STRING)s)",
+        #     "JSON_QUERY(`json_table`.`cart`, '$.items[0]')",
+        # ),
+    ),
+)
+def test_json_path(faux_conn, json_column, index_values, sql, literal_sql):
+    expr = json_column[index_values]
+
+    expected_sql = f"SELECT {sql} AS `anon_1` \nFROM `json_table`"
+    expected_literal_sql = f"SELECT {literal_sql} AS `anon_1` \nFROM `json_table`"
+
+    actual_sql = sqlalchemy.select(expr).compile(faux_conn).string
+    actual_literal_sql = sqlalchemy.select(expr).compile(faux_conn, compile_kwargs={"literal_binds": True}).string
+
+    assert expected_sql == actual_sql
+    assert expected_literal_sql == actual_literal_sql
+
 # TODO: AFAICT, JSON is not a supported query parameter type - enforce this
 
 # TODO: Test _json_serializer set from create_engine