mongodb java 單例_Java單例MongoDB工具類

我經常對MongoDB進行一些基礎操作，將這些常用操作合并到一個工具類中，方便自己開發使用。

沒用Spring Data、Morphia等框架是為了減少學習、維護成本，另外自己直接JDBC方式的話可以更靈活，為自己以后的積累留一個腳印。

Java驅動版本：

org.mongodb

mongo-java-driver

3.0.2

工具類代碼如下：

package utils;

import java.util.ArrayList;

import java.util.List;

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 com.mongodb.BasicDBObject;

import com.mongodb.MongoClient;

import com.mongodb.MongoClientOptions;

import com.mongodb.MongoClientOptions.Builder;

import com.mongodb.WriteConcern;

import com.mongodb.client.MongoCollection;

import com.mongodb.client.MongoCursor;

import com.mongodb.client.MongoDatabase;

import com.mongodb.client.MongoIterable;

import com.mongodb.client.model.Filters;

import com.mongodb.client.result.DeleteResult;

/**

* MongoDB工具類 Mongo實例代表了一個數據庫連接池，即使在多線程的環境中，一個Mongo實例對我們來說已經足夠了

* 注意Mongo已經實現了連接池，并且是線程安全的。

* 設計為單例模式， 因 MongoDB的Java驅動是線程安全的，對于一般的應用，只要一個Mongo實例即可，

* Mongo有個內置的連接池(默認為10個) 對于有大量寫和讀的環境中，為了確保在一個Session中使用同一個DB時，

* DB和DBCollection是絕對線程安全的

*

* @author zhoulingfei

* @date 2015-5-29 上午11:49:49

* @version 0.0.0

* @Copyright (c)1997-2015 NavInfo Co.Ltd. All Rights Reserved.

*/

