MongoDB Java接入

MongoDB的Java驱动已经提供比较全的操作，分为三块：1.普通用户操作2.管理员操作3.oplog操作具体可以添加一个eclipse testng插件，再在工程中导入testng.jar包即可看到。本文主要说明各个使用点和注意事项。
1.连接一个复制集（replica sets）mongod：复制集是mongo解决稳定性的一个方案，也是可以实现读写分离的一种实现，这里介绍复制集的java连接方式。[java]

static Mongo m;
static {
List<ServerAddress> addresslist = new ArrayList<ServerAddress>（）;
try {
addresslist.add（new ServerAddress（"127.0.0.1:10240"））;
addresslist.add（new ServerAddress（"127.0.0.1:11240"））;
addresslist.add（new ServerAddress（"127.0.0.1:12240"））;
} catch （UnknownHostException e） {
System.err.println（"address check error."）;
System.exit（-1）;
}
MongoOptions options = new MongoOptions（）;
options.autoConnectRetry = true;
options.connectionsPerHost = 20;
options.connectTimeout = 6000;
options.maxAutoConnectRetryTime = 12000;
options.maxWaitTime = 12000;
options.socketKeepAlive = true;
options.socketTimeout = 2000;
try {
m = new Mongo（addresslist, options）;
} catch （MongoException e） {
System.err.println（"mongo create error."）;
System.exit（-1）;
}
}

注：一般例子采用的连接方式是直接连一个mongod服务，但是作为单台的生产环境显然安全性不足，因此采用复制集方式，连接也区别于一般，是使用 [java]

public Mongo（ List<ServerAddress> replicaSetSeeds , MongoOptions options ） throws MongoException

方法。 MongoOptions根据自己的需求设置，参数说明已经很多了，不细讲。注意mongo实例使用单例模式。
2.获取db：[java]

DB db = m.getDB（"test"）;

注：取到名为test的db进行操作；若该db不存在，该操作会创建对应的db。

3.获取集合：[java]

DBCollection col = db.getCollection（"offer"）;

注：取名字为offer的集合；类似于db的表。
以上三个操作是建立连接，接下去才是db中常用的操作。
4.查询：[java]

DBCursor cursor = col.find（）;
while（cursor.hasNext（）） {
System.out.println（cursor.next（））;
i++;
}

注：全集合查询，输出每条记录，正常情况不会作类似操作，记住两个东西，find（）和cursor
[java]

BasicDBObject query = new BasicDBObject（）;
query = new BasicDBObject（）;
query.put（"i", new BasicDBObject（"$gt", 20）.append（"$lte", 30））; // i.e. 20 < i <= 30
<pre name="code" class="java"> DBCursor cur = coll.find（query）;
while（cur.hasNext（）） {
System.out.println（cur.next（））;
}

注：查询指定条件的offer信息。
[java]

DBObject tmpdoc = col.findOne（doc）;

注：查询单条记录；在很明确一条记录有且只有一条时，findOne（）比较方便，免得游标移动麻烦。

5.更新：[java]

DBObject tmpdoc = col.findOne（doc）;
tmpdoc.put（"i", （Integer）tmpdoc.get（"i"）+1）;
System.out.println（"update obj: " + col.findOne（tmpdoc））;

注：更新一条记录，先整个读出再更新部分信息再写入，切记不要读出一部分更新回去。
6.插入：
[java]

int i=1000;
BasicDBObject doc = new BasicDBObject（）;
doc.put（"i", i+1）;
col.insert（doc）;
System.out.println（"insert obj: " + col.findOne（doc））;

注：插入一条记录｛i:1001｝,_id自动生成。

7.删除：[java]

BasicDBObject doc = new BasicDBObject（）;
doc.put（"i", i+1）;
col.remove（doc）;
System.out.println（"insert obj: " + col.findOne（doc））;

注：删除一条记录。Neo4j推出基于Python的嵌入式图数据存储Oracle ADF基于AM的两种回滚写法及切换行事件（附代码）相关资讯 MongoDB

MongoDB 3.3.0 发布下载（01月14日）
使用MongoDB C#官方驱动操作（12/31/2015 16:27:56）
CentOS 6.6下安装MongoDB 3.0.1 （12/21/2015 19:29:02）

MongoDB 3.2版WiredTiger存储引擎（01月02日）
进程监控工具Supervisor 启动（12/26/2015 10:49:57）
MongoDB 3.2.1 RC0 发布下载（12/18/2015 11:32:29）

本文评论查看全部评论（0）