Java操作MongoDB数据库方法详解--688IT编程网

Java操作MongoDB数据库⽅法详解Java与mongodb的连接

1. 连单台mongodb

Mongo mg = new Mongo();//默认连本机127.0.0.1 端⼝为27017

Mongo mg = new Mongo(ip);//可以指定ip 端⼝默认为27017

Mongo mg = new Mongo(ip,port);//也可以指定ip及端⼝

2. 连双台mongodb

//ip为主机ip地址，port为端⼝号，dataBaseName相当于数据库名

DBAddress left = new DBAddress("ip:port/dataBaseName");

DBAddress right = new DBAddress("ip:port/dataBaseName ");

//若⼀个mongodb出现问题，会⾃动连另外⼀台

Mongo mongo = new Mongo(left, right);

3. 连多台mongodb

List<ServerAddress> mongoHostList = new ArrayList<ServerAddress>();

mongoHostList.add(new ServerAddress("ip",port));

Mongo mg = new Mongo(mongoHostList);

Java获取mongodb的数据库名

1. 获取mongodb的db（数据库）

//dataBaseName相当于关系数据库⾥的数据库名，mongodb中若没有该

//数据库名也不会报错，默认mongodb会建⽴这个数据库名，为空。

DB db = mg.getDB(dataBaseName);

注意：mongodb区分⼤⼩写，程序中⼀定要注意

//安全认证java代码返回true表⽰通过，false表⽰没通过不能进⾏操作

db.authenticate("userName", "password".toCharArray());

if(db.authenticate("admin", "123".toCharArray())){

System.out.println("连接mongodb成功...");

} else{

System.out.println("连接mongodb失败...");

}

1.得到mongodb中的db的collection（表）

//参数tableName相当于关系数据库⾥的表名,

/若mongodb中没有该tableName，默认会创建该tableName，为空

DBCollection users = db.getCollection(tableName);

//列出库的集合列表，相对于表对象

Set<String> colls = db.getCollectionNames();

for(String s : colls){

}

// 获取单个集合

DBCollection con = db.getCollection("users");

Mongodb中也像传统的关系数据库⾥表⼀样，有主键（_id）概念，⽤来唯⼀标识他们。当⽤户往collection中插⼊⼀条新记录的时候，如果没有指定_id属性，那么mongodb会⾃动⽣成⼀个ObjectId类型的值，保存为_id的值。

_id的值可以为任何类型，除了数组，在实际应⽤中，⿎励⽤户⾃⼰定义_id值，但是要保证他的唯⼀性。

传统的数据库中，通常⽤⼀个递增的序列来提供主键，在Mongodb中⽤ObjectId来代替，我们可以通过如下的⽅法来得到主键。

public class Tools {

/**

* 实现mongodb主键⾃增长的功能

* @param users

* @param tableName

* @return

public static long getNext(DBCollection users,String tableName){

long incId = 0;

try {

DBObject ret = users.findAndModify(

new BasicDBObject("_id", tableName), null, null, false,

new BasicDBObject("$inc", new BasicDBObject("next", 1)),

true, true);

incId = Long.("next").toString());

} catch (Exception e) {

e.printStackTrace();

}

return incId;

}

3.java对collection进⾏插⼊操作

DB db = m.getDB("testdb");

DBCollection con = db.getCollection("users");

//普通添加

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);

con.insert(doc); //插⼊对象

//特殊添加

// 添加多个特殊数据(模式⾃由)

for(int i = 1; i <=20; i++){

con.insert(new BasicDBObject().append("i", i));

}

DBObject user_json = (DBObject)JSON.parse("{'user':[{'name':'AAA', 'age':'18'},{'name':'BBB', 'age':'19'}]}");

con.insert(user_json);

//添加JAVA对象

// 添加java对象，对象要序列化Serializable接⼝

UserInfo userinfo = new UserInfo("⽤户甲AA", 1);

User user = new User(1, "123", userinfo);

ByteArrayOutputStream os = new ByteArrayOutputStream();

os.close(); out.close();

con.insert(MonGoUtil.insertObject("user_info",os.toByteArray()));

List<UserInfo> list = new ArrayList<UserInfo>();

list.add(new UserInfo("List1", 1));

list.add(new UserInfo("List2", 2));

list.add(new UserInfo("List3", 3));

ByteArrayOutputStream os = new ByteArrayOutputStream();

ObjectOutputStream out = new ObjectOutputStream(os);

out.writeObject(list);

os.close(); out.close();

con.insert(MonGoUtil.insertObject("lists",os.toByteArray()));

4.java对collection的查询操作

/** 输出获取到的⽂档 **/

public static void showDBCursor(DBCursor cur){

while(cur.hasNext()){

System.out.());

}

System.out.println();

}

⾼级查询

//查询_id为30000 返回cust_Id的值，mongodb查询都会返回主键的值

System.out.println(users.findOne(new BasicDBObject("_id",30000),new BasicDBObject("cust_Id",true))); findAndRemove() 查询_id=30000的数据，并且删除

users.findAndRemove(new BasicDBObject("_id", 30000));

findAndModify介绍

users.findAndModify(

new BasicDBObject("_id", 28), //查询_id=28的数据

new BasicDBObject("cust_Id", true), //查询cust_Id属性

new BasicDBObject("notice_Id", true), //按照notice_Id排序

false, //查询到的记录是否删除，true表⽰删除

new BasicDBObject("province_Id", "100"), //将province_id的值改为100

true, //是否返回新记录 true返回，false不返回

true //如果没有查询到该数据是否插collection true⼊库，false不⼊

));

查询所有数据

//列出所有⽂档