世上本沒(méi)有路，走的人多了也就成了路。為什么不能在 Postgres上建一個(gè)MongoDB 呢? 

Postgres 社區(qū)在 NoSQL采取一系列動(dòng)作后并沒(méi)有坐以待斃.  Postgres一直在進(jìn)步: 集成了 JSON和 PLV8.  PLV8 引入了 V8 Javascript引擎 . 操作 JSON也更簡(jiǎn)單了 (需要驗(yàn)證).

開(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() 方法.

#p#

在本部分中將覆蓋保存數(shù)據(jù)以及從MongDB查詢中構(gòu)建WHERE從句，以便檢索我們已經(jīng)寫(xiě)入的數(shù)據(jù)。

保存數(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) 

英文原文：Building a MongoDB Clone in Postgres: Part 1

譯文鏈接：http://www.oschina.net/translate/building_a_mongodb_clone_in_postgres_part_1