侯体宗的博客
  • 首页
  • Hyperf版
  • beego仿版
  • 人生(杂谈)
  • 技术
  • 关于我
  • 更多分类
    • 文件下载
    • 文字修仙
    • 中国象棋ai
    • 群聊
    • 九宫格抽奖
    • 拼图
    • 消消乐
    • 相册

Java操作MongoDB数据库示例分享

Java  /  管理员 发布于 8年前   146

MongoDB是一个文档型数据库,是NOSQL家族中最重要的成员之一,以下代码封装了MongoDB的基本操作。

MongoDBConfig.java

package com.posoftframework.mongodb;import java.io.File;import java.io.FileInputStream;import java.io.IOException;import java.util.Enumeration;import java.util.HashMap;import java.util.Hashtable;import java.util.List;import java.util.Map;import java.util.Properties;import com.mongodb.DB;import com.mongodb.Mongo;/** * MongoDB配置类 *  * @author yongtree * @date 2010-7-7 下午07:45:08 * @version 1.0 */public class MongoDBConfig {  private static Mongo mongo;  private static DB db;  private static final String MONGO_DB_ADDRESS = "localhost";  private static final int MONGO_DB_PORT = 27017;  private static final String MONGO_DB_USERNAME = "root";  private static final String MONGO_DB_PASSWORD = "root";  private static final String MONGO_DB_DBNAME = "mongodb";  private static final String MONGO_DB_RESOURCE_FILE = "mongodb.cfg.properties";  /**   * Mongo数据库参数   */  private static Map<String, String> cfgMap = new HashMap<String, String>();  private static Hashtable<String, DB> mongoDBs = new Hashtable<String, DB>();  /**   * 初始化Mongo的数据库   */  static {    init();  }  public static File getConfigFile() {    String path = MongoDBConfig.class.getResource("/").getPath();    String fileName = path + MONGO_DB_RESOURCE_FILE;    File file = new File(fileName);    if (file.exists()) {      return file;    }    return null;  }  @SuppressWarnings("unchecked")  private static void initCfgMap() {    File file = getConfigFile();    if (file != null) {      Properties p = new Properties();      try {        p.load(new FileInputStream(file));        for (Enumeration enu = p.propertyNames(); enu.hasMoreElements();) {          String key = (String) enu.nextElement();          String value = (String) p.getProperty(key);          cfgMap.put(key, value);        }      } catch (IOException e) {        System.out.println("记载Mongo配置文件失败!");        e.printStackTrace();      }    } else {      cfgMap.put("mongo.db.address", MONGO_DB_ADDRESS);      cfgMap.put("mongo.db.port", String.valueOf(MONGO_DB_PORT));      cfgMap.put("mongo.db.username", MONGO_DB_USERNAME);      cfgMap.put("mongo.db.password", MONGO_DB_PASSWORD);      cfgMap.put("mongo.db.dbname", MONGO_DB_DBNAME);    }  }  /**   * 初始化Mongo数据库   */  private static void init() {    initCfgMap();    try {      String address = cfgMap.get("mongo.db.address");      int port = Integer.parseInt(cfgMap.get("mongo.db.port").toString());      String dbName = cfgMap.get("mongo.db.dbname");      String username = cfgMap.get("mongo.db.username");      String password = cfgMap.get("mongo.db.password");      mongo = new Mongo(address, port);      if (dbName != null && !"".equals(dbName)) {        db = mongo.getDB(dbName);        if (username != null && !"".equals(username)) {          db.addUser(username, password.toCharArray());        }        mongoDBs.put(dbName, db);      }    } catch (IOException e) {      e.printStackTrace();    }  }  /**   * 得到Mongo的实例   *    * @return   */  public static Mongo getMongo() {    return mongo;  }  /**   * 得到Mongo的图片数据库   *    * @return   */  public static DB getDB() {    return db;  }  public static List<String> getDBNames() {    return mongo.getDatabaseNames();  }  /**   * 根据数据库名称,得到数据库<br/>   * 如果不存在,则创建一个该名称的数据库,并设置用户名和密码为配置文件中的参数值</br>   *    * @param dbName   * @return   */  public static DB getDBByName(String dbName) {    DB db = mongo.getDB(dbName);    if (!mongoDBs.contains(db)) {      db.addUser(cfgMap.get("mongo.db.username"), cfgMap.get(          "mongo.db.password").toCharArray());      mongoDBs.put(dbName, db);    }    return db;  }}

MongoService.java

