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
ตัวอย่าง
สมมติว่ามีฐานข้อมูลที่มีชื่อ local_database ใน PouchDB และประกอบด้วยเอกสาร 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'}
และมีฐานข้อมูลที่มีชื่อ Remote_Database ใน CouchDB และประกอบด้วยเอกสาร 2 ชุด doc1, doc2 ซึ่งมีเนื้อหาดังที่แสดงด้านล่าง
doc1 = {_id: '001', name: 'Geeta', age: 25, Designation: 'Programmer'}
doc2 = {_id: '002', name: 'Zara Ali', age: 24, Designation: 'Manager'}
ต่อไปนี้เป็นตัวอย่างของการซิงโครไนซ์ฐานข้อมูลทั้งสองนี้โดยที่ฐานข้อมูลหนึ่งถูกเก็บไว้ใน PouchDB และอื่น ๆ จะถูกเก็บไว้ใน CouchDB โดยใช้ replicate.to() และ replicate.from() วิธีการ
//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. เปิดพรอมต์คำสั่งและเรียกใช้ไฟล์ JavaScript โดยใช้node ดังแสดงด้านล่าง
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) ถูกคัดลอกในฐานข้อมูลนี้ดังที่แสดงด้านล่าง
ในทำนองเดียวกันหากคุณดึงเนื้อหาของไฟล์ local_database เก็บไว้ใน PouchDB คุณสามารถสังเกตได้ว่าเอกสารของฐานข้อมูลที่เก็บไว้ใน 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'
}
}
]
คุณสามารถเขียนโปรแกรมข้างต้นใหม่โดยใช้ไฟล์ sync() วิธีการจัดทำโดย PouchDB แทนที่จะเป็นสองวิธี replicate.to() และ replicate.from() ดังแสดงด้านล่าง
//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);
}
});
ในการรันโปรแกรมข้างต้นจะซิงโครไนซ์ฐานข้อมูลทั้งสองที่แสดงข้อความต่อไปนี้
{
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)
}
}