Merge pull request #1815 from d4ilys/master

修复ClickHouse 批量更新DateTime问题，增加ClickHouse表分区功能（Preview）

FreeSql.DbContext/FreeSql.DbContext.xml

@@ -826,5 +826,14 @@
             <param name="that"></param>
             <returns></returns>
         </member>
+        <member name="M:Microsoft.Extensions.DependencyInjection.FreeSqlRepositoryDependencyInjection.AddFreeRepository(Microsoft.Extensions.DependencyInjection.IServiceCollection,System.Action{FreeSql.FluentDataFilter},System.Reflection.Assembly[])">
+            <summary>
+            批量注入 Repository，可以参考代码自行调整
+            </summary>
+            <param name="services"></param>
+            <param name="globalDataFilter"></param>
+            <param name="assemblies"></param>
+            <returns></returns>
+        </member>
     </members>
 </doc>

FreeSql.Tests/FreeSql.Tests/ClickHouse/ClickhouseIssueTest.cs

@@ -0,0 +1,182 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using FreeSql.DataAnnotations;
+using FreeSql.Provider.ClickHouse.Attributes;
+using Xunit;
+using Xunit.Abstractions;
+
+namespace FreeSql.Tests.ClickHouse
+{
+    public class ClickhouseIssueTest
+    {
+        private readonly ITestOutputHelper _output;
+
+        private static IFreeSql _fsql;
+
+        public ClickhouseIssueTest(ITestOutputHelper output)
+        {
+            _output = output;
+
+            _fsql = new FreeSqlBuilder().UseConnectionString(DataType.ClickHouse,
+                    "Host=192.168.1.123;Port=8123;Database=test_issue;Compress=True;Min Pool Size=1")
+                .UseMonitorCommand(cmd => _output.WriteLine($"线程：{cmd.CommandText}\r\n"))
+                .UseNoneCommandParameter(true)
+                .UseAdoConnectionPool(true)
+                .Build();
+        }
+
+        #region https: //github.com/dotnetcore/FreeSql/issues/1813
+
+        [Fact]
+        public void TestIssue1813()
+        {
+            //普通修改
+            _fsql.Update<Person>()
+                .Set(p => p.Name == "update_name")
+                .Set(p => p.UpdateTime == DateTime.Now)
+                .Where(p => p.Id == "25e8d92e-29f2-43ff-b861-9ade0eec4041")
+                .ExecuteAffrows();
+
+            //批量修改
+            var updatePerson = new List<Person>();
+            updatePerson.Add(new Person
+            {
+                Id = "9cd7af52-85cc-4d26-898a-4020cadb0491",
+                Name = "update_name1",
+                UpdateTime = DateTime.Now,
+                CreateTime = DateTime.Parse("2024-05-30 10:01:02")
+            });
+
+            updatePerson.Add(new Person
+            {
+                Id = "bd9f9ed6-bd03-4675-abb4-12b7fdac7678",
+                Name = "update_name2",
+                UpdateTime = DateTime.Now,
+                CreateTime = DateTime.Parse("2024-05-30 10:01:02")
+            });
+
+            var sql = _fsql.Update<Person>().SetSource(updatePerson)
+                .UpdateColumns(person => new
+                {
+                    person.Name,
+                    person.UpdateTime,
+                    person.CreateTime
+                }).ToSql();
+        }
+
+        [Fact]
+        public void TestIssue1813CodeFirst()
+        {
+            _fsql.CodeFirst.SyncStructure<Person>();
+            var insertSingle = _fsql.Insert(new Person
+            {
+                Name = $"test{DateTime.Now.Millisecond}",
+                Age = 18,
+                CreateTime = DateTime.Now
+            }).ExecuteAffrows();
+
+            _output.WriteLine(insertSingle.ToString());
+
+            var persons = new List<Person>
+            {
+                new Person
+                {
+                    Name = $"test2{DateTime.Now.Millisecond}",
+                    Age = 20,
+                    CreateTime = DateTime.Now
+                },
+                new Person
+                {
+                    Name = "test3" + 286,
+                    Age = 22,
+                    CreateTime = DateTime.Now
+                }
+            };
+
+            var insertMany = _fsql.Insert(persons).ExecuteAffrows();
+        }
+
+        [Fact]
+        public void TestIssue1813CodeFirst2()
+        {
+            _fsql.CodeFirst.SyncStructure<Person>();
+            var insertSingle = _fsql.Insert(new Person
+            {
+                Id = Guid.NewGuid().ToString(),
+                Name = $"test{DateTime.Now.Millisecond}",
+                Age = 18,
+                CreateTime = DateTime.Now
+            }).ExecuteAffrows();
+
+            _output.WriteLine(insertSingle.ToString());
+
+            var persons = new List<Person>
+            {
+                new Person
+                {
+                    Id = Guid.NewGuid().ToString(),
+                    Name = $"test2{DateTime.Now.Millisecond}",
+                    Age = 20,
+                    CreateTime = DateTime.Now
+                },
+                new Person
+                {
+                    Id = Guid.NewGuid().ToString(),
+                    Name = "test3" + 286,
+                    Age = 22,
+                    CreateTime = DateTime.Now
+                }
+            };
+
+            var insertMany = _fsql.Insert(persons).ExecuteAffrows();
+        }
+
+
+        public class Person
+        {
+            [Column(IsPrimary = true, IsIdentity = true)]
+            public string Id { get; set; }
+
+            public string Name { get; set; }
+            public int Age { get; set; }
+
+            public DateTime CreateTime { get; set; }
+
+            public DateTime? UpdateTime { get; set; }
+        }
+
+        #endregion
+
+        #region https: //github.com/dotnetcore/FreeSql/issues/1814
+
+        public class Test1814Table
+        {
+            [Column(IsPrimary = true, IsIdentity = true)]
+            public int Id { get; set; }
+
+            public string Name { get; set; }
+
+            [ClickHousePartition]
+            [Column(Name = "create_time")]
+            public DateTime CreateTime { get; set; }
+        }
+
+        [Fact]
+        public void TestIssue1814()
+        {
+            _fsql.CodeFirst.SyncStructure<Test1814Table>();
+
+            var insert = _fsql.Insert(new Test1814Table
+            {
+                Name = "test",
+                CreateTime = DateTime.Now
+            }).ExecuteAffrows();
+
+            var query = _fsql.Select<Test1814Table>().ToList();
+        }
+        #endregion
+    }
+}

