From d085025ea3219fbaef8fe51510e71095a4efb616 Mon Sep 17 00:00:00 2001
From: Joel Kociolek <joel@annatel.net>
Date: Tue, 21 May 2024 13:05:53 +0300
Subject: [PATCH] fix: make tests that use JSON_EXTRACT() internally pass

---
 lib/sql_implementation.ex | 32 ++++++++++----------------------
 1 file changed, 10 insertions(+), 22 deletions(-)

diff --git a/lib/sql_implementation.ex b/lib/sql_implementation.ex
index 12fafa6..dce5e69 100644
--- a/lib/sql_implementation.ex
+++ b/lib/sql_implementation.ex
@@ -349,9 +349,13 @@ defmodule AshMysql.SqlImplementation do
          bindings,
          embedded?,
          acc,
-         type \\ nil
+         _type \\ nil
        ) do
-    path = "$." <> Enum.join(right, ".")
+    field = Ash.Query.Ref.name(left)
+    path = Enum.map(right, &to_string/1)
+
+    expr =
+      Ecto.Query.dynamic([row], json_extract_path(field(row, ^field), ^path))
 
     {expr, acc} =
       AshSql.Expr.dynamic_expr(
@@ -359,34 +363,18 @@ defmodule AshMysql.SqlImplementation do
         %Ash.Query.Function.Fragment{
           embedded?: pred_embedded?,
           arguments: [
-            raw: "json_extract(",
-            expr: left,
-            raw: ", ",
-            expr: path,
+            raw: "json_unquote(",
+            expr: expr,
             raw: ")"
           ]
         },
         bindings,
         embedded?,
-        type,
+        Ash.Type.String,
         acc
       )
 
-    if type do
-      {expr, acc} =
-        AshSql.Expr.dynamic_expr(
-          query,
-          %Ash.Query.Function.Type{arguments: [expr, type, []]},
-          bindings,
-          embedded?,
-          type,
-          acc
-        )
-
-      {:ok, expr, acc}
-    else
-      {:ok, expr, acc}
-    end
+    {:ok, expr, acc}
   end
 
   defp determine_type_at_path(type, path) do