Gazler · October 24, 2023 11:03 · Oct 24, 2023 · Oct 24, 2023
diff --git a/gistfile1.txt → sqlite_crash.exs b/gistfile1.txt → sqlite_crash.exs
diff --git a/gistfile1.txt b/gistfile1.txt
@@ -0,0 +1,88 @@
+Mix.install([
+  {:ecto_sql, "~> 3.10"},
+  {:ecto_sqlite3, ">= 0.12.0"},
+  {:exqlite, ">= 0.0.0"}
+])
+
+Application.put_env(:foo, Repo, database: ":memory:", pool_size: 1)
+
+defmodule Repo do
+  use Ecto.Repo,
+    adapter: Ecto.Adapters.SQLite3,
+    otp_app: :foo
+end
+
+defmodule Migration0 do
+  use Ecto.Migration
+
+  def change do
+    create table("posts") do
+      add(:title, :string)
+      timestamps(type: :utc_datetime_usec)
+    end
+  end
+end
+
+defmodule Post do
+  use Ecto.Schema
+
+  schema "posts" do
+    field(:title, :string)
+    timestamps(type: :utc_datetime_usec)
+  end
+end
+
+defmodule Main do
+  import Ecto.Query, warn: false
+
+  def start() do
+    children = [
+      Repo
+    ]
+
+    _ = Repo.__adapter__().storage_down(Repo.config())
+    :ok = Repo.__adapter__().storage_up(Repo.config())
+
+    {:ok, _} = Supervisor.start_link(children, strategy: :one_for_one)
+
+    Ecto.Migrator.run(Repo, [{0, Migration0}], :up, all: true, log_migrations_sql: :debug)
+    Repo.insert!(%Post{title: "Hello, World!"})
+
+  end
+
+  def query do
+    from(Post) |> Repo.all()
+  end
+
+  def blowup do
+    query = """
+      WITH RECURSIVE r(i) AS (
+      VALUES(0)
+      UNION ALL
+      SELECT i FROM r
+      LIMIT 1000000
+      )
+      SELECT i FROM r WHERE i = 1;
+      """
+    spawn_link(fn ->
+      :timer.sleep(10)
+      raise "bad"
+    end)
+
+    Repo.query(query)
+  end
+end
+
+Main.start()
+
+Main.query() |> IO.inspect()
+
+# We can trigger an error during a query
+Process.flag(:trap_exit, true)
+pid = spawn(&Main.blowup/0)
+Process.monitor(pid)
+receive do
+  {:DOWN, _ref, :process, ^pid, _} -> :noop
+end
+
+Main.query() |> IO.inspect()
No results found