初级 rmongodb 简单入手

〇、适用对象

本内容适用于R 和 mongodb 的新手，rmongodb 的包有153个API, 手册有163页文档，内容太多，容易遮住重点。这里提供一个快速上手的内容。

一、mongodb的优势

1.mongodb 是种内存数据库，存储无关系型数据，符合近年技术趋势。而且从我跟随mongodb 版本以来，已经有快10个版本的更新，mongodb本身已经趋于稳定，可以用于各种生产系统中。当然最适合mongodb 的平台是Linux-x64.通过rapache, 古老的LAMP (Linux+Apache+Mysql+Perl/PHP/Python) 可以变成LAMR ( Linux+Apache+Mongodb+R )。实在是居家旅行，杀人越货之必备良器。

2.mongodb IO很快，可以支持大并发的情况，传统关系型数据库单机支持每秒几千次SQL语句，而单机的 mongodb 轻易就能提高10倍到几万次的查询。而且CPU消耗很低。对比各种数据库服务器，CPU负载绝对是很低水平的。一般而言，只要数据索引小于内存大小都可以执行的很好，在数据远远大于内存的情况下，mongodb中将数据库目录放在SSD上是一个比较好的选择。

3.mongodb 支持水平无缝扩展，轻松实现数据库端扩容，要增加并发处理能力，只要通过运维人员操作增加mongodb的服务器，前端代码都不用改的。

4.mongodb 能方便结合 R ,也可以方便地串味多种语言，合并他种语言的粗放数据到 mongdb,再用R来处理统计和图形。在R里安装很方便，直接

 install.package("rmongodb",dep=T)

就好了。

二、mongodb的Handle

Handle 就是在使用mongodb的时候的操纵入口，必须要有。

<br />
mongo <- mongo.create(host="127.0.0.1", name="",<br />
                  username="", password="", db="admin", timeout=0L)<br />

重点在于host 可以是一个服务器主机的 list ，即使有两百个mongodb主机也不怕，可以直接使用

<br />
 mongo <- mongo.create( host=as.list(paste("172.19.0",c(2:254),sep=".")) ）<br />

建立一个多主机连接的Handle,如果谁有超过255个主机的mongodb , 我强力要求参观啊。

在Handle使用中，需要检查是否连接，防止连接中断的异常。

<br />
 if (mongo.is.connected(mongo)) {<br />
         print(mongo.count(mongo, "test.people"))<br />
     }<br />

三、数据插入 mongodb

举例将一段数据输出到mongodb中，

</p>
<p>            buf <- mongo.bson.buffer.create()<br />
            mongo.bson.buffer.append.string(buf, "stk",as.character(stk_name));<br />
            mongo.bson.buffer.append.int(buf, "d", as.integer(date_str));<br />
            mongo.bson.buffer.append.int(buf, "n", as.integer(ncol(tick_data)));<br />
            mongo.bson.buffer.append.double(buf, "s_param",<br />
              c( mean.tick,mean.sd,<br />
                        mean(tpb),sd(tpb),<br />
                        mean(tab),sd(tab),<br />
                        mean(tpa),sd(tpa),<br />
                        mean(tad),sd(tad)<br />
                         ));</p>
<p>            b <- mongo.bson.from.buffer(buf)</p>
<p>	     dbname<-"hft"<br />
	     collections<-"tk_summary"<br />
            ns<-paste(dbname,collections,sep=".")</p>
<p>            mongo.insert(mongo, ns, b)<br />

这样，在mongodb中的Documents是这样的一个形式：

<br />
_id     (oid) "51be03121342401d8cff8b73"<br />
stk     (string) "sh600000"<br />
d       (int) 20130117<br />
n       (int) 1609<br />
s_param (array) [...]<br />
                0 : 1    5.377856<br />
                1 : 1    0.697179<br />
                2 : 1    1.557914<br />
                3 : 1    1.772376<br />
                4 : 1    5.193002<br />
                5 : 1    0.929928<br />
                6 : 1    1.559056<br />
                7 : 1    1.671283<br />
                8 : 1    5.392237<br />
                9 : 1    0.920493<br />

四、查询 mongodb

从mongodb中查询一条记录

<br />
apply( stk_name_list,1,function(x) {<br />
       buf <- mongo.bson.buffer.create()<br />
       mongo.bson.buffer.append(buf, "stk",x)<br />
       b<-mongo.bson.from.buffer(buf)<br />
       a<-mongo.find.one(mongo,ns,b)<br />
       if (is.null(a)) return(c(NA))<br />
       xi<-mongo.bson.to.list(a)<br />
       return(xi)<br />
} )</p>
<p>

返回的结果是一个list对象

<br />
$<code>_id</code><br />
{ $oid : "51be03111342401d8cff8b6a" }<br />
$stk<br />
[1] "sh600000"<br />
$d<br />
[1] 20130104<br />
$n<br />
[1] 1618<br />
$s_param<br />
 [1] 5.7423648868 0.6659471895 1.9342256089 1.8053735140 5.5047508942 0.8770237151 1.8501099687 1.7236801895<br />
 [9] 5.4077963568 0.9583607486<br />

这里因为和上例中是不同的记录，所以数值不同。

查询多条记录

</p>
<p> buf <- mongo.bson.buffer.create()<br />
 mongo.bson.buffer.append(buf, "stk",x)<br />
 b<-mongo.bson.from.buffer(buf)</p>
<p> ns = sprintf("hft.tk_summary");<br />
 rx<-c(1:10)<br />
 cursor<-mongo.find(mongo,ns,b,limit=10)<br />
 while (mongo.cursor.next(cursor)) {<br />
    rx<-mongo.bson.to.list(mongo.cursor.value(cursor));<br />
    print(rx$s_param) ;<br />
}<br />

得到输出如下

<br />
 [1] 5.7423648868 0.6659471895 1.9342256089 1.8053735140 5.5047508942 0.8770237151 1.8501099687 1.7236801895<br />
 [9] 5.4077963568 0.9583607486<br />
 [1] 5.6335280716 0.7060272050 1.9156906137 1.7776210534 6.1729319069 0.9693073557 1.5177611844 1.5934791414<br />
 [9] 5.9825883190 0.4297353371<br />
 [1] 5.5176866302 0.6665996866 1.8179511204 1.8061154724 5.6041862786 0.6920359519 1.5952517039 1.7049531083<br />
 [9] 5.5078507827 0.9010992525<br />

五、提供一个mongodb的工具

链接在这里

http://pan.baidu.com/s/1hqn5GMg

这里是个C版的工具，编译命令, 除了xfind.c 外，其他文件从 mongodb-c-driver stable version 里拷贝过来。

</p>
<p> gcc xfind.c bcon.c bson.c numbers.c encoding.c env.c mongo.c md5.c -o xfind<br />