diff --git a/Examples/base_entity/Program.cs b/Examples/base_entity/Program.cs
index 7f38c8d4a..13ef61d3d 100644
--- a/Examples/base_entity/Program.cs
+++ b/Examples/base_entity/Program.cs
@@ -621,7 +621,16 @@ namespace base_entity
             BaseEntity.Initialization(fsql, () => _asyncUow.Value);
             #endregion
 
+            fsql.Delete<User1>().Where("1=1").ExecuteAffrows();
+            fsql.Insert(new List<User1>
+            {
+                new User1 { Nickname = "nickname11", Username = "username11", Description = "desc11" },
+                new User1 { Nickname = "n2", Username = "u2", Description = "d2" },
+                new User1 { Nickname = "n3", Username = "u3", Description = "d3" },
+            }).ExecuteAffrows();
+
             fsql.Insert(new User1()).ExecuteInserted();
+            fsql.Update<User1>().SetSource(new User1()).ExecuteUpdated();
 
             fsql.InsertOrUpdate<AppInfoEntity>().SetSource(new AppInfoEntity { AppID = "03DN8CW8", AppName = "app_01" }).ExecuteAffrows();
             var repo2211 = fsql.GetRepository<AppInfoEntity>();
diff --git a/FreeSql.DbContext/FreeSql.DbContext.xml b/FreeSql.DbContext/FreeSql.DbContext.xml
index a7a94fcda..c941a15d9 100644
--- a/FreeSql.DbContext/FreeSql.DbContext.xml
+++ b/FreeSql.DbContext/FreeSql.DbContext.xml
@@ -758,5 +758,13 @@
             <param name="that"></param>
             <returns></returns>
         </member>
+        <member name="M:Microsoft.Extensions.DependencyInjection.FreeSqlRepositoryDependencyInjection.AddFreeRepository(Microsoft.Extensions.DependencyInjection.IServiceCollection,System.Reflection.Assembly[])">
+            <summary>
+            批量注入 Repository，可以参考代码自行调整
+            </summary>
+            <param name="services"></param>
+            <param name="assemblies"></param>
+            <returns></returns>
+        </member>
     </members>
 </doc>
diff --git a/FreeSql/Interface/Curd/IDelete.cs b/FreeSql/Interface/Curd/IDelete.cs
index 6f78b31f7..ec8f21263 100644
--- a/FreeSql/Interface/Curd/IDelete.cs
+++ b/FreeSql/Interface/Curd/IDelete.cs
@@ -133,6 +133,11 @@ namespace FreeSql
 #if net40
 #else
         Task<int> ExecuteAffrowsAsync(CancellationToken cancellationToken = default);
+        /// <summary>
+        /// 执行SQL语句，返回被删除的记录<para></para>
+        /// 注意：此方法只有 Postgresql/SqlServer/Maridb/Firebird/人大金仓 有效果
+        /// </summary>
+        /// <returns></returns>
         Task<List<T1>> ExecuteDeletedAsync(CancellationToken cancellationToken = default);
 #endif
     }
diff --git a/FreeSql/Interface/Curd/IInsert.cs b/FreeSql/Interface/Curd/IInsert.cs
index 0b3be6998..0ecee4b97 100644
--- a/FreeSql/Interface/Curd/IInsert.cs
+++ b/FreeSql/Interface/Curd/IInsert.cs
@@ -156,7 +156,7 @@ namespace FreeSql
         long ExecuteIdentity();
         /// <summary>
         /// 执行SQL语句，返回插入后的记录<para></para>
-        /// 注意：此方法只有 Postgresql/SqlServer/MySql8.0.30+/Maridb/Firebird/DuckDB/人大金仓 有效果
+        /// 注意：此方法只有 Postgresql/SqlServer/Maridb/Firebird/DuckDB/人大金仓 有效果
         /// </summary>
         /// <returns></returns>
         List<T1> ExecuteInserted();
@@ -176,7 +176,7 @@ namespace FreeSql
         Task<long> ExecuteIdentityAsync(CancellationToken cancellationToken = default);
         /// <summary>
         /// 执行SQL语句，返回插入后的记录<para></para>
-        /// 注意：此方法只有 Postgresql/SqlServer/MySql8.0.30+/Maridb/Firebird/DuckDB/人大金仓 有效果
+        /// 注意：此方法只有 Postgresql/SqlServer/Maridb/Firebird/DuckDB/人大金仓 有效果
         /// </summary>
         /// <returns></returns>
         Task<List<T1>> ExecuteInsertedAsync(CancellationToken cancellationToken = default);
diff --git a/FreeSql/Interface/Curd/IUpdate.cs b/FreeSql/Interface/Curd/IUpdate.cs
index b52893959..70e6d8135 100644
--- a/FreeSql/Interface/Curd/IUpdate.cs
+++ b/FreeSql/Interface/Curd/IUpdate.cs
@@ -303,11 +303,11 @@ namespace FreeSql
 #if net40
 #else
 		Task<int> ExecuteAffrowsAsync(CancellationToken cancellationToken = default);
-		/// <summary>
-		/// 执行SQL语句，返回更新后的记录<para></para>
-		/// 注意：此方法只有 Postgresql/SqlServer 有效果
-		/// </summary>
-		/// <returns></returns>
+        /// <summary>
+        /// 执行SQL语句，返回更新后的记录<para></para>
+        /// 注意：此方法只有 Postgresql/SqlServer/Maridb/Firebird/人大金仓 有效果
+        /// </summary>
+        /// <returns></returns>
 		Task<List<T1>> ExecuteUpdatedAsync(CancellationToken cancellationToken = default);
 		Task<List<TReturn>> ExecuteUpdatedAsync<TReturn>(Expression<Func<T1, TReturn>> returnColumns, CancellationToken cancellationToken = default);
 #endif
