http://www.blogjava.net/watchzerg/archive/2012/09/22/388346.html

mongoDB java驱动学习笔记

指定新mongo实例:
Mongo m = new Mongo();
Mongo m = new Mongo( "localhost" );
Mongo m = new Mongo( "localhost" , 27017 );
// or, to connect to a replica set, supply a seed list ofmembers
Mongo m = new Mongo(Arrays.asList(newServerAddress("localhost", 27017),
new ServerAddress("localhost", 27018),
new ServerAddress("localhost", 27019)));
然后发起连接(必须指定数据库名,可以不存在)
DB db = m.getDB( "mydb" );
注意Mongo已经实现了连接池,并且是线程安全的。
大部分用户使用mongodb都在安全内网下,但如果将mongodb设为安全验证模式,就需要在客户端提供用户名和密码:
boolean auth = db.authenticate(myUserName, myPassword);
获取集合(collection)的名称列表(类似show databases):
Set colls = db.getCollectionNames();
获取一个集合(以便增删改查操作):
DBCollection coll = db.getCollection("testCollection")
-------------------------------------------------------------
先假设要插入的json数据如下:
{
"name" : "MongoDB",
"type" :"database",
"count" : 1,
"info" : {
x : 203,
y : 102
}
}
将其插入数据库:
BasicDBObject doc = new BasicDBObject();
doc.put("name", "MongoDB");
doc.put("type", "database");
doc.put("count", 1);
BasicDBObject info = new BasicDBObject();
info.put("x", 203);
info.put("y", 102);
doc.put("info", info);
coll.insert(doc);
-------------------------------------------------------------
设定write concern,以便操作失败时得到提示:
m.setWriteConcern(WriteConcern.SAFE);
-------------------------------------------------------------
查找一个/第一个记录:
DBObject myDoc = coll.findOne();
System.out.println(myDoc);
注意:属性名不能以下划线或者美元符号开始,mongodb自己保留。
获取总记录数:
System.out.println(coll.getCount());
使用游标操作查询结果:
DBCursor cursor = coll.find();
try {
while(cursor.hasNext()) {
System.out.println(cursor.next());
}
} finally {
cursor.close();
}
条件查询:
BasicDBObject query = new BasicDBObject();
query.put("i", 71);
cursor = coll.find(query);
try {
while(cursor.hasNext()) {
System.out.println(cursor.next());
}
} finally {
cursor.close();
}
如果想使用shell里的类似以下语句的功能:
db.things.find({j: {$ne: 3}, k: {$gt: 10} });
在java驱动里,{$ne: 3}也是一个普通的DBObject:
BasicDBObject query = new BasicDBObject();
query.put("j", new BasicDBObject("$ne",3));
query.put("k", new BasicDBObject("$gt",10));
cursor = coll.find(query);
try {
while(cursor.hasNext()) {
System.out.println(cursor.next());
}
} finally {
cursor.close();
}
条件查询一批数据:
以下是查询i > 50的记录:
query = new BasicDBObject();
query.put("i", new BasicDBObject("$gt", 50)); // e.g. find all where i > 50
cursor = coll.find(query);
try {
while(cursor.hasNext()) {
System.out.println(cursor.next());
}
} finally {
cursor.close();
}        
以下是查询20 < i <= 30的记录:
query = new BasicDBObject();
query.put("i", new BasicDBObject("$gt",20).append("$lte", 30));  // i.e.  20 < i <= 30
cursor = coll.find(query);
try {
while(cursor.hasNext()) {
System.out.println(cursor.next());
}
} finally {
cursor.close();
}
-------------------------------------------------------------
创建索引:
指定collection和要index的列即可,1代表升序,-1代表降序。
coll.createIndex(newBasicDBObject("i", 1));  // create index on "i",ascending
获取索引列表:
List list = coll.getIndexInfo();
for (DBObject o : list){
System.out.println(o);
}
-------------------------------------------------------------
数据库管理相关的命令:
获取数据库名称列表:
m.getDatabaseNames()
删除数据库:
m.dropDatabase("my_new_db");
-------------------------------------------------------------
聚合函数:使用DBCollection.aggregate()产生聚合任务:
http://www.mongodb.org/display/DOCS/Using+The+Aggregation+Framework+with+The+Java+Driver
// create our pipeline operations, firstwith the $match
DBObject match = newBasicDBObject("$match", new BasicDBObject("type", "airfare"));
// build the $projectionoperation
DBObject fields = newBasicDBObject("department", 1);
fields.put("amount", 1);
fields.put("_id", 0);
DBObject project = newBasicDBObject("$project", fields );
// Now the $group operation
DBObject groupFields = newBasicDBObject( "_id", "$department");
groupFields.put("average", newBasicDBObject( "$avg", "$amount"));
DBObject group = newBasicDBObject("$group", groupFields);
// run aggregation
AggregationOutput output =collection.aggregate( match, project, group );
返回结果是一个AggregationOutput对象,可以用以下方式获取其中信息:
public Iterable results()
public CommandResultgetCommandResult
public DBObjectgetCommand()
示例:
System.out.println(output.getCommandResult());
{
"serverUsed" : "/127.0.0.1:27017",
"result" : [
{"_id" : "Human Resources" , "average" :74.91735537190083} ,
{"_id" : "Sales" , "average" :72.30275229357798} ,
{"_id" : "Engineering" , "average" :74.1}
] ,
"ok" : 1.0
}
-------------------------------------------------------------
使用DBObject存取对象:
http://www.mongodb.org/display/DOCS/Java+-+Saving+Objects+Using+DBObject
假设一个类叫做twitter,存储前必须实现DBObject接口:
public class Tweet implements DBObject {
}
然后就可以存了:
Tweet myTweet = new Tweet();
myTweet.put("user", userId);
myTweet.put("message", msg);
myTweet.put("date", new Date());
collection.insert(myTweet);
一个文档从数据库取出时,自动被转为DBObject。如果想取出时转为需要的类,可以先调用DBCollection.setObjectClass(),然后再进行类型强制转换:
collection.setObjectClass(Tweet.class);
Tweet myTweet = (Tweet)collection.findOne();
如果想要改变Tweet类的属性,可以改完后再存入:
Tweet myTweet = (Tweet)collection.findOne();
myTweet.put("message", newMsg);
collection.save(myTweet);
-------------------------------------------------------------
JAVA驱动的并发:
http://www.mongodb.org/display/DOCS/Java+Driver+Concurrency
mongodb的java驱动是线程安全的,如果是在web服务环境下,应该创建单例的mongo对象,用这个对象处理每一个请求。mongo对象维护一个内部连接池(默认大小为10),对于每个请求(查找插入等),java线程会从线程池取一个连接,执行操作,然后释放连接——这意味着每次操作所使用的连接很有可能是不同的。
------------------------------
在复制(replica)模式下,如果设置slaveOK选项为on,那么读操作会被均匀的分布到各个slave上。这意味着对于同一个线程,一个写操作后紧跟着的一个读操作,有可能被发送到不同的服务器上(写操作发送到master上,读操作发送到slave上),这样读操作有可能不会立刻反映出上一个写操作的数据(因为主从的异步性)。
如果你想要确保在一个session中完整的一致性(例如在一个http请求中),你可能希望java驱动是用同一个socket连接,这时你可以通过使用"consistentrequest"来达到目的——在操作前后分别调用requestStart()和requestDone()。
DB db...;
db.requestStart();
try {
//Ensures that aconnection exists for the "consistent request"
db.requestEnsureConnection();
code....
} finally {
db.requestDone();
}
------------------------------
在单独写操作上的WriteConcern选项:
默认情况下,每次写操作后,连接就被释放回连接池——此时你调用getLastError()是没用的。
所以可以采用两种方式:
1,使用类似WriteConcern.SAFE这样的写策略来代替默认策略,这样java驱动会自动首先调用getLastError(),然后才将连接放回连接池。
DBCollection coll...;
coll.insert(..., WriteConcern.SAFE);
2,采用上述的requestStart()和requestDone()方式来维持连接不被释放,中间调用getLastError()获取错误信息。
DB db...;
DBCollection coll...;
db.requestStart();
try {
coll.insert(...);
DBObject err =db.getLastError();
} finally {
db.requestDone();
}
这两种方式等价。
-------------------------------------------------------------
java类型:
http://www.mongodb.org/display/DOCS/Java+Types
----------------------------
Object id被用来自动生成唯一的ID:
ObjectId id = new ObjectId();
ObjectId copy = new ObjectId(id);
----------------------------
正则表达式:
java驱动使用JDK的java.util.regex.Pattern表达正则:
Pattern john = Pattern.compile("joh?n",CASE_INSENSITIVE);
BasicDBObject query = new BasicDBObject("name", john);
// finds all people with "name" matching /joh?n/i
DBCursor cursor = collection.find(query);
----------------------------
java驱动使用JDK的 java.util.Date表示日期时间:
Date now = new Date();
BasicDBObject time = new BasicDBObject("ts", now);
collection.save(time);
----------------------------
com.mongodb.DBRef被用来表示数据库引用(官方一般建议手动引用):
DBRef addressRef = new DBRef(db, "foo.bar", address_id);
DBObject address = addressRef.fetch();
DBObject person = BasicDBObjectBuilder.start()
.add("name","Fred")
.add("address",addressRef)
.get();
collection.save(person);
DBObject fred = collection.findOne();
DBRef addressObj = (DBRef)fred.get("address");
addressObj.fetch()
----------------------------
二进制数据:
java中的字节数组会自动被包装成二进制数据存入数据库。
二进制类可以被用来表示二进制对象,这可以用来取一个自定义类型的字节。
----------------------------
时间戳数据(BSONTimestamp对象):
时间戳数据是一个mongoDB使用的特殊对象,表示一个(以秒为单位的时间,自增ID)的键值对,这被用于主从复制的操作日志中。
----------------------------
代码对象:
用于表示javascript代码,例如保存可执行的方法到system.js集合中。
Code和CodeWScope类用来表示这种数据。
注意有些方法(比如map/reduce)接收字符串,但是在驱动中将其包装为代码对象。
----------------------------
嵌套对象:
在javascript里面这样一个json文档:
{
"x" : {
"y" : 3
}
}
在java中对应的形式是:
BasicDBObject y = new BasicDBObject("y", 3);
BasicDBObject x = new BasicDBObject("x", y);
----------------------------
数组:
java中所有实现List接口的都被以数组形式在数据库中保存:
所以如果想保存这样一个json:
{
"x" : [
1,
2,
{"foo" : "bar"},
4
]
}
在java中可以这么做:
ArrayList x = new ArrayList();
x.add(1);
x.add(2);
x.add(new BasicDBObject("foo", "bar"));
x.add(4);
BasicDBObject doc = new BasicDBObject("x", x);
-------------------------------------------------------------
在java驱动中的优先读取策略(Read Preferences)和节点标记(Tagging)
http://www.mongodb.org/display/DOCS/Read+Preferences+and+Tagging+in+The+Java+Driver
用来允许应用程序开发者能将读写操作指定在某个主从集合的成员节点上。
2.2版本在节点标记(node tagging)带来些新的东西让你能更好的控制你的数据的读写。
java驱动的2.9.0集成了mongodb2.2提供的所有新特性。
----------------------------
优先读取策略(Read Preferences):
用于提供客户端程序选择那个节点来读取,有以下五个选择:
PRIMARY : 默认方式,从主节点读取,如果主节点不可用则抛出异常,无法与标签(tags)一起使用。
PRIMARY PREFERRED : 优先读取主节点,失败的话从副节点读取。
SECONDARY : 从副节点读取,失败则抛异常。
SECONDARY PREFERRED : 优先读取副节点,失败则从主节点读取。
NEAREST : 从最近的节点读取,“最近”的定义为ping的响应时间最短(也得满足15毫秒以内)。
java实现:类ReadPreference的工厂模式可以创建对应上述五种策略的对象:
ReadPreference.primary();
ReadPreference.primaryPreferred();
ReadPreference.secondary();
ReadPreference.secondaryPreferred();
ReadPreference.nearest();
例如:假设我们的应用需要保持强一致性(写入的数据立即可以被读出),但是我们又希望万一主库挂掉以后,从库依然可以读取。这种情况下,我们需要选择PRIMARYPREFERRED模式:
ReadPreference preference =ReadPreference.primaryPreferred();
DBCursor cur = new DBCursor(collection, query, null,preference);
java驱动保持着各个节点的状态信息(每隔一段时间ping一次所有节点),在这个例子中,java驱动会检测到主库的挂掉,从而将读操作指向从节点。
----------------------------
节点标记(Tags):
在mongoDB2.0之后,主从集群中的每一个节点都可以被标记一个描述,称为tags。可以用来标记一个节点的位置,和在集群中的从属关系或者特性。这可以让你的应用程序从指定节点中读写。
例子:
假设我们要运行一个三节点的主从集群,三个节点分别在三个不同地理位置的数据中心当中。我们希望确保我们的数据在灾难中也可以恢复,所以我们对每一个节点标记其地理位置,配置文件样例如下:
foo:SECONDARY> rs.conf()
{
"_id":"foo",
"version":103132,
"members":[
{
"_id":0,
"host":"localhost:27017",
"priority":10,
"tags":{
"datacenter":"Los Angeles",
"region":"US_West"
}
},
{
"_id":1,
"host":"localhost:27018",
"tags":{
"datacenter":"San Jose",
"region":"US_West"
}
},
{
"_id":2,
"host":"localhost:27019",
"tags":{
"datacenter":"Richmond",
"region":"US_Eest"
}
}
],
"settings":{
"getLastErrorModes":{
"DRSafe":{
"region":2
}
}
}
}
foo:SECONDARY>
注意上面settings字段,我们定义了一个新的getLastErrorModes对象,键为DRSafe。当我们客户端采用此错误模式作为WriteConcern的时候,它会使写操作在完成前复制到至少两个节点上。下面是使用的例子:
//使用自定义的getLastErrorMode创建WriteConcern
WriteConcern concern = new WriteConcern("DRSafe");
//使用自定义的WriteConcern进行写操作
coll.insert(new BasicDBObject("name", "simple doc"),concern);
----------------------------
在优先读取策略(Read Preferences)中使用节点标记(Tags):
假如我们想要将读请求发送到最近的节点上以便减少请求延时:
DBObject query = new BasicDBObject("name", "simple doc")
DBObject result = coll.findOne(query, null,ReadPreference.nearest());
这样java驱动会自动将读请求发送到ping值最小的节点(也有可能是主节点)。
但是,如果我们的java驱动可以确定自己的请求发送源位置,那么就可以明确指定将读请求发送到距离最近的数据中心。再看上面的例子,假如这个读请求来自南加利福尼亚,我们就明确指定这个读请求到LosAngeles数据中心:
// initialize a properly tagged read preference
ReadPreference tagged_pref =ReadPreference.secondaryPreferred(new BasicDBObject("datacenter","Los Angeles"));
// include the tagged read preference in this request}}
DBObject result = coll.findOne(}}
new BasicDBObject("name", "simple doc"), null,tagged_pref);
下面的例子指定多个tag,如果读请求在Los Angeles失败,则发送到"US_West"区域的某个节点:
// read from either LA or US_West
DBObject tagSetOne = new BasicDBObject("datacenter", "LosAngeles"):
DBObject tagSetTwo = new BasicDBObject("region","US_West");
ReadPreference pref =ReadPreference.primaryPreferred(tagSetOne, tagSetTwo);
下面的例子同样指定多个tag,首先请求"datacenter=LosAngeles"且"rack=1"的节点,如果失败则查找"region=US_West"的节点
// read from either LA or US_West
DBObject tagSetOne = new BasicDBObject("datacenter", "LosAngeles");
tagSetOne.put("rack", "1");
DBObject tagSetTwo = new BasicDBObject("region","US_West");
ReadPreference pref =ReadPreference.primaryPreferred(tagSetOne, tagSetTwo);
优先读取策略(Read Preferences)可以在operation, collection, DB, Mongo,MongoOptions,MongoURI各个级别来设置,而且设置会以slaveOK和WriteConcer类似的方式来继承。
优先读取策略(Read Preferences)在支持主从复制的服务器上(1.6+)都可以使用。
在优先读取策略(ReadPreferences)中使用节点标记(Tags)在所有支持节点标记的服务器(2.0+)都可以使用。
在分片(shard)上使用节点标记(Tags),必须是2.2+版本的服务器才可以。

