为所有数据库 CodeFirst 中的 LocalExecuteScalar 增加 AOP

Author: hyzx86

FreeSql.DbContext/FreeSql.DbContext.xml

@@ -612,8 +612,8 @@ class 测试中文表
         [Fact]
         public void AddUniques()
         {
-            var sql = g.sqlserver.CodeFirst.GetComparisonDDLStatements<AddUniquesInfo>();
             g.sqlserver.CodeFirst.SyncStructure<AddUniquesInfo>();
+            var sql = g.sqlserver.CodeFirst.GetComparisonDDLStatements<AddUniquesInfo>();
             g.sqlserver.CodeFirst.SyncStructure(typeof(AddUniquesInfo), "AddUniquesInfo1");
         }
         [Table(Name = "AddUniquesInfo", OldName = "AddUniquesInfo2")]

FreeSql.Tests/FreeSql.Tests/SqlServer/SqlServerCodeFirstTest.cs

@@ -480,7 +480,9 @@ object LocalExecuteScalar(string db, string sql)
                     using (var cmd = conn.Value.CreateCommand())
                     {
                         cmd.CommandText = sql;
-                        cmd.CommandType = CommandType.Text;
+                        cmd.CommandType = CommandType.Text; 
+                        var before = new Aop.CommandBeforeEventArgs(cmd);
+                        this._orm?.Aop.CommandBeforeHandler?.Invoke(this._orm, before);
                         return cmd.ExecuteScalar();
                     }
                 }

Providers/FreeSql.Provider.ClickHouse/ClickHouseCodeFirst.cs

@@ -78,7 +78,7 @@ protected override string GetComparisonDDLStatements(params TypeAndName[] object
         {
             Object<DbConnection> conn = null;
             string database = null;
-            
+
             try
             {
                 conn = _orm.Ado.MasterPool.Get(TimeSpan.FromSeconds(5));
@@ -382,6 +382,8 @@ object LocalExecuteScalar(string db, string sql)
                     {
                         cmd.CommandText = sql;
                         cmd.CommandType = CommandType.Text;
+                        var before = new Aop.CommandBeforeEventArgs(cmd);
+                        this._orm?.Aop.CommandBeforeHandler?.Invoke(this._orm, before);
                         return cmd.ExecuteScalar();
                     }
                 }

Providers/FreeSql.Provider.Custom/MySql/CustomMySqlCodeFirst.cs

@@ -474,6 +474,8 @@ object LocalExecuteScalar(string db, string sql)
                     {
                         cmd.CommandText = sql;
                         cmd.CommandType = CommandType.Text;
+                        var before = new Aop.CommandBeforeEventArgs(cmd);
+                        this._orm?.Aop.CommandBeforeHandler?.Invoke(this._orm, before);
                         return cmd.ExecuteScalar();
                     }
                 }

Providers/FreeSql.Provider.Custom/SqlServer/CustomSqlServerCodeFirst.cs

@@ -186,7 +186,9 @@ object LocalExecuteScalar(string db, string sql)
                     using (var cmd = conn.Value.CreateCommand())
                     {
                         cmd.CommandText = sql;
-                        cmd.CommandType = CommandType.Text;
+                        cmd.CommandType = CommandType.Text; 
+                        var before = new Aop.CommandBeforeEventArgs(cmd);
+                        this._orm?.Aop.CommandBeforeHandler?.Invoke(this._orm, before);
                         return cmd.ExecuteScalar();
                     }
                 }

Providers/FreeSql.Provider.GBase/GBaseCodeFirst.cs

@@ -393,6 +393,8 @@ object LocalExecuteScalar(string db, string sql)
                     {
                         cmd.CommandText = sql;
                         cmd.CommandType = CommandType.Text;
+                        var before = new Aop.CommandBeforeEventArgs(cmd);
+                        this._orm?.Aop.CommandBeforeHandler?.Invoke(this._orm, before);
                         return cmd.ExecuteScalar();
                     }
                 }

Providers/FreeSql.Provider.MySql/MySqlCodeFirst.cs

@@ -383,6 +383,8 @@ object LocalExecuteScalar(string db, string sql)
                     {
                         cmd.CommandText = sql;
                         cmd.CommandType = CommandType.Text;
+                        var before = new Aop.CommandBeforeEventArgs(cmd);
+                        this._orm?.Aop.CommandBeforeHandler?.Invoke(this._orm, before);
                         return cmd.ExecuteScalar();
                     }
                 }

Providers/FreeSql.Provider.Odbc/MySql/OdbcMySqlCodeFirst.cs

@@ -475,6 +475,8 @@ object LocalExecuteScalar(string db, string sql)
                     {
                         cmd.CommandText = sql;
                         cmd.CommandType = CommandType.Text;
+                        var before = new Aop.CommandBeforeEventArgs(cmd);
+                        this._orm?.Aop.CommandBeforeHandler?.Invoke(this._orm, before);
                         return cmd.ExecuteScalar();
                     }
                 }

Providers/FreeSql.Provider.Odbc/SqlServer/OdbcSqlServerCodeFirst.cs

@@ -477,6 +477,8 @@ object LocalExecuteScalar(string db, string sql)
                     {
                         cmd.CommandText = sql;
                         cmd.CommandType = CommandType.Text;
+                        var before = new Aop.CommandBeforeEventArgs(cmd);
+                        this._orm?.Aop.CommandBeforeHandler?.Invoke(this._orm, before);
                         return cmd.ExecuteScalar();
                     }
                 }