mongodb操作代码,Java代码库,德仔网

代码语言
代码分类
【Java】 mongodb操作
作者:柠檬爱曾 / 发布于2015/10/19/ 747

	/**
	 * 数据读取
	 */
	 @SuppressWarnings("unchecked")
	 public static List<Map<String,String>> readColData(int page,int pageSize){
	 DBCollection dbCol = db.getCollection(COLLECTION_NAME);
	 DBCursor ret = dbCol.find().skip((page - 1) * pageSize).limit(pageSize);
	 System.out.println("从数据集中读取数据：");
	 List<Map<String,String>> list = new ArrayList<Map<String,String>>();
	 int j =0;
	 while(ret.hasNext()){
	
	 BasicDBObject bdbObj = (BasicDBObject) ret.next();
	 if(bdbObj != null){
	 j++;
	 Map<String,String> res = new HashMap<String, String>();
	 String mac = bdbObj.getString("_id");
	 if(StringUtil.isNotEmpty(mac)){
	 if(bdbObj.containsKey("address")){
	 String province = ((Map<String,String>)bdbObj.get("address")).get("province");
	 String city = ((Map<String,String>)bdbObj.get("address")).get("city");
	 String district = ((Map<String,String>)bdbObj.get("address")).get("district");
	 String address = ((Map<String,String>)bdbObj.get("address")).get("address");
	 String desc = ((Map<String,String>)bdbObj.get("address")).get("desc");
	 res.put("province", province);
	 res.put("city", city);
	 res.put("address", address);
	 res.put("desc", desc);
	 res.put("district", district);
	 }
	 String location = bdbObj.getString("location",null);
	
	 String ssid = bdbObj.getString("ssid");
	 String lat = null;
	 String lng = null;
	 if(StringUtil.isNotEmpty(location)){
	 String[] array = location.replace("[", "").replace("]", "").replace(" ", "").split(",");
	 if(array.length==2){
	 lat = array[0];
	 lng = array[1];
	 }
	 }
	 res.put("assetMac", mac);
	 res.put("ssid", ssid);
	
	 res.put("lat", lat);
	 res.put("lng", lng);
	 list.add(res);
	 }else{
	 System.out.println(mac);
	 }
	 }
	 }
	 System.out.println("get mongodb size is ->"+(j));
	 return list;
	 }
	
	 public static long getCount(){
	 DBCollection dbCol = db.getCollection(COLLECTION_NAME);
	 long count = 0;
	 count = dbCol.count();
	 return count;
	 }
	
	 /**
	 * 数据更新
	 * update(q, o, upsert, multi)
	 * update(q, o, upsert, multi, concern)
	 * update(arg0, arg1, arg2, arg3, arg4, arg5)
	 * updateMulti(q, o)
	 */
	 public static void updateColData(){
	 System.out.println("------------------------------");
	 DBCollection dbCol = db.getCollection(COLLECTION_NAME);
	 DBCursor ret = dbCol.find();
	 BasicDBObject doc = new BasicDBObject();
	 BasicDBObject res = new BasicDBObject();
	 res.put("age", 40);
	 System.out.println("将数据集中的所有文档的age修改成40！");
	 doc.put("$set", res);
	 dbCol.update(new BasicDBObject(),doc,false,true);
	 System.out.println("更新数据完成！");
	 System.out.println("------------------------------");
	 }
	
	 /**
	 * 数据删除
	 */
	 public static void deleteColData(){
	 System.out.println("------------------------------");
	 DBCollection dbCol = db.getCollection(COLLECTION_NAME);
	 System.out.println("删除【小李】！");
	 BasicDBObject doc = new BasicDBObject();
	 doc.put("name", "小李");
	 dbCol.remove(doc);
	 System.out.println("------------------------------");
	 }
	
	 /**
	 * 关闭mongodb数据库连接
	 */
	 public static void stopMondoDBConn(){
	 if (null != m) {
	 if (null != db) {
	 // 结束Mongo数据库的事务请求
	 try {
	 db.requestDone();
	 } catch(Exception e) {
	 e.printStackTrace();
	 }
	 }
	 try
	 {
	 m.close();
	 } catch(Exception e) {
	 e.printStackTrace();
	 }
	 m = null;
	 db = null;
	 }
	 }
	
	 /**
	 * 获取mongodb数据库连接
	 */
	 public static void startMongoDBConn(){
	 try {
	 //Mongo(p1, p2):p1=>IP地址 p2=>端口
	 m = new Mongo("127.0.0.1", 27017);
	 //根据mongodb数据库的名称获取mongodb对象
	 db = m.getDB("pawf-op");
	 //校验用户密码是否正确
	 if (!db.authenticate("sa", "sa".toCharArray())){
	 System.out.println("连接MongoDB数据库,校验失败！");
	 }else{
	 System.out.println("连接MongoDB数据库,校验成功！");
	 }
	 } catch (UnknownHostException e) {
	 e.printStackTrace();
	 } catch (MongoException e) {
	 e.printStackTrace();
	 }
试试其它关键字
　mongodb　
同语言下
可能有用的
柠檬爱曾贡献的其它代码(8)