转载于:https://www.cnblogs.com/leeeee/p/7276594.html

转载:mongoDB java驱动学习笔记相关推荐

  1. Java NIO学习笔记之图解ByteBuffer

    转载自 Java NIO学习笔记之图解ByteBuffer ByteBuffer前前后后看过好几次了,实际使用也用了一些,总觉得条理不够清晰. <程序员的思维修炼>一本书讲过,主动学习,要 ...

  2. Java NIO 学习笔记(三)----Selector

    目录: Java NIO 学习笔记(一)----概述,Channel/Buffer Java NIO 学习笔记(二)----聚集和分散,通道到通道 Java NIO 学习笔记(三)----Select ...

  3. 可能是最全面的 Java G1学习笔记

    转载自 可能是最全面的 Java G1学习笔记 引子 最近遇到很多朋友过来咨询G1调优的问题,我自己去年有专门学过一次G1,但是当时只是看了个皮毛,因此自己也有不少问题.总体来讲,对于G1我有几个疑惑 ...

  4. 深入浅出 Java CMS 学习笔记

    转载自  深入浅出 Java CMS 学习笔记 引子 带着问题去学习一个东西,才会有目标感,我先把一直以来自己对CMS的一些疑惑罗列了下,希望这篇学习笔记能解决掉这些疑惑,希望也能对你有所帮助. 1. ...

  5. 尚学堂JAVA高级学习笔记_1/2

    尚学堂JAVA高级学习笔记 文章目录 尚学堂JAVA高级学习笔记 写在前面 第1章 手写webserver 1. 灵魂反射 2. 高效解析xml 3. 解析webxml 4. 反射webxml 5. ...

  6. Android(java)学习笔记176: 远程服务的应用场景(移动支付案例)

    一. 移动支付:       用户需要在移动终端提交账号.密码以及金额等数据 到 远端服务器.然后远端服务器匹配这些信息,进行逻辑判断,进而完成交易,返回交易成功或失败的信息给移动终端.用户提交账号. ...

  7. java web学习笔记(持续更新)

    java web学习笔记 一.Java Web简介 二.认识Servlet 1.什么是Servlet? 2.请求路径 3.tomcat 4.Servlet的使用 三.Servlet简单应用 1.创建S ...

  8. java设计模式学习笔记之装饰模式

    java设计模式学习笔记之装饰模式 尊重原创,转载请注明出处,原文地址: http://blog.csdn.net/qq137722697 这是一个使用策略模式和构建模式设计的网络请求框架,去看看吧& ...

  9. 【Java】学习笔记2——从小白到入门(技术提升篇)

    写在前面 [Java]学习笔记1--从小小白到小白 (基础知识篇)里记录了Java中最最基础的知识,在对基础知识有了基本了解之后,就可以开始着手技术提升了.本篇博客也将延续第一篇,继续记录我的Java ...