FreeSql/FreeSql.xml

@@ -1104,6 +1104,93 @@
             </summary>
             <returns></returns>
         </member>
+        <member name="T:FreeSql.Extensions.DynamicEntity.DynamicCompileBuilder">
+            <summary>
+            动态创建实体类型
+            </summary>
+        </member>
+        <member name="M:FreeSql.Extensions.DynamicEntity.DynamicCompileBuilder.#ctor(IFreeSql,System.String,System.Attribute[])">
+            <summary>
+            配置Class
+            </summary>
+            <param name="className">类名</param>
+            <param name="attributes">类标记的特性[Table(Name = "xxx")] [Index(xxxx)]</param>
+            <returns></returns>
+        </member>
+        <member name="P:FreeSql.Extensions.DynamicEntity.DynamicCompileBuilder.TypeBuilder">
+            <summary>
+            获取类型构建器，可作为要构建的Type来引用
+            </summary>
+        </member>
+        <member name="M:FreeSql.Extensions.DynamicEntity.DynamicCompileBuilder.Property(System.String,System.Type,System.Attribute[])">
+            <summary>
+            配置属性
+            </summary>
+            <param name="propertyName">属性名称</param>
+            <param name="propertyType">属性类型</param>
+            <param name="attributes">属性标记的特性-支持多个</param>
+            <returns></returns>
+        </member>
+        <member name="M:FreeSql.Extensions.DynamicEntity.DynamicCompileBuilder.Property(System.String,System.Type,System.Boolean,System.Attribute[])">
+            <summary>
+            配置属性
+            </summary>
+            <param name="propertyName">属性名称</param>
+            <param name="propertyType">属性类型</param>
+            <param name="isOverride">该属性是否重写父类属性</param>
+            <param name="attributes">属性标记的特性-支持多个</param>
+            <returns></returns>
+        </member>
+        <member name="M:FreeSql.Extensions.DynamicEntity.DynamicCompileBuilder.Property(System.String,System.Type,System.Boolean,System.Object,System.Attribute[])">
+            <summary>
+            配置属性
+            </summary>
+            <param name="propertyName">属性名称</param>
+            <param name="propertyType">属性类型</param>
+            <param name="isOverride">该属性是否重写父类属性</param>
+            <param name="defaultValue">属性默认值</param>
+            <param name="attributes">属性标记的特性-支持多个</param>
+            <returns></returns>
+        </member>
+        <member name="M:FreeSql.Extensions.DynamicEntity.DynamicCompileBuilder.Extend(System.Type)">
+            <summary>
+            配置父类
+            </summary>
+            <param name="superClass">父类类型</param>
+            <returns></returns>
+        </member>
+        <member name="M:FreeSql.Extensions.DynamicEntity.DynamicCompileBuilder.OverrideProperty(System.Reflection.Emit.TypeBuilder@,System.Reflection.Emit.MethodBuilder,FreeSql.Extensions.DynamicEntity.DynamicCompileBuilder.PropertyMethodEnum,System.String)">
+            <summary>
+            Override属性
+            </summary>
+            <param name="typeBuilder"></param>
+        </member>
+        <member name="M:FreeSql.Extensions.DynamicEntity.DynamicCompileBuilder.Build">
+            <summary>
+            Emit动态创建出Class - Type
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="M:FreeSql.Extensions.DynamicEntity.DynamicCompileBuilder.BuildJustType">
+            <summary>
+            Emit动态创建出Class - Type，不附带获取TableInfo
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="M:FreeSql.Extensions.DynamicEntity.DynamicCompileBuilder.FirstCharToLower(System.String)">
+            <summary>
+            首字母小写
+            </summary>
+            <param name="input"></param>
+            <returns></returns>
+        </member>
+        <member name="M:FreeSql.Extensions.DynamicEntity.DynamicCompileBuilder.FirstCharToUpper(System.String)">
+            <summary>
+            首字母大写
+            </summary>
+            <param name="input"></param>
+            <returns></returns>
+        </member>
         <member name="M:FreeSql.Extensions.EntityUtil.EntityUtilExtensions.GetEntityKeyString(IFreeSql,System.Type,System.Object,System.Boolean,System.String)">
             <summary>
             获取实体的主键值，以 "*|_,[,_|*" 分割，当任意一个主键属性无值时，返回 ""
