diff --git a/FreeSql/Internal/CommonProvider/InsertOrUpdateProvider.cs b/FreeSql/Internal/CommonProvider/InsertOrUpdateProvider.cs
index 082358d4..2c6fefdf 100644
--- a/FreeSql/Internal/CommonProvider/InsertOrUpdateProvider.cs
+++ b/FreeSql/Internal/CommonProvider/InsertOrUpdateProvider.cs
@@ -290,6 +290,7 @@ namespace FreeSql.Internal.CommonProvider
         public abstract string ToSql();
         public int ExecuteAffrows()
         {
+            if (_sourceSql != null) return this.RawExecuteAffrows();
             var affrows = 0;
             var ss = SplitSourceByIdentityValueIsNull(_source);
             try
@@ -408,6 +409,7 @@ namespace FreeSql.Internal.CommonProvider
         }
         async public Task<int> ExecuteAffrowsAsync(CancellationToken cancellationToken = default)
         {
+            if (_sourceSql != null) return this.RawExecuteAffrows();
             var affrows = 0;
             var ss = SplitSourceByIdentityValueIsNull(_source);
             try