diff --git a/FreeSql/Internal/CommonProvider/AdoProvider/AdoProvider.cs b/FreeSql/Internal/CommonProvider/AdoProvider/AdoProvider.cs
index 8a0b0d2e6..84ca94b41 100644
--- a/FreeSql/Internal/CommonProvider/AdoProvider/AdoProvider.cs
+++ b/FreeSql/Internal/CommonProvider/AdoProvider/AdoProvider.cs
@@ -92,7 +92,7 @@ namespace FreeSql.Internal.CommonProvider
             }
         }
 
-        internal Dictionary<string, PropertyInfo> GetQueryTypeProperties(Type type)
+        public static Dictionary<string, PropertyInfo> GetQueryTypeProperties(Type type)
         {
             return type.GetPropertiesDictIgnoreCase(); //与 ExecuteArrayRowReadClassOrTuple 顺序同步，防止【延时属性】获取到位置不对的问题
             //var tb = _util.GetTableByEntity(type);
diff --git a/FreeSql/Internal/CommonProvider/UpdateProvider.cs b/FreeSql/Internal/CommonProvider/UpdateProvider.cs
index 66d3fe650..71fd55997 100644
--- a/FreeSql/Internal/CommonProvider/UpdateProvider.cs
+++ b/FreeSql/Internal/CommonProvider/UpdateProvider.cs
@@ -8,6 +8,7 @@ using System.Data.Common;
 using System.Linq;
 using System.Linq.Expressions;
 using System.Text;
+using System.Threading;
 using System.Threading.Tasks;
 
 namespace FreeSql.Internal.CommonProvider
@@ -476,13 +477,20 @@ namespace FreeSql.Internal.CommonProvider
 		public abstract int ExecuteAffrows();
 		protected abstract List<TReturn> ExecuteUpdated<TReturn>(IEnumerable<ColumnInfo> columns);
 
-        public List<T1> ExecuteUpdated() => ExecuteUpdated<T1>(_table.ColumnsByPosition);
+        public List<T1> ExecuteUpdated()
+        {
+            var ret = ExecuteUpdated<T1>(_table.Columns.Values);
+            if (_table.TypeLazySetOrm != null) ret.ForEach(item => _table.TypeLazySetOrm.Invoke(item, new object[] { _orm }));
+            return ret;
+        }
         public List<TReturn> ExecuteUpdated<TReturn>(Expression<Func<T1, TReturn>> returnColumns)
 		{
             var cols = _commonExpression.ExpressionSelectColumns_MemberAccess_New_NewArrayInit(null, null, returnColumns?.Body, false, null)
                 .Distinct().Select(a => _table.ColumnsByCs.TryGetValue(a, out var c) ? c : null).Where(a => a != null).ToArray();
-			return ExecuteUpdated<TReturn>(cols);
-		}
+			var ret = ExecuteUpdated<TReturn>(cols);
+            if (_table.TypeLazySetOrm != null) ret.ForEach(item => _table.TypeLazySetOrm.Invoke(item, new object[] { _orm }));
+            return ret;
+        }
 
 		public IUpdate<T1> IgnoreColumns(Expression<Func<T1, object>> columns) => IgnoreColumns(_commonExpression.ExpressionSelectColumns_MemberAccess_New_NewArrayInit(null, null, columns?.Body, false, null));
         public IUpdate<T1> UpdateColumns(Expression<Func<T1, object>> columns) => UpdateColumns(_commonExpression.ExpressionSelectColumns_MemberAccess_New_NewArrayInit(null, null, columns?.Body, false, null));
diff --git a/FreeSql/Internal/CommonProvider/UpdateProviderAsync.cs b/FreeSql/Internal/CommonProvider/UpdateProviderAsync.cs
index 45bc2f898..4f999d309 100644
--- a/FreeSql/Internal/CommonProvider/UpdateProviderAsync.cs
+++ b/FreeSql/Internal/CommonProvider/UpdateProviderAsync.cs
@@ -143,13 +143,20 @@ namespace FreeSql.Internal.CommonProvider
 		public abstract Task<int> ExecuteAffrowsAsync(CancellationToken cancellationToken = default);
 		protected abstract Task<List<TReturn>> ExecuteUpdatedAsync<TReturn>(IEnumerable<ColumnInfo> columns, CancellationToken cancellationToken = default);
 
-		public Task<List<T1>> ExecuteUpdatedAsync(CancellationToken cancellationToken = default) => ExecuteUpdatedAsync<T1>(_table.ColumnsByPosition, cancellationToken);
-		public Task<List<TReturn>> ExecuteUpdatedAsync<TReturn>(Expression<Func<T1, TReturn>> returnColumns, CancellationToken cancellationToken = default)
+		async public Task<List<T1>> ExecuteUpdatedAsync(CancellationToken cancellationToken = default)
+		{
+			var ret = await ExecuteUpdatedAsync<T1>(_table.ColumnsByPosition, cancellationToken);
+            if (_table.TypeLazySetOrm != null) ret.ForEach(item => _table.TypeLazySetOrm.Invoke(item, new object[] { _orm }));
+            return ret;
+        }
+		async public Task<List<TReturn>> ExecuteUpdatedAsync<TReturn>(Expression<Func<T1, TReturn>> returnColumns, CancellationToken cancellationToken = default)
 		{
 			var cols = _commonExpression.ExpressionSelectColumns_MemberAccess_New_NewArrayInit(null, null, returnColumns?.Body, false, null)
 				.Distinct().Select(a => _table.ColumnsByCs.TryGetValue(a, out var c) ? c : null).Where(a => a != null).ToArray();
-			return ExecuteUpdatedAsync<TReturn>(cols, cancellationToken);
-		}
+			var ret = await ExecuteUpdatedAsync<TReturn>(cols, cancellationToken);
+            if (_table.TypeLazySetOrm != null) ret.ForEach(item => _table.TypeLazySetOrm.Invoke(item, new object[] { _orm }));
+            return ret;
+        }
 #endif
 	}
 }
