Feature/admin forth/1259/add delete many to dataapi

adminforth/dataConnectors/clickhouse.ts

@@ -499,6 +499,21 @@ class ClickhouseConnector extends AdminForthBaseConnector implements IAdminForth
       return res;
     }
 
+    async deleteMany({ resource, recordIds }: { resource: AdminForthResource; recordIds: any[] }): Promise<number> {
+      const pkColumn = resource.dataSourceColumns.find((col) => col.primaryKey);
+      if (!pkColumn || !recordIds || recordIds.length === 0) {
+         return 0;
+       }
+      const paramNames = recordIds.map((_, idx) => `id${idx}`);
+      const conditions = paramNames.map((name) => `${pkColumn.name} = {${name}:${pkColumn._underlineType}}`).join(' OR ');
+      const queryParams = paramNames.reduce((acc, name, idx) => {acc[name] = recordIds[idx]; return acc;}, {} as Record<string, any>);
+      await this.client.command({
+        query: `ALTER TABLE ${this.dbName}.${resource.table} DELETE WHERE ${conditions}`,
+        query_params: queryParams,
+      });
+      return recordIds.length ?? 0;
+    }
+
     close() {
       this.client.disconnect();
     }

adminforth/dataConnectors/mongo.ts

@@ -397,6 +397,12 @@ class MongoConnector extends AdminForthBaseConnector implements IAdminForthDataS
         return res.deletedCount > 0;
     }
 
+    async deleteMany({ resource, recordIds }: { resource: AdminForthResource; recordIds: any[] }): Promise<number> {
+        const collection = this.client.db().collection(resource.table);
+        const res = await collection.deleteMany({[this.getPrimaryKey(resource)]: { $in: recordIds }});
+        return res.deletedCount ?? 0;
+    }
+
     async close() {
         await this.client.close()
     }

adminforth/dataConnectors/mysql.ts

@@ -420,6 +420,13 @@ class MysqlConnector extends AdminForthBaseConnector implements IAdminForthDataS
     return res.rowCount > 0;
   }
 
+  async deleteMany({ resource, recordIds }: { resource: AdminForthResource; recordIds: any[] }): Promise<number> {
+    const placeholders = recordIds.map(() => '?').join(',');
+    const query = `DELETE FROM ${resource.table} WHERE ${this.getPrimaryKey(resource)} IN (${placeholders})`;
+    const [result] = await this.client.execute(query, recordIds);
+    return result.affectedRows ?? 0;
+  }
+
   async close() {
     await this.client.end();
   }

adminforth/dataConnectors/postgres.ts

@@ -455,6 +455,13 @@ class PostgresConnector extends AdminForthBaseConnector implements IAdminForthDa
         return res.rowCount > 0;
     }
 
+    async deleteMany({ resource, recordIds }: { resource: AdminForthResource; recordIds: any[] }): Promise<number> {
+        const placeholders = recordIds.map((_, idx) => `$${idx + 1}`).join(', ');
+        const query = `DELETE FROM "${resource.table}" WHERE "${this.getPrimaryKey(resource)}" IN (${placeholders})`;
+        const res = await this.client.query(query, recordIds);
+        return res.rowCount ?? 0;
+    }
+
     async close() {
         await this.client.end();
     }

adminforth/dataConnectors/sqlite.ts

@@ -382,6 +382,13 @@ class SQLiteConnector extends AdminForthBaseConnector implements IAdminForthData
       return res.changes > 0;
     }
 
+    async deleteMany({ resource, recordIds }: { resource: AdminForthResource, recordIds: any[] }): Promise<number> {
+      const placeholders = recordIds.map(() => '?').join(',');
+      const q = this.client.prepare(`DELETE FROM ${resource.table} WHERE ${this.getPrimaryKey(resource)} IN (${placeholders})`);
+      const res = await q.run(...recordIds);
+      return res.changes ?? 0;
+    }
+
     close() {
       this.client.close();
     }

adminforth/types/Back.ts

@@ -1760,6 +1760,8 @@ export interface IOperationalResource {
   update: (primaryKey: any, record: any) => Promise<any>;
 
   delete: (primaryKey: any) => Promise<boolean>;
+
+  deleteMany?(recordIds: any[]): Promise<number>;
 
   dataConnector: IAdminForthDataSourceConnectorBase;
 }

dev-demo/Taskfile.yaml

@@ -30,6 +30,7 @@ vars:
     - "adminforth-quick-filters"
     - "adminforth-many2many"
     - "adminforth-background-jobs"
+    - "adminforth-auto-remove"
 
   ADAPTERS:
     - "adminforth-completion-adapter-open-ai-chat-gpt"