weiai/FreeSql
1
0
Fork 0
mirror of https://github.com/dotnetcore/FreeSql.git synced 2026-02-23 16:50:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

- 恢复 MySql8.0.30 ExecuteInserted/ExecuteUpdated/ExecuteDeleted 的适配改动；#2001

Browse Source
This commit is contained in:
2881099
2025-03-31 16:51:23 +08:00
parent 1fcda96b5b
commit 66d94d0a88
12 changed files with 148 additions and 358 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
FreeSql/Interface/Curd/IDelete.cs
View File

@@ -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
}

4
FreeSql/Interface/Curd/IInsert.cs
View File

@@ -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);

2
FreeSql/Interface/Curd/IUpdate.cs
View File

@@ -305,7 +305,7 @@ namespace FreeSql
Task<int> ExecuteAffrowsAsync(CancellationToken cancellationToken = default);
/// <summary>
/// 执行SQL语句，返回更新后的记录<para></para>
/// 注意：此方法只有 Postgresql/SqlServer 有效果
/// 注意：此方法只有 Postgresql/SqlServer/Maridb/Firebird/人大金仓 有效果
/// </summary>
/// <returns></returns>
Task<List<T1>> ExecuteUpdatedAsync(CancellationToken cancellationToken = default);

43
Providers/FreeSql.Provider.Custom/MySql/Curd/CustomMySqlDelete.cs
View File

