something works

Author: ruslandoga

lib/ch/row_binary.ex

@@ -551,6 +551,8 @@ defmodule Ch.RowBinary do
               :uuid,
               :date,
               :date32,
+              :time,
+              :time64,
               :ipv4,
               :ipv6,
               :point,
@@ -878,6 +880,11 @@ defmodule Ch.RowBinary do
         <<d::32-little-signed, bin::bytes>> = bin
         decode_rows(types_rest, bin, [Date.add(@epoch_date, d) | row], rows, types)
 
+      :time ->
+        <<s::32-little, bin::bytes>> = bin
+        t = Time.from_seconds_after_midnight(s)
+        decode_rows(types_rest, bin, [t | row], rows, types)
+
       {:datetime, timezone} ->
         <<s::32-little, bin::bytes>> = bin
 

lib/ch/types.ex

@@ -24,6 +24,8 @@ defmodule Ch.Types do
       {"DateTime64", :datetime64, [:int, :string]},
       {"DateTime", :datetime, [:string]},
       # {"DateTime", :datetime, []},
+      {"Time64", :time64, []},
+      {"Time", :time, []},
       {"Date32", :date32, []},
       {"Date", :date, []},
       {"LowCardinality", :low_cardinality, [:type]},

test/ch/query_test.exs

@@ -92,9 +92,11 @@ defmodule Ch.QueryTest do
     end
 
     test "decode time", %{conn: conn} do
-      assert Ch.query!(conn, "SELECT '12:34:56'::time", [],
-               settings: [enable_time_time64_type: 1]
-             ).rows == [[~T[12:34:56]]]
+      settings = [enable_time_time64_type: 1]
+
+      assert Ch.query!(conn, "SELECT '12:34:56'::time", [], settings: settings).rows == [
+               [~T[12:34:56]]
+             ]
     end
 
     test "decode arrays", %{conn: conn} do