- 修复 IUpdate.SetSource SqlServer 批量更新 Cast 问题；#1755

dotnetcore · Mar 22, 2024 · 63a8e8e · 63a8e8e
1 parent ce8d699
commit 63a8e8e
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/Providers/FreeSql.Provider.Custom/SqlServer/Curd/CustomSqlServerUpdate.cs b/Providers/FreeSql.Provider.Custom/SqlServer/Curd/CustomSqlServerUpdate.cs
@@ -90,7 +90,7 @@ protected override void ToSqlCase(StringBuilder caseWhen, ColumnInfo[] primarys)
 			foreach (var pk in primarys)
 			{
 				if (pkidx > 0) caseWhen.Append(" + '+' + ");
-				caseWhen.Append("cast(").Append(_commonUtils.RereadColumn(pk, _commonUtils.QuoteSqlName(pk.Attribute.Name))).Append(" as varchar)");
+				caseWhen.Append("cast(").Append(_commonUtils.RereadColumn(pk, _commonUtils.QuoteSqlName(pk.Attribute.Name))).Append(" as varchar(2000))");
 				++pkidx;
 			}
 			caseWhen.Append(")");
@@ -107,7 +107,7 @@ protected override void ToSqlWhen(StringBuilder sb, ColumnInfo[] primarys, objec
 			foreach (var pk in primarys)
 			{
 				if (pkidx > 0) sb.Append(" + '+' + ");
-				sb.Append("cast(").Append(_commonUtils.FormatSql("{0}", pk.GetDbValue(d))).Append(" as varchar)");
+				sb.Append("cast(").Append(_commonUtils.FormatSql("{0}", pk.GetDbValue(d))).Append(" as varchar(2000))");
 				++pkidx;
 			}
 		}

diff --git a/Providers/FreeSql.Provider.Odbc/SqlServer/Curd/OdbcSqlServerUpdate.cs b/Providers/FreeSql.Provider.Odbc/SqlServer/Curd/OdbcSqlServerUpdate.cs
@@ -90,7 +90,7 @@ protected override void ToSqlCase(StringBuilder caseWhen, ColumnInfo[] primarys)
 			foreach (var pk in primarys)
 			{
 				if (pkidx > 0) caseWhen.Append(" + '+' + ");
-				caseWhen.Append("cast(").Append(_commonUtils.RereadColumn(pk, _commonUtils.QuoteSqlName(pk.Attribute.Name))).Append(" as varchar)");
+				caseWhen.Append("cast(").Append(_commonUtils.RereadColumn(pk, _commonUtils.QuoteSqlName(pk.Attribute.Name))).Append(" as varchar(2000))");
 				++pkidx;
 			}
 			caseWhen.Append(")");
@@ -107,7 +107,7 @@ protected override void ToSqlWhen(StringBuilder sb, ColumnInfo[] primarys, objec
 			foreach (var pk in primarys)
 			{
 				if (pkidx > 0) sb.Append(" + '+' + ");
-				sb.Append("cast(").Append(_commonUtils.FormatSql("{0}", pk.GetDbValue(d))).Append(" as varchar)");
+				sb.Append("cast(").Append(_commonUtils.FormatSql("{0}", pk.GetDbValue(d))).Append(" as varchar(2000))");
 				++pkidx;
 			}
 		}

diff --git a/Providers/FreeSql.Provider.SqlServer/Curd/SqlServerUpdate.cs b/Providers/FreeSql.Provider.SqlServer/Curd/SqlServerUpdate.cs
@@ -90,7 +90,7 @@ protected override void ToSqlCase(StringBuilder caseWhen, ColumnInfo[] primarys)
             foreach (var pk in primarys)
             {
                 if (pkidx > 0) caseWhen.Append(" + '+' + ");
-                caseWhen.Append("cast(").Append(_commonUtils.RereadColumn(pk, _commonUtils.QuoteSqlName(pk.Attribute.Name))).Append(" as varchar)");
+                caseWhen.Append("cast(").Append(_commonUtils.RereadColumn(pk, _commonUtils.QuoteSqlName(pk.Attribute.Name))).Append(" as varchar(2000))");
                 ++pkidx;
             }
             caseWhen.Append(")");
@@ -107,7 +107,7 @@ protected override void ToSqlWhen(StringBuilder sb, ColumnInfo[] primarys, objec
             foreach (var pk in primarys)
             {
                 if (pkidx > 0) sb.Append(" + '+' + ");
-                sb.Append("cast(").Append(_commonUtils.FormatSql("{0}", pk.GetDbValue(d))).Append(" as varchar)");
+                sb.Append("cast(").Append(_commonUtils.FormatSql("{0}", pk.GetDbValue(d))).Append(" as varchar(2000))");
                 ++pkidx;
             }
         }