@@ -24,9 +24,6 @@ namespace FreeSql.Custom.MySql
var ret = new List<T1>();
DbParameter[] dbParms = null;
StringBuilder sbret = null;
var queryType = _table.TypeLazy ?? _table.Type;
int[] queryIndexs = null;
var queryFlag = "";
ToSqlFetch(sb =>
{
if (dbParms == null)
@@ -36,36 +33,26 @@ namespace FreeSql.Custom.MySql
sbret.Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in _table.Columns.Values)
{
if (colidx > 0) sbret.Append(", ");
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
queryIndexs = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
queryFlag = sbflag.ToString();
}
var sql = sb.Append(sbret).ToString();
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Delete, sql, dbParms);
_orm.Aop.CurdBeforeHandler?.Invoke(this, before);
Exception exception = null;
try
{
_orm.Ado.ExecuteReader(_connection, _transaction, fetch =>
{
ret.Add((T1)Utils.ExecuteReaderToClass(queryFlag, queryType, queryIndexs, fetch.Object, 0, _commonUtils));
}, CommandType.Text, sql, _commandTimeout, dbParms);
ret.AddRange(_orm.Ado.Query<T1>(_table.TypeLazy ?? _table.Type, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms));
}
catch (Exception ex)
{
exception = ex;
throw ex;
throw;
}
finally
{
@@ -88,9 +75,6 @@ namespace FreeSql.Custom.MySql
var ret = new List<T1>();
DbParameter[] dbParms = null;
StringBuilder sbret = null;
var queryType = _table.TypeLazy ?? _table.Type;
int[] queryIndexs = null;
var queryFlag = "";
await ToSqlFetchAsync(async sb =>
{
if (dbParms == null)
@@ -100,37 +84,26 @@ namespace FreeSql.Custom.MySql
sbret.Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in _table.Columns.Values)
{
if (colidx > 0) sbret.Append(", ");
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
queryIndexs = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
queryFlag = sbflag.ToString();
}
var sql = sb.Append(sbret).ToString();
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Delete, sql, dbParms);
_orm.Aop.CurdBeforeHandler?.Invoke(this, before);
Exception exception = null;
try
{
await _orm.Ado.ExecuteReaderAsync(_connection, _transaction, fetch =>
{
ret.Add((T1)Utils.ExecuteReaderToClass(queryFlag, queryType, queryIndexs, fetch.Object, 0, _commonUtils));
return Task.FromResult(false);
}, CommandType.Text, sql, _commandTimeout, dbParms, cancellationToken);
ret.AddRange(await _orm.Ado.QueryAsync<T1>(_table.TypeLazy ?? _table.Type, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms, cancellationToken));
}
catch (Exception ex)
{
exception = ex;
throw ex;
throw;
}
finally
{

31
Providers/FreeSql.Provider.Custom/MySql/Curd/CustomMySqlInsert.cs
View File

@@ -91,20 +91,12 @@ namespace FreeSql.Custom.MySql
sb.Append(sql).Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in _table.Columns.Values)
{
if (colidx > 0) sb.Append(", ");
sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
var queryType = _table.TypeLazy ?? _table.Type;
var indexes = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
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);
@@ -112,10 +104,7 @@ namespace FreeSql.Custom.MySql
Exception exception = null;
try
{
_orm.Ado.ExecuteReader(_connection, _transaction, fetch =>
{
ret.Add((T1)Utils.ExecuteReaderToClass(flag, queryType, 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)
{
@@ -182,20 +171,12 @@ namespace FreeSql.Custom.MySql
sb.Append(sql).Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in _table.Columns.Values)
{
if (colidx > 0) sb.Append(", ");
sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
var queryType = _table.TypeLazy ?? _table.Type;
var indexes = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
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);
@@ -203,11 +184,7 @@ namespace FreeSql.Custom.MySql
Exception exception = null;
try
{
await _orm.Ado.ExecuteReaderAsync(_connection, _transaction, fetch =>
{
ret.Add((T1)Utils.ExecuteReaderToClass(flag, queryType, 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)
{

39
Providers/FreeSql.Provider.Custom/MySql/Curd/CustomMySqlUpdate.cs
View File

@@ -36,9 +36,6 @@ namespace FreeSql.Custom.MySql
var ret = new List<TReturn>();
DbParameter[] dbParms = null;
StringBuilder sbret = null;
var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
int[] queryIndexs = null;
var queryFlag = "";
ToSqlFetch(sb =>
{
if (dbParms == null)
@@ -48,19 +45,12 @@ namespace FreeSql.Custom.MySql
sbret.Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in columns)
{
if (colidx > 0) sbret.Append(", ");
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
queryIndexs = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
queryFlag = sbflag.ToString();
}
var sql = sb.Append(sbret).ToString();
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
@@ -69,11 +59,8 @@ namespace FreeSql.Custom.MySql
Exception exception = null;
try
{
var rettmp = new List<TReturn>();
_orm.Ado.ExecuteReader(_connection, _transaction, fetch =>
{
rettmp.Add((TReturn)Utils.ExecuteReaderToClass(queryFlag, queryType, queryIndexs, fetch.Object, 0, _commonUtils));
}, CommandType.Text, sql, _commandTimeout, 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);
}
@@ -139,9 +126,6 @@ namespace FreeSql.Custom.MySql
var ret = new List<TReturn>();
DbParameter[] dbParms = null;
StringBuilder sbret = null;
var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
int[] queryIndexs = null;
var queryFlag = "";
await ToSqlFetchAsync(async sb =>
{
if (dbParms == null)
@@ -151,19 +135,12 @@ namespace FreeSql.Custom.MySql
sbret.Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in columns)
{
if (colidx > 0) sbret.Append(", ");
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
queryIndexs = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
queryFlag = sbflag.ToString();
}
var sql = sb.Append(sbret).ToString();
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
@@ -172,12 +149,8 @@ namespace FreeSql.Custom.MySql
Exception exception = null;
try
{
var rettmp = new List<TReturn>();
await _orm.Ado.ExecuteReaderAsync(_connection, _transaction, fetch =>
{
rettmp.Add((TReturn)Utils.ExecuteReaderToClass(queryFlag, queryType, queryIndexs, fetch.Object, 0, _commonUtils));
return Task.FromResult(false);
}, CommandType.Text, sql, _commandTimeout, dbParms, cancellationToken);
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);
}

51
Providers/FreeSql.Provider.MySql/Curd/MySqlDelete.cs
View File

@@ -24,9 +24,6 @@ namespace FreeSql.MySql.Curd
var ret = new List<T1>();
DbParameter[] dbParms = null;
StringBuilder sbret = null;
var queryType = _table.TypeLazy ?? _table.Type;
int[] queryIndexs = null;
var queryFlag = "";
ToSqlFetch(sb =>
{
if (dbParms == null)
@@ -36,31 +33,21 @@ namespace FreeSql.MySql.Curd
sbret.Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in _table.Columns.Values)
{
if (colidx > 0) sbret.Append(", ");
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
queryIndexs = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
queryFlag = sbflag.ToString();
}
var sql = sb.Append(sbret).ToString();
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Delete, sql, dbParms);
_orm.Aop.CurdBeforeHandler?.Invoke(this, before);
Exception exception = null;
try
{
_orm.Ado.ExecuteReader(_connection, _transaction, fetch =>
{
ret.Add((T1)Utils.ExecuteReaderToClass(queryFlag, queryType, queryIndexs, fetch.Object, 0, _commonUtils));
}, CommandType.Text, sql, _commandTimeout, dbParms);
ret.AddRange(_orm.Ado.Query<T1>(_table.TypeLazy ?? _table.Type, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms));
}
catch (Exception ex)
{
@@ -73,7 +60,11 @@ namespace FreeSql.MySql.Curd
_orm.Aop.CurdAfterHandler?.Invoke(this, after);
}
});
sbret?.Clear();
if (dbParms != null)
{
this.ClearData();
sbret.Clear();
}
return ret;
}
@@ -84,9 +75,6 @@ namespace FreeSql.MySql.Curd
var ret = new List<T1>();
DbParameter[] dbParms = null;
StringBuilder sbret = null;
var queryType = _table.TypeLazy ?? _table.Type;
int[] queryIndexs = null;
var queryFlag = "";
await ToSqlFetchAsync(async sb =>
{
if (dbParms == null)
@@ -96,32 +84,21 @@ namespace FreeSql.MySql.Curd
sbret.Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in _table.Columns.Values)
{
if (colidx > 0) sbret.Append(", ");
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
queryIndexs = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
queryFlag = sbflag.ToString();
}
var sql = sb.Append(sbret).ToString();
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Delete, sql, dbParms);
_orm.Aop.CurdBeforeHandler?.Invoke(this, before);
Exception exception = null;
try
{
await _orm.Ado.ExecuteReaderAsync(_connection, _transaction, fetch =>
{
ret.Add((T1)Utils.ExecuteReaderToClass(queryFlag, queryType, queryIndexs, fetch.Object, 0, _commonUtils));
return Task.FromResult(false);
}, CommandType.Text, sql, _commandTimeout, dbParms, cancellationToken);
ret.AddRange(await _orm.Ado.QueryAsync<T1>(_table.TypeLazy ?? _table.Type, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms, cancellationToken));
}
catch (Exception ex)
{
@@ -134,7 +111,11 @@ namespace FreeSql.MySql.Curd
_orm.Aop.CurdAfterHandler?.Invoke(this, after);
}
});
sbret?.Clear();
if (dbParms != null)
{
this.ClearData();
sbret.Clear();
}
return ret;
}
#endif

31
Providers/FreeSql.Provider.MySql/Curd/MySqlInsert.cs
View File

@@ -79,20 +79,12 @@ namespace FreeSql.MySql.Curd
sb.Append(sql).Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in _table.Columns.Values)
{
if (colidx > 0) sb.Append(", ");
sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
var queryType = _table.TypeLazy ?? _table.Type;
var indexes = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
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);
@@ -100,10 +92,7 @@ namespace FreeSql.MySql.Curd
Exception exception = null;
try
{
_orm.Ado.ExecuteReader(_connection, _transaction, fetch =>
{
ret.Add((T1)Utils.ExecuteReaderToClass(flag, queryType, 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)
{
@@ -159,20 +148,12 @@ namespace FreeSql.MySql.Curd
sb.Append(sql).Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in _table.Columns.Values)
{
if (colidx > 0) sb.Append(", ");
sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
var queryType = _table.TypeLazy ?? _table.Type;
var indexes = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
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);
@@ -180,11 +161,7 @@ namespace FreeSql.MySql.Curd
Exception exception = null;
try
{
await _orm.Ado.ExecuteReaderAsync(_connection, _transaction, fetch =>
{
ret.Add((T1)Utils.ExecuteReaderToClass(flag, queryType, 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)
{

39
Providers/FreeSql.Provider.MySql/Curd/MySqlUpdate.cs
View File

@@ -36,9 +36,6 @@ namespace FreeSql.MySql.Curd
var ret = new List<TReturn>();
DbParameter[] dbParms = null;
StringBuilder sbret = null;
var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
int[] queryIndexs = null;
var queryFlag = "";
ToSqlFetch(sb =>
{
if (dbParms == null)
@@ -48,19 +45,12 @@ namespace FreeSql.MySql.Curd
sbret.Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in columns)
{
if (colidx > 0) sbret.Append(", ");
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
queryIndexs = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
queryFlag = sbflag.ToString();
}
var sql = sb.Append(sbret).ToString();
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
@@ -69,11 +59,8 @@ namespace FreeSql.MySql.Curd
Exception exception = null;
try
{
var rettmp = new List<TReturn>();
_orm.Ado.ExecuteReader(_connection, _transaction, fetch =>
{
rettmp.Add((TReturn)Utils.ExecuteReaderToClass(queryFlag, queryType, queryIndexs, fetch.Object, 0, _commonUtils));
}, CommandType.Text, sql, _commandTimeout, 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);
}
@@ -139,9 +126,6 @@ namespace FreeSql.MySql.Curd
var ret = new List<TReturn>();
DbParameter[] dbParms = null;
StringBuilder sbret = null;
var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
int[] queryIndexs = null;
var queryFlag = "";
await ToSqlFetchAsync(async sb =>
{
if (dbParms == null)
@@ -151,19 +135,12 @@ namespace FreeSql.MySql.Curd
sbret.Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in columns)
{
if (colidx > 0) sbret.Append(", ");
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
queryIndexs = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
queryFlag = sbflag.ToString();
}
var sql = sb.Append(sbret).ToString();
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
@@ -172,12 +149,8 @@ namespace FreeSql.MySql.Curd
Exception exception = null;
try
{
var rettmp = new List<TReturn>();
await _orm.Ado.ExecuteReaderAsync(_connection, _transaction, fetch =>
{
rettmp.Add((TReturn)Utils.ExecuteReaderToClass(queryFlag, queryType, queryIndexs, fetch.Object, 0, _commonUtils));
return Task.FromResult(false);
}, CommandType.Text, sql, _commandTimeout, dbParms, cancellationToken);
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);
}

51
Providers/FreeSql.Provider.Odbc/MySql/Curd/OdbcMySqlDelete.cs
View File

@@ -24,9 +24,6 @@ namespace FreeSql.Odbc.MySql
var ret = new List<T1>();
DbParameter[] dbParms = null;
StringBuilder sbret = null;
var queryType = _table.TypeLazy ?? _table.Type;
int[] queryIndexs = null;
var queryFlag = "";
ToSqlFetch(sb =>
{
if (dbParms == null)
@@ -36,31 +33,21 @@ namespace FreeSql.Odbc.MySql
sbret.Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in _table.Columns.Values)
{
if (colidx > 0) sbret.Append(", ");
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
queryIndexs = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
queryFlag = sbflag.ToString();
}
var sql = sb.Append(sbret).ToString();
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Delete, sql, dbParms);
_orm.Aop.CurdBeforeHandler?.Invoke(this, before);
Exception exception = null;
try
{
_orm.Ado.ExecuteReader(_connection, _transaction, fetch =>
{
ret.Add((T1)Utils.ExecuteReaderToClass(queryFlag, queryType, queryIndexs, fetch.Object, 0, _commonUtils));
}, CommandType.Text, sql, _commandTimeout, dbParms);
ret.AddRange(_orm.Ado.Query<T1>(_table.TypeLazy ?? _table.Type, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms));
}
catch (Exception ex)
{
@@ -73,7 +60,11 @@ namespace FreeSql.Odbc.MySql
_orm.Aop.CurdAfterHandler?.Invoke(this, after);
}
});
sbret?.Clear();
if (dbParms != null)
{
this.ClearData();
sbret.Clear();
}
return ret;
}
@@ -84,9 +75,6 @@ namespace FreeSql.Odbc.MySql
var ret = new List<T1>();
DbParameter[] dbParms = null;
StringBuilder sbret = null;
var queryType = _table.TypeLazy ?? _table.Type;
int[] queryIndexs = null;
var queryFlag = "";
await ToSqlFetchAsync(async sb =>
{
if (dbParms == null)
@@ -96,32 +84,21 @@ namespace FreeSql.Odbc.MySql
sbret.Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in _table.Columns.Values)
{
if (colidx > 0) sbret.Append(", ");
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
queryIndexs = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
queryFlag = sbflag.ToString();
}
var sql = sb.Append(sbret).ToString();
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Delete, sql, dbParms);
_orm.Aop.CurdBeforeHandler?.Invoke(this, before);
Exception exception = null;
try
{
await _orm.Ado.ExecuteReaderAsync(_connection, _transaction, fetch =>
{
ret.Add((T1)Utils.ExecuteReaderToClass(queryFlag, queryType, queryIndexs, fetch.Object, 0, _commonUtils));
return Task.FromResult(false);
}, CommandType.Text, sql, _commandTimeout, dbParms, cancellationToken);
ret.AddRange(await _orm.Ado.QueryAsync<T1>(_table.TypeLazy ?? _table.Type, _connection, _transaction, CommandType.Text, sql, _commandTimeout, dbParms, cancellationToken));
}
catch (Exception ex)
{
@@ -134,7 +111,11 @@ namespace FreeSql.Odbc.MySql
_orm.Aop.CurdAfterHandler?.Invoke(this, after);
}
});
sbret?.Clear();
if (dbParms != null)
{
this.ClearData();
sbret.Clear();
}
return ret;
}
#endif

31
Providers/FreeSql.Provider.Odbc/MySql/Curd/OdbcMySqlInsert.cs
View File

@@ -91,20 +91,12 @@ namespace FreeSql.Odbc.MySql
sb.Append(sql).Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in _table.Columns.Values)
{
if (colidx > 0) sb.Append(", ");
sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
var queryType = _table.TypeLazy ?? _table.Type;
var indexes = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
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);
@@ -112,10 +104,7 @@ namespace FreeSql.Odbc.MySql
Exception exception = null;
try
{
_orm.Ado.ExecuteReader(_connection, _transaction, fetch =>
{
ret.Add((T1)Utils.ExecuteReaderToClass(flag, queryType, 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)
{
@@ -182,20 +171,12 @@ namespace FreeSql.Odbc.MySql
sb.Append(sql).Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in _table.Columns.Values)
{
if (colidx > 0) sb.Append(", ");
sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sb.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
var queryType = _table.TypeLazy ?? _table.Type;
var indexes = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
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);
@@ -203,11 +184,7 @@ namespace FreeSql.Odbc.MySql
Exception exception = null;
try
{
await _orm.Ado.ExecuteReaderAsync(_connection, _transaction, fetch =>
{
ret.Add((T1)Utils.ExecuteReaderToClass(flag, queryType, 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)
{

39
Providers/FreeSql.Provider.Odbc/MySql/Curd/OdbcMySqlUpdate.cs
View File

@@ -36,9 +36,6 @@ namespace FreeSql.Odbc.MySql
var ret = new List<TReturn>();
DbParameter[] dbParms = null;
StringBuilder sbret = null;
var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
int[] queryIndexs = null;
var queryFlag = "";
ToSqlFetch(sb =>
{
if (dbParms == null)
@@ -48,19 +45,12 @@ namespace FreeSql.Odbc.MySql
sbret.Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in columns)
{
if (colidx > 0) sbret.Append(", ");
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
queryIndexs = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
queryFlag = sbflag.ToString();
}
var sql = sb.Append(sbret).ToString();
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
@@ -69,11 +59,8 @@ namespace FreeSql.Odbc.MySql
Exception exception = null;
try
{
var rettmp = new List<TReturn>();
_orm.Ado.ExecuteReader(_connection, _transaction, fetch =>
{
rettmp.Add((TReturn)Utils.ExecuteReaderToClass(queryFlag, queryType, queryIndexs, fetch.Object, 0, _commonUtils));
}, CommandType.Text, sql, _commandTimeout, 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);
}
@@ -139,9 +126,6 @@ namespace FreeSql.Odbc.MySql
var ret = new List<TReturn>();
DbParameter[] dbParms = null;
StringBuilder sbret = null;
var queryType = typeof(TReturn) == typeof(T1) ? (_table.TypeLazy ?? _table.Type) : null;
int[] queryIndexs = null;
var queryFlag = "";
await ToSqlFetchAsync(async sb =>
{
if (dbParms == null)
@@ -151,19 +135,12 @@ namespace FreeSql.Odbc.MySql
sbret.Append(" RETURNING ");
var colidx = 0;
var sbflag = new StringBuilder().Append("adoQuery(crud)");
var dic = new Dictionary<string, int>(StringComparer.CurrentCultureIgnoreCase);
foreach (var col in columns)
{
if (colidx > 0) sbret.Append(", ");
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name)));
if (dic.ContainsKey(col.CsName)) continue;
sbflag.Append(col.Attribute.Name).Append(":").Append(colidx).Append(",");
dic.Add(col.CsName, colidx);
sbret.Append(_commonUtils.RereadColumn(col, _commonUtils.QuoteSqlName(col.Attribute.Name))).Append(" as ").Append(_commonUtils.QuoteSqlName(col.CsName));
++colidx;
}
queryIndexs = AdoProvider.GetQueryTypeProperties(queryType).Select(a => dic.TryGetValue(a.Key, out var tryint) ? tryint : -1).ToArray();
queryFlag = sbflag.ToString();
}
var sql = sb.Append(sbret).ToString();
var before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Update, sql, dbParms);
@@ -172,12 +149,8 @@ namespace FreeSql.Odbc.MySql
Exception exception = null;
try
{
var rettmp = new List<TReturn>();
await _orm.Ado.ExecuteReaderAsync(_connection, _transaction, fetch =>
{
rettmp.Add((TReturn)Utils.ExecuteReaderToClass(queryFlag, queryType, queryIndexs, fetch.Object, 0, _commonUtils));
return Task.FromResult(false);
}, CommandType.Text, sql, _commandTimeout, dbParms, cancellationToken);
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);
}