/************************* 版权声明 ********************************* *   * *           版权所有:百洋软件    * *     Copyright (c) 2010 by www.po-soft.com* *   * ************************* 变更记录 ********************************* * * 创建者:yongtree  创建日期: 2010-7-7 * 备注: *  * 修改者:    修改日期: * 备注: *  */package com.posoftframework.mongodb;import java.util.List;import java.util.Map;import com.mongodb.DB;import com.mongodb.DBCollection;import com.mongodb.DBObject;/** * 操作MongoDB的DAO接口 *  * @author yongtree * @date 2010-7-7 下午04:44:43 * @version 1.0 */public interface MongoService {  public abstract DBCollection getCollection();  /**   * 根据数据集合的Map,插入数据 map的key对应数据库中的DBCollection的key值   *    * @param obj   */  public abstract DBObject insert(DBObject obj);  /**   * 根据List<Map<String,Object>>结构的数据集合,插入数据   *    * @param list   */  public abstract void insertBatch(List<DBObject> list);  /**   * 按照条件参数集合map,删除数据   *    * @param map   */  public abstract void delete(DBObject obj);  /**   * 按照多种条件的并集,批量删除数据   *    * @param list   */  public abstract void deleteBatch(List<DBObject> list);  /**   * 得到Collection()总的记录数   *    * @return   */  public abstract long getCollectionCount();  public abstract long getCount(DBObject query);  public abstract List<DBObject> find(DBObject query);  public abstract List<DBObject> find(DBObject query,DBObject sort);  public abstract List<DBObject> find(DBObject query,DBObject sort,int start,int limit);  /**   * 根据whereFields参数,更新setFields值   *    * @param setFields   * @param whereFields   */  public abstract void update(DBObject setFields,      DBObject whereFields);  public abstract List<DBObject> findAll();  /**   * 根据ID找到唯一数据 有1个id字段标记   *    * @param id   * @return   */  public abstract DBObject getById(String id);  /**   * 获取所有数据库名称   *    * @return   */  public List<String> getAllDBNames();  public abstract String getDbName();  public abstract void setDbName(String dbName);  public abstract DB getDb();  public abstract String getCollName();  public abstract void setCollName(String collName);}

MongoServiceImpl.java

