com.sh.javax.mongodb

类 MongoHelper

java.lang.Object

com.sh.javax.mongodb.MongoHelper

public class MongoHelper
extends java.lang.Object

Description:

Title:首亨软件 - TSS/CRM等

从以下版本开始:

2018年6月29日

版本:

3.0

作者:

江兴春

方法概要

限定符和类型	方法和说明
void	closeMongoClient(com.mongodb.client.MongoDatabase mongoDataBase, com.mongodb.client.MongoClient mongoClient) 关闭连接
java.lang.String	createGeoIndex(com.mongodb.client.MongoDatabase db, java.lang.String table, java.lang.String field) 创建GEO索引
long	deleteMany(com.mongodb.client.MongoDatabase db, java.lang.String table, com.mongodb.BasicDBObject document) 删除多条记录
long	deleteOne(com.mongodb.client.MongoDatabase db, java.lang.String table, com.mongodb.BasicDBObject document) 删除一条记录
org.bson.Document	geoNear(com.mongodb.client.MongoDatabase db, java.lang.String table, double maxDistance, double centerLon, double centerLat) 地理位置搜索功能
static MongoHelper	getInstance()
com.mongodb.client.MongoClient	getMongoClient(java.lang.String url)
com.sh.javax.mongodb.MongoDBConnInfo	getMongoDBConnInfo(java.lang.String url)
boolean	hasIndexByName(com.mongodb.client.MongoDatabase db, java.lang.String table, java.lang.String indexName) 判断索引是否存在
boolean	insertMany(com.mongodb.client.MongoDatabase db, java.lang.String table, java.util.List<org.bson.Document> documents) 插入多条记录
boolean	insertOne(com.mongodb.client.MongoDatabase db, java.lang.String table, org.bson.Document document) 插入一条记录
com.mongodb.client.MongoCursor<org.bson.Document>	queryByDoc(com.mongodb.client.MongoDatabase db, java.lang.String table, com.mongodb.BasicDBObject doc) 根据一个doc，来检索，当doc是空的时候检索全部
com.mongodb.client.MongoCursor<org.bson.Document>	queryById(com.mongodb.client.MongoDatabase db, java.lang.String table, java.lang.String id) 按主键查询
long	updateMany(com.mongodb.client.MongoDatabase db, java.lang.String table, com.mongodb.BasicDBObject whereDoc, com.mongodb.BasicDBObject updateDoc) 更新多条记录
long	updateOne(com.mongodb.client.MongoDatabase db, java.lang.String table, com.mongodb.BasicDBObject whereDoc, com.mongodb.BasicDBObject updateDoc) 更新一条记录

从类继承的方法 java.lang.Object

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

方法详细资料

getInstance

public static MongoHelper getInstance()

getMongoDBConnInfo

public com.sh.javax.mongodb.MongoDBConnInfo getMongoDBConnInfo(java.lang.String url)

getMongoClient

public com.mongodb.client.MongoClient getMongoClient(java.lang.String url)

queryById

public com.mongodb.client.MongoCursor<org.bson.Document> queryById(com.mongodb.client.MongoDatabase db,
                                                                   java.lang.String table,
                                                                   java.lang.String id)
                                                            throws java.lang.Exception

按主键查询

参数:

db - 数据库实例

table - 表名

id - 主键值

返回:

MongoCursor

抛出:

java.lang.Exception - 异常信息

queryByDoc

public com.mongodb.client.MongoCursor<org.bson.Document> queryByDoc(com.mongodb.client.MongoDatabase db,
                                                                    java.lang.String table,
                                                                    com.mongodb.BasicDBObject doc)

根据一个doc，来检索，当doc是空的时候检索全部

参数:

db - MongoDatabase数据库

table - 表

doc - BasicDBObject

返回:

MongoCursor

insertOne

public boolean insertOne(com.mongodb.client.MongoDatabase db,
                         java.lang.String table,
                         org.bson.Document document)

插入一条记录

参数:

db - MongoDatabase

table - 表

document - Document

返回:

是否成功

insertMany

public boolean insertMany(com.mongodb.client.MongoDatabase db,
                          java.lang.String table,
                          java.util.List<org.bson.Document> documents)

插入多条记录

参数:

db - MongoDatabase

table - 表名

documents - Document

返回:

是否成功

deleteOne

public long deleteOne(com.mongodb.client.MongoDatabase db,
                      java.lang.String table,
                      com.mongodb.BasicDBObject document)

删除一条记录

参数:

db - MongoDatabase

table - 表名

document - BasicDBObject

返回:

删除数量

deleteMany

public long deleteMany(com.mongodb.client.MongoDatabase db,
                       java.lang.String table,
                       com.mongodb.BasicDBObject document)

删除多条记录

参数:

db - MongoDatabase

table - 表

document - BasicDBObject

返回:

删除数量

updateOne

public long updateOne(com.mongodb.client.MongoDatabase db,
                      java.lang.String table,
                      com.mongodb.BasicDBObject whereDoc,
                      com.mongodb.BasicDBObject updateDoc)

更新一条记录

参数:

db - MongoDatabase

table - 表

whereDoc - BasicDBObject

updateDoc - BasicDBObject

返回:

更新数量

updateMany

public long updateMany(com.mongodb.client.MongoDatabase db,
                       java.lang.String table,
                       com.mongodb.BasicDBObject whereDoc,
                       com.mongodb.BasicDBObject updateDoc)

更新多条记录

参数:

db - MongoDatabase

table - 表

whereDoc - BasicDBObject

updateDoc - BasicDBObject

返回:

更新数量

hasIndexByName

public boolean hasIndexByName(com.mongodb.client.MongoDatabase db,
                              java.lang.String table,
                              java.lang.String indexName)

判断索引是否存在

参数:

db - MongoDatabase

table - 表

indexName - 索引名

返回:

是否成功

createGeoIndex

public java.lang.String createGeoIndex(com.mongodb.client.MongoDatabase db,
                                       java.lang.String table,
                                       java.lang.String field)

创建GEO索引

参数:

db - MongoDatabase

table - 表

field - 字段名

返回:

结果

geoNear

public org.bson.Document geoNear(com.mongodb.client.MongoDatabase db,
                                 java.lang.String table,
                                 double maxDistance,
                                 double centerLon,
                                 double centerLat)

地理位置搜索功能

参数:

db - MongoDatabase

table - 表

maxDistance - 判断距离

centerLon - 经度

centerLat - 纬度 需要创建 索引 db.sysUser.createIndex({loc: "2dsphere"})

返回:

Document

closeMongoClient

public void closeMongoClient(com.mongodb.client.MongoDatabase mongoDataBase,
                             com.mongodb.client.MongoClient mongoClient)

关闭连接

参数:

mongoDataBase - MongoDatabase

mongoClient - MongoClient