public enum MongoDBUtil {

/**

* 定義一個枚舉的元素，它代表此類的一個實例

*/

instance;

private MongoClient mongoClient;

static {

System.out.println("===============MongoDBUtil初始化========================");

CompositeConfiguration config = new CompositeConfiguration();

try {

config.addConfiguration(new PropertiesConfiguration("mongodb.properties"));

} catch (ConfigurationException e) {

e.printStackTrace();

}

// 從配置文件中獲取屬性值

String ip = config.getString("host");

int port = config.getInt("port");

instance.mongoClient = new MongoClient(ip, port);

// or, to connect to a replica set, with auto-discovery of the primary, supply a seed list of members

// List listHost = Arrays.asList(new ServerAddress("localhost", 27017),new ServerAddress("localhost", 27018));

// instance.mongoClient = new MongoClient(listHost);

// 大部分用戶使用mongodb都在安全內網下，但如果將mongodb設為安全驗證模式，就需要在客戶端提供用戶名和密碼：

// boolean auth = db.authenticate(myUserName, myPassword);

Builder options = new MongoClientOptions.Builder();

// options.autoConnectRetry(true);// 自動重連true

// options.maxAutoConnectRetryTime(10); // the maximum auto connect retry time

options.connectionsPerHost(300);// 連接池設置為300個連接,默認為100

options.connectTimeout(15000);// 連接超時，推薦>3000毫秒

options.maxWaitTime(5000); //

options.socketTimeout(0);// 套接字超時時間，0無限制

options.threadsAllowedToBlockForConnectionMultiplier(5000);// 線程隊列數，如果連接線程排滿了隊列就會拋出“Out of semaphores to get db”錯誤。

options.writeConcern(WriteConcern.SAFE);//

options.build();

}

// ------------------------------------共用方法---------------------------------------------------

/**

* 獲取DB實例 - 指定DB

*

* @param dbName

* @return

*/

public MongoDatabase getDB(String dbName) {

if (dbName != null && !"".equals(dbName)) {

MongoDatabase database = mongoClient.getDatabase(dbName);

return database;

}

return null;

}

/**

* 獲取collection對象 - 指定Collection

*

* @param collName

* @return

*/

public MongoCollection getCollection(String dbName, String collName) {

if (null == collName || "".equals(collName)) {

return null;

}

if (null == dbName || "".equals(dbName)) {

return null;

}

MongoCollection collection = mongoClient.getDatabase(dbName).getCollection(collName);

return collection;

}

/**

* 查詢DB下的所有表名

*/

public List getAllCollections(String dbName) {

MongoIterable colls = getDB(dbName).listCollectionNames();

List _list = new ArrayList();

for (String s : colls) {

_list.add(s);

}

return _list;

}

/**

* 獲取所有數據庫名稱列表

*

* @return

*/

public MongoIterable getAllDBNames() {

MongoIterable s = mongoClient.listDatabaseNames();

return s;

}

/**

* 刪除一個數據庫

*/

public void dropDB(String dbName) {

getDB(dbName).drop();

}

/**

* 查找對象 - 根據主鍵_id

*

* @param collection

* @param id

* @return

*/

public Document findById(MongoCollection coll, String id) {

ObjectId _idobj = null;

try {

_idobj = new ObjectId(id);

} catch (Exception e) {

return null;

}

Document myDoc = coll.find(Filters.eq("_id", _idobj)).first();

return myDoc;

}

/** 統計數 */

public int getCount(MongoCollection coll) {

int count = (int) coll.count();

return count;

}

/** 條件查詢 */

public MongoCursor find(MongoCollection coll, Bson filter) {

return coll.find(filter).iterator();

}

/** 分頁查詢 */

public MongoCursor findByPage(MongoCollection coll, Bson filter, int pageNo, int pageSize) {

Bson orderBy = new BasicDBObject("_id", 1);

return coll.find(filter).sort(orderBy).skip((pageNo - 1) * pageSize).limit(pageSize).iterator();

}

/**

* 通過ID刪除

*

* @param coll

* @param id

* @return

*/

public int deleteById(MongoCollection coll, String id) {

int count = 0;

ObjectId _id = null;

try {

_id = new ObjectId(id);

} catch (Exception e) {

return 0;

}

Bson filter = Filters.eq("_id", _id);

DeleteResult deleteResult = coll.deleteOne(filter);

count = (int) deleteResult.getDeletedCount();

return count;

}

/**

* FIXME

*

* @param coll

* @param id

* @param newdoc

* @return

*/

public Document updateById(MongoCollection coll, String id, Document newdoc) {

ObjectId _idobj = null;

try {

_idobj = new ObjectId(id);

} catch (Exception e) {

return null;

}

Bson filter = Filters.eq("_id", _idobj);

// coll.replaceOne(filter, newdoc); // 完全替代

coll.updateOne(filter, new Document("$set", newdoc));

return newdoc;

}

public void dropCollection(String dbName, String collName) {

getDB(dbName).getCollection(collName).drop();

}

/**

* 關閉Mongodb

*/

public void close() {

if (mongoClient != null) {

mongoClient.close();

mongoClient = null;

}

}

/**

* 測試入口

*

* @param args

*/

public static void main(String[] args) {

String dbName = "GC_MAP_DISPLAY_DB";

String collName = "COMMUNITY_BJ";

MongoCollection coll = MongoDBUtil.instance.getCollection(dbName, collName);

// 插入多條

// for (int i = 1; i <= 4; i++) {

// Document doc = new Document();

// doc.put("name", "zhoulf");

// doc.put("school", "NEFU" + i);

// Document interests = new Document();

// interests.put("game", "game" + i);

// interests.put("ball", "ball" + i);

// doc.put("interests", interests);

// coll.insertOne(doc);

// }

// // 根據ID查詢

// String id = "556925f34711371df0ddfd4b";

// Document doc = MongoDBUtil2.instance.findById(coll, id);

// System.out.println(doc);

// 查詢多個

// MongoCursor cursor1 = coll.find(Filters.eq("name", "zhoulf")).iterator();

// while (cursor1.hasNext()) {

// org.bson.Document _doc = (Document) cursor1.next();

// System.out.println(_doc.toString());

// }

// cursor1.close();

// 查詢多個

// MongoCursor cursor2 = coll.find(Person.class).iterator();

// 刪除數據庫

// MongoDBUtil2.instance.dropDB("testdb");

// 刪除表

// MongoDBUtil2.instance.dropCollection(dbName, collName);

// 修改數據

// String id = "556949504711371c60601b5a";

// Document newdoc = new Document();

// newdoc.put("name", "時候");

// MongoDBUtil.instance.updateById(coll, id, newdoc);

// 統計表

// System.out.println(MongoDBUtil.instance.getCount(coll));

// 查詢所有

Bson filter = Filters.eq("count", 0);

MongoDBUtil.instance.find(coll, filter);

}

}

也請多提寶貴意見和建議。0b1331709591d260c1c78e86d0c51c18.png

本文來自互聯網用戶投稿，該文觀點僅代表作者本人，不代表本站立場。本站僅提供信息存儲空間服務，不擁有所有權，不承擔相關法律責任。
如若轉載，請注明出處：http://www.pswp.cn/news/539572.shtml
繁體地址，請注明出處：http://hk.pswp.cn/news/539572.shtml
英文地址，請注明出處：http://en.pswp.cn/news/539572.shtml

如若內容造成侵權/違法違規/事實不符，請聯系多彩編程網進行投訴反饋email:809451989@qq.com，一經查實，立即刪除！

相關文章

Spring IOC容器-注解的方式

Spring IOC容器-注解的方式

