MongoDB不支持子查詢，碰到這些復(fù)雜的運(yùn)算就只能先將數(shù)據(jù)讀出后再計(jì)算，而用Java等語言編寫這類計(jì)算也不是很簡(jiǎn)單，這時(shí)可以考慮用集算器esProc輔助實(shí)現(xiàn)。下面我們通過一個(gè)例子來看一下具體做法。

創(chuàng)新互聯(lián)建站主要從事成都網(wǎng)站制作、網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計(jì)、企業(yè)做網(wǎng)站、公司建網(wǎng)站等業(yè)務(wù)。立足成都服務(wù)夷陵,10多年網(wǎng)站建設(shè)經(jīng)驗(yàn),價(jià)格優(yōu)惠、服務(wù)專業(yè),歡迎來電咨詢建站服務(wù):18982081108

MongoDB中的文檔orders保存了訂單數(shù)據(jù)，employee保存了員工數(shù)據(jù)。如下：

> db.orders.find();

{ "_id" :ObjectId("5434f88dd00ab5276493e270"), "ORDERID" : 1,"CLIENT" : "UJRNP

", "SELLERID" : 17,"AMOUNT" : 392, "ORDERDATE" : "2008/11/2 15:28" }

{ "_id" :ObjectId("5434f88dd00ab5276493e271"), "ORDERID" : 2,"CLIENT" : "SJCH"

, "SELLERID" : 6,"AMOUNT" : 4802, "ORDERDATE" : "2008/11/9 15:28"}

{ "_id" :ObjectId("5434f88dd00ab5276493e272"), "ORDERID" : 3,"CLIENT" : "UJRNP

", "SELLERID" : 16,"AMOUNT" : 13500, "ORDERDATE" : "2008/11/5 15:28"}

{ "_id" :ObjectId("5434f88dd00ab5276493e273"), "ORDERID" : 4,"CLIENT" : "PWQ",

 "SELLERID" : 9, "AMOUNT" :26100, "ORDERDATE" : "2008/11/8 15:28" }

…

> db.employee.find();

{ "_id" :ObjectId("5437413513bdf2a4048f3480"), "EID" : 1,"NAME" : "Rebecca", "

SURNAME" : "Moore","GENDER" : "F", "STATE" : "California","BIRTHDAY" : "1974-1

1-20", "HIREDATE" :"2005-03-11", "DEPT" : "R&D","SALARY" : 7000 }

{ "_id" :ObjectId("5437413513bdf2a4048f3481"), "EID" : 2,"NAME" : "Ashley", "S

URNAME" : "Wilson","GENDER" : "F", "STATE" : "New York","BIRTHDAY" : "1980-07-

19", "HIREDATE" :"2008-03-16", "DEPT" : "Finance","SALARY" : 11000 }

{ "_id" :ObjectId("5437413513bdf2a4048f3482"), "EID" : 3,"NAME" : "Rachel", "S

URNAME" : "Johnson","GENDER" : "F", "STATE" : "New Mexico","BIRTHDAY" : "1970-

12-17", "HIREDATE" :"2010-12-01", "DEPT" : "Sales","SALARY" : 9000 }

…

例子中的需求是查出訂單信息，要求訂單中的SELLERID必須是employee集合中STATE= California的員工id。如果寫成sql就是：

Select * fromorders where orders.sellerid in (select eid from employee where employee.state=’California’)。

Orders的數(shù)據(jù)量較大無法一次取出。employee的數(shù)據(jù)量較小，最終結(jié)果的數(shù)據(jù)量也較小。

用集算器esProc協(xié)助mongodb實(shí)現(xiàn)這個(gè)子查詢的的腳本如下：

  A1: 連接mongodb數(shù)據(jù)庫，ip和端口號(hào)是localhost:27017，數(shù)據(jù)庫是test，用戶名和密碼都是test。

  A2: 使用find函數(shù)從mongodb中取數(shù)，形成游標(biāo)。集合是orders，過濾條件是空，指定鍵_id不取出。esProc在find函數(shù)中采用了和mongdb的find語句一樣的參數(shù)格式。esProc的游標(biāo)是分批讀取和處理數(shù)據(jù)，可以避免數(shù)據(jù)量過大，內(nèi)存出現(xiàn)溢出的情況。

  A3: 取得employee中的數(shù)據(jù)，條件是STATE="California"。

  A4: 將A3(employee)中的EID排序。

  A5: 按照條件過濾orders數(shù)據(jù)，條件是SELLERID必須在A4中，相當(dāng)于SELLERIDin A4。一次性取出結(jié)果。如果結(jié)果較大，也可以分批取出，比如取出前1000行：fetch(1000)。

計(jì)算結(jié)果是：

需要說明的是：esProc并不包含mongodb的java驅(qū)動(dòng)包。用esProc來訪問mongodb，必須提前將mongodb的java驅(qū)動(dòng)包（例如：mongo-java-driver-2.12.2.jar）放到[esProc安裝目錄]\common\jdbc中。

集算器esProc協(xié)助mongodb計(jì)算的腳本很容易集成到j(luò)ava中，只要增加一行，寫成resultA6即可向java輸出resultset形式的結(jié)果，具體的代碼參考esProc教程。同樣，用java調(diào)用esProc訪問mongodb也必須將mongdb的java驅(qū)動(dòng)包放到j(luò)ava程序的classpath中。