From aac02169b686767a5bd7f00c0d053bd701628e77 Mon Sep 17 00:00:00 2001 From: sunkaixuan <610262374@qq.com> Date: Sat, 13 Aug 2022 19:02:01 +0800 Subject: [PATCH] Update ClickHouse --- .../ClickHouseTest/Demo/Demo3_Insertable.cs | 12 ++++++------ .../ClickHouse/SqlBuilder/ClickHouseInsertBuilder.cs | 2 +- 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/Src/Asp.NetCore2/ClickHouseTest/Demo/Demo3_Insertable.cs b/Src/Asp.NetCore2/ClickHouseTest/Demo/Demo3_Insertable.cs index 4035eb4a4..4d727c496 100644 --- a/Src/Asp.NetCore2/ClickHouseTest/Demo/Demo3_Insertable.cs +++ b/Src/Asp.NetCore2/ClickHouseTest/Demo/Demo3_Insertable.cs @@ -37,18 +37,18 @@ namespace OrmTest }; //Ignore CreateTime - db.Insertable(insertObj).IgnoreColumns(it => new { it.CreateTime }).ExecuteReturnIdentity();//get identity - db.Insertable(insertObj).IgnoreColumns("CreateTime").ExecuteReturnIdentity(); + db.Insertable(insertObj).IgnoreColumns(it => new { it.CreateTime }).ExecuteReturnSnowflakeId();//get identity + db.Insertable(insertObj).IgnoreColumns("CreateTime").ExecuteReturnSnowflakeId(); //Only insert Name and Price - db.Insertable(insertObj).InsertColumns(it => new { it.Name, it.Price }).ExecuteReturnIdentity(); - db.Insertable(insertObj).InsertColumns("Name", "Price").ExecuteReturnIdentity(); + db.Insertable(insertObj).InsertColumns(it => new { it.Name, it.Price }).ExecuteReturnSnowflakeId(); + db.Insertable(insertObj).InsertColumns("Name", "Price").ExecuteReturnSnowflakeId(); //ignore null columns - db.Insertable(updateObjs).ExecuteCommand();//get change row count + db.Insertable(updateObjs).ExecuteReturnSnowflakeId();//get change row count //Use Lock - db.Insertable(insertObj).With(SqlWith.UpdLock).ExecuteCommand(); + db.Insertable(insertObj).With(SqlWith.UpdLock).ExecuteReturnSnowflakeId(); Console.WriteLine("#### Insertable End ####"); } diff --git a/Src/Asp.NetCore2/SqlSugar.ClickHouseCore/ClickHouse/SqlBuilder/ClickHouseInsertBuilder.cs b/Src/Asp.NetCore2/SqlSugar.ClickHouseCore/ClickHouse/SqlBuilder/ClickHouseInsertBuilder.cs index 88420b6aa..256456e71 100644 --- a/Src/Asp.NetCore2/SqlSugar.ClickHouseCore/ClickHouse/SqlBuilder/ClickHouseInsertBuilder.cs +++ b/Src/Asp.NetCore2/SqlSugar.ClickHouseCore/ClickHouse/SqlBuilder/ClickHouseInsertBuilder.cs @@ -27,7 +27,7 @@ namespace SqlSugar.ClickHouse int i = 0; public object FormatValue(object value, string name) { - var n = "N"; + var n = ""; if (this.Context.CurrentConnectionConfig.MoreSettings != null && this.Context.CurrentConnectionConfig.MoreSettings.DisableNvarchar) { n = "";