注解方式可以簡化spring的IOC容器的配置&#xff0c;但不利于后期維護&#xff0c;對象之間的依賴關系不能像xml文件一樣方便查閱&#xff0c;一目了然。 注解可以和XML配置一起使用。 使用注解步驟&#xff1a; 1&#xff09;先引入context名稱空間 xmlns:context"htt…
閱讀更多...
前端請求進化之路--從form表單到JSONP

前端請求進化之路--從form表單到JSONP

簡單梳理前端請求的變遷史&#xff0c;著重對JSONP進行整理 請求演變 使用form表單提交請求&#xff0c;缺點是每次提交必定會刷新頁面在1基礎之上使用iframe進行局部刷新&#xff0c;用戶體驗得到一定優化動態創建圖片提交請求 注意請求與返回內容類型須一致每次必須返回圖片較…
閱讀更多...
Spring IOC容器-注解的方式【更簡化】

Spring IOC容器-注解的方式【更簡化】

----更加簡化的版本 UserAction.java import javax.annotation.Resource;import org.springframework.stereotype.Component; import org.springframework.stereotype.Controller;//Component("userAction") // 加入IOC容器//ComponentController // 控制層的組件…
閱讀更多...
hive安裝mysql驅動_Hadoop-2.6.0為基礎的Hive安裝

hive安裝mysql驅動_Hadoop-2.6.0為基礎的Hive安裝

Hive安裝軟件需求與環境說明假設已經搭建好 Hadoop-2.6.0 環境&#xff0c;并能正常運行mysql 安裝軟件服務端&#xff1a;MySQL-server-5.5.16-1.rhel5.x86_64.rpm客戶端&#xff1a;MySQL-client-5.5.16-1.rhel5.x86_64.rpmhive安裝軟件&#xff1a;apache-hive-1.2.1-bin.ta…
閱讀更多...
視頻通信原理——NAT介紹

視頻通信原理——NAT介紹

一&#xff1a;為什么需要NAT由于IP地址隨著互聯網的發展而逐漸稀缺&#xff0c;難以使得每臺主機都擁有一個公網上的IP地址&#xff0c;且并不是所有主機都需要一個公網上的地址&#xff0c;于是就有了NAT技術。NAT&#xff08;The IP Network Address Translator&#xff09;…
閱讀更多...
Oracle中執行存儲過程call和exec區別

Oracle中執行存儲過程call和exec區別

在sqlplus中這兩種方法都可以使用&#xff1a; exec pro_name(參數1..); call pro_name(參數1..); 區別&#xff1a; 1. 但是exec是sqlplus命令&#xff0c;只能在sqlplus中使用&#xff1b;call為SQL命令&#xff0c;沒有限制. 2. 存儲過程沒有參數時,exec可以直接跟過…
閱讀更多...
java和cnc_Java程序員的目標，你都達到了多少條？

java和cnc_Java程序員的目標，你都達到了多少條？

該樓層疑似違規已被系統折疊 隱藏此樓查看此樓7.你需要學習Servlets&#xff0c;JSP&#xff0c;以及JSTL(StandardTagLibraries)和可以選擇的第三方TagLibraries。8.你需要熟悉主流的網頁框架&#xff0c;例如JSF&#xff0c;Struts&#xff0c;Tapestry&#xff0c;Cocoon&am…
閱讀更多...
每秒處理10萬訂單樂視集團支付架構

每秒處理10萬訂單樂視集團支付架構

原文&#xff1a;http://www.iteye.com/news/31550 ----------- 隨著樂視硬件搶購的不斷升級&#xff0c;樂視集團支付面臨的請求壓力百倍乃至千倍的暴增。作為商品購買的最后一環&#xff0c;保證用戶快速穩定的完成支付尤為重要。所以在15年11月&#xff0c;我們對整個支付…
閱讀更多...
X--名稱空間詳解

X--名稱空間詳解

轉自:http://blog.csdn.net/lisenyang/article/details/18312039 X名稱空間里面的成員(如X:Name,X:Class)都是寫給XAML編譯器看的、用來引導XAML代碼將XAML代碼編譯為CLR代碼。 4.1X名稱空間里面到底都有些什么&#xff1f; x名稱空間映射的是:http://schemas.microsoft.com/wi…
閱讀更多...
事物 php,什么是php事務

事物 php,什么是php事務

事務&#xff1a;用于保證數據的一致性&#xff0c;他由一組相關的dml語句組成&#xff0c;改組的dml語句要么全部成功&#xff0c;要么全部失敗。當前版本的插件并不是事務安全的&#xff0c;因為他并沒有識別全部的事務操作。SQL 事務單元是在單一服務器中運行的。插件并不能…
閱讀更多...
那些年，在nodejs上踩過的坑

