Add SQLite support to BatchDelete && BatchUpdate

Add SQLite support to BatchDelete && BatchUpdate

Author: zzzprojects

src/shared/Z.EF.Plus.BatchDelete.Shared/BatchDelete.cs

@@ -56,6 +56,14 @@ WHERE EXISTS ( SELECT 1 FROM ({Select}) AS B
         internal const string CommandTextOracleTemplate = @"
 DELETE
 FROM    {TableName}
+WHERE EXISTS ( SELECT 1 FROM ({Select}) B
+               WHERE {PrimaryKeys}
+           )
+";
+
+        internal const string CommandTextSQLiteTemplate = @"
+DELETE
+FROM    {TableName}
 WHERE EXISTS ( SELECT 1 FROM ({Select}) B
                WHERE {PrimaryKeys}
            )
@@ -253,7 +261,7 @@ public int Execute<T>(IQueryable<T> query) where T : class
                     int totalRowAffecteds = DbInterception.Dispatch.Command.NonQuery(command, interceptionContext);
                     return totalRowAffecteds;
                 }
-                else if (command.Connection.GetType().Name.Contains("Oracle"))
+                else if (command.Connection.GetType().Name.Contains("Oracle") || command.Connection.GetType().Name.Contains("SQLite"))
                 {
                     int totalRowAffecteds = DbInterception.Dispatch.Command.NonQuery(command, interceptionContext);
                     return totalRowAffecteds;
@@ -355,6 +363,7 @@ internal DbCommand CreateCommand<T>(ObjectQuery query, SchemaEntityType<T> entit
             bool isMySql = command.GetType().FullName.Contains("MySql");
             var isSqlCe = command.GetType().Name == "SqlCeCommand";
             var isOracle = command.GetType().Namespace.Contains("Oracle");
+            var isSQLite = command.GetType().Namespace.Contains("SQLite");
 
             // Oracle BindByName
             if (isOracle)
@@ -380,6 +389,10 @@ internal DbCommand CreateCommand<T>(ObjectQuery query, SchemaEntityType<T> entit
             {
                 tableName = string.Concat("[", store.Table, "]");
             }
+            else if (isSQLite)
+            {
+                tableName = string.Concat("\"", store.Table, "\"");
+            }
             else if (isOracle)
             {
                 tableName = string.IsNullOrEmpty(store.Schema) || store.Schema == "dbo" ?
@@ -416,6 +429,8 @@ internal DbCommand CreateCommand<T>(ObjectQuery query, SchemaEntityType<T> entit
                         CommandTextTemplate_MySql :
                         isSqlCe ?
                             CommandTextSqlCeTemplate :
+                            isSQLite ?
+                                CommandTextSQLiteTemplate :
                             BatchSize > 0 ?
                                 BatchDelayInterval > 0 ?
                                     CommandTextWhileDelayTemplate :
@@ -434,7 +449,7 @@ internal DbCommand CreateCommand<T>(ObjectQuery query, SchemaEntityType<T> entit
 
             // GET primary key join
             string primaryKeys;
-            if (isSqlCe || isOracle)
+            if (isSqlCe || isOracle || isSQLite)
             {
                 primaryKeys = string.Join(Environment.NewLine + "AND ", columnKeys.Select(x => string.Concat(tableName + ".", EscapeName(x, isMySql, isOracle), " = B.", EscapeName(x, isMySql, isOracle), "")));
             }

src/shared/Z.EF.Plus.BatchUpdate.Shared/BatchUpdate.cs

@@ -63,6 +63,14 @@ WHERE EXISTS ( SELECT 1 FROM ({Select}) B
         internal const string CommandTextTemplate_PostgreSQL = @"
 UPDATE {TableName}
 SET {SetValue}
+WHERE EXISTS ( SELECT 1 FROM ({Select}) B
+               WHERE {PrimaryKeys}
+           )  
+";
+
+        internal const string CommandTextTemplate_SQLite = @"
+UPDATE {TableName}
+SET {SetValue}
 WHERE EXISTS ( SELECT 1 FROM ({Select}) B
                WHERE {PrimaryKeys}
            )  
@@ -316,6 +324,7 @@ internal DbCommand CreateCommand<T>(ObjectQuery query, SchemaEntityType<T> entit
             var isSqlCe = command.GetType().Name == "SqlCeCommand";
             var isOracle = command.GetType().Namespace.Contains("Oracle");
             var isPostgreSQL = command.GetType().Name == "NpgsqlCommand";
+            var isSQLite = command.GetType().Namespace.Contains("SQLite");
 
             // Oracle BindByName
             if (isOracle)
@@ -353,6 +362,10 @@ internal DbCommand CreateCommand<T>(ObjectQuery query, SchemaEntityType<T> entit
                     string.Concat("\"", store.Table, "\"") :
                     string.Concat("\"", store.Schema, "\".\"", store.Table, "\"");
             }
+            else if (isSQLite)
+            {
+                tableName = string.Concat("\"", store.Table, "\"");
+            }
             else
             {
                 tableName = string.IsNullOrEmpty(store.Schema) ?
@@ -388,6 +401,7 @@ internal DbCommand CreateCommand<T>(ObjectQuery query, SchemaEntityType<T> entit
                 isOracle ? CommandTextOracleTemplate :
                 isMySql ? CommandTextTemplate_MySQL : 
                 isSqlCe ? CommandTextTemplateSqlCe :
+                isSQLite ? CommandTextTemplate_SQLite :
                 CommandTextTemplate;
 
             // GET inner query
@@ -421,6 +435,15 @@ internal DbCommand CreateCommand<T>(ObjectQuery query, SchemaEntityType<T> entit
                     string.Concat(EscapeName(x.Item1, isMySql, isOracle, isPostgreSQL), " = ", ((ConstantExpression)x.Item2).Value) :
                     string.Concat(EscapeName(x.Item1, isMySql, isOracle, isPostgreSQL), " = :zzz_BatchUpdate_", i)));
             }
+            else if (isSQLite)
+            {
+                primaryKeys = string.Join(Environment.NewLine + "AND ", columnKeys.Select(x => string.Concat(EscapeName(x, isMySql, isOracle, isPostgreSQL), " = B.", EscapeName(x, isMySql, isOracle, isPostgreSQL), "")));
+
+                // GET updateSetValues
+                setValues = string.Join("," + Environment.NewLine, values.Select((x, i) => x.Item2 is ConstantExpression ?
+                    string.Concat(EscapeName(x.Item1, isMySql, isOracle, isPostgreSQL), " = ", ((ConstantExpression)x.Item2).Value) :
+                    string.Concat(EscapeName(x.Item1, isMySql, isOracle, isPostgreSQL), " = @zzz_BatchUpdate_", i)));
+            }
             else
             {
                 primaryKeys = string.Join(Environment.NewLine + "AND ", columnKeys.Select(x => string.Concat("A.", EscapeName(x, isMySql, isOracle, isPostgreSQL), " = B.", EscapeName(x, isMySql, isOracle, isPostgreSQL), "")));

version.txt

@@ -1 +1 @@
-v1.6.13
+v1.6.16