代码语言
.
CSharp
.
JS
Java
Asp.Net
C
MSSQL
PHP
Css
PLSQL
Python
Shell
EBS
ASP
Perl
ObjC
VB.Net
VBS
MYSQL
GO
Delphi
AS
DB2
Domino
Rails
ActionScript
Scala
代码分类
文件
系统
字符串
数据库
网络相关
图形/GUI
多媒体
算法
游戏
Jquery
Extjs
Android
HTML5
菜单
网页交互
WinForm
控件
企业应用
安全与加密
脚本/批处理
开放平台
其它
【
Java
】
mongodb操作
作者:
柠檬爱曾
/ 发布于
2015/10/19
/
689
/** * 数据读取 */ @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
同语言下
.
List 切割成几份 工具类
.
一行一行读取txt的内容
.
Java PDF转换成图片并输出给前台展示
.
java 多线程框架
.
double类型如果小数点后为零则显示整数否则保留两位小
.
将图片转换为Base64字符串公共类抽取
.
sqlParser 处理SQL(增删改查) 替换schema 用于多租户
.
JAVA 月份中的第几周处理 1-7属于第一周 依次类推 29-
.
java计算两个经纬度之间的距离
.
输入时间参数计算年龄
可能有用的
.
C#实现的html内容截取
.
List 切割成几份 工具类
.
SQL查询 多列合并成一行用逗号隔开
.
一行一行读取txt的内容
.
C#动态修改文件夹名称(FSO实现,不移动文件)
.
c# 移动文件或文件夹
.
c#图片添加水印
.
Java PDF转换成图片并输出给前台展示
.
网站后台修改图片尺寸代码
.
处理大图片在缩略图时的展示
柠檬爱曾
贡献的其它代码
(
8
)
.
php简单异或运算
.
透明LCD时钟
.
计算年龄 精确到天
.
卡拉兹的猜想
.
mongodb操作
.
随机生成短信验证码
.
rsa加密
.
蓝牙的搜索,配对,解除配对等
Copyright © 2004 - 2024 dezai.cn. All Rights Reserved
站长博客
粤ICP备13059550号-3