那些年，在nodejs上踩過的坑

原文&#xff1a;http://cnodejs.org/topic/4fc7789a8be5d070121141cd ----------------------------------------------------------- 自己寫nodejs也有一段時間&#xff0c;踩過很多坑&#xff08;而且大部分是自己給自己埋&#xff09;&#xff0c;也見過很多別人踩過的坑&…
閱讀更多...
Flask form(登錄，注冊)

Flask form(登錄，注冊)

用戶登錄 from flask import Flask, render_template, request, redirect from wtforms import Form from wtforms.fields import core from wtforms.fields import html5 from wtforms.fields import simple from wtforms import validators from wtforms import widgetsapp …
閱讀更多...
substr php,PHP substr() 函數

substr php,PHP substr() 函數

更多實例例子 1使用帶有不同正負數的 start 參數&#xff1a;<?phpecho substr("Hello world",10)."";echo substr("Hello world",1)."";echo substr("Hello world",3)."";echo substr("Hello world&quo…
閱讀更多...
怎么看so文件是哪個aar引進來的_手機愛奇藝下載視頻存在哪個文件夾

怎么看so文件是哪個aar引進來的_手機愛奇藝下載視頻存在哪個文件夾

我們很多朋友喜歡看視頻使用愛奇藝觀看&#xff0c;并且喜歡直接把視頻緩沖到手機里&#xff0c;或是直接下載視頻文件&#xff0c;但是經常不知道手機愛奇藝下載視頻存在哪個文件夾&#xff0c;不知道怎么分享給好友或是傳到電腦上&#xff0c;下面就來簡單介紹一下。手機愛奇…
閱讀更多...
Node.js 異步編程之 Callback介紹

Node.js 異步編程之 Callback介紹

原文&#xff1a;http://www.jb51.net/article/63070.htm ------------------------------------- Node.js 基于 JavaScript 引擎 v8&#xff0c;是單線程的。Node.js 采用了與通常 Web 上的 JavaScript 異步編程的方式來處理會造成阻塞的I/O操作。在 Node.js 中讀取文件、訪問…
閱讀更多...
php雙向鏈表+性能,PHP雙向鏈表定義與用法示例

php雙向鏈表+性能,PHP雙向鏈表定義與用法示例

本文實例講述了PHP雙向鏈表定義與用法。分享給大家供大家參考&#xff0c;具體如下&#xff1a;由于需要對一組數據多次進行移動操作&#xff0c;所以寫個雙向鏈表。但對php實在不熟悉&#xff0c;雖然測試各個方法沒啥問題&#xff0c;就是不知道php語言深層的這些指針和unset…
閱讀更多...
反擊爬蟲，前端工程師的腦洞可以有多大？

反擊爬蟲，前端工程師的腦洞可以有多大？

對于一張網頁&#xff0c;我們往往希望它是結構良好&#xff0c;內容清晰的&#xff0c;這樣搜索引擎才能準確地認知它。 而反過來&#xff0c;又有一些情景&#xff0c;我們不希望內容能被輕易獲取&#xff0c; 前言 比方說電商網站的交易額&#xff0c;教育網站的題目等。因為…
閱讀更多...
Spring與Struts框架整合

Spring與Struts框架整合

Spring&#xff0c;負責對象對象創建 Struts&#xff0c;用Action處理請求 Spring與Struts框架整合&#xff0c;關鍵點&#xff1a;讓struts框架action對象的創建&#xff0c;交給spring完成&#xff01; 1.步驟&#xff1a; 引入jar文件 1&#xff09;引入struts .jar相關文件…
閱讀更多...
esxi能直通的顯卡型號_顯卡刷bios教程

esxi能直通的顯卡型號_顯卡刷bios教程

一般來說顯卡默認的出廠bios就已經很穩定&#xff0c;如果沒有特殊情況下建議不要刷顯卡bios。一般而言部分網友刷顯卡BIOS目的是開核或超頻&#xff0c;那么對于一個不會刷顯卡bios的網友來說肯定會問顯卡怎么刷bios類似的問題&#xff0c;那么本文這里就說一下有關顯卡怎么刷…
閱讀更多...
關于Linux網卡調優之：RPS (Receive Packet Steering)

關于Linux網卡調優之：RPS (Receive Packet Steering)

昨天在查LVS調度均衡性問題時&#xff0c;最終確定是 persistence_timeout 參數會使用IP哈希。目的是為了保證長連接&#xff0c;即一定時間內訪問到的是同一臺機器。而我們內部系統&#xff0c;由于出口IP相對單一&#xff0c;所以總會被哈希到相同的RealServer。 過去使用LVS…
閱讀更多...
最新文章

Copyright @ 2022~2023