@@ -3283,6 +3370,13 @@
             </summary>
             <returns></returns>
         </member>
+        <member name="M:FreeSql.IUpdate`1.ExecuteUpdatedAsync(System.Threading.CancellationToken)">
+            <summary>
+            执行SQL语句，返回更新后的记录<para></para>
+            注意：此方法只有 Postgresql/SqlServer 有效果
+            </summary>
+            <returns></returns>
+        </member>
         <member name="M:FreeSql.IUpdateJoin`2.WithTransaction(System.Data.Common.DbTransaction)">
             <summary>
             指定事务对象
@@ -3627,6 +3721,177 @@
             <param name="parms"></param>
             <returns></returns>
         </member>
+        <member name="M:FreeSql.IAdo.ExecuteConnectTestAsync(System.Int32,System.Threading.CancellationToken)">
+            <summary>
+            测试数据库是否连接正确，本方法执行如下命令：<para></para>
+            MySql/SqlServer/PostgreSQL/达梦/人大金仓/神通: SELECT 1<para></para>
+            Oracle: SELECT 1 FROM dual<para></para>
+            </summary>
+            <param name="commandTimeout">命令超时设置(秒)</param>
+            <param name="cancellationToken"></param>
+            <returns>true: 成功, false: 失败</returns>
+        </member>
+        <member name="M:FreeSql.IAdo.ExecuteReaderAsync(System.Func{FreeSql.Internal.Model.FetchCallbackArgs{System.Data.Common.DbDataReader},System.Threading.Tasks.Task},System.Data.CommandType,System.String,System.Data.Common.DbParameter[],System.Threading.CancellationToken)">
+            <summary>
+            查询，若使用读写分离，查询【从库】条件cmdText.StartsWith("SELECT ")，否则查询【主库】
+            </summary>
+            <param name="readerHander"></param>
+            <param name="cmdType"></param>
+            <param name="cmdText"></param>
+            <param name="cmdParms"></param>
+            <param name="cancellationToken"></param>
+        </member>
+        <member name="M:FreeSql.IAdo.ExecuteReaderAsync(System.Func{FreeSql.Internal.Model.FetchCallbackArgs{System.Data.Common.DbDataReader},System.Threading.Tasks.Task},System.String,System.Object,System.Threading.CancellationToken)">
+            <summary>
+            查询，ExecuteReaderAsync(dr => {}, "select * from user where age > @age", new { age = 25 })<para></para>
+            提示：parms 参数还可以传 Dictionary&lt;string, object&gt;
+            </summary>
+            <param name="readerHander"></param>
+            <param name="cmdText"></param>
+            <param name="parms"></param>
+            <param name="cancellationToken"></param>
+        </member>
+        <member name="M:FreeSql.IAdo.ExecuteArrayAsync(System.Data.CommandType,System.String,System.Data.Common.DbParameter[],System.Threading.CancellationToken)">
+            <summary>
+            查询
+            </summary>
+            <param name="cmdType"></param>
+            <param name="cmdText"></param>
+            <param name="cmdParms"></param>
+            <param name="cancellationToken"></param>
+        </member>
+        <member name="M:FreeSql.IAdo.ExecuteArrayAsync(System.String,System.Object,System.Threading.CancellationToken)">
+            <summary>
+            查询，ExecuteArrayAsync("select * from user where age > @age", new { age = 25 })<para></para>
+            提示：parms 参数还可以传 Dictionary&lt;string, object&gt;
+            </summary>
+            <param name="cmdText"></param>
+            <param name="parms"></param>
+            <param name="cancellationToken"></param>
+            <returns></returns>
+        </member>
+        <member name="M:FreeSql.IAdo.ExecuteDataSetAsync(System.Data.CommandType,System.String,System.Data.Common.DbParameter[],System.Threading.CancellationToken)">
+            <summary>
+            查询
+            </summary>
+            <param name="cmdType"></param>
+            <param name="cmdText"></param>
+            <param name="cmdParms"></param>
+            <param name="cancellationToken"></param>
+        </member>
+        <member name="M:FreeSql.IAdo.ExecuteDataSetAsync(System.String,System.Object,System.Threading.CancellationToken)">
+            <summary>
+            查询，ExecuteDataSetAsync("select * from user where age > @age; select 2", new { age = 25 })<para></para>
+            提示：parms 参数还可以传 Dictionary&lt;string, object&gt;
+            </summary>
+            <param name="cmdText"></param>
+            <param name="parms"></param>
+            <param name="cancellationToken"></param>
+            <returns></returns>
+        </member>
+        <member name="M:FreeSql.IAdo.ExecuteDataTableAsync(System.Data.CommandType,System.String,System.Data.Common.DbParameter[],System.Threading.CancellationToken)">
+            <summary>
+            查询
+            </summary>
+            <param name="cmdType"></param>
+            <param name="cmdText"></param>
+            <param name="cmdParms"></param>
+            <param name="cancellationToken"></param>
+        </member>
+        <member name="M:FreeSql.IAdo.ExecuteDataTableAsync(System.String,System.Object,System.Threading.CancellationToken)">
+            <summary>
+            查询，ExecuteDataTableAsync("select * from user where age > @age", new { age = 25 })<para></para>
+            提示：parms 参数还可以传 Dictionary&lt;string, object&gt;
+            </summary>
+            <param name="cmdText"></param>
+            <param name="parms"></param>
+            <param name="cancellationToken"></param>
+            <returns></returns>
+        </member>
+        <member name="M:FreeSql.IAdo.ExecuteNonQueryAsync(System.Data.CommandType,System.String,System.Data.Common.DbParameter[],System.Threading.CancellationToken)">
+            <summary>
+            在【主库】执行
+            </summary>
+            <param name="cmdType"></param>
+            <param name="cmdText"></param>
+            <param name="cmdParms"></param>
+            <param name="cancellationToken"></param>
+        </member>
+        <member name="M:FreeSql.IAdo.ExecuteNonQueryAsync(System.String,System.Object,System.Threading.CancellationToken)">
+            <summary>
+            在【主库】执行，ExecuteNonQueryAsync("delete from user where age > @age", new { age = 25 })<para></para>
+            提示：parms 参数还可以传 Dictionary&lt;string, object&gt;
+            </summary>
+            <param name="cmdText"></param>
+            <param name="parms"></param>
+            <param name="cancellationToken"></param>
+            <returns></returns>
+        </member>
+        <member name="M:FreeSql.IAdo.ExecuteScalarAsync(System.Data.CommandType,System.String,System.Data.Common.DbParameter[],System.Threading.CancellationToken)">
+            <summary>
+            在【主库】执行
+            </summary>
+            <param name="cmdType"></param>
+            <param name="cmdText"></param>
+            <param name="cmdParms"></param>
+            <param name="cancellationToken"></param>
+        </member>
+        <member name="M:FreeSql.IAdo.ExecuteScalarAsync(System.String,System.Object,System.Threading.CancellationToken)">
+            <summary>
+            在【主库】执行，ExecuteScalarAsync("select 1 from user where age > @age", new { age = 25 })<para></para>
+            提示：parms 参数还可以传 Dictionary&lt;string, object&gt;
+            </summary>
+            <param name="cmdText"></param>
+            <param name="parms"></param>
+            <param name="cancellationToken"></param>
+            <returns></returns>
+        </member>
+        <member name="M:FreeSql.IAdo.QueryAsync``1(System.Data.CommandType,System.String,System.Data.Common.DbParameter[],System.Threading.CancellationToken)">
+            <summary>
+            执行SQL返回对象集合，QueryAsync&lt;User&gt;("select * from user where age > @age", new SqlParameter { ParameterName = "age", Value = 25 })
+            </summary>
+            <typeparam name="T"></typeparam>
+            <param name="cmdType"></param>
+            <param name="cmdText"></param>
+            <param name="cmdParms"></param>
+            <param name="cancellationToken"></param>
+            <returns></returns>
+        </member>
+        <member name="M:FreeSql.IAdo.QueryAsync``1(System.String,System.Object,System.Threading.CancellationToken)">
+            <summary>
+            执行SQL返回对象集合，QueryAsync&lt;User&gt;("select * from user where age > @age", new { age = 25 })<para></para>
+            提示：parms 参数还可以传 Dictionary&lt;string, object&gt;
+            </summary>
+            <typeparam name="T"></typeparam>
+            <param name="cmdText"></param>
+            <param name="parms"></param>
+            <param name="cancellationToken"></param>
+            <returns></returns>
+        </member>
+        <member name="M:FreeSql.IAdo.QueryAsync``2(System.Data.CommandType,System.String,System.Data.Common.DbParameter[],System.Threading.CancellationToken)">
+            <summary>
+            执行SQL返回对象集合，Query&lt;User&gt;("select * from user where age > @age; select * from address", new SqlParameter { ParameterName = "age", Value = 25 })
+            </summary>
+            <typeparam name="T1"></typeparam>
+            <typeparam name="T2"></typeparam>
+            <param name="cmdType"></param>
+            <param name="cmdText"></param>
+            <param name="cmdParms"></param>
+            <param name="cancellationToken"></param>
+            <returns></returns>
+        </member>
+        <member name="M:FreeSql.IAdo.QueryAsync``2(System.String,System.Object,System.Threading.CancellationToken)">
+            <summary>
+            执行SQL返回对象集合，Query&lt;User, Address&gt;("select * from user where age > @age; select * from address", new { age = 25 })<para></para>
+            提示：parms 参数还可以传 Dictionary&lt;string, object&gt;
+            </summary>
+            <typeparam name="T1"></typeparam>
+            <typeparam name="T2"></typeparam>
+            <param name="cmdText"></param>
+            <param name="parms"></param>
+            <param name="cancellationToken"></param>
+            <returns></returns>
+        </member>
         <member name="E:FreeSql.IAop.ParseExpression">
             <summary>
             可自定义解析表达式
