cn.hutool.db.nosql.mongo

Class MongoDS

java.lang.Object

cn.hutool.db.nosql.mongo.MongoDS

All Implemented Interfaces:

Closeable, AutoCloseable

public class MongoDS
extends Object
implements Closeable

MongoDB4工具类

Author:

VampireAchao

Field Summary

Fields

Modifier and Type	Field and Description
static String	MONGO_CONFIG_PATH 默认配置文件

Constructor Summary

Constructors

Constructor and Description
MongoDS(Setting mongoSetting, String... groups) 构造MongoDB数据源 当提供多个数据源时，这些数据源将为一个副本集或者mongos 调用者必须持有MongoDS实例，否则会被垃圾回收导致写入失败！
MongoDS(Setting mongoSetting, String host, int port) 构造MongoDB数据源 调用者必须持有MongoDS实例，否则会被垃圾回收导致写入失败！
MongoDS(String... groups) 构造MongoDB数据源 当提供多个数据源时，这些数据源将为一个副本集或者多个mongos 调用者必须持有MongoDS实例，否则会被垃圾回收导致写入失败！
MongoDS(String host, int port) 构造MongoDB数据源 调用者必须持有MongoDS实例，否则会被垃圾回收导致写入失败！

Method Summary

Modifier and Type	Method and Description
void	close()
com.mongodb.client.MongoCollection<org.bson.Document>	getCollection(String dbName, String collectionName) 获得MongoDB中指定集合对象
com.mongodb.client.MongoDatabase	getDb(String dbName) 获得DB
com.mongodb.client.MongoClient	getMongo()
void	init() 初始化，当给定分组数大于一个时使用
void	initCloud() 初始化集群 集群的其它客户端设定参数使用全局设定 集群中每一个实例成员用一个group表示，例如： user = test1 pass = 123456 database = test [db0] host = 192.168.1.1:27117 [db1] host = 192.168.1.1:27118 [db2] host = 192.168.1.1:27119
void	initSingle() 初始化 设定文件中的host和端口有三种形式： host = host:port host = host port = port host = host
void	setSetting(Setting setting) 设定MongoDB配置文件

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MONGO_CONFIG_PATH

public static final String MONGO_CONFIG_PATH

默认配置文件

See Also:

Constant Field Values

Constructor Detail

MongoDS

public MongoDS(String host,
               int port)

构造MongoDB数据源
调用者必须持有MongoDS实例，否则会被垃圾回收导致写入失败！

Parameters:

host - 主机（域名或者IP）

port - 端口

MongoDS

public MongoDS(Setting mongoSetting,
               String host,
               int port)

构造MongoDB数据源
调用者必须持有MongoDS实例，否则会被垃圾回收导致写入失败！

Parameters:

mongoSetting - MongoDB的配置文件，如果是null则读取默认配置文件或者使用MongoDB默认客户端配置

host - 主机（域名或者IP）

port - 端口

MongoDS

public MongoDS(String... groups)

构造MongoDB数据源
当提供多个数据源时，这些数据源将为一个副本集或者多个mongos
调用者必须持有MongoDS实例，否则会被垃圾回收导致写入失败！ 官方文档： http://docs.mongodb.org/manual/administration/replica-sets/

Parameters:

groups - 分组列表，当为null或空时使用无分组配置，一个分组使用单一模式，否则使用副本集模式

MongoDS

public MongoDS(Setting mongoSetting,
               String... groups)

构造MongoDB数据源
当提供多个数据源时，这些数据源将为一个副本集或者mongos
调用者必须持有MongoDS实例，否则会被垃圾回收导致写入失败！
官方文档： http://docs.mongodb.org/manual/administration/replica-sets/

Parameters:

mongoSetting - MongoDB的配置文件，必须有

groups - 分组列表，当为null或空时使用无分组配置，一个分组使用单一模式，否则使用副本集模式

Method Detail

init

public void init()

初始化，当给定分组数大于一个时使用

initSingle

public void initSingle()

初始化
设定文件中的host和端口有三种形式：

 host = host:port
 

 host = host
 port = port
 

 host = host
 

initCloud

public void initCloud()

初始化集群
集群的其它客户端设定参数使用全局设定
集群中每一个实例成员用一个group表示，例如：

 user = test1
 pass = 123456
 database = test
 [db0]
 host = 192.168.1.1:27117
 [db1]
 host = 192.168.1.1:27118
 [db2]
 host = 192.168.1.1:27119
 

setSetting

public void setSetting(Setting setting)

设定MongoDB配置文件

Parameters:

setting - 配置文件

getMongo

public com.mongodb.client.MongoClient getMongo()

Returns:

获得MongoDB客户端对象

getDb

public com.mongodb.client.MongoDatabase getDb(String dbName)

获得DB

Parameters:

dbName - DB

Returns:

DB

getCollection

public com.mongodb.client.MongoCollection<org.bson.Document> getCollection(String dbName,
                                                                           String collectionName)

获得MongoDB中指定集合对象

Parameters:

dbName - 库名

collectionName - 集合名

Returns:

DBCollection

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable