tk/FreeSql
1
0
Fork 0
mirror of https://github.com/nsnail/FreeSql.git synced 2025-04-22 02:32:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

- 优化 Update 无字段时不做任何处理；

Browse Source
This commit is contained in:
2881099 2023-12-02 00:05:11 +08:00
parent 5f01fbd457
commit 60d329265a
2 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
FreeSql/Internal/CommonProvider/DeleteProvider.cs
View File

@ -205,7 +205,7 @@ namespace FreeSql.Internal.CommonProvider
_tableRule = old => name; _tableRule = old => name;
sb.Clear().Append("DELETE FROM ").Append(_commonUtils.QuoteSqlName(TableRuleInvoke())).Append(newwhere); sb.Clear().Append("DELETE FROM ").Append(_commonUtils.QuoteSqlName(TableRuleInvoke())).Append(newwhere);
_interceptSql?.Invoke(sb); _interceptSql?.Invoke(sb);
fetch(sb); if (sb.Length > 0) fetch(sb);
} }
_tableRule = oldTableRule; _tableRule = oldTableRule;
return; return;
@ -240,7 +240,7 @@ namespace FreeSql.Internal.CommonProvider
_tableRule = old => name; _tableRule = old => name;
sb.Clear().Append("DELETE FROM ").Append(_commonUtils.QuoteSqlName(TableRuleInvoke())).Append(newwhere); sb.Clear().Append("DELETE FROM ").Append(_commonUtils.QuoteSqlName(TableRuleInvoke())).Append(newwhere);
_interceptSql?.Invoke(sb); _interceptSql?.Invoke(sb);
await fetchAsync(sb); if (sb.Length > 0) await fetchAsync(sb);
} }
_tableRule = oldTableRule; _tableRule = oldTableRule;
return; return;

10
FreeSql/Internal/CommonProvider/UpdateProvider.cs
View File

@ -1002,7 +1002,7 @@ namespace FreeSql.Internal.CommonProvider
{ {
var sb1 = new StringBuilder(); var sb1 = new StringBuilder();
ToSqlExtension110(sb1, false); ToSqlExtension110(sb1, false);
fetch(sb1); if (sb1.Length > 0) fetch(sb1);
return; return;
} }
if (_where.Length == 0) return; if (_where.Length == 0) return;
@ -1035,7 +1035,7 @@ namespace FreeSql.Internal.CommonProvider
{ {
var sb1 = new StringBuilder(); var sb1 = new StringBuilder();
ToSqlExtension110(sb1, false); ToSqlExtension110(sb1, false);
await fetchAsync(sb1); if (sb1.Length > 0) await fetchAsync(sb1);
sb1.Clear(); sb1.Clear();
return; return;
} }
@ -1126,7 +1126,11 @@ namespace FreeSql.Internal.CommonProvider
++colidx; ++colidx;
} }
} }
if (colidx == 0) return; if (colidx == 0)
{
sb.Clear();
return;
}
} }
else if (_source.Count > 1) else if (_source.Count > 1)