diff --git a/src/Cortex.States.ClickHouse/ClickHouseSchemaManager.cs b/src/Cortex.States.ClickHouse/ClickHouseSchemaManager.cs index 229052d..5beaa6b 100644 --- a/src/Cortex.States.ClickHouse/ClickHouseSchemaManager.cs +++ b/src/Cortex.States.ClickHouse/ClickHouseSchemaManager.cs @@ -1,5 +1,5 @@ -using ClickHouse.Client.ADO.Parameters; -using ClickHouse.Client.ADO; +using ClickHouse.Driver.ADO.Parameters; +using ClickHouse.Driver.ADO; using System; using System.Collections.Generic; using System.Linq; @@ -199,7 +199,7 @@ private string GetClickhouseScalarType(Type type) if (type == typeof(bool)) return "UInt8"; // or use Int8, but bool->UInt8 is common if (type == typeof(DateTime)) - return "DateTime64(3)"; + return "DateTime64(3, 'UTC')"; // Use UTC for deterministic behavior regardless of server timezone if (type == typeof(decimal)) return "Decimal(18,4)"; // adjust as needed if (type == typeof(double)) diff --git a/src/Cortex.States.ClickHouse/ClickHouseStateStore.cs b/src/Cortex.States.ClickHouse/ClickHouseStateStore.cs index c6844c6..6995528 100644 --- a/src/Cortex.States.ClickHouse/ClickHouseStateStore.cs +++ b/src/Cortex.States.ClickHouse/ClickHouseStateStore.cs @@ -1,5 +1,5 @@ -using ClickHouse.Client.ADO.Parameters; -using ClickHouse.Client.ADO; +using ClickHouse.Driver.ADO.Parameters; +using ClickHouse.Driver.ADO; using System; using System.Collections.Generic; using System.Linq; diff --git a/src/Cortex.States.ClickHouse/Cortex.States.ClickHouse.csproj b/src/Cortex.States.ClickHouse/Cortex.States.ClickHouse.csproj index 96a8544..fffc712 100644 --- a/src/Cortex.States.ClickHouse/Cortex.States.ClickHouse.csproj +++ b/src/Cortex.States.ClickHouse/Cortex.States.ClickHouse.csproj @@ -31,7 +31,7 @@ - +