@@ -4626,6 +4891,12 @@
             <param name="timeout">超时</param>
             <returns></returns>
         </member>
+        <member name="M:FreeSql.Internal.ObjectPool.IObjectPool`1.GetAsync">
+            <summary>
+            获取资源
+            </summary>
+            <returns></returns>
+        </member>
         <member name="M:FreeSql.Internal.ObjectPool.IObjectPool`1.Return(FreeSql.Internal.ObjectPool.Object{`0},System.Boolean)">
             <summary>
             使用完毕后，归还资源
@@ -4701,6 +4972,12 @@
             </summary>
             <param name="obj">资源对象</param>
         </member>
+        <member name="M:FreeSql.Internal.ObjectPool.IPolicy`1.OnGetAsync(FreeSql.Internal.ObjectPool.Object{`0})">
+            <summary>
+            从对象池获取对象成功的时候触发，通过该方法统计或初始化对象
+            </summary>
+            <param name="obj">资源对象</param>
+        </member>
         <member name="M:FreeSql.Internal.ObjectPool.IPolicy`1.OnReturn(FreeSql.Internal.ObjectPool.Object{`0})">
             <summary>
             归还对象给对象池的时候触发
@@ -5631,6 +5908,28 @@
             请使用 fsql.InsertDict(dict) 方法插入字典数据
             </summary>
         </member>
