为 PostgreSQL 增加 BuildDeleteSql 支持

NewLifeX · Jun 4, 2024 · c78f5ba · c78f5ba
1 parent f2d429d
commit c78f5ba
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/XCode/DataAccessLayer/Database/PostgreSQL.cs b/XCode/DataAccessLayer/Database/PostgreSQL.cs
@@ -134,6 +134,17 @@ public override String FormatName(String name)
         return $"\"{name}\"";
     }
 
+    /// <inheritdoc/>
+    public override String? BuildDeleteSql(String tableName, String where, Int32 batchSize)
+    {
+        if (batchSize <= 0) return base.BuildDeleteSql(tableName, where, 0);
+        var xWhere = string.Empty;
+        var xTable = this.FormatName(tableName);
+        if (!string.IsNullOrWhiteSpace(where)) xWhere = " Where " + where;
+        var sql = $"WITH to_delete AS (SELECT ctid FROM {xTable} {xWhere} LIMIT {batchSize}) ";
+        sql += $"DELETE FROM {xTable} where ctid in (SELECT ctid from to_delete)";
+        return sql;
+    }
     #endregion 数据库特性
 
     #region 分页