最新文章

  1. 网页游戏 服务器 性能测试工具,简单的压力测试工具
  2. TCP的三次握手建立连接和四次握手释放连接
  3. 天池 在线编程 停车困境(双指针)
  4. 从事python需要掌握哪些知识和技能_零基础想转行从事Python?需要掌握如下技能...
  5. 基于小波变换的数字图像处理(MATLAB源代码)
  6. C++PrimerPlus学习——第七章编程练习
  7. 黄金周张家界之行(1)
  8. 12306再曝漏洞,一张身份证可买两张相同火车票
  9. 使用这些 HTTP 头保护 Web 应用
  10. Linux下C程序进程地址空间布局[转]
  11. [每天一个知识点]20-Java语言-菱形运算符
  12. 利用OpenCV实现——目标跟踪方法(一)
  13. python程序运行后没有反应_为什么我的电脑在运行这个python程序时速度变慢,没有反应?...
  14. Python在线编程网站
  15. 自主创业一年,自己总结了5个创业心得
  16. 全国计算机等级考点申请,全国计算机等级考试(NCRE)考点申请书某高校(367)
  17. Oracle19C下载安装教程(图文详解)
  18. 微信小程序 MinUI 组件库系列之 abnor 异常流组件
  19. 10019---Linux查看CPU、内存、硬盘、版本信息
  20. 第四次面试----华数电力科技有限公司

热门文章

  1. Informix IDS 11零碎治理(918考试)认证指南,第 7 部分: IDS复制(24)
  2. Jenkins自动编译库并上传服务器
  3. Apache Accumulo 1.9.3 发布,高性能 K/V 存储方案
  4. 【Java学习】JDBC可以再深一点理解
  5. 数据监测驱动下的信息流广告优化
  6. Tomcat - Maven plugin: 运行找不到webapp
  7. FTP自动上传日期命名文件
  8. DataTable.Compute功能
  9. Android应用开发—Intent组件详解
  10. android 的各种文件类