怎么在PostgreSQL的基礎(chǔ)上創(chuàng)建一個(gè)MongoDB的副本-創(chuàng)新互聯(lián)

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

公司主營業(yè)務(wù)：網(wǎng)站制作、成都網(wǎng)站建設(shè)、移動(dòng)網(wǎng)站開發(fā)等業(yè)務(wù)。幫助企業(yè)客戶真正實(shí)現(xiàn)互聯(lián)網(wǎng)宣傳，提高企業(yè)的競爭能力。成都創(chuàng)新互聯(lián)公司是一支青春激揚(yáng)、勤奮敬業(yè)、活力青春激揚(yáng)、勤奮敬業(yè)、活力澎湃、和諧高效的團(tuán)隊(duì)。公司秉承以“開放、自由、嚴(yán)謹(jǐn)、自律”為核心的企業(yè)文化，感謝他們對(duì)我們的高要求，感謝他們從不同領(lǐng)域給我們帶來的挑戰(zhàn)，讓我們激情的團(tuán)隊(duì)有機(jī)會(huì)用頭腦與智慧不斷的給客戶帶來驚喜。成都創(chuàng)新互聯(lián)公司推出峨眉山免費(fèi)做網(wǎng)站回饋大家。

開始前需要做的準(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í)別是集合.  集合可以用表來表示:


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

字符型的JSON 被保存在 Postgres 表里，簡單易行 (現(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);

一旦表建好了，就可以通過存儲(chǔ)過程自動(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ǔ)過程，就方便多了:
 

 SELECT create_collection('my_collection');


解決了集合存儲(chǔ)的問題，下面看看MongoDB數(shù)據(jù)解析.  MongoDB 通過點(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;

接下來是數(shù)據(jù)查詢.  通過現(xiàn)有的材料來實(shí)現(xiàn) find() 方法.
保存數(shù)據(jù)到集合中很簡單。首先，我們需要檢查JSON對(duì)象并尋找一個(gè)_id值。這部分代碼是原生的假設(shè)，如果_id已存在這意味著一個(gè)更新，否則就意味著一個(gè)插入。請注意，我們目前還沒有創(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)建一些插入的簡單文檔：

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

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

其它翻譯版本(1)

現(xiàn)在我們已經(jīng)有了一些數(shù)據(jù)，讓我們再查詢一下。假設(shè)我們想查找住在俄勒岡或華盛頓州年齡大于30的所有人，使用一個(gè)MongoDB風(fēng)格的find()：


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

因?yàn)樯洗挝覀円呀?jīng)創(chuàng)建了一些深度的包檢測，現(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ù)來建立WHERE子句的方法。它有點(diǎn)長，所以我沒有把它貼在這里而是放在GitHub上。一旦find()存儲(chǔ)過程被創(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í)，請繼續(xù)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編會(huì)繼續(xù)努力為大家?guī)砀鄬?shí)用的文章！

標(biāo)題名稱：怎么在PostgreSQL的基礎(chǔ)上創(chuàng)建一個(gè)MongoDB的副本-創(chuàng)新互聯(lián)
URL地址：http://www.muchs.cn/article22/diiojc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站設(shè)計(jì)、微信公眾號(hào)、關(guān)鍵詞優(yōu)化、用戶體驗(yàn)、網(wǎng)站維護(hù)、網(wǎng)站設(shè)計(jì)公司

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)

成都定制網(wǎng)站網(wǎng)頁設(shè)計(jì)