+        <member name="M:FreeSqlGlobalDynamicEntityExtensions.DynamicEntity(FreeSql.ICodeFirst,System.String,System.Attribute[])">
+            <summary>
+            动态构建Class Type
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="M:FreeSqlGlobalDynamicEntityExtensions.CreateInstance(FreeSql.Internal.Model.TableInfo,System.Collections.Generic.Dictionary{System.String,System.Object})">
+            <summary>
+            根据字典，创建 table 对应的实体对象
+            </summary>
+            <param name="table"></param>
+            <param name="dict"></param>
+            <returns></returns>
+        </member>
+        <member name="M:FreeSqlGlobalDynamicEntityExtensions.CreateDictionary(FreeSql.Internal.Model.TableInfo,System.Object)">
+            <summary>
+            根据实体对象，创建 table 对应的字典
+            </summary>
+            <param name="table"></param>
+            <param name="instance"></param>
+            <returns></returns>
+        </member>
         <member name="M:FreeSqlGlobalExpressionCallExtensions.Between(System.DateTime,System.DateTime,System.DateTime)">
             <summary>
             C#： that >= between &amp;&amp; that &lt;= and<para></para>

Providers/FreeSql.Provider.ClickHouse/Attributes/ClickHousePartitionAttribute.cs

@@ -0,0 +1,17 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace FreeSql.Provider.ClickHouse.Attributes
+{
+    [AttributeUsage(AttributeTargets.Property)]
+    public class ClickHousePartitionAttribute : Attribute
+    {
+        public ClickHousePartitionAttribute(string format = "toYYYYMM({0})")
+        {
+            Format = format;
+        }
+
+        public string Format { get; set; }
+    }
+}

