如何获取PouchDB当前拉取seq编号？解决CouchDB回滚同步问题

嘿，这个场景我之前刚好处理过，给你梳理几个实用的方案：

一、获取PouchDB同步的最新Seq编号 #

你不需要完全依赖手动监听sync.on('change')来记录，PouchDB其实已经内置了同步状态的存储机制：

1. 读取同步状态的_local文档
   PouchDB会自动把同步的最新状态存在一个_local类型的文档里，文档ID格式通常是pouchdb_sync_<远端URL的哈希值>。你可以通过以下代码查询：

// 假设你的本地数据库实例是db
db.allDocs({
  include_docs: true,
  startkey: '_local/pouchdb_sync_',
  endkey: '_local/pouchdb_sync_\uffff'
}).then(result => {
  if (result.rows.length > 0) {
    const syncDoc = result.rows[0].doc;
    console.log('同步的最新远端Seq:', syncDoc.last_seq);
  }
});

这个文档里的last_seq字段，就是你最后一次同步时从远端CouchDB获取的最新seq编号。

2. 监听同步事件实时获取
   如果需要实时记录同步的seq，你可以在同步过程中通过change或complete事件直接拿到：

const sync = db.sync(remoteDbUrl, { live: true, retry: true });

sync.on('change', info => {
  // 只关注拉取方向的同步事件
  if (info.direction === 'pull') {
    console.log('本次拉取的最新Seq:', info.change.last_seq);
    // 可以把这个值存在localStorage里，方便应用重载后读取
    localStorage.setItem('lastSyncSeq', info.change.last_seq);
  }
});

sync.on('complete', info => {
  if (info.direction === 'pull') {
    console.log('同步完成后的最新Seq:', info.last_seq);
  }
});

二、处理CouchDB回滚导致的数据超前问题 #

要检测回滚，核心思路是对比本地存储的同步Seq和远端CouchDB当前的Seq：

1. 查询远端CouchDB的当前Seq
   你可以通过CouchDB的_db_info端点获取当前数据库的最新seq：

fetch(`${remoteDbUrl}/_db_info`)
  .then(res => res.json())
  .then(dbInfo => {
    const remoteCurrentSeq = dbInfo.update_seq;
    // 取出之前存在本地的同步Seq
    const localLastSyncSeq = localStorage.getItem('lastSyncSeq');
    
    // 注意：如果是数字类型的seq，直接转数字对比即可；如果是带前缀的字符串，需用字符串自然排序逻辑
    if (parseInt(remoteCurrentSeq) < parseInt(localLastSyncSeq)) {
      // 检测到回滚，执行销毁本地库并重新同步的逻辑
      handleRollback(db);
    }
  });

2. 销毁本地库并重新加载
   当确认发生回滚时，你可以销毁本地数据库，重新初始化并同步：

function handleRollback(localDb) {
  // 先关闭数据库连接
  localDb.close().then(() => {
    // 销毁本地数据库实例
    return PouchDB.destroy(localDb.name);
  }).then(() => {
    // 重新初始化数据库并启动同步
    const newDb = new PouchDB(localDb.name);
    newDb.sync(remoteDbUrl, { live: true, retry: true });
    // 重置本地存储的Seq记录
    localStorage.removeItem('lastSyncSeq');
    console.log('数据库已重置并重新开始同步');
  }).catch(err => {
    console.error('处理回滚时出错:', err);
  });
}

额外提示 #

• 如果你的CouchDB使用的是UUID格式的seq（非数字型），不要直接转数字对比，建议用字符串的自然排序逻辑来判断大小。
• 可以把回滚检测的逻辑放在应用启动时执行，确保每次加载都能验证数据一致性。

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