/************************* 版权声明 ********************************* *   * *           版权所有:百洋软件    * *     Copyright (c) 2010 by www.po-soft.com* *   * ************************* 变更记录 ********************************* * * 创建者:yongtree  创建日期: 2010-7-7 * 备注: *  * 修改者:    修改日期: * 备注: *  */package com.posoftframework.mongodb;import java.util.ArrayList;import java.util.List;import java.util.Map;import org.bson.types.ObjectId;import com.mongodb.BasicDBObject;import com.mongodb.DB;import com.mongodb.DBCollection;import com.mongodb.DBCursor;import com.mongodb.DBObject;/** *  * @author yongtree * @date 2010-7-7 下午07:22:15 * @version 1.0 */public class MongoServiceImpl implements MongoService {  private String dbName;  private String collName;  private DB db;  public MongoServiceImpl(String dbName, String collName) {    this.dbName = dbName;    this.collName = collName;    try {      db = MongoDBConfig.getDBByName(this.dbName);    } catch (Throwable e) {      e.printStackTrace();    }  }  public MongoServiceImpl() {    getDb();  }  public DBCollection getCollection() {    return db.getCollection(this.collName);  }  public DBObject map2Obj(Map<String, Object> map) {    DBObject obj = new BasicDBObject();    if (map.containsKey("class") && map.get("class") instanceof Class)      map.remove("class");    obj.putAll(map);    return obj;  }  public DBObject insert(DBObject obj) {    getCollection().insert(obj);    return obj;  }  public void insertBatch(List<DBObject> list) {    if (list == null || list.isEmpty()) {      return;    }    List<DBObject> listDB = new ArrayList<DBObject>();    for (int i = 0; i < list.size(); i++) {      listDB.add(list.get(i));    }    getCollection().insert(listDB);  }  public void delete(DBObject obj) {    getCollection().remove(obj);  }  public void deleteBatch(List<DBObject> list) {    if (list == null || list.isEmpty()) {      return;    }    for (int i = 0; i < list.size(); i++) {      getCollection().remove(list.get(i));    }  }  public long getCollectionCount() {    return getCollection().getCount();  }  public long getCount(DBObject obj) {    if (obj != null)      return getCollection().getCount(obj);    return getCollectionCount();  }  public List<DBObject> find(DBObject obj) {    DBCursor cur = getCollection().find(obj);    return DBCursor2list(cur);  }  @Override  public List<DBObject> find(DBObject query, DBObject sort) {    DBCursor cur;    if (query != null) {      cur = getCollection().find(query);    } else {      cur = getCollection().find();    }    if (sort != null) {      cur.sort(sort);    }    return DBCursor2list(cur);  }  @Override  public List<DBObject> find(DBObject query, DBObject sort, int start,      int limit) {    DBCursor cur;    if (query != null) {      cur = getCollection().find(query);    } else {      cur = getCollection().find();    }    if (sort != null) {      cur.sort(sort);    }    if (start == 0) {      cur.batchSize(limit);    } else {      cur.skip(start).limit(limit);    }    return DBCursor2list(cur);  }  private List<DBObject> DBCursor2list(DBCursor cur) {    List<DBObject> list = new ArrayList<DBObject>();    if (cur != null) {      list = cur.toArray();    }    return list;  }  public void update(DBObject setFields, DBObject whereFields) {    getCollection().updateMulti(setFields, whereFields);  }  public List<DBObject> findAll() {    DBCursor cur = getCollection().find();    List<DBObject> list = new ArrayList<DBObject>();    if (cur != null) {      list = cur.toArray();    }    return list;  }  public DBObject getById(String id) {    DBObject obj = new BasicDBObject();    obj.put("_id", new ObjectId(id));    DBObject result = getCollection().findOne(obj);    return result;  }  public String getDbName() {    return dbName;  }  public void setDbName(String dbName) {    this.dbName = dbName;    this.db = MongoDBConfig.getDBByName(this.dbName);  }  public String getCollName() {    return collName;  }  public void setCollName(String collName) {    this.collName = collName;  }  public DB getDb() {    if (this.db == null) {      if (this.dbName == null) {        this.db = MongoDBConfig.getDB();      } else {        this.db = MongoDBConfig.getDBByName(this.dbName);      }    }    return this.db;  }  public List<String> getAllDBNames() {    return MongoDBConfig.getDBNames();  }}


  • 上一条:
    java实现插入mysql二进制文件,blob类型,遇到问题及解决办法
    下一条:
    MongoDB系列教程(六):java操作mongodb实例
  • 昵称:

    邮箱:

    0条评论 (评论内容有缓存机制,请悉知!)
    最新最热
    • 分类目录
    • 人生(杂谈)
    • 技术
    • linux
    • Java
    • php
    • 框架(架构)
    • 前端
    • ThinkPHP
    • 数据库
    • 微信(小程序)
    • Laravel
    • Redis
    • Docker
    • Go
    • swoole
    • Windows
    • Python
    • 苹果(mac/ios)
    • 相关文章
    • 在java中实现的脱敏工具类代码示例分享(0个评论)
    • zookeeper安装流程步骤(0个评论)
    • 在java中你背的“八股文”可能已经过时了(2个评论)
    • 在php8.0+版本中使用属性来增加值代码示例(3个评论)
    • java 正则表达式基础,实例学习资料收集大全 原创(0个评论)
    • 近期文章
    • 智能合约Solidity学习CryptoZombie第三课:组建僵尸军队(高级Solidity理论)(0个评论)
    • 智能合约Solidity学习CryptoZombie第二课:让你的僵尸猎食(0个评论)
    • 智能合约Solidity学习CryptoZombie第一课:生成一只你的僵尸(0个评论)
    • 在go中实现一个常用的先进先出的缓存淘汰算法示例代码(0个评论)
    • 在go+gin中使用"github.com/skip2/go-qrcode"实现url转二维码功能(0个评论)
    • 在go语言中使用api.geonames.org接口实现根据国际邮政编码获取地址信息功能(1个评论)
    • 在go语言中使用github.com/signintech/gopdf实现生成pdf分页文件功能(0个评论)
    • gmail发邮件报错:534 5.7.9 Application-specific password required...解决方案(0个评论)
    • 欧盟关于强迫劳动的规定的官方举报渠道及官方举报网站(0个评论)
    • 在go语言中使用github.com/signintech/gopdf实现生成pdf文件功能(0个评论)
    • 近期评论
    • 122 在

      学历:一种延缓就业设计,生活需求下的权衡之选中评论 工作几年后,报名考研了,到现在还没认真学习备考,迷茫中。作为一名北漂互联网打工人..
    • 123 在

      Clash for Windows作者删库跑路了,github已404中评论 按理说只要你在国内,所有的流量进出都在监控范围内,不管你怎么隐藏也没用,想搞你分..
    • 原梓番博客 在

      在Laravel框架中使用模型Model分表最简单的方法中评论 好久好久都没看友情链接申请了,今天刚看,已经添加。..
    • 博主 在

      佛跳墙vpn软件不会用?上不了网?佛跳墙vpn常见问题以及解决办法中评论 @1111老铁这个不行了,可以看看近期评论的其他文章..
    • 1111 在

      佛跳墙vpn软件不会用?上不了网?佛跳墙vpn常见问题以及解决办法中评论 网站不能打开,博主百忙中能否发个APP下载链接,佛跳墙或极光..
    • 2016-11
    • 2018-03
    • 2020-03
    • 2023-05
    • 2023-11
    • 2024-01
    Top

    Copyright·© 2019 侯体宗版权所有· 粤ICP备20027696号 PHP交流群

    侯体宗的博客