共计 7154 个字符,预计需要花费 18 分钟才能阅读完成。
1、上面建设一个 JavaProject 工程,导入下载下来的驱动包。即可在 Java 中应用 mongoDB,目录如下:
二、Java 操作 MongoDB 示例
在本示例之前你须要启动 mongod.exe 的服务,启动后,上面的程序能力顺利执行;
1、建设 SimpleTest.java,实现简略的 mongoDB 数据库操作
Mongo mongo = new Mongo();
这样就创立了一个 MongoDB 的数据库连贯对象,它默认连贯到以后机器的 localhost 地址,端口是 27017。
DB db = mongo.getDB(“test”);
这样就取得了一个 test 的数据库,如果 mongoDB 中没有创立这个数据库也是能够失常运行的。如果你就晓得,mongoDB 能够在没有创立这个数据库的状况下,实现数据的增加操作。当增加的时候,没有这个库,mongoDB 会主动创立以后数据库。
失去了 db,下一步咱们要获取一个“汇集汇合 DBCollection”,通过 db 对象的 getCollection 办法来实现。
DBCollection users = db.getCollection(“users”);
这样就取得了一个 DBCollection,它相当于咱们数据库的“表”。
查问所有数据
DBCursor cur = users.find();
while (cur.hasNext()) {undefined
System.out.println(cur.next());
}
残缺源码
package com.hoo.test;
import java.net.UnknownHostException;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.mongodb.util.JSON;
/**
- function:MongoDB 简略示例
- @author hoojo
- @createDate 2011-5-24 下午 02:42:29
- @file SimpleTest.java
- @package com.hoo.test
- @project MongoDB
- @blog http://blog.csdn.net/IBM_hoojo
- @email hoojo_@126.com
- @version 1.0
*/
public class SimpleTest {
public static void main(String[] args) throws UnknownHostException, MongoException {Mongo mg = new Mongo();
// 查问所有的 Database
for (String name : mg.getDatabaseNames()) {System.out.println("dbName:" + name);
}
DB db = mg.getDB("test");
// 查问所有的汇集汇合
for (String name : db.getCollectionNames()) {System.out.println("collectionName:" + name);
}
DBCollection users = db.getCollection("users");
// 查问所有的数据
DBCursor cur = users.find();
while (cur.hasNext()) {System.out.println(cur.next());
}
System.out.println(cur.count());
System.out.println(cur.getCursorId());
System.out.println(JSON.serialize(cur));
}
}
2、实现 CRUD 操作,首先建设一个 MongoDB4CRUDTest.java,根本测试代码如下:
package com.hoo.test;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.List;
import org.bson.types.ObjectId;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import com.mongodb.BasicDBObject;
import com.mongodb.Bytes;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.mongodb.QueryOperators;
import com.mongodb.util.JSON;
/**
- function: 实现 MongoDB 的 CRUD 操作
- @author hoojo
- @createDate 2011-6-2 下午 03:21:23
- @file MongoDB4CRUDTest.java
- @package com.hoo.test
- @project MongoDB
- @blog http://blog.csdn.net/IBM_hoojo
- @email hoojo_@126.com
- @version 1.0
*/
public class MongoDB4CRUDTest {
private Mongo mg = null;
private DB db;
private DBCollection users;
@Before
public void init() {
try {mg = new Mongo();
//mg = new Mongo("localhost", 27017);
} catch (UnknownHostException e) {e.printStackTrace();
} catch (MongoException e) {e.printStackTrace();
}
// 获取 temp DB;如果默认没有创立,mongodb 会主动创立
db = mg.getDB("temp");
// 获取 users DBCollection;如果默认没有创立,mongodb 会主动创立
users = db.getCollection("users");
}
@After
public void destory() {if (mg != null)
mg.close();
mg = null;
db = null;
users = null;
System.gc();}
public void print(Object o) {System.out.println(o);
}
}
3、增加操作
在增加操作之前,咱们须要写个查询方法,来查问所有的数据。代码如下:
/**
- function: 查问所有数据
- @author hoojo
- @createDate 2011-6-2 下午 03:22:40
*/
private void queryAll() {
print("查问 users 的所有数据:");
//db 游标
DBCursor cur = users.find();
while (cur.hasNext()) {print(cur.next());
}
}
@Test
public void add() {
// 先查问所有数据
queryAll();
print("count:" + users.count());
DBObject user = new BasicDBObject();
user.put("name", "hoojo");
user.put("age", 24);
//users.save(user) 保留,getN() 获取影响行数
//print(users.save(user).getN());
// 扩大字段,随便增加字段,不影响现有数据
user.put("sex", "男");
print(users.save(user).getN());
// 增加多条数据,传递 Array 对象
print(users.insert(user, new BasicDBObject("name", "tom")).getN());
// 增加 List 汇合
List<DBObject> list = new ArrayList<DBObject>();
list.add(user);
DBObject user2 = new BasicDBObject("name", "lucy");
user.put("age", 22);
list.add(user2);
// 增加 List 汇合
print(users.insert(list).getN());
// 查问下数据,看看是否增加胜利
print("count:" + users.count());
queryAll();
}
4、删除数据
@Test
public void remove() {
queryAll();
print("删除 id = 4de73f7acd812d61b4626a77:" + users.remove(new BasicDBObject("_id", new ObjectId("4de73f7acd812d61b4626a77"))).getN());
print("remove age >= 24:" + users.remove(new BasicDBObject("age", new BasicDBObject("$gte", 24))).getN());
}
5、批改数据
@Test
public void modify() {
print("批改:" + users.update(new BasicDBObject("_id", new ObjectId("4dde25d06be7c53ffbd70906")), new BasicDBObject("age", 99)).getN());
print("批改:" + users.update(new BasicDBObject("_id", new ObjectId("4dde2b06feb038463ff09042")),
new BasicDBObject("age", 121),
true,// 如果数据库不存在,是否增加
false// 多条批改
).getN());
print("批改:" + users.update(new BasicDBObject("name", "haha"),
new BasicDBObject("name", "dingding"),
true,// 如果数据库不存在,是否增加
true//false 只批改第一天,true 如果有多条就不批改
).getN());
// 当数据库不存在就不批改、不增加数据,当多条数据就不批改
//print("批改多条:" + coll.updateMulti(new BasicDBObject("_id", new ObjectId("4dde23616be7c19df07db42c")), new BasicDBObject("name", "199")));
}
6、查问数据
@Test
public void query() {
// 查问所有
//queryAll();
// 查问 id = 4de73f7acd812d61b4626a77
print("find id = 4de73f7acd812d61b4626a77:" + users.find(new BasicDBObject("_id", new ObjectId("4de73f7acd812d61b4626a77"))).toArray());
// 查问 age = 24
print("find age = 24:" + users.find(new BasicDBObject("age", 24)).toArray());
// 查问 age >= 24
print("find age >= 24:" + users.find(new BasicDBObject("age", new BasicDBObject("$gte", 24))).toArray());
print("find age <= 24:" + users.find(new BasicDBObject("age", new BasicDBObject("$lte", 24))).toArray());
print("查问 age!=25:" + users.find(new BasicDBObject("age", new BasicDBObject("$ne", 25))).toArray());
print("查问 age in 25/26/27:" + users.find(new BasicDBObject("age", new BasicDBObject(QueryOperators.IN, new int[] {25, 26, 27}))).toArray());
print("查问 age not in 25/26/27:" + users.find(new BasicDBObject("age", new BasicDBObject(QueryOperators.NIN, new int[] {25, 26, 27}))).toArray());
print("查问 age exists 排序:" + users.find(new BasicDBObject("age", new BasicDBObject(QueryOperators.EXISTS, true))).toArray());
print("只查问 age 属性:" + users.find(null, new BasicDBObject("age", true)).toArray());
print("只查属性:" + users.find(null, new BasicDBObject("age", true), 0, 2).toArray());
print("只查属性:" + users.find(null, new BasicDBObject("age", true), 0, 2, Bytes.QUERYOPTION_NOTIMEOUT).toArray());
// 只查问一条数据,多条去第一条
print("findOne:" + users.findOne());
print("findOne:" + users.findOne(new BasicDBObject("age", 26)));
print("findOne:" + users.findOne(new BasicDBObject("age", 26), new BasicDBObject("name", true)));
// 查问批改、删除
print("findAndRemove 查问 age=25 的数据,并且删除:" + users.findAndRemove(new BasicDBObject("age", 25)));
// 查问 age=26 的数据,并且批改 name 的值为 Abc
print("findAndModify:" + users.findAndModify(new BasicDBObject("age", 26), new BasicDBObject("name", "Abc")));
print("findAndModify:" + users.findAndModify(new BasicDBObject("age", 28), // 查问 age=28 的数据
new BasicDBObject("name", true), // 查问 name 属性
new BasicDBObject("age", true), // 依照 age 排序
false, // 是否删除,true 示意删除
new BasicDBObject("name", "Abc"), // 批改的值,将 name 批改成 Abc
true,
true));
queryAll();
}
mongoDB 不反对联结查问、子查问,这须要咱们本人在程序中实现。将查问的后果集在 Java 查问中进行须要的过滤即可。
7、其余操作
public void testOthers() {
DBObject user = new BasicDBObject();
user.put("name", "hoojo");
user.put("age", 24);
//JSON 对象转换
print("serialize:" + JSON.serialize(user));
// 反序列化
print("parse:" + JSON.parse("{ \"name\": \"hoojo\", \"age\": 24}"));
print("判断 temp Collection 是否存在:" + db.collectionExists("temp"));
// 如果不存在就创立
if (!db.collectionExists("temp")) {DBObject options = new BasicDBObject();
options.put("size", 20);
options.put("capped", 20);
options.put("max", 20);
print(db.createCollection("account", options));
}
// 设置 db 为只读
db.setReadOnly(true);
// 只读不能写入数据
db.getCollection("test").save(user);
}
好了,这里基本上就介绍这么多 Java 操作 MongoDB 的办法。其余的货色还须要你本人多多钻研。下面操作 MongoDB 的办法都是一些罕用的办法,比较简单。如果有什么问题微我 hua2021ei