Pouchdb-synchronization

提供:Dev Guides
移動先:案内検索

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'}

また、CouchDBには Remote_Database という名前のデータベースがあり、次のような内容を持つ2つのドキュメントdoc1、doc2が含まれています。

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

次に、これら2つのデータベースを同期する例を示します。1つはPouchDBに、もう1つは* replicate.to()および replicate.from()*メソッドを使用してCouchDBに格納されます。

//Requiring the package
var PouchDB = require('PouchDB');

//Creating local database object
var localDB = new PouchDB('local_database');

//Creating remote database object
var remoteDB = new PouchDB('http://localhost:5984/remote_database');

//Synchronising both databases
localDB.replicate.to(remoteDB);
remoteDB.replicate.from(localDB);
console.log("Databases synchronized successfully");

上記のコードを Synchronising_databases.js という名前のファイルに保存します。 以下に示すように、コマンドプロンプトを開き、 node を使用してJavaScriptファイルを実行します。

C:\PouchDB_Examples >node Synchronising_databases.js

これにより、2つのデータベースremoteDBとlocalDBが同期され、以下に示すようにコンソールにメッセージが表示されます。

Databases synchronized successfully.

2つのデータベースを同期した後、 http://127.0.0.1:5984/_utils/indexl にアクセスして 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'
      }
   }
]

以下に示すように、2つのメソッド* replicate.to()および replicate.from()の代わりに、PouchDBが提供する sync()*メソッドを使用して、上記のプログラムを書き換えることができます。

//Requiring the package
var PouchDB = require('PouchDB');

//Creating local database object
var localDB = new PouchDB('local');

//Creating remote database object
var remoteDB = new PouchDB('http://localhost:5984/remote_database');

//Synchronising Remote and local databases
localDB.sync(remoteDB, function(err, response) {
   if (err) {
      return console.log(err);
   } else {
      console.log(response);
   }
});

上記のプログラムを実行すると、次のメッセージを表示する2つのデータベースを同期します。

{
   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)
   }
}