开发手册 欢迎您!
软件开发者资料库

PouchDB - 同步

PouchDB同步 - 从简单和简单的步骤学习PouchDB,从基本到高级概念,包括概述,环境,创建,信息,删除数据库,创建,读取,更新,删除文档,创建,获取,更新,删除批处理,添加,检索,删除附件,复制,同步,杂项。

您可以将PouchDB中本地存储的数据库与存储在CouchDB中的数据库同步.在上一章中,我们已经了解了如何使用PouchDB复制数据库.我们使用了方法 PouchDB.replicate(source,destination).

除此之外,我们还可以复制数据,从本地数据库到远程数据库,使用 replicate.to() replicate.from()方法从远程数据库到本地数据库,如下所示.

//Replicating data from local database to remote database localDB.replicate.to(remoteDB);//Replicating data from remote database to local database localDB.replicate.from(remoteDB);

其中, localDB 是PouchDB本地存储的数据库对象,而 remoteDB 是一个对象存储在CouchDB中的数据库.

示例

假设PouchDB中存在名为 local_database 的数据库,它包含3个文档,doc1,doc2和doc3,内容如下所示.

doc1 = {_id: '003', name: 'Ram', age: 26, Designation: 'Programmer'} doc2 = {_id: '004', name: 'Robert', age: 27, Designation: 'Programmer'} doc3 = {_id: '005', name: 'Rahim', age: 28, Designation: 'Programmer'}

并且有一个名为

doc1 = {_id: '001', name: 'Geeta', age: 25, Designation: 'Programmer'} doc2 = {_id: '002', name: 'Zara Ali', age: 24, Designation: 'Manager'}

以下是同步这两个数据库的示例,其中一个存储在PouchDB和其他文件中使用 replicate.to() replicate.from()方法存储在CouchDB中.

//Requiring the packagevar PouchDB = require('PouchDB');//Creating local database objectvar localDB = new PouchDB('local_database');//Creating remote database objectvar remoteDB = new PouchDB('http://localhost:5984/remote_database');//Synchronising both databaseslocalDB.replicate.to(remoteDB);remoteDB.replicate.from(localDB);console.log("Databases synchronized successfully");

将上述代码保存在名为 Synchronising_databases.js 的文件中.打开命令提示符并使用 node 执行JavaScript文件,如下所示.

  C:\ PouchDB_Examples> node Synchronising_databases.js

这会同步两个数据库remoteDB和localDB,并在控制台上显示一条消息,如下所示.

Databases synchronized successfully.

同步两个数据库后,请访问 http://127.0.0.1:5984/_utils/index.html 并选择 remote_database 的.您可以观察到本地数据库(003,004,005)的文档已复制到此数据库中,如下所示.

远程数据库

以同样的方式,如果你获取存储在PouchDB中的 local_database 的内容,你可以观察到数据库的文件是存储在CouchDB中的文件被复制到这里.

[    {       id: '001',      key: '001',      value: { rev: '1-23cf3767e32a682c247053b16caecedb' },      doc: {          name: 'Geeta',         age: 25,         Designation: 'Programmer',         _id: '001',         _rev: '1-23cf3767e32a682c247053b16caecedb'       }    },   {       id: '002',      key: '002',      value: { rev: '1-d5bcfafbd4d4fae92fd7fc4fdcaa3a79' },      doc: {          name: 'Zara Ali',         age: 24,         Designation: 'Manager',         _id: '002',         _rev: '1-d5bcfafbd4d4fae92fd7fc4fdcaa3a79'       }    },   {       id: '003',      key: '003',      value: { rev: '1-bf4619471ac346fdde46cfa8fbf3587f' },      doc: {          name: 'Ram',         age: 26,         Designation: 'Programmer',         _id: '003',         _rev: '1-bf4619471ac346fdde46cfa8fbf3587f'       }    },   {       id: '004',      key: '004',      value: { rev: '1-29b8f803958c994e3eb37912a45d869c' },      doc: {          name: 'Robert',         age: 27,         Designation: 'Programmer',         _id: '004',         _rev: '1-29b8f803958c994e3eb37912a45d869c'       }    },   {       id: '005',      key: '005',      value: { rev: '1-0eb89f71998ffa8430a640fdb081abd2' },      doc: {          name: 'Rahim',         age: 28,         Designation: 'Programmer',         _id: '005',         _rev: '1-0eb89f71998ffa8430a640fdb081abd2'       }    } ]

您可以使用PouchDB提供的 sync()方法重写上述程序,而不是两种方法 replicate.to() replicate.from( )如下所示.

//Requiring the packagevar PouchDB = require('PouchDB');//Creating local database objectvar localDB = new PouchDB('local');//Creating remote database objectvar remoteDB = new PouchDB('http://localhost:5984/remote_database');//Synchronising Remote and local databaseslocalDB.sync(remoteDB, function(err, response) {   if (err) {      return console.log(err);   } else {      console.log(response);   }});

在执行上述程序时,它会同步显示以下消息的两个数据库.

{    push: {       ok: true,      start_time: Fri Mar 25 2016 15:54:37 GMT+0530 (India Standard Time),      docs_read: 6,      docs_written: 6,      doc_write_failures: 0,      errors: [],      last_seq: 10,      status: 'complete',      end_time: Fri Mar 25 2016 15:54:37 GMT+0530 (India Standard Time)    },   pull: {       ok: true,      start_time: Fri Mar 25 2016 15:54:37 GMT+0530 (India Standard Time),      docs_read: 0,      docs_written: 0,      doc_write_failures: 0,      errors: [],      last_seq: 2,      status: 'complete',      end_time: Fri Mar 25 2016 15:54:37 GMT+0530 (India Standard Time)    } }