diff --git a/Providers/FreeSql.Provider.Custom/MySql/Curd/CustomMySqlDelete.cs b/Providers/FreeSql.Provider.Custom/MySql/Curd/CustomMySqlDelete.cs
index 90e4f2044..6645c100c 100644
--- a/Providers/FreeSql.Provider.Custom/MySql/Curd/CustomMySqlDelete.cs
+++ b/Providers/FreeSql.Provider.Custom/MySql/Curd/CustomMySqlDelete.cs
@@ -1,8 +1,10 @@
 using FreeSql.Internal;
+using FreeSql.Internal.CommonProvider;
 using System;
 using System.Collections.Generic;
 using System.Data;
 using System.Data.Common;
+using System.Linq;
 using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
@@ -50,7 +52,7 @@ namespace FreeSql.Custom.MySql
                 catch (Exception ex)
                 {
                     exception = ex;
-                    throw ex;
+                    throw;
                 }
                 finally
                 {
@@ -101,7 +103,7 @@ namespace FreeSql.Custom.MySql
                 catch (Exception ex)
                 {
                     exception = ex;
-                    throw ex;
+                    throw;
                 }
                 finally
                 {
diff --git a/Providers/FreeSql.Provider.Custom/MySql/Curd/CustomMySqlInsert.cs b/Providers/FreeSql.Provider.Custom/MySql/Curd/CustomMySqlInsert.cs
index a6902fbec..505ada97c 100644
--- a/Providers/FreeSql.Provider.Custom/MySql/Curd/CustomMySqlInsert.cs
+++ b/Providers/FreeSql.Provider.Custom/MySql/Curd/CustomMySqlInsert.cs
@@ -1,10 +1,12 @@
 using FreeSql.Internal;
+using FreeSql.Internal.CommonProvider;
 using FreeSql.Internal.Model;
 using FreeSql.Internal.ObjectPool;
 using System;
 using System.Collections.Generic;
 using System.Data;
 using System.Data.Common;
+using System.Linq;
 using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
@@ -89,25 +91,12 @@ namespace FreeSql.Custom.MySql
             sb.Append(sql).Append(" RETURNING ");
 
             var colidx = 0;
-            var propidx = 0;
-            var props = _table.Type.GetPropertiesDictIgnoreCase();
-            var indexes = new int[props.Count];
-            var sbflag = new StringBuilder().Append("insertedQuery");
-            foreach (var prop in props)
+            foreach (var col in _table.Columns.Values)
             {
-                if (_table.ColumnsByCs.TryGetValue(prop.Key, out var col))
-                {
-                    if (colidx > 0) sb.Append(", ");
-                    sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
-                    sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
-                    indexes[propidx] = colidx;
-                    ++colidx;
-                }
-                else
-                    indexes[propidx] = -1;
-                ++propidx;
+                if (colidx > 0) sb.Append(", ");
+                sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
+                ++colidx;
             }
-            var flag = sbflag.ToString();
             sql = sb.ToString();
             var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Insert, sql, _params);
             _orm.Aop.CurdBeforeHandler?.Invoke(this, before);
@@ -115,10 +104,7 @@ namespace FreeSql.Custom.MySql
             Exception exception = null;
             try
             {
-                _orm.Ado.ExecuteReader(_connection, _transaction, fetch =>
-                {
-                    ret.Add((T1)Utils.ExecuteReaderToClass(flag, _table.TypeLazy ?? _table.Type, indexes, fetch.Object, 0, _commonUtils));
-                }, CommandType.Text, sql, _commandTimeout, _params);
+                ret = _orm.Ado.Query<T1>(_table.TypeLazy ?? _table.Type, _connection, _transaction, CommandType.Text, sql, _commandTimeout, _params);
             }
             catch (Exception ex)
             {
@@ -185,25 +171,12 @@ namespace FreeSql.Custom.MySql
             sb.Append(sql).Append(" RETURNING ");
 
             var colidx = 0;
-            var propidx = 0;
-            var props = _table.Type.GetPropertiesDictIgnoreCase();
-            var indexes = new int[props.Count];
-            var sbflag = new StringBuilder().Append("insertedQuery");
-            foreach (var prop in props)
+            foreach (var col in _table.Columns.Values)
             {
-                if (_table.ColumnsByCs.TryGetValue(prop.Key, out var col))
-                {
-                    if (colidx > 0) sb.Append(", ");
-                    sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
-                    sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
-                    indexes[propidx] = colidx;
-                    ++colidx;
-                }
-                else
-                    indexes[propidx] = -1;
-                ++propidx;
+                if (colidx > 0) sb.Append(", ");
+                sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
+                ++colidx;
             }
-            var flag = sbflag.ToString();
             sql = sb.ToString();
             var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Insert, sql, _params);
             _orm.Aop.CurdBeforeHandler?.Invoke(this, before);
@@ -211,11 +184,7 @@ namespace FreeSql.Custom.MySql
             Exception exception = null;
             try
             {
-                await _orm.Ado.ExecuteReaderAsync(_connection, _transaction, fetch =>
-                {
-                    ret.Add((T1)Utils.ExecuteReaderToClass(flag, _table.TypeLazy ?? _table.Type, indexes, fetch.Object, 0, _commonUtils));
-                    return Task.FromResult(false);
-                }, CommandType.Text, sql, _commandTimeout, _params);
+                ret = await _orm.Ado.QueryAsync<T1>(_table.TypeLazy ?? _table.Type, _connection, _transaction, CommandType.Text, sql, _commandTimeout, _params, cancellationToken);
             }
             catch (Exception ex)
             {
diff --git a/Providers/FreeSql.Provider.Custom/MySql/Curd/CustomMySqlUpdate.cs b/Providers/FreeSql.Provider.Custom/MySql/Curd/CustomMySqlUpdate.cs
index 65929f1c0..53e436521 100644
--- a/Providers/FreeSql.Provider.Custom/MySql/Curd/CustomMySqlUpdate.cs
+++ b/Providers/FreeSql.Provider.Custom/MySql/Curd/CustomMySqlUpdate.cs
@@ -1,4 +1,5 @@
 using FreeSql.Internal;
+using FreeSql.Internal.CommonProvider;
 using FreeSql.Internal.Model;
 using System;
 using System.Collections.Generic;
@@ -30,55 +31,55 @@ namespace FreeSql.Custom.MySql
 		public override int ExecuteAffrows() => base.SplitExecuteAffrows(_batchRowsLimit > 0 ? _batchRowsLimit : 500, _batchParameterLimit > 0 ? _batchParameterLimit : 3000);
 		protected override List<TReturn> ExecuteUpdated<TReturn>(IEnumerable<ColumnInfo> columns) => base.SplitExecuteUpdated<TReturn>(_batchRowsLimit > 0 ? _batchRowsLimit : 500, _batchParameterLimit > 0 ? _batchParameterLimit : 3000, columns);
 
-		protected override List<TReturn> RawExecuteUpdated<TReturn>(IEnumerable<ColumnInfo> columns)
-		{
-			var ret = new List<TReturn>();
-			DbParameter[] dbParms = null;
-			StringBuilder sbret = null;
-			ToSqlFetch(sb =>
-			{
-				if (dbParms == null)
-				{
-					dbParms = _params.Concat(_paramsSource).ToArray();
-					sbret = new StringBuilder();
-					sbret.Append(" RETURNING ");
+        protected override List<TReturn> RawExecuteUpdated<TReturn>(IEnumerable<ColumnInfo> columns)
+        {
+            var ret = new List<TReturn>();
+            DbParameter[] dbParms = null;
+            StringBuilder sbret = null;
+            ToSqlFetch(sb =>
+            {
+                if (dbParms == null)
+                {
+                    dbParms = _params.Concat(_paramsSource).ToArray();
+                    sbret = new StringBuilder();
+                    sbret.Append(" RETURNING ");
 
-					var colidx = 0;
-					foreach (var col in columns)
-					{
-						if (colidx > 0) sbret.Append(", ");
-						sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
-						++colidx;
-					}
-				}
-				var sql = sb.Append(sbret).ToString();
-				var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
-				_orm.Aop.CurdBeforeHandler?.Invoke(this, before);
+                    var colidx = 0;
+                    foreach (var col in columns)
+                    {
+                        if (colidx > 0) sbret.Append(", ");
+                        sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
+                        ++colidx;
+                    }
+                }
+                var sql = sb.Append(sbret).ToString();
+                var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
+                _orm.Aop.CurdBeforeHandler?.Invoke(this, before);
 
-				Exception exception = null;
-				try
-				{
-					var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
-					var rettmp = _orm.Ado.Query<TReturn>(queryType, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms);
-					ValidateVersionAndThrow(rettmp.Count, sql, dbParms);
-					ret.AddRange(rettmp);
-				}
-				catch (Exception ex)
-				{
-					exception = ex;
-					throw;
-				}
-				finally
-				{
-					var after = new Aop.CurdAfterEventArgs(before, exception, ret);
-					_orm.Aop.CurdAfterHandler?.Invoke(this, after);
-				}
-			});
-			sbret?.Clear();
-			return ret;
-		}
+                Exception exception = null;
+                try
+                {
+                    var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
+                    var rettmp = _orm.Ado.Query<TReturn>(queryType, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms);
+                    ValidateVersionAndThrow(rettmp.Count, sql, dbParms);
+                    ret.AddRange(rettmp);
+                }
+                catch (Exception ex)
+                {
+                    exception = ex;
+                    throw;
+                }
+                finally
+                {
+                    var after = new Aop.CurdAfterEventArgs(before, exception, ret);
+                    _orm.Aop.CurdAfterHandler?.Invoke(this, after);
+                }
+            });
+            sbret?.Clear();
+            return ret;
+        }
 
-		protected override void ToSqlCase(StringBuilder caseWhen, ColumnInfo[] primarys)
+        protected override void ToSqlCase(StringBuilder caseWhen, ColumnInfo[] primarys)
 		{
 			if (primarys.Length == 1)
 			{
@@ -120,8 +121,8 @@ namespace FreeSql.Custom.MySql
         public override Task<int> ExecuteAffrowsAsync(CancellationToken cancellationToken = default) => base.SplitExecuteAffrowsAsync(_batchRowsLimit > 0 ? _batchRowsLimit : 500, _batchParameterLimit > 0 ? _batchParameterLimit : 3000, cancellationToken);
 		protected override Task<List<TReturn>> ExecuteUpdatedAsync<TReturn>(IEnumerable<ColumnInfo> columns, CancellationToken cancellationToken = default) => base.SplitExecuteUpdatedAsync<TReturn>(_batchRowsLimit > 0 ? _batchRowsLimit : 500, _batchParameterLimit > 0 ? _batchParameterLimit : 3000, columns, cancellationToken);
 
-		async protected override Task<List<TReturn>> RawExecuteUpdatedAsync<TReturn>(IEnumerable<ColumnInfo> columns, CancellationToken cancellationToken = default)
-		{
+        async protected override Task<List<TReturn>> RawExecuteUpdatedAsync<TReturn>(IEnumerable<ColumnInfo> columns, CancellationToken cancellationToken = default)
+        {
             var ret = new List<TReturn>();
             DbParameter[] dbParms = null;
             StringBuilder sbret = null;
@@ -147,10 +148,10 @@ namespace FreeSql.Custom.MySql
 
                 Exception exception = null;
                 try
-				{
-					var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
-					var rettmp = await _orm.Ado.QueryAsync<TReturn>(queryType, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms, cancellationToken);
-					ValidateVersionAndThrow(rettmp.Count, sql, dbParms);
+                {
+                    var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
+                    var rettmp = await _orm.Ado.QueryAsync<TReturn>(queryType, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms, cancellationToken);
+                    ValidateVersionAndThrow(rettmp.Count, sql, dbParms);
                     ret.AddRange(rettmp);
                 }
                 catch (Exception ex)
@@ -168,5 +169,5 @@ namespace FreeSql.Custom.MySql
             return ret;
         }
 #endif
-	}
+    }
 }
diff --git a/Providers/FreeSql.Provider.MySql/Curd/MySqlDelete.cs b/Providers/FreeSql.Provider.MySql/Curd/MySqlDelete.cs
index 43f48c993..5d38e44a8 100644
--- a/Providers/FreeSql.Provider.MySql/Curd/MySqlDelete.cs
+++ b/Providers/FreeSql.Provider.MySql/Curd/MySqlDelete.cs
@@ -1,8 +1,10 @@
 using FreeSql.Internal;
+using FreeSql.Internal.CommonProvider;
 using System;
 using System.Collections.Generic;
 using System.Data;
 using System.Data.Common;
+using System.Linq;
 using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
diff --git a/Providers/FreeSql.Provider.MySql/Curd/MySqlInsert.cs b/Providers/FreeSql.Provider.MySql/Curd/MySqlInsert.cs
index 33e358e92..82e44fe09 100644
--- a/Providers/FreeSql.Provider.MySql/Curd/MySqlInsert.cs
+++ b/Providers/FreeSql.Provider.MySql/Curd/MySqlInsert.cs
@@ -1,9 +1,11 @@
 using FreeSql.Internal;
+using FreeSql.Internal.CommonProvider;
 using FreeSql.Internal.Model;
 using System;
 using System.Collections.Generic;
 using System.Data;
 using System.Data.Common;
+using System.Linq;
 using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
@@ -77,25 +79,12 @@ namespace FreeSql.MySql.Curd
             sb.Append(sql).Append(" RETURNING ");
 
             var colidx = 0;
-            var propidx = 0;
-            var props = _table.Type.GetPropertiesDictIgnoreCase(); //与 ExecuteArrayRowReadClassOrTuple 顺序同步
-            var indexes = new int[props.Count];
-            var sbflag = new StringBuilder().Append("insertedQuery");
-            foreach (var prop in props)
+            foreach (var col in _table.Columns.Values)
             {
-                if (_table.ColumnsByCs.TryGetValue(prop.Key, out var col))
-                {
-                    if (colidx > 0) sb.Append(", ");
-                    sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
-                    sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
-                    indexes[propidx] = colidx;
-                    ++colidx;
-                }
-                else
-                    indexes[propidx] = -1;
-                ++propidx;
+                if (colidx > 0) sb.Append(", ");
+                sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
+                ++colidx;
             }
-            var flag = sbflag.ToString();
             sql = sb.ToString();
             var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Insert, sql, _params);
             _orm.Aop.CurdBeforeHandler?.Invoke(this, before);
@@ -103,10 +92,7 @@ namespace FreeSql.MySql.Curd
             Exception exception = null;
             try
             {
-                _orm.Ado.ExecuteReader(_connection, _transaction, fetch =>
-                {
-                    ret.Add((T1)Utils.ExecuteReaderToClass(flag, _table.TypeLazy ?? _table.Type, indexes, fetch.Object, 0, _commonUtils));
-                }, CommandType.Text, sql, _commandTimeout, _params);
+                ret = _orm.Ado.Query<T1>(_table.TypeLazy ?? _table.Type, _connection, _transaction, CommandType.Text, sql, _commandTimeout, _params);
             }
             catch (Exception ex)
             {
@@ -162,25 +148,12 @@ namespace FreeSql.MySql.Curd
             sb.Append(sql).Append(" RETURNING ");
 
             var colidx = 0;
-            var propidx = 0;
-            var props = _table.Type.GetPropertiesDictIgnoreCase();
-            var indexes = new int[props.Count];
-            var sbflag = new StringBuilder().Append("insertedQuery");
-            foreach (var prop in props)
+            foreach (var col in _table.Columns.Values)
             {
-                if (_table.ColumnsByCs.TryGetValue(prop.Key, out var col))
-                {
-                    if (colidx > 0) sb.Append(", ");
-                    sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
-                    sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
-                    indexes[propidx] = colidx;
-                    ++colidx;
-                }
-                else
-                    indexes[propidx] = -1;
-                ++propidx;
+                if (colidx > 0) sb.Append(", ");
+                sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
+                ++colidx;
             }
-            var flag = sbflag.ToString();
             sql = sb.ToString();
             var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Insert, sql, _params);
             _orm.Aop.CurdBeforeHandler?.Invoke(this, before);
@@ -188,11 +161,7 @@ namespace FreeSql.MySql.Curd
             Exception exception = null;
             try
             {
-                await _orm.Ado.ExecuteReaderAsync(_connection, _transaction, fetch =>
-                {
-                    ret.Add((T1)Utils.ExecuteReaderToClass(flag, _table.TypeLazy ?? _table.Type, indexes, fetch.Object, 0, _commonUtils));
-                    return Task.FromResult(false);
-                }, CommandType.Text, sql, _commandTimeout, _params);
+                ret = await _orm.Ado.QueryAsync<T1>(_table.TypeLazy ?? _table.Type, _connection, _transaction, CommandType.Text, sql, _commandTimeout, _params, cancellationToken);
             }
             catch (Exception ex)
             {
diff --git a/Providers/FreeSql.Provider.MySql/Curd/MySqlUpdate.cs b/Providers/FreeSql.Provider.MySql/Curd/MySqlUpdate.cs
index cee1e9ef3..bccb59111 100644
--- a/Providers/FreeSql.Provider.MySql/Curd/MySqlUpdate.cs
+++ b/Providers/FreeSql.Provider.MySql/Curd/MySqlUpdate.cs
@@ -1,4 +1,5 @@
 using FreeSql.Internal;
+using FreeSql.Internal.CommonProvider;
 using FreeSql.Internal.Model;
 using System;
 using System.Collections.Generic;
@@ -30,8 +31,8 @@ namespace FreeSql.MySql.Curd
         public override int ExecuteAffrows() => base.SplitExecuteAffrows(_batchRowsLimit > 0 ? _batchRowsLimit : 500, _batchParameterLimit > 0 ? _batchParameterLimit : 3000);
 		protected override List<TReturn> ExecuteUpdated<TReturn>(IEnumerable<ColumnInfo> columns) => base.SplitExecuteUpdated<TReturn>(_batchRowsLimit > 0 ? _batchRowsLimit : 500, _batchParameterLimit > 0 ? _batchParameterLimit : 3000, columns);
 
-		protected override List<TReturn> RawExecuteUpdated<TReturn>(IEnumerable<ColumnInfo> columns)
-		{
+        protected override List<TReturn> RawExecuteUpdated<TReturn>(IEnumerable<ColumnInfo> columns)
+        {
             var ret = new List<TReturn>();
             DbParameter[] dbParms = null;
             StringBuilder sbret = null;
@@ -57,10 +58,10 @@ namespace FreeSql.MySql.Curd
 
                 Exception exception = null;
                 try
-				{
-					var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
-					var rettmp = _orm.Ado.Query<TReturn>(queryType, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms);
-					ValidateVersionAndThrow(rettmp.Count, sql, dbParms);
+                {
+                    var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
+                    var rettmp = _orm.Ado.Query<TReturn>(queryType, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms);
+                    ValidateVersionAndThrow(rettmp.Count, sql, dbParms);
                     ret.AddRange(rettmp);
                 }
                 catch (Exception ex)
@@ -120,8 +121,8 @@ namespace FreeSql.MySql.Curd
         public override Task<int> ExecuteAffrowsAsync(CancellationToken cancellationToken = default) => base.SplitExecuteAffrowsAsync(_batchRowsLimit > 0 ? _batchRowsLimit : 500, _batchParameterLimit > 0 ? _batchParameterLimit : 3000, cancellationToken);
 		protected override Task<List<TReturn>> ExecuteUpdatedAsync<TReturn>(IEnumerable<ColumnInfo> columns, CancellationToken cancellationToken = default) => base.SplitExecuteUpdatedAsync<TReturn>(_batchRowsLimit > 0 ? _batchRowsLimit : 500, _batchParameterLimit > 0 ? _batchParameterLimit : 3000, columns, cancellationToken);
 
-		async protected override Task<List<TReturn>> RawExecuteUpdatedAsync<TReturn>(IEnumerable<ColumnInfo> columns, CancellationToken cancellationToken = default)
-		{
+        async protected override Task<List<TReturn>> RawExecuteUpdatedAsync<TReturn>(IEnumerable<ColumnInfo> columns, CancellationToken cancellationToken = default)
+        {
             var ret = new List<TReturn>();
             DbParameter[] dbParms = null;
             StringBuilder sbret = null;
@@ -147,10 +148,10 @@ namespace FreeSql.MySql.Curd
 
                 Exception exception = null;
                 try
-				{
-					var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
-					var rettmp = await _orm.Ado.QueryAsync<TReturn>(queryType, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms, cancellationToken);
-					ValidateVersionAndThrow(rettmp.Count, sql, dbParms);
+                {
+                    var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
+                    var rettmp = await _orm.Ado.QueryAsync<TReturn>(queryType, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms, cancellationToken);
+                    ValidateVersionAndThrow(rettmp.Count, sql, dbParms);
                     ret.AddRange(rettmp);
                 }
                 catch (Exception ex)
diff --git a/Providers/FreeSql.Provider.Odbc/MySql/Curd/OdbcMySqlDelete.cs b/Providers/FreeSql.Provider.Odbc/MySql/Curd/OdbcMySqlDelete.cs
index fdf91e47a..24aa2168e 100644
--- a/Providers/FreeSql.Provider.Odbc/MySql/Curd/OdbcMySqlDelete.cs
+++ b/Providers/FreeSql.Provider.Odbc/MySql/Curd/OdbcMySqlDelete.cs
@@ -1,8 +1,10 @@
 using FreeSql.Internal;
+using FreeSql.Internal.CommonProvider;
 using System;
 using System.Collections.Generic;
 using System.Data;
 using System.Data.Common;
+using System.Linq;
 using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
@@ -50,7 +52,7 @@ namespace FreeSql.Odbc.MySql
                 catch (Exception ex)
                 {
                     exception = ex;
-                    throw ex;
+                    throw;
                 }
                 finally
                 {
@@ -101,7 +103,7 @@ namespace FreeSql.Odbc.MySql
                 catch (Exception ex)
                 {
                     exception = ex;
-                    throw ex;
+                    throw;
                 }
                 finally
                 {
diff --git a/Providers/FreeSql.Provider.Odbc/MySql/Curd/OdbcMySqlInsert.cs b/Providers/FreeSql.Provider.Odbc/MySql/Curd/OdbcMySqlInsert.cs
index 703071dbd..25adfbe3b 100644
--- a/Providers/FreeSql.Provider.Odbc/MySql/Curd/OdbcMySqlInsert.cs
+++ b/Providers/FreeSql.Provider.Odbc/MySql/Curd/OdbcMySqlInsert.cs
@@ -1,10 +1,12 @@
 using FreeSql.Internal;
+using FreeSql.Internal.CommonProvider;
 using FreeSql.Internal.Model;
 using FreeSql.Internal.ObjectPool;
 using System;
 using System.Collections.Generic;
 using System.Data;
 using System.Data.Common;
+using System.Linq;
 using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
@@ -89,25 +91,12 @@ namespace FreeSql.Odbc.MySql
             sb.Append(sql).Append(" RETURNING ");
 
             var colidx = 0;
-            var propidx = 0;
-            var props = _table.Type.GetPropertiesDictIgnoreCase();
-            var indexes = new int[props.Count];
-            var sbflag = new StringBuilder().Append("insertedQuery");
-            foreach (var prop in props)
+            foreach (var col in _table.Columns.Values)
             {
-                if (_table.ColumnsByCs.TryGetValue(prop.Key, out var col))
-                {
-                    if (colidx > 0) sb.Append(", ");
-                    sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
-                    sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
-                    indexes[propidx] = colidx;
-                    ++colidx;
-                }
-                else
-                    indexes[propidx] = -1;
-                ++propidx;
+                if (colidx > 0) sb.Append(", ");
+                sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
+                ++colidx;
             }
-            var flag = sbflag.ToString();
             sql = sb.ToString();
             var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Insert, sql, _params);
             _orm.Aop.CurdBeforeHandler?.Invoke(this, before);
@@ -115,10 +104,7 @@ namespace FreeSql.Odbc.MySql
             Exception exception = null;
             try
             {
-                _orm.Ado.ExecuteReader(_connection, _transaction, fetch =>
-                {
-                    ret.Add((T1)Utils.ExecuteReaderToClass(flag, _table.TypeLazy ?? _table.Type, indexes, fetch.Object, 0, _commonUtils));
-                }, CommandType.Text, sql, _commandTimeout, _params);
+                ret = _orm.Ado.Query<T1>(_table.TypeLazy ?? _table.Type, _connection, _transaction, CommandType.Text, sql, _commandTimeout, _params);
             }
             catch (Exception ex)
             {
@@ -185,25 +171,12 @@ namespace FreeSql.Odbc.MySql
             sb.Append(sql).Append(" RETURNING ");
 
             var colidx = 0;
-            var propidx = 0;
-            var props = _table.Type.GetPropertiesDictIgnoreCase();
-            var indexes = new int[props.Count];
-            var sbflag = new StringBuilder().Append("insertedQuery");
-            foreach (var prop in props)
+            foreach (var col in _table.Columns.Values)
             {
-                if (_table.ColumnsByCs.TryGetValue(prop.Key, out var col))
-                {
-                    if (colidx > 0) sb.Append(", ");
-                    sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
-                    sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
-                    indexes[propidx] = colidx;
-                    ++colidx;
-                }
-                else
-                    indexes[propidx] = -1;
-                ++propidx;
+                if (colidx > 0) sb.Append(", ");
+                sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
+                ++colidx;
             }
-            var flag = sbflag.ToString();
             sql = sb.ToString();
             var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Insert, sql, _params);
             _orm.Aop.CurdBeforeHandler?.Invoke(this, before);
@@ -211,11 +184,7 @@ namespace FreeSql.Odbc.MySql
             Exception exception = null;
             try
             {
-                await _orm.Ado.ExecuteReaderAsync(_connection, _transaction, fetch =>
-                {
-                    ret.Add((T1)Utils.ExecuteReaderToClass(flag, _table.TypeLazy ?? _table.Type, indexes, fetch.Object, 0, _commonUtils));
-                    return Task.FromResult(false);
-                }, CommandType.Text, sql, _commandTimeout, _params);
+                ret = await _orm.Ado.QueryAsync<T1>(_table.TypeLazy ?? _table.Type, _connection, _transaction, CommandType.Text, sql, _commandTimeout, _params, cancellationToken);
             }
             catch (Exception ex)
             {
diff --git a/Providers/FreeSql.Provider.Odbc/MySql/Curd/OdbcMySqlUpdate.cs b/Providers/FreeSql.Provider.Odbc/MySql/Curd/OdbcMySqlUpdate.cs
index a34e97dc4..058a05764 100644
--- a/Providers/FreeSql.Provider.Odbc/MySql/Curd/OdbcMySqlUpdate.cs
+++ b/Providers/FreeSql.Provider.Odbc/MySql/Curd/OdbcMySqlUpdate.cs
@@ -1,4 +1,5 @@
 using FreeSql.Internal;
+using FreeSql.Internal.CommonProvider;
 using FreeSql.Internal.Model;
 using System;
 using System.Collections.Generic;
@@ -30,55 +31,55 @@ namespace FreeSql.Odbc.MySql
 		public override int ExecuteAffrows() => base.SplitExecuteAffrows(_batchRowsLimit > 0 ? _batchRowsLimit : 500, _batchParameterLimit > 0 ? _batchParameterLimit : 3000);
 		protected override List<TReturn> ExecuteUpdated<TReturn>(IEnumerable<ColumnInfo> columns) => base.SplitExecuteUpdated<TReturn>(_batchRowsLimit > 0 ? _batchRowsLimit : 500, _batchParameterLimit > 0 ? _batchParameterLimit : 3000, columns);
 
-		protected override List<TReturn> RawExecuteUpdated<TReturn>(IEnumerable<ColumnInfo> columns)
-		{
-			var ret = new List<TReturn>();
-			DbParameter[] dbParms = null;
-			StringBuilder sbret = null;
-			ToSqlFetch(sb =>
-			{
-				if (dbParms == null)
-				{
-					dbParms = _params.Concat(_paramsSource).ToArray();
-					sbret = new StringBuilder();
-					sbret.Append(" RETURNING ");
+        protected override List<TReturn> RawExecuteUpdated<TReturn>(IEnumerable<ColumnInfo> columns)
+        {
+            var ret = new List<TReturn>();
+            DbParameter[] dbParms = null;
+            StringBuilder sbret = null;
+            ToSqlFetch(sb =>
+            {
+                if (dbParms == null)
+                {
+                    dbParms = _params.Concat(_paramsSource).ToArray();
+                    sbret = new StringBuilder();
+                    sbret.Append(" RETURNING ");
 
-					var colidx = 0;
-					foreach (var col in columns)
-					{
-						if (colidx > 0) sbret.Append(", ");
-						sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
-						++colidx;
-					}
-				}
-				var sql = sb.Append(sbret).ToString();
-				var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
-				_orm.Aop.CurdBeforeHandler?.Invoke(this, before);
+                    var colidx = 0;
+                    foreach (var col in columns)
+                    {
+                        if (colidx > 0) sbret.Append(", ");
+                        sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
+                        ++colidx;
+                    }
+                }
+                var sql = sb.Append(sbret).ToString();
+                var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
+                _orm.Aop.CurdBeforeHandler?.Invoke(this, before);
 
-				Exception exception = null;
-				try
-				{
-					var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
-					var rettmp = _orm.Ado.Query<TReturn>(queryType, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms);
-					ValidateVersionAndThrow(rettmp.Count, sql, dbParms);
-					ret.AddRange(rettmp);
-				}
-				catch (Exception ex)
-				{
-					exception = ex;
-					throw;
-				}
-				finally
-				{
-					var after = new Aop.CurdAfterEventArgs(before, exception, ret);
-					_orm.Aop.CurdAfterHandler?.Invoke(this, after);
-				}
-			});
-			sbret?.Clear();
-			return ret;
-		}
+                Exception exception = null;
+                try
+                {
+                    var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
+                    var rettmp = _orm.Ado.Query<TReturn>(queryType, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms);
+                    ValidateVersionAndThrow(rettmp.Count, sql, dbParms);
+                    ret.AddRange(rettmp);
+                }
+                catch (Exception ex)
+                {
+                    exception = ex;
+                    throw;
+                }
+                finally
+                {
+                    var after = new Aop.CurdAfterEventArgs(before, exception, ret);
+                    _orm.Aop.CurdAfterHandler?.Invoke(this, after);
+                }
+            });
+            sbret?.Clear();
+            return ret;
+        }
 
-		protected override void ToSqlCase(StringBuilder caseWhen, ColumnInfo[] primarys)
+        protected override void ToSqlCase(StringBuilder caseWhen, ColumnInfo[] primarys)
 		{
 			if (primarys.Length == 1)
 			{
@@ -120,53 +121,53 @@ namespace FreeSql.Odbc.MySql
 		public override Task<int> ExecuteAffrowsAsync(CancellationToken cancellationToken = default) => base.SplitExecuteAffrowsAsync(_batchRowsLimit > 0 ? _batchRowsLimit : 500, _batchParameterLimit > 0 ? _batchParameterLimit : 3000, cancellationToken);
 		protected override Task<List<TReturn>> ExecuteUpdatedAsync<TReturn>(IEnumerable<ColumnInfo> columns, CancellationToken cancellationToken = default) => base.SplitExecuteUpdatedAsync<TReturn>(_batchRowsLimit > 0 ? _batchRowsLimit : 500, _batchParameterLimit > 0 ? _batchParameterLimit : 3000, columns, cancellationToken);
 
-		async protected override Task<List<TReturn>> RawExecuteUpdatedAsync<TReturn>(IEnumerable<ColumnInfo> columns, CancellationToken cancellationToken = default)
-		{
-			var ret = new List<TReturn>();
-			DbParameter[] dbParms = null;
-			StringBuilder sbret = null;
-			await ToSqlFetchAsync(async sb =>
-			{
-				if (dbParms == null)
-				{
-					dbParms = _params.Concat(_paramsSource).ToArray();
-					sbret = new StringBuilder();
-					sbret.Append(" RETURNING ");
+        async protected override Task<List<TReturn>> RawExecuteUpdatedAsync<TReturn>(IEnumerable<ColumnInfo> columns, CancellationToken cancellationToken = default)
+        {
+            var ret = new List<TReturn>();
+            DbParameter[] dbParms = null;
+            StringBuilder sbret = null;
+            await ToSqlFetchAsync(async sb =>
+            {
+                if (dbParms == null)
+                {
+                    dbParms = _params.Concat(_paramsSource).ToArray();
+                    sbret = new StringBuilder();
+                    sbret.Append(" RETURNING ");
 
-					var colidx = 0;
-					foreach (var col in columns)
-					{
-						if (colidx > 0) sbret.Append(", ");
-						sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
-						++colidx;
-					}
-				}
-				var sql = sb.Append(sbret).ToString();
-				var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
-				_orm.Aop.CurdBeforeHandler?.Invoke(this, before);
+                    var colidx = 0;
+                    foreach (var col in columns)
+                    {
+                        if (colidx > 0) sbret.Append(", ");
+                        sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
+                        ++colidx;
+                    }
+                }
+                var sql = sb.Append(sbret).ToString();
+                var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
+                _orm.Aop.CurdBeforeHandler?.Invoke(this, before);
 
-				Exception exception = null;
-				try
-				{
-					var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
-					var rettmp = await _orm.Ado.QueryAsync<TReturn>(queryType, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms, cancellationToken);
-					ValidateVersionAndThrow(rettmp.Count, sql, dbParms);
-					ret.AddRange(rettmp);
-				}
-				catch (Exception ex)
-				{
-					exception = ex;
-					throw;
-				}
-				finally
-				{
-					var after = new Aop.CurdAfterEventArgs(before, exception, ret);
-					_orm.Aop.CurdAfterHandler?.Invoke(this, after);
-				}
-			});
-			sbret?.Clear();
-			return ret;
-		}
+                Exception exception = null;
+                try
+                {
+                    var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
+                    var rettmp = await _orm.Ado.QueryAsync<TReturn>(queryType, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms, cancellationToken);
+                    ValidateVersionAndThrow(rettmp.Count, sql, dbParms);
+                    ret.AddRange(rettmp);
+                }
+                catch (Exception ex)
+                {
+                    exception = ex;
+                    throw;
+                }
+                finally
+                {
+                    var after = new Aop.CurdAfterEventArgs(before, exception, ret);
+                    _orm.Aop.CurdAfterHandler?.Invoke(this, after);
+                }
+            });
+            sbret?.Clear();
+            return ret;
+        }
 #endif
-	}
+    }
 }