Updated BatchUpdateString

Author: “llt”

frameworks/CSharp/appmpower/src/appMpower.Orm/Data/DbCommand.cs

@@ -1,4 +1,5 @@
 using System.Data;
+using System.Data.Common;
 using System.Threading.Tasks;
 
 namespace appMpower.Orm.Data
@@ -130,31 +131,31 @@ public IDbDataParameter CreateParameter()
          return _dbCommand.CreateParameter();
       }
 
-      public IDbDataParameter CreateParameter(string name, object value)
+      public DbParameter CreateParameter(string name, object value)
       {
          return CreateParameter(name, DbType.String, value);
       }
 
-      public IDbDataParameter CreateParameter(string name, DbType dbType, object value)
+      public DbParameter CreateParameter(string name, DbType dbType, object value)
       {
-         IDbDataParameter dbDataParameter;
+         DbParameter dbParameter;
 
          if (_dbCommand.Parameters.Contains(name))
          {
-            dbDataParameter = _dbCommand.Parameters[name];
-            dbDataParameter.Value = value;
+            dbParameter = _dbCommand.Parameters[name];
+            dbParameter.Value = value;
          }
          else
          {
-            dbDataParameter = _dbCommand.CreateParameter();
+            dbParameter = _dbCommand.CreateParameter();
 
-            dbDataParameter.ParameterName = name;
-            dbDataParameter.DbType = dbType;
-            dbDataParameter.Value = value;
-            _dbCommand.Parameters.Add(dbDataParameter);
+            dbParameter.ParameterName = name;
+            dbParameter.DbType = dbType;
+            dbParameter.Value = value;
+            _dbCommand.Parameters.Add(dbParameter);
          }
 
-         return dbDataParameter;
+         return dbParameter;
       }
 
       public int ExecuteNonQuery()

frameworks/CSharp/appmpower/src/appMpower.Orm/Microsoft/BatchUpdateString.cs

@@ -2,8 +2,6 @@
 // Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information. 
 
 using System.Linq;
-using appMpower.Orm; 
-using appMpower.Orm.Data; 
 
 namespace PlatformBenchmarks
 {
@@ -35,32 +33,51 @@ public static string Query(int batchSize)
          //sb.Append("(?::int,?::int)) AS temp(id, randomNumber) WHERE temp.id = world.id");
          */
 
-         if (Constants.Dbms == Dbms.MySQL)
+#if MYSQL
+         for (int i = 0; i < batchSize; i++)
          {
-            for (int i = 0; i < batchSize; i++)
-            {
-               sb.Append("UPDATE world SET randomNumber=? WHERE id=?;");
-            }
+            sb.Append("UPDATE world SET randomNumber=? WHERE id=?;");
          }
-         else
+#elif ADO
+         /*
+         sb.Append("UPDATE world SET randomNumber = temp.randomNumber FROM (VALUES ");
+         Enumerable.Range(0, lastIndex).ToList().ForEach(i => sb.Append($"(@i{i}, @r{i}), "));
+         sb.Append($"(@i{lastIndex}, @r{lastIndex}) ORDER BY 1) AS temp(id, randomNumber) WHERE temp.id = world.id");
+         */
+
+         sb.Append("UPDATE world SET randomNumber=CASE id ");
+
+         for (int i = 0; i < batchSize; i++)
+         {
+            sb.Append("WHEN @i" + i + " THEN @r" + i + " ");
+         }
+
+         sb.Append("ELSE randomnumber END WHERE id IN(");
+
+         for (int i = 0; i < lastIndex; i++)
          {
-            sb.Append("UPDATE world SET randomNumber=CASE id ");
+            sb.Append("@j" + i + ",");
+         }
 
-            for (int i = 0; i < batchSize; i++)
-            {
-               sb.Append("WHEN ? THEN ? ");
-            }
+         sb.Append("@j" + lastIndex + ")");
+#else
+         sb.Append("UPDATE world SET randomNumber=CASE id ");
 
-            sb.Append("ELSE randomnumber END WHERE id IN(");
+         for (int i = 0; i < batchSize; i++)
+         {
+            sb.Append("WHEN ? THEN ? ");
+         }
 
-            for (int i = 0; i < lastIndex; i++)
-            {
-               sb.Append("?,");
-            }
+         sb.Append("ELSE randomnumber END WHERE id IN(");
 
-            sb.Append("?)");
+         for (int i = 0; i < lastIndex; i++)
+         {
+            sb.Append("?,");
          }
 
+         sb.Append("?)");
+#endif
+
          return _queries[batchSize] = StringBuilderCache.GetStringAndRelease(sb);
       }
    }