本篇文章给大家分享的是有关mongoDB中怎么封装一个操作类,小编觉得挺实用的,因此分享给大家学习,希望大家阅读完这篇文章后可以有所收获,话不多说,跟着小编一起来看看吧。MongoDB操作类封装monGob
本篇文章给大家分享的是有关mongoDB中怎么封装一个操作类,小编觉得挺实用的,因此分享给大家学习,希望大家阅读完这篇文章后可以有所收获,话不多说,跟着小编一起来看看吧。
MongoDB操作类封装
monGobase代码如下:
package com.fun.mongodb;
import com.fun.frame.SourceCode;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import java.util.Arrays;
import java.util.List;
public class MongoBase extends SourceCode {
public static List<ServerAddress> getServers(ServerAddress... addresses) {
return Arrays.asList(addresses);
}
public static ServerAddress getServerAdress(String host, int port) {
return new ServerAddress(host, port);
}
public static List<MongoCredential> getCredentials(MongoCredential... credentials) {
return Arrays.asList(credentials);
}
public static MongoCredential getMongoCredential(String userName, String database, String passWord) {
return MongoCredential.createCredential(userName, database, password.toCharArray());
}
public static MongoClient getMongoClient(List<ServerAddress> addresses, List<MongoCredential> credentials) {
return new MongoClient(addresses, credentials);
}
public static MongoDatabase getMongoDatabase(MongoClient mongoClient, String databaseName) {
return mongoClient.getDatabase(databaseName);
}
public static MongoCollection<Document> getMongoCollection(MongoDatabase mongoDatabase, String collectionName) {
return mongoDatabase.getCollection(collectionName);
}
public static void MongoOver(MongoClient mongoClient) {
mongoClient.close();
}
public static MongoClient getMongoClient(MongoObject mongoObject) {
MongoClient mongoClient = new MongoClient(getServers(getServerAdress(mongoObject.host, mongoObject.port)), getCredentials(getMongoCredential(mongoObject.user, mongoObject.database, mongoObject.password)));
return mongoClient;
}
public static MongoClient getMongoClientOnline(MongoObject mongoObject) {
String fORMat = String.format("mongodb://%s:%s@%s:%d/%s", mongoObject.user, mongoObject.password, mongoObject.host, mongoObject.port, mongoObject.database);
return new MongoClient(new MongoClientURI(format));
}
public static MongoCollection<Document> getCollection(MongoObject mongoObject, String collectionName) {
return getMongoClient(mongoObject).getDatabase(mongoObject.database).getCollection(collectionName);
}
public static MongoCollection<Document> getCollectionOnline(MongoObject mongoObject, String collectionName) {
return getMongoClientOnline(mongoObject).getDatabase(mongoObject.database).getCollection(collectionName);
}
}
mongoobject的代码如下:
package com.fun.mongodb;
import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import org.bson.Document;
public class MongoObject extends MongoBase {
String host;
int port;
String user;
String password;
String database;
MongoClient mongoClient;
public MongoObject(String host, int port, String user, String password, String database) {
this.host = host;
this.port = port;
this.user = user;
this.password = password;
this.database = database;
this.mongoClient = getMongoClient(this);
}
public MongoObject(int port, String host, String user, String password, String database) {
this.host = host;
this.port = port;
this.user = user;
this.password = password;
this.database = database;
this.mongoClient = getMongoClientOnline(this);
}
public MongoCollection<Document> getMongoCollection(String collectionName) {
MongoClient mongoClientOnline = getMongoClientOnline(this);
return mongoClientOnline.getDatabase(database).getCollection(collectionName);
}
public void over() {
MongoOver(this.mongoClient);
}
}
@Override
public MongoObject clone() {
return new MongoObject(this.host, this.port, this.user, this.password, this.database);
}
public MongoObject clone2() {
return new MongoObject(this.port, this.host, this.user, this.password, this.database);
}
具体效果非常不错,测试代码如下:
public static void main(String[] args) {
MongoObject ready = new MongoObject("*****", 5117, "fission_record", "fission_record", "fission_record");
MongoCollection<Document> app = ready.getMongoCollection("app_logs_20181109");
Document first = app.find().first();
output(first);
ready.over();
}
打印内容如下:
Document{{_id=5be4ce052ce01b21b6c26a64, _class=com.fission.next.record.bean.AppRecordBean, user_id=5482, action_type={"gameId":2,"userId":"5482"}, action_extern=DataSta_Game_Starts, client_version=15, client_ip=114.5.146.239, client_imei=UNKNOWN, client_dev=xiaomi-Redmi 5 Plus, client_type=200, server_time=1541721601655, os_name=200, os_version=15, client_time=1541721577025}}
以上就是MongoDB中怎么封装一个操作类,小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注编程网数据库频道。
--结束END--
本文标题: MongoDB中怎么封装一个操作类
本文链接: https://www.lsjlt.com/news/56581.html(转载时请注明来源链接)
有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
下载Word文档到电脑,方便收藏和打印~
2024-05-14
2024-05-14
2024-05-14
2024-05-14
2024-05-14
2024-05-14
2024-05-14
2024-05-14
2024-05-14
2024-05-14
回答
回答
回答
回答
回答
回答
回答
回答
回答
回答
0