java环境下：MongoDB的crud操作之Update (一)

最近由于项目的需要，接触了一下MongoDB 从最开始的cmd环境下操作，到客户端操作，然后是java语言操作数据库

下面记录一下我用java语言对数据库执行update操作：

package com.zl.mongodb.util;

import java.net.UnknownHostException;
import java.util.Date;

import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBObject;
import com.mongodb.MongoClient;
import com.mongodb.ServerAddress;
import com.mongodb.WriteResult;

/**
* @author jacky
*
*/
public class MongoDBUtil {

private static MongoClient client;

/**
* 生成MongoClient的客户端
* @param ip  要连接的主机ip
* @param port  连接的端口号
* @return  MongoClient
*/
public static MongoClient getClient(String ip,int port){
try {
ServerAddress address = new ServerAddress(ip, port);
client = new MongoClient(address);
} catch (UnknownHostException e) {
e.printStackTrace();
}
return client;
}
/**
* 更新操作：如果存在id则插入时间字段：millseconds,如果不存在则不执行更新操作
*
* @param client  Mongo客户端
* @param dbName  数据库名
* @param collectionName 集合名称
* @param id id号
* @return
*/
public static boolean update(MongoClient client,String dbName,String collectionName,int id){
DB db = client.getDB(dbName);
DBCollection collection  = db.getCollection(collectionName);
DBObject query = collection.findOne(new BasicDBObject().append("id", id));
//获取时间
Date time = (Date) query.get("time");
long random = Math.round(Math.floor(Math.random() * 1000));
WriteResult result = collection.update(query, new BasicDBObject().append("$set", new BasicDBObject().append("millseconds", (time.getTime()+random)+"")));
if(result.getN()>0){
return true;
}
return false;
}
}

数据库中初始数据：



执行下面的函数：

public static void testUpdate1(){
String ip = "192.168.2.3";
int port = 27017;
String[] citys = {"beijing","tianjing","wuhan"};
MongoClient client = MongoDBUtil.getClient(ip, port);
DB db = client.getDB("zhanglong_test");
DBCollection collection = db.getCollection("students");
BasicDBObject query = new BasicDBObject("name", "timmy");

/*
* DBCollection对象的update方法重载
* update(query,obj)-->表示update(query,obj,false,false)
* update(query,obj,true,true)
* 第一个参数表示要被替换的对象，第二个参数表示替换的对象，第三个参数：false表示如果没有查询到则不执行更新操作，
* 第四个参数表示是否执行批量操作(因为可能满足query对象的数据有很多)
*/

/*
* 注意：mongodb在执行update语句和sql数据库在执行update语句的最大不同点是：如果不带修改器关键字(如：$set $unset等)
* 则表示将新的obj对象替换原来的query对象
*/
//执行下面函数，则找到第一条name为timmy将其替换
collection.update(query, new BasicDBObject().append("email", "timmy@126.com"));

}

数据库的输出结果显示：



如果执行的是

collection.update(obj, new BasicDBObject().append("email", "timmy@126.com"),false,true);则会把两条name为timmy的文档都替换成email:"timmy@126.com"
再次强调：

①第一个boolean类型的参数表示是否在没有查到指定的query时，添加记录。有点类似于insertOrUpdate，false表示只更新，不作添加操作；true表示如果查询不到，就添加记录

②第二个boolean类型的参数表示是否对查询出来的数据进行批量修改，false表示只对查到的第一条记录做修改，true表示对查询到的所有记录做修改(

好吧，记录是在sql数据库中的说法，mongodb中称之为文档，实际上一个意思)

下一篇blog，总结一下对带修改器关键字的操作