feat: add deleteMany method to data source connectors for batch deletion

Author: Pavlo Kulyk

adminforth/dataConnectors/clickhouse.ts

@@ -499,6 +499,13 @@ class ClickhouseConnector extends AdminForthBaseConnector implements IAdminForth
       return res;
     }
 
+    async deleteMany({ resource, recordIds }: { resource: AdminForthResource; recordIds: any[] }): Promise<number> {
+      const idsList = recordIds.map(id => `'${id}'`).join(', ');
+      const query = `ALTER TABLE ${resource.table} DELETE WHERE ${this.getPrimaryKey(resource)} IN (${idsList})`;
+      const res = await this.client.query({ query });
+      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

@@ -292,6 +292,8 @@ export interface IAdminForthDataSourceConnectorBase extends IAdminForthDataSourc
   }): Promise<{ok: boolean, error?: string}>;
 
   getMinMaxForColumns({ resource, columns }: { resource: AdminForthResource, columns: AdminForthResourceColumn[] }): Promise<{ [key: string]: { min: any, max: any } }>;
+
+  deleteMany?(params: { resource: AdminForthResource; recordIds: any[] }): Promise<number>;
 }
 
 
@@ -1760,6 +1762,8 @@ export interface IOperationalResource {
   update: (primaryKey: any, record: any) => Promise<any>;
 
   delete: (primaryKey: any) => Promise<boolean>;
+  
+  deleteMany?(params: { resource: AdminForthResource; recordIds: any[] }): Promise<number>;
 
   dataConnector: IAdminForthDataSourceConnectorBase;
 }