test latest clickhouse by default, but include Plausible-specific ver…

…sion in the matrix

.github/workflows/test.yml

@@ -16,17 +16,24 @@ jobs:
       matrix:
         elixir: ["1.14", "1.15", "1.16"]
         otp: ["25", "26"]
-        clickhouse: ["23.3.7.5", "latest"]
+        clickhouse: ["latest"]
         timezone: ["UTC"]
         include:
           - elixir: "1.16"
             otp: "26"
-            clickhouse: "23.3.7.5"
+            clickhouse: "latest"
             timezone: "Europe/Berlin"
+          # Plausible
+          # - https://github.com/plausible/analytics/blob/master/.tool-versions
+          # - https://github.com/plausible/analytics/blob/master/.github/workflows/elixir.yml
+          - elixir: "1.16.0"
+            otp: "26.2.1"
+            clickhouse: "23.3.7.5"
+            timezone: "UTC"
 
     services:
       clickhouse:
-        image: clickhouse/clickhouse-server:${{ matrix.clickhouse }}-alpine
+        image: clickhouse/clickhouse-server:${{ matrix.clickhouse }}
         ports:
           - 8123:8123
         env:

test/ch/connection_test.exs

@@ -1282,8 +1282,9 @@ defmodule Ch.ConnectionTest do
       assert {:error, %Ch.Error{code: 81} = error} =
                Ch.query(conn, "select 1 + 1", _params = [], database: "no-db")
 
-      assert Exception.message(error) =~
-               "Code: 81. DB::Exception: Database `no-db` doesn't exist. (UNKNOWN_DATABASE)"
+      assert Exception.message(error) =~ "Code: 81."
+      assert Exception.message(error) =~ "`no-db`"
+      assert Exception.message(error) =~ "(UNKNOWN_DATABASE)"
     end
 
     test "can provide custom database", %{conn: conn} do

test/ch/stream_test.exs

@@ -10,20 +10,19 @@ defmodule Ch.StreamTest do
     test "emits %Ch.Result{}", %{conn: conn} do
       count = 1_000_000
 
-      assert [%Result{command: :select, data: header} | rest] =
+      assert [%Result{command: :select, data: header} | _rest] =
+               results =
                DBConnection.run(conn, fn conn ->
                  conn
                  |> Ch.stream("select * from numbers({count:UInt64})", %{"count" => 1_000_000})
                  |> Enum.into([])
                end)
 
-      assert header == [<<1, 6, "number", 6, "UInt64">>]
+      assert [<<1, 6, "number", 6, "UInt64">> | _] = header
 
-      decoded =
-        Enum.flat_map(rest, fn %Result{data: data} ->
-          data |> IO.iodata_to_binary() |> RowBinary.decode_rows([:u64])
-        end)
+      decoded = results |> Enum.map(& &1.data) |> IO.iodata_to_binary() |> RowBinary.decode_rows()
 
+      assert [[0], [1], [2] | _] = decoded
       assert length(decoded) == count
     end