Providers/FreeSql.Provider.ClickHouse/ClickHouseCodeFirst.cs

@@ -8,8 +8,10 @@ using System.Linq;
 using System.Text;
 using System.Text.RegularExpressions;
 using System.Data.Common;
+using System.Reflection;
 using FreeSql.Internal.ObjectPool;
 using ClickHouse.Client.ADO;
+using FreeSql.Provider.ClickHouse.Attributes;
 
 namespace FreeSql.ClickHouse
 {
@@ -95,10 +97,11 @@ namespace FreeSql.ClickHouse
                 {
                     var arrayDbType = $"Array({value.dbtype})";
                     var defaultArray = new ArrayList(0);
-                    return new DbInfoResult(Convert.ToInt32(DbType.Object), arrayDbType, arrayDbType, false,defaultArray);
+                    return new DbInfoResult(Convert.ToInt32(DbType.Object), arrayDbType, arrayDbType, false,
+                        defaultArray);
                 }
-            
             }
+
             return null;
         }
 
@@ -132,7 +135,7 @@ namespace FreeSql.ClickHouse
             if (interfaces.Any(t => t.Name == "IEnumerable"))
                 flag = true;
 
-            if (type.Name  == "Array")
+            if (type.Name == "Array")
             {
                 flag = true;
                 resultType = typeof(string);
@@ -173,7 +176,8 @@ namespace FreeSql.ClickHouse
                     if (tb == null)
                         throw new Exception(CoreStrings.S_Type_IsNot_Migrable(obj.tableSchema.Type.FullName));
                     if (tb.Columns.Any() == false)
-                        throw new Exception(CoreStrings.S_Type_IsNot_Migrable_0Attributes(obj.tableSchema.Type.FullName));
+                        throw new Exception(
+                            CoreStrings.S_Type_IsNot_Migrable_0Attributes(obj.tableSchema.Type.FullName));
                     var tbname = _commonUtils.SplitTableName(tb.DbName);
                     if (tbname?.Length == 1)
                         tbname = new[] { database, tbname[0] };
@@ -254,28 +258,47 @@ namespace FreeSql.ClickHouse
                                 sb.Append("TYPE set(8192) GRANULARITY 5,");
                             }
 
