java封装Mongodb3.2.1工具类
发表于:2025-01-20 作者:千家信息网编辑
千家信息网最后更新 2025年01月20日,由于最近项目要使用mongodb来处理一些日志,提前学习了一下mongodb的一些基本用法,大概写了一些常用的。开发环境为:WIN7-64,JDK7-64,MAVEN3.3.9-64,IDEA2017
千家信息网最后更新 2025年01月20日java封装Mongodb3.2.1工具类
由于最近项目要使用mongodb来处理一些日志,提前学习了一下mongodb的一些基本用法,大概写了一些常用的。
开发环境为:WIN7-64,JDK7-64,MAVEN3.3.9-64,IDEA2017-64.
程序基本结构为:
下面贴出核心代码示例:
pom.xml
4.0.0 TestWebProjectMaven TestWebProjectMaven war 1.0-SNAPSHOT TestWebProjectMaven Maven Webapp nexus-repos Team Nexus Repository http://192.168.200.205:8081/nexus/content/groups/public/ true true nexus-repos Team Nexus Repository http://192.168.200.205:8081/nexus/content/groups/public/ true true junit junit 3.8.1 test org.springframework spring-webmvc 4.1.6.RELEASE org.springframework spring-context 4.1.6.RELEASE org.mongodb mongo-java-driver 3.2.1 org.jetbrains annotations-java5 RELEASE commons-configuration commons-configuration 1.10 TestWebProjectMaven src/main/java **/*.properties src/main/resources
mongodb.properties
MONGODB_IP=192.168.200.234MONGODB_PORT=10143MONGODB_DATABASE_NAME=runoobMONGODB_COLLECTION_NAME=test
MongodbUtil
package org.mbox.util;import com.mongodb.MongoClient;import com.mongodb.client.*;import com.mongodb.client.model.Filters;import com.mongodb.client.model.UpdateOptions;import com.mongodb.client.result.DeleteResult;import org.apache.commons.configuration.CompositeConfiguration;import org.apache.commons.configuration.ConfigurationException;import org.apache.commons.configuration.PropertiesConfiguration;import org.bson.Document;import org.bson.conversions.Bson;import org.bson.types.ObjectId;import org.mbox.model.PageVO;import java.beans.IntrospectionException;import java.beans.PropertyDescriptor;import java.lang.reflect.Field;import java.lang.reflect.InvocationTargetException;import java.lang.reflect.Method;import java.util.*;/** * Created by pc on 2017/6/5. */public class MongodbUtil { private static MongoClient MONGODB_CLIENT = null; private static String MONGODB_IP = null; private static Integer MONGODB_PORT = null; private static String MONGODB_DATABASE_NAME = null; private static String MONGODB_COLLECTION_NAME = null; static{ CompositeConfiguration compositeConfiguration = new CompositeConfiguration(); try { compositeConfiguration.addConfiguration(new PropertiesConfiguration("mongodb.properties")); } catch (ConfigurationException e) { e.printStackTrace(); } MONGODB_IP = compositeConfiguration.getString("MONGODB_IP"); MONGODB_PORT = compositeConfiguration.getInt("MONGODB_PORT"); MONGODB_DATABASE_NAME = compositeConfiguration.getString("MONGODB_DATABASE_NAME"); MONGODB_COLLECTION_NAME = compositeConfiguration.getString("MONGODB_COLLECTION_NAME"); MONGODB_CLIENT = new MongoClient(MONGODB_IP,MONGODB_PORT); } private MongodbUtil() { } /** * 初始化mongodb数据源 * @return */ public static MongoDatabase getMongodbDatabase(){ return MONGODB_CLIENT.getDatabase(MONGODB_DATABASE_NAME); } /** * 关闭MongoClient连接 */ public static void closeMongodbClient(){ if(null != MONGODB_CLIENT){ MONGODB_CLIENT.close(); MONGODB_CLIENT = null; } } /** * 获取mongodb的表对象 * @return */ public static MongoCollectiongetMongoCollection(){ return getMongodbDatabase().getCollection(MONGODB_COLLECTION_NAME); } /** * 通过map插入一条数据到表中 * @param map */ public static void insertOneCollectionByMap(Map map){ getMongoCollection().insertOne(handleMap(map)); } /** * 通过集合map一次性插入多条数据到表中 * @param listMap */ public static void insertManyCollectionByMap(List
数据
查询
条件
对象
实体
处理
更新
内容
多条
子集
字段
形式
结果
一次性
前端
手工
方法
问题
上一
参考
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全
数据库店铺分区和布局
化学文摘的数据库有哪些
数据库怎样判断数据是否准确
我的世界热门网络游戏服务器
机关网络安全保障工作制度
租制服务器
网络安全组件是什么
ncdb数据库使用指南
番禺医院服务器
魔兽世界5区服务器排名
将数据库中查出的数据求和
数据库中的窗体有几种视图
上海支付宝扫码点餐软件开发
金融服务企业网络安全
拼音计算机网络技术
手动关闭数据库msql
打开网络安全手抄报简单
汕头商联网络技术有限公司
数据库判断是否为空
万方数据库明
软件开发Debug仪器
线上网络安全等级
呼和浩特服务器机柜公司
论文数据库 学校购买
魔兽世界5区服务器排名
帝国神话官方服务器1000
家用小型服务器配置
服务器改了端口登陆不了
湖北品质软件开发设施价钱
汕头商联网络技术有限公司