本文實作一個通用泛型封裝實作類，需要給定一個集合對象，類似mysql中與java對應的表；思想就是把給定的對象解析出所有非空字段，保存到一個BasicDBObject中，這裡一定要保證java物件與mongodb中的文件欄位名字一樣，因為程式碼為了實現通用，就是預設以java物件的欄位為BasicDBObject的查詢欄位。
核心程式碼1：這是將java物件轉換為查詢條件。
/**
* 通过反射获取非空字段信息
* @param record
* @param <Q>
* @return
*/
private <Q> BasicDBObject getCondition(Q record) {
BasicDBObject cond = new BasicDBObject();
Class clazz = record.getClass();
Field[] fields = clazz.getDeclaredFields();
for (Field field : fields) {
try {
field.setAccessible(true);
Object value = field.get(record);
if (value != null)
cond.put(field.getName(), value);
} catch (IllegalAccessException e) {
e.printStackTrace();
}
}
return cond;
}核心程式碼2：這是將查詢到的文檔轉換為java對象，這裡也是預設java對象的字段和資料庫文檔字段一樣，也是利用java的反射動態獲取用戶自訂對象的所有字段，然後進行賦值，我在賦值過程中單獨判斷了int和long型，因為插入mongodb的時候一般是以double存的，這樣就會造成轉型錯誤。
/**
* 将结果转化为自定义对象
* @param document
* @param target
* @param <Q>
* @return
*/
private <Q> Q parseToObject(Document document, Class<Q> target) {
try {
Q result = target.newInstance();
Field[] fields = target.getDeclaredFields();
for (Field f : fields) {
f.setAccessible(true);
Object value = document.get(f.getName());
if (value == null)
continue;
else if (f.getType() == Integer.class)
f.set(result, ((Number) value).intValue());
else if (f.getType() == Long.class)
f.set(result, ((Number) value).longValue());
else
f.set(result, document.get(f.getName(), f.getType()));
}
return result;
} catch (IllegalAccessException e) {
e.printStackTrace();
return null;
} catch (InstantiationException e) {
e.printStackTrace();
return null;
}
}呼叫方法：先轉換查詢參數，查詢的時候是以id來判斷正序倒序，所以預設資料庫中一定要有id的識別欄位。
public <Q> List<Q> queryByCondition(BaseQuery<Q> query,boolean up) {
Q record = query.getQuery();
BasicDBObject cond = getCondition(record);
FindIterable<Document> findIterable;
if (query.getStart() != null && query.getRows() != null)
findIterable = thisCollection().find(cond)
.sort(new BasicDBObject("id", up ? 1 : -1))
.skip((query.getStart() - 1) * query.getRows())
.limit(query.getRows());
else
findIterable = thisCollection().find(cond)
.sort(new BasicDBObject("id", up ? 1 : -1));
MongoCursor<Document> iterator = findIterable.iterator();
List<Q> result = new ArrayList<>();
while (iterator.hasNext()) {
Document document = iterator.next();
result.add((Q) parseToObject(document, record.getClass()));
}
iterator.close();
return result;
}這裡傳入的BaseQuery如下：裡面的query就是個需要查詢的java對象，start&rows是為了用來分頁的。這裡是用到了lombok的插件，這樣簡化很多的gettter&setter等程式碼。
@Setter
@Getter
@NoArgsConstructor
@AllArgsConstructor
@Data
@Accessors(chain = true)
public class BaseQuery<Q> {
private Integer start;
private Integer rows;
private Q query;
public BaseQuery(Class clazz) {
try {
this.query = (Q) clazz.newInstance();
} catch (InstantiationException e) {
e.printStackTrace();
} catch (IllegalAccessException e) {
e.printStackTrace();
}
}
}測試條件查詢方法：這裡用到的實體如下：
@Data
@AllArgsConstructor
@NoArgsConstructor
@Accessors(chain = true)
public class User_info {
private Integer id;
private String name;
private Integer age;
private Integer role;
}public static void main(String[] args) {
User_info record = new User_info();
BaseQuery<User_info> query = new BaseQuery<>();
query.setQuery(record);
BaseMongoDao dao = new BaseMongoDao("test");
List<User_info> result = dao.queryByCondition(query, true);
for (User_info user : result) {
System.out.println(user);
}
}#因為這裡用到的查詢條件為空，所有會符合資料庫的所有項目：
現在測試設定權限為1的資料：
public static void main(String[] args) {
User_info record = new User_info();
record.setRole(1);
BaseQuery<User_info> query = new BaseQuery<>();
query.setQuery(record);
BaseMongoDao dao = new BaseMongoDao("test");
List<User_info> result = dao.queryByCondition(query, true);
for (User_info user : result) {
System.out.println(user);
}
}輸出：
這個條件查詢方法就是一個例子，其他的刪除，增加，修改都是這個原理，下面帶有：
1.public List
queryByCondition(BaseQuery
query,boolean up)
2.public Integer queryCoditionCount(BaseQuery
query)
3.public boolean insertOne(Q record)
4.public booleanOne(Q record)
4.public boolean insertList(List
records)
5.public boolean deleteById(Integer id)
6.public boolean deleteByIds(List
7.public void updateById(Q record)
放上所有程式碼：
package cn.wzy.dao;
import com.mongodb.*;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import org.cn.wzy.query.BaseQuery;
import org.cn.wzy.util.PropertiesUtil;
import java.lang.reflect.Field;
import java.util.ArrayList;
import java.util.List;
/**
* Create by Wzy
* on 2018/7/28 18:15
* 不短不长八字刚好
*/
public class BaseMongoDao {
private static final MongoClient mongoClient;
private static final MongoDatabase mongo;
static {
MongoClientOptions options = MongoClientOptions.builder()
.connectionsPerHost(150)
.maxWaitTime(2000)
.socketTimeout(2000)
.maxConnectionLifeTime(5000)
.connectTimeout(5000).build();
ServerAddress serverAddress = new ServerAddress(PropertiesUtil.StringValue("mongo.host"),
PropertiesUtil.IntegerValue("mongo.port"));
List addrs = new ArrayList<>();
addrs.add(serverAddress);
MongoCredential credential = MongoCredential.createScramSha1Credential(
PropertiesUtil.StringValue("mongo.user")
, PropertiesUtil.StringValue("mongo.db")
, PropertiesUtil.StringValue("mongo.pwd").toCharArray());
mongoClient = new MongoClient(addrs, credential, options);
mongo = mongoClient.getDatabase(PropertiesUtil.StringValue("mongo.db"));
}
public BaseMongoDao(String colName) {
this.colName = colName;
}
private String colName;
private MongoCollection thisCollection() {
return mongo.getCollection(colName);
}
public <Q> List<Q> queryByCondition(BaseQuery<Q> query,boolean up) {
Q record = query.getQuery();
BasicDBObject cond = getCondition(record);
FindIterable<Document> findIterable;
if (query.getStart() != null && query.getRows() != null)
findIterable = thisCollection().find(cond)
.sort(new BasicDBObject("id", up ? 1 : -1))
.skip((query.getStart() - 1) * query.getRows())
.limit(query.getRows());
else
findIterable = thisCollection().find(cond)
.sort(new BasicDBObject("id", up ? 1 : -1));
MongoCursor<Document> iterator = findIterable.iterator();
List<Q> result = new ArrayList<>();
while (iterator.hasNext()) {
Document document = iterator.next();
result.add((Q) parseToObject(document, record.getClass()));
}
iterator.close();
return result;
}
public Integer queryCoditionCount(BaseQuery query) {
Q record = query.getQuery();
BasicDBObject cond = getCondition(record);
return (int) thisCollection().countDocuments(cond);
}
public boolean insertOne(Q record) {
BasicDBObject cond = getCondition(record);
try {
int top = getTop();
cond.put("id",++top);
thisCollection().insertOne(new Document(cond));
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
public boolean insertList(List records) {
try {
List list = new ArrayList<>(records.size());
if (!changeIds(records))
return false;
for (Q record : records) {
list.add(new Document(getCondition(record)));
}
thisCollection().insertMany(list);
return true;
}catch (Exception e) {
e.printStackTrace();
return false;
}
}
public boolean deleteById(Integer id) {
try {
if (id == null)
return false;
thisCollection().deleteOne(new BasicDBObject("id",id));
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
public boolean deleteByIds(List ids) {
BasicDBObject cond = new BasicDBObject("id",new BasicDBObject("$in",ids.toArray()));
try {
thisCollection().deleteMany(cond);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 只通过id更改，查询就只是搜索id
* @param record
* @param
*/
public void updateById(Q record) {
BasicDBObject cond = getCondition(record);
BasicDBObject update = new BasicDBObject("$set",cond);
BasicDBObject query = new BasicDBObject("id",cond.get("id"));
thisCollection().updateOne(query,update);
}
/**
* 通过反射获取非空字段信息
* @param record
* @param <Q>
* @return
*/
private <Q> BasicDBObject getCondition(Q record) {
BasicDBObject cond = new BasicDBObject();
Class clazz = record.getClass();
Field[] fields = clazz.getDeclaredFields();
for (Field field : fields) {
try {
field.setAccessible(true);
Object value = field.get(record);
if (value != null)
cond.put(field.getName(), value);
} catch (IllegalAccessException e) {
e.printStackTrace();
}
}
return cond;
}
/**
* 将结果转化为自定义对象
* @param document
* @param target
* @param <Q>
* @return
*/
private <Q> Q parseToObject(Document document, Class<Q> target) {
try {
Q result = target.newInstance();
Field[] fields = target.getDeclaredFields();
for (Field f : fields) {
f.setAccessible(true);
Object value = document.get(f.getName());
if (value == null)
continue;
else if (f.getType() == Integer.class)
f.set(result, ((Number) value).intValue());
else if (f.getType() == Long.class)
f.set(result, ((Number) value).longValue());
else
f.set(result, document.get(f.getName(), f.getType()));
}
return result;
} catch (IllegalAccessException e) {
e.printStackTrace();
return null;
} catch (InstantiationException e) {
e.printStackTrace();
return null;
}
}
/**
* 使id自增
* @param records
* @param
* @return
*/
private boolean changeIds(List records) {
if (records == null || records.size() == 0)
return false;
Class clazz = records.get(0).getClass();
try {
Field id = clazz.getDeclaredField("id");
id.setAccessible(true);
int top = getTop();
for (Q record: records) {
id.set(record,++top);
}
} catch (NoSuchFieldException e) {
e.printStackTrace();
return false;
} catch (IllegalAccessException e) {
e.printStackTrace();
return false;
}
return true;
}
/**
* 查找顶针
* @return
*/
private int getTop() {
return ((Number) thisCollection().find().sort(new BasicDBObject("id",-1)).first().get("id")).intValue();
}
}
相關影片：以上是java實作對mongodb，泛型封裝增刪查改、條件查詢等操作的詳細內容。更多資訊請關注PHP中文網其他相關文章！
陳述
本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn
如何使用咖啡因或Guava Cache等庫在Java應用程序中實現多層緩存？Mar 17, 2025 pm 05:44 PM本文討論了使用咖啡因和Guava緩存在Java中實施多層緩存以提高應用程序性能。它涵蓋設置，集成和績效優勢，以及配置和驅逐政策管理最佳PRA
如何在Java中實施功能編程技術？Mar 11, 2025 pm 05:51 PM本文使用lambda表達式，流API，方法參考和可選探索將功能編程集成到Java中。 它突出顯示了通過簡潔性和不變性改善代碼可讀性和可維護性等好處
Java的類負載機制如何起作用，包括不同的類載荷及其委託模型？Mar 17, 2025 pm 05:35 PMJava的類上載涉及使用帶有引導，擴展程序和應用程序類負載器的分層系統加載，鏈接和初始化類。父代授權模型確保首先加載核心類別，從而影響自定義類LOA
如何將JPA（Java持久性API）用於具有高級功能（例如緩存和懶惰加載）的對象相關映射？Mar 17, 2025 pm 05:43 PM本文討論了使用JPA進行對象相關映射，並具有高級功能，例如緩存和懶惰加載。它涵蓋了設置，實體映射和優化性能的最佳實踐，同時突出潛在的陷阱。[159個字符]
如何將Maven或Gradle用於高級Java項目管理，構建自動化和依賴性解決方案？Mar 17, 2025 pm 05:46 PM本文討論了使用Maven和Gradle進行Java項目管理，構建自動化和依賴性解決方案，以比較其方法和優化策略。
如何將Java的Nio（新輸入/輸出）API用於非阻滯I/O？Mar 11, 2025 pm 05:51 PM本文使用選擇器和頻道使用單個線程有效地處理多個連接的Java的NIO API，用於非阻滯I/O。 它詳細介紹了過程，好處（可伸縮性，性能）和潛在的陷阱（複雜性，
如何使用適當的版本控制和依賴項管理創建和使用自定義Java庫（JAR文件）？Mar 17, 2025 pm 05:45 PM本文使用Maven和Gradle之類的工具討論了具有適當的版本控制和依賴關係管理的自定義Java庫（JAR文件）的創建和使用。
如何使用Java的插座API進行網絡通信？Mar 11, 2025 pm 05:53 PM本文詳細介紹了用於網絡通信的Java的套接字API，涵蓋了客戶服務器設置，數據處理和關鍵考慮因素，例如資源管理，錯誤處理和安全性。 它還探索了性能優化技術，我
熱AI工具
Undresser.AI Undress
人工智慧驅動的應用程序，用於創建逼真的裸體照片
AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。
Undress AI Tool
免費脫衣圖片
Clothoff.io
AI脫衣器
AI Hentai Generator
免費產生 AI 無盡。
熱門文章
R.E.P.O.能量晶體解釋及其做什麼（黃色晶體）
3 週前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳圖形設置
3 週前By尊渡假赌尊渡假赌尊渡假赌
刺客信條陰影：貝殼謎語解決方案
1 週前ByDDD
R.E.P.O.如果您聽不到任何人，如何修復音頻
3 週前By尊渡假赌尊渡假赌尊渡假赌
在哪裡可以找到原子中的起重機控制鑰匙卡
1 週前ByDDD
熱工具
SublimeText3漢化版
中文版，非常好用
PhpStorm Mac 版本
最新（2018.2.1 ）專業的PHP整合開發工具
EditPlus 中文破解版
體積小，語法高亮，不支援程式碼提示功能
MantisBT
Mantis是一個易於部署的基於Web的缺陷追蹤工具，用於幫助產品缺陷追蹤。它需要PHP、MySQL和一個Web伺服器。請查看我們的演示和託管服務。
SAP NetWeaver Server Adapter for Eclipse
將Eclipse與SAP NetWeaver應用伺服器整合。