-                            sb.Remove(sb.Length - 1, 1);
+                            //sb.Remove(sb.Length - 1, 1);
+
+                            if (tb.Primarys.Any())
+                            {
+                                var primaryKeys = string.Join(",",
+                                    tb.Primarys.Select(p => _commonUtils.QuoteSqlName(p.Attribute.Name)));
+                                sb.Append(" \r\n   PRIMARY KEY ");
+                                sb.Append($"( {primaryKeys} ) ");
+                            }
+
                             sb.Append("\r\n) ");
                             sb.Append("\r\nENGINE = MergeTree()");
 
                             if (tb.Primarys.Any())
                             {
-                                sb.Append(" \r\nORDER BY ( ");
+                                var primaryKeys = string.Join(",",
-                                var ls = new StringBuilder();
+                                    tb.Primarys.Select(p => _commonUtils.QuoteSqlName(p.Attribute.Name)));
-                                foreach (var tbcol in tb.Primarys)
+                                sb.Append(" \r\nORDER BY ");
-                                    ls.Append(_commonUtils.QuoteSqlName(tbcol.Attribute.Name)).Append(", ");
+                                sb.Append($"( {primaryKeys} ) ");
-                                sb.Append(ls);
-                                sb.Remove(sb.Length - 2, 2);
-                                sb.Append(" )");
-                                sb.Append(" \r\nPRIMARY KEY ");
-                                sb.Append($"({ls})   ");
-                                sb.Remove(sb.Length - 2, 2).Append(",");
                             }
 
