CouchDB创建文档后检索不全：如何确认创建完成？

方案1：使用wait_for_commit参数强制等待提交完成 #

在创建文档的API请求中添加wait_for_commit=true查询参数，CouchDB会等待文档写入磁盘并完成索引更新后再返回响应。这样请求返回后立即检索，就能确保文档已被索引。

示例TypeScript代码：

import axios from 'axios';

async function createDocument(dbUrl: string, doc: Record<string, any>) {
  const response = await axios.post(
    `${dbUrl}?wait_for_commit=true`,
    doc,
    { auth: { username: 'admin', password: 'your-password' } }
  );
  return response.data;
}

注意：该参数会增加请求响应时间，仅适合测试场景，生产环境需谨慎使用。

方案2：轮询检查目标文档是否存在 #

创建文档后，针对每个新文档的_id发起单独的GET请求，直到确认所有文档都能被查询到，再执行后续检索操作。

示例TypeScript代码：

async function waitForDocuments(
  dbUrl: string,
  docIds: string[],
  maxAttempts = 10,
  delayMs = 200
) {
  const foundIds = new Set<string>();
  let attempts = 0;

  while (foundIds.size < docIds.length && attempts < maxAttempts) {
    await Promise.all(docIds.map(async (id) => {
      if (!foundIds.has(id)) {
        try {
          await axios.get(`${dbUrl}/${id}`, {
            auth: { username: 'admin', password: 'your-password' }
          });
          foundIds.add(id);
        } catch {
          // 文档未就绪，忽略错误继续轮询
        }
      }
    }));
    attempts++;
    if (foundIds.size < docIds.length) {
      await new Promise(resolve => setTimeout(resolve, delayMs));
    }
  }

  if (foundIds.size !== docIds.length) {
    const missingIds = docIds.filter(id => !foundIds.has(id)).join(', ');
    throw new Error(`部分文档(${missingIds})超时未创建完成`);
  }
}

// 使用方式
const createdDocIds = ['doc-id-1', 'doc-id-2'];
await waitForDocuments('http://localhost:5984/your-db', createdDocIds);
// 此处执行检索操作

方案3：通过更新序列（Update Sequence）确认数据库更新 #

CouchDB每个数据库都有一个递增的更新序列，文档增删改操作都会触发序列值上升。可以在创建文档前获取当前序列值，轮询直到序列值大于初始值，再执行检索。

示例TypeScript代码：

async function getDbUpdateSequence(dbUrl: string) {
  const response = await axios.get(dbUrl, {
    auth: { username: 'admin', password: 'your-password' }
  });
  return response.data.update_seq;
}

async function waitForDbUpdate(
  dbUrl: string,
  initialSeq: number,
  maxAttempts = 10,
  delayMs = 200
) {
  let attempts = 0;
  let currentSeq = initialSeq;

  while (currentSeq <= initialSeq && attempts < maxAttempts) {
    currentSeq = await getDbUpdateSequence(dbUrl);
    attempts++;
    if (currentSeq <= initialSeq) {
      await new Promise(resolve => setTimeout(resolve, delayMs));
    }
  }

  if (currentSeq <= initialSeq) {
    throw new Error('数据库更新序列未递增，文档可能创建失败');
  }
}

// 使用方式
const initialSeq = await getDbUpdateSequence('http://localhost:5984/your-db');
// 执行批量创建文档操作
await batchCreateDocuments();
// 等待数据库更新完成
await waitForDbUpdate('http://localhost:5984/your-db', initialSeq);
// 此处执行检索操作

注意事项 #

• 以上方案仅建议在测试场景使用，生产环境频繁轮询或启用wait_for_commit会影响性能。
• 批量创建文档时，需先确认批量请求本身返回成功（CouchDB批量API会返回每个文档的创建结果），再执行等待逻辑。

内容的提问来源于stack exchange，提问作者SiliconValley