关于javascript:MongoDB-for-JavaJava操作MongoDB

30次阅读

共计 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

正文完
 0