-                            sb.Remove(sb.Length - 1, 1);
+                            //查找属性是否标记了分区特性
+                            var partitionColumnInfos = tb.Properties.Where(
+                                c => c.Value.GetCustomAttribute<ClickHousePartitionAttribute>() != null).ToList();
+
+                            if (partitionColumnInfos != null && partitionColumnInfos.Any())
+                            {
+                                var partitionProperty = partitionColumnInfos.First();
+
+                                var partitionColumnInfo = tb.Columns.FirstOrDefault(pair =>
+                                    pair.Value.CsName == partitionProperty.Value.Name);
+                                var partitionName = _commonUtils.QuoteSqlName(partitionColumnInfo.Value.Attribute.Name);
+                                var partitionAttribute = partitionProperty.Value
+                                    .GetCustomAttribute<ClickHousePartitionAttribute>();
+                                sb.Append($" \r\nPARTITION BY {string.Format(partitionAttribute.Format, partitionName)}");
+                            }
+
+
                             //if (string.IsNullOrEmpty(tb.Comment) == false)
                             //    sb.Append(" Comment=").Append(_commonUtils.FormatSql("{0}", tb.Comment));
-                            sb.Append(" SETTINGS index_granularity = 8192;\r\n");
+                            sb.Append(" \r\nSETTINGS index_granularity = 8192;\r\n");
                             continue;
                         }
 
@@ -477,16 +500,13 @@ where a.database in ({0}) and a.table in ({1})", tboldname ?? tbname);
 
                     if (tb.Primarys.Any())
                     {
+                        var primaryKeys = string.Join(",",
+                            tb.Primarys.Select(p => _commonUtils.QuoteSqlName(p.Attribute.Name)));
                         sb.Append(" \r\nORDER BY ( ");
-                        var ls = new StringBuilder();
+                        sb.Append(primaryKeys);
-                        foreach (var tbcol in tb.Primarys)
-                            ls.Append(_commonUtils.QuoteSqlName(tbcol.Attribute.Name)).Append(", ");
-                        sb.Append(ls);
-                        sb.Remove(sb.Length - 2, 2);
                         sb.Append(" )");
                         sb.Append(" \r\nPRIMARY KEY ");
-                        sb.Append($"({ls})   ");
+                        sb.Append($"({primaryKeys})   ");
-                        sb.Remove(sb.Length - 2, 2).Append(",");
                     }
 
                     sb.Remove(sb.Length - 1, 1);

Providers/FreeSql.Provider.ClickHouse/ClickHouseUtils.cs

@@ -158,7 +158,7 @@ namespace FreeSql.ClickHouse
                 var ts = (TimeSpan)value;
                 value = $"{Math.Floor(ts.TotalHours)}:{ts.Minutes}:{ts.Seconds}";
             }
-			else if (value is Array)
+            else if (value is Array)
 			{
 				var valueArr = value as Array;
 				var eleType = type.GetElementType();

Providers/FreeSql.Provider.ClickHouse/Curd/ClickHouseUpdate.cs

@@ -7,6 +7,7 @@ using System.Linq;
 using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
+using DateTime = System.DateTime;
 
 namespace FreeSql.ClickHouse.Curd
 {
@@ -167,6 +168,14 @@ namespace FreeSql.ClickHouse.Curd
 
                                 var colsql = _noneParameter ? _commonUtils.GetNoneParamaterSqlValue(_paramsSource, "u", col, col.Attribute.MapType, val) :
                                     _commonUtils.QuoteWriteParamterAdapter(col.Attribute.MapType, _commonUtils.QuoteParamterName($"p_{_paramsSource.Count}"));
+
+                                //判断是否是DateTime类型，如果是DateTime类型，需要转换成ClickHouse支持的时间格式
+                                if (col.Attribute.MapType == typeof(DateTime) || col.Attribute.MapType == typeof(DateTime?) )
+                                {
+                                    //获取当前实时区
+                                    colsql = $"toDateTime({colsql},'Asia/Shanghai')";
+                                }
+
                                 cwsb.Append(_commonUtils.RewriteColumn(col, colsql));
                                 if (_noneParameter == false)
                                     _commonUtils.AppendParamter(_paramsSource, null, col, col.Attribute.MapType, val);