怎么在PostgreSQL的基礎(chǔ)上創(chuàng)建一個(gè)MongoDB的副本

149次閱讀

共計(jì) 4695 個(gè)字符，預(yù)計(jì)需要花費(fèi) 12 分鐘才能閱讀完成。

這篇文章主要介紹“怎么在 PostgreSQL 的基礎(chǔ)上創(chuàng)建一個(gè) MongoDB 的副本”，在日常操作中，相信很多人在怎么在 PostgreSQL 的基礎(chǔ)上創(chuàng)建一個(gè) MongoDB 的副本問(wèn)題上存在疑惑，丸趣 TV 小編查閱了各式資料，整理出簡(jiǎn)單好用的操作方法，希望對(duì)大家解答”怎么在 PostgreSQL 的基礎(chǔ)上創(chuàng)建一個(gè) MongoDB 的副本”的疑惑有所幫助！接下來(lái)，請(qǐng)跟著丸趣 TV 小編一起來(lái)學(xué)習(xí)吧！

開(kāi)始前需要做的準(zhǔn)備:

Postgres 9.2+ (as of this blog entry, 9.2 is in beta) – http://www.postgresql.org/ftp/source/

V8 – https://github.com/v8/v8

PLV8 – http://code.google.com/p/plv8js/wiki/PLV8

MongoDB 的最低級(jí)別是集合. 集合可以用表來(lái)表示:

 CREATE TABLE some_collection (
 some_collection_id SERIAL NOT NULL PRIMARY KEY,
 data JSON
 );

字符型的 JSON 被保存在 Postgres 表里，簡(jiǎn)單易行 (現(xiàn)在看是這樣).

下面實(shí)現(xiàn)自動(dòng)創(chuàng)建集合. 保存在集合表里:

 CREATE TABLE collection (
 collection_id SERIAL NOT NULL PRIMARY KEY,
 name VARCHAR
 );
 
 -- make sure the name is unique
 CREATE UNIQUE INDEX idx_collection_constraint ON collection (name);

