提交 37aa7e92 编写于 作者: s0611163's avatar s0611163

SQL打印 漏写 SQL参数

上级 4e86d719
...@@ -282,7 +282,7 @@ namespace Dapper.LiteSql ...@@ -282,7 +282,7 @@ namespace Dapper.LiteSql
Tuple<string, string> delTmpl = _provider.CreateDeleteSqlTempldate(); Tuple<string, string> delTmpl = _provider.CreateDeleteSqlTempldate();
sbSql.Append(string.Format(delTmpl.Item1 + " {0} " + delTmpl.Item2 + " {1}", GetTableName(_provider, type), condition)); sbSql.Append(string.Format(delTmpl.Item1 + " {0} " + delTmpl.Item2 + " {1}", GetTableName(_provider, type), condition));
OnExecuting?.Invoke(sbSql.ToString(), null); OnExecuting?.Invoke(sbSql.ToString(), cmdParms);
using (_conn = _connFactory.GetConnection(_tran)) using (_conn = _connFactory.GetConnection(_tran))
{ {
...@@ -304,7 +304,7 @@ namespace Dapper.LiteSql ...@@ -304,7 +304,7 @@ namespace Dapper.LiteSql
Tuple<string, string> delTmpl = _provider.CreateDeleteSqlTempldate(); Tuple<string, string> delTmpl = _provider.CreateDeleteSqlTempldate();
sbSql.Append(string.Format(delTmpl.Item1 + " {0} " + delTmpl.Item2 + " {1}", GetTableName(_provider, type), condition)); sbSql.Append(string.Format(delTmpl.Item1 + " {0} " + delTmpl.Item2 + " {1}", GetTableName(_provider, type), condition));
OnExecuting?.Invoke(sbSql.ToString(), null); OnExecuting?.Invoke(sbSql.ToString(), cmdParms);
using (_conn = await _connFactory.GetConnectionAsync(_tran)) using (_conn = await _connFactory.GetConnectionAsync(_tran))
{ {
......
...@@ -241,7 +241,7 @@ namespace Dapper.LiteSql ...@@ -241,7 +241,7 @@ namespace Dapper.LiteSql
public bool Exists(string sqlString, DbParameter[] cmdParms) public bool Exists(string sqlString, DbParameter[] cmdParms)
{ {
SqlFilter(ref sqlString); SqlFilter(ref sqlString);
OnExecuting?.Invoke(sqlString, null); OnExecuting?.Invoke(sqlString, cmdParms);
using (_conn = _connFactory.GetConnection(_tran)) using (_conn = _connFactory.GetConnection(_tran))
{ {
...@@ -266,7 +266,7 @@ namespace Dapper.LiteSql ...@@ -266,7 +266,7 @@ namespace Dapper.LiteSql
public async Task<bool> ExistsAsync(string sqlString, DbParameter[] cmdParms) public async Task<bool> ExistsAsync(string sqlString, DbParameter[] cmdParms)
{ {
SqlFilter(ref sqlString); SqlFilter(ref sqlString);
OnExecuting?.Invoke(sqlString, null); OnExecuting?.Invoke(sqlString, cmdParms);
using (_conn = await _connFactory.GetConnectionAsync(_tran)) using (_conn = await _connFactory.GetConnectionAsync(_tran))
{ {
...@@ -294,7 +294,7 @@ namespace Dapper.LiteSql ...@@ -294,7 +294,7 @@ namespace Dapper.LiteSql
public T QuerySingle<T>(string sqlString, DbParameter[] cmdParms) public T QuerySingle<T>(string sqlString, DbParameter[] cmdParms)
{ {
SqlFilter(ref sqlString); SqlFilter(ref sqlString);
OnExecuting?.Invoke(sqlString, null); OnExecuting?.Invoke(sqlString, cmdParms);
using (_conn = _connFactory.GetConnection(_tran)) using (_conn = _connFactory.GetConnection(_tran))
{ {
...@@ -321,7 +321,7 @@ namespace Dapper.LiteSql ...@@ -321,7 +321,7 @@ namespace Dapper.LiteSql
public object QuerySingle(string sqlString, DbParameter[] cmdParms) public object QuerySingle(string sqlString, DbParameter[] cmdParms)
{ {
SqlFilter(ref sqlString); SqlFilter(ref sqlString);
OnExecuting?.Invoke(sqlString, null); OnExecuting?.Invoke(sqlString, cmdParms);
using (_conn = _connFactory.GetConnection(_tran)) using (_conn = _connFactory.GetConnection(_tran))
{ {
...@@ -348,7 +348,7 @@ namespace Dapper.LiteSql ...@@ -348,7 +348,7 @@ namespace Dapper.LiteSql
public async Task<T> QuerySingleAsync<T>(string sqlString, DbParameter[] cmdParms) public async Task<T> QuerySingleAsync<T>(string sqlString, DbParameter[] cmdParms)
{ {
SqlFilter(ref sqlString); SqlFilter(ref sqlString);
OnExecuting?.Invoke(sqlString, null); OnExecuting?.Invoke(sqlString, cmdParms);
using (_conn = await _connFactory.GetConnectionAsync(_tran)) using (_conn = await _connFactory.GetConnectionAsync(_tran))
{ {
...@@ -375,7 +375,7 @@ namespace Dapper.LiteSql ...@@ -375,7 +375,7 @@ namespace Dapper.LiteSql
public async Task<object> QuerySingleAsync(string sqlString, DbParameter[] cmdParms) public async Task<object> QuerySingleAsync(string sqlString, DbParameter[] cmdParms)
{ {
SqlFilter(ref sqlString); SqlFilter(ref sqlString);
OnExecuting?.Invoke(sqlString, null); OnExecuting?.Invoke(sqlString, cmdParms);
using (_conn = await _connFactory.GetConnectionAsync(_tran)) using (_conn = await _connFactory.GetConnectionAsync(_tran))
{ {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册