在异步编程模型中，批量删除数据库实体若处理不当，极易引发连接池耗尽、事务冲突和数据丢失。我们需要在保证性能的同时，确保每一次删除都可控且可回滚。
为什么异步循环删除有风险
异步循环通常指使用 for-await-of 或 Promise.all 并发处理多个任务。若在每个循环迭代中直接发起删除且不加限制，会出现以下问题：
- 并发数过高，数据库连接被占满
- 大事务锁表，阻塞其他业务
- 单批数据过大，导致回滚段暴涨
安全删除的核心策略
1. 分页或游标拉取主键
不要一次性查出全部实体，而是按主键范围或游标分批查询，仅获取待删除的 ID 列表。
2. 限制并发与批量大小
使用串行删除或固定大小的并发队列，每批删除 100 到 500 行较为稳妥。
3. 事务与错误重试
每一批删除放在独立事务中，失败时可仅重做该批，不影响整体。
代码示例：Node.js 串行分批删除
以下示例基于 pg 库，展示如何在异步循环中安全地批量删除用户日志实体：
const { Pool } = require('pg');
const pool = new Pool({ connectionString: 'postgres://user:pass@127.0.0.1:5432/app' });
// 每批删除数量
const BATCH_SIZE = 200;
async function batchDeleteOldLogs(beforeDate) {
let lastId = 0;
while (true) {
// 分页查询待删除主键
const selectRes = await pool.query(
'SELECT id FROM user_log WHERE id > $1 AND created_at < $2 ORDER BY id LIMIT $3',
[lastId, beforeDate, BATCH_SIZE]
);
const rows = selectRes.rows;
if (rows.length === 0) break;
const ids = rows.map(r => r.id);
lastId = ids[ids.length - 1];
// 在事务中批量删除
const client = await pool.connect();
try {
await client.query('BEGIN');
await client.query('DELETE FROM user_log WHERE id = ANY($1)', [ids]);
await client.query('COMMIT');
console.log('已删除批次，数量:', ids.length);
} catch (err) {
await client.query('ROLLBACK');
console.error('本批删除失败，稍后重试:', err.message);
throw err;
} finally {
client.release();
}
}
}
batchDeleteOldLogs('2023-01-01').catch(() => process.exit(1));
注意事项
| 项目 | 建议值 |
|---|---|
| 单批行数 | 100-500 |
| 并发删除任务 | 1（串行）或 2-4 |
| 事务超时 | 不超过 5 秒 |
若使用 ORM，也要注意其 bulkDelete 方法是否真正分批，避免生成单一超大 SQL。通过合理分页、受限并发与事务隔离，即可在异步循环中安全地批量删除数据库实体。
async_loopbatch_deletedatabase_entity修改时间：2026-07-29 23:21:12