一旦表建好了，就可以通過(guò)存儲(chǔ)過(guò)程自動(dòng)創(chuàng)建集合. 方法就是先建表，然后插入建表序列.

 CREATE OR REPLACE FUNCTION create_collection(collection varchar) RETURNS
 boolean AS $$
 var plan1 = plv8.prepare(INSERT INTO collection (name) VALUES ($1) , [  varchar  ]);
 var plan2 = plv8.prepare( CREATE TABLE col_  + collection +
   (col_  + collection +  _id INT NOT NULL PRIMARY KEY, data JSON) 
 var plan3 = plv8.prepare(CREATE SEQUENCE seq_col_  + collection);
 
 var ret;
 
 try { plv8.subtransaction(function () { plan1.execute([ collection ]);
 plan2.execute([ ]);
 plan3.execute([ ]);
 
 ret = true;
 });
 } catch (err) {
 ret = false;
 }
 
 plan1.free();
 plan2.free();
 plan3.free();
 
 return ret;
 $$ LANGUAGE plv8 IMMUTABLE STRICT;

有了存儲(chǔ)過(guò)程，就方便多了:

 SELECT create_collection(my_collection

解決了集合存儲(chǔ)的問(wèn)題，下面看看 MongoDB 數(shù)據(jù)解析. MongoDB 通過(guò)點(diǎn)式注解方法操作完成這一動(dòng)作:

 CREATE OR REPLACE FUNCTION find_in_obj(data json, key varchar) RETURNS
 VARCHAR AS $$
 var obj = JSON.parse(data);
 var parts = key.split( . 
 
 var part = parts.shift();
 while (part   (obj = obj[part]) !== undefined) { part = parts.shift();
 }
 
 // this will either be the value, or undefined
 return obj;
 $$ LANGUAGE plv8 STRICT;

上述功能返回 VARCHAR, 并不適用所有情形，但對(duì)于字符串的比較很有用:

 SELECT data
 FROM col_my_collection
 WHERE find_in_obj(data,  some.element) =  something cool

除了字符串的比較, MongoDB 還提供了數(shù)字類型的比較并提供關(guān)鍵字 exists . 下面是 find_in_obj() 方法的不同實(shí)現(xiàn):

 CREATE OR REPLACE FUNCTION find_in_obj_int(data json, key varchar) RETURNS
 INT AS $$
 var obj = JSON.parse(data);
 var parts = key.split( . 
 
 var part = parts.shift();
 while (part   (obj = obj[part]) !== undefined) { part = parts.shift();
 }
 
 return Number(obj);
 $$ LANGUAGE plv8 STRICT;
 
 CREATE OR REPLACE FUNCTION find_in_obj_exists(data json, key varchar) RETURNS
 BOOLEAN AS $$
 var obj = JSON.parse(data);
 var parts = key.split( . 
 
 var part = parts.shift();
 while (part   (obj = obj[part]) !== undefined) { part = parts.shift();
 }
 
 return (obj === undefined ?  f  :  t 
 $$ LANGUAGE plv8 STRICT;

接下來(lái)是數(shù)據(jù)查詢. 通過(guò)現(xiàn)有的材料來(lái)實(shí)現(xiàn) find() 方法.
保存數(shù)據(jù)到集合中很簡(jiǎn)單。首先，我們需要檢查 JSON 對(duì)象并尋找一個(gè)_id 值。這部分代碼是原生的假設(shè)，如果_id 已存在這意味著一個(gè)更新，否則就意味著一個(gè)插入。請(qǐng)注意，我們目前還沒(méi)有創(chuàng)建 objectID，只使用了一個(gè)序列待其發(fā)生：

 CREATE OR REPLACE FUNCTION save(collection varchar, data json) RETURNS
 BOOLEAN AS $$
 var obj = JSON.parse(data);
 
 var id = obj._id;
 
 // if there is no id, naively assume an insert
 if (id === undefined) {
 // get the next value from the sequence for the ID
 var seq = plv8.prepare( SELECT nextval( seq_col_  +
 collection +  ) AS id 
 var rows = seq.execute([ ]);
 
 id = rows[0].id;
 obj._id = id;
 
 seq.free();
 
 var insert = plv8.prepare( INSERT INTO col_  + collection +
   (col_  + collection +  _id, data) VALUES ($1, $2) ,
 [  int ,  json 
 
 insert.execute([ id, JSON.stringify(obj) ]);
 insert.free();
 } else {
 var update = plv8.prepare( UPDATE col_  + collection +
   SET data = $1 WHERE col_  + collection +  _id = $2 ,
 [  json ,  int  ]);
 
 update.execute([ data, id ]);
 }
 
 return true;
 $$ LANGUAGE plv8 IMMUTABLE STRICT;

基于這個(gè)觀點(diǎn)，我們可以構(gòu)建一些插入的簡(jiǎn)單文檔：

 {
  name :  Jane Doe ,
  address : {
  street :  123 Fake Street ,
  city :  Portland ,
  state :  OR 
 },
  age : 33
 }
 
 {
  name :  Sarah Smith ,
  address : {
  street :  456 Real Ave ,
  city :  Seattle ,
  state :  WA 
 }
 }
 
 {
  name :  James Jones ,
  address : {
  street :  789 Infinity Way ,
  city :  Oakland ,
  state :  CA 
 },
  age : 23
 }

讓我們創(chuàng)建一個(gè)集合并插入一些數(shù)據(jù)：

 work=# SELECT create_collection( data 
 create_collection
 -------------------
 t
 (1 row)
 
 work=# SELECT save(data ,  { our object } 
 save
 ------
 t
 (1 row)

你可以通過(guò)檢查“col_data”表的內(nèi)容來(lái)查看對(duì)象。

其它翻譯版本 (1)

現(xiàn)在我們已經(jīng)有了一些數(shù)據(jù)，讓我們?cè)俨樵円幌隆＜僭O(shè)我們想查找住在俄勒岡或華盛頓州年齡大于 30 的所有人，使用一個(gè) MongoDB 風(fēng)格的 find()：

 {
  $or : [
 {
  address.state :  OR 
 },
 {
  address.state :  WA 
 }
 ],
  age : {
  $gt : 30
 }
 }

因?yàn)樯洗挝覀円呀?jīng)創(chuàng)建了一些深度的包檢測(cè)，現(xiàn)在就很容易創(chuàng)建查詢并返回 Jane Doe：

 SELECT data
 FROM col_data
 WHERE find_in_obj_int(data,  age)   30
 AND ( find_in_obj(data,  address.state) =  OR 
 OR
 find_in_obj(data,  address.state) =  WA 
 )

我采用了寫一個(gè)遞歸調(diào)用函數(shù)來(lái)建立 WHERE 子句的方法。它有點(diǎn)長(zhǎng)，所以我沒(méi)有把它貼在這里而是放在 GitHub 上。一旦 find() 存儲(chǔ)過(guò)程被創(chuàng)建，我們就可以在查詢中使用它。我們應(yīng)該能夠看到 Jane Doe 被返回：

 work=# SELECT find(data ,  {  $or : [ {  address.state :  OR  }, {  address.state :  WA  } ],  age : {  $gt : 30 } }

到此，關(guān)于“怎么在 PostgreSQL 的基礎(chǔ)上創(chuàng)建一個(gè) MongoDB 的副本”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí)，請(qǐng)繼續(xù)關(guān)注丸趣 TV 網(wǎng)站，丸趣 TV 小編會(huì)繼續(xù)努力為大家?guī)?lái)更多實(shí)用的文章！

正文完