當前位置：首頁 > 前端技术 > javascript >内容正文

javascript

大数据之mongodb -- （2）java集成 MongoDB 3.2,使用Spring-data-mongodb进行集成

發布時間：2024/9/27 javascript 22 豆豆

生活随笔收集整理的這篇文章主要介紹了大数据之mongodb -- （2）java集成 MongoDB 3.2,使用Spring-data-mongodb进行集成小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

Java集成MongoDB有很多方式，可以直接用mongodb的java驅動程序來發送語句到mongodb服務器，也可以用第三方的工具包來做。

(1) 選擇版本

選擇的就是springdata集成的mongodb（spring-data-mongodb）

1.1 spring-data-mongodb版本

gradle坐標：

org.springframework.data:spring-data-mongodb:1.7.2.RELEASE

maven 坐標

<dependency><groupId>org.springframework.data</groupId><artifactId>spring-data-mongodb</artifactId><version>1.7.2.RELEASE</version> </dependency>

1.2 java驅動器版本

gradle坐標：

org.mongodb:mongo-java-driver:3.2.0

maven 坐標

<dependency><groupId>org.mongodb</groupId><artifactId>mongo-java-driver</artifactId><version>3.2.0</version> </dependency>

(2) 集成

2.1 spring 配置文件

新建文件 mongodb-context.xml

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"xmlns:mongo="http://www.springframework.org/schema/data/mongo"xsi:schemaLocation="http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/data/mongo http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd"><mongo:mongo id="mongo" host="192.168.1.202" port="27017" /><bean id="userCredentials" class="org.springframework.data.authentication.UserCredentials"><constructor-arg name="username" value="root"/><constructor-arg name="password" value="root"/></bean><bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate"><constructor-arg ref="mongo" /><constructor-arg value="demodb" /><constructor-arg ref="userCredentials" /></bean></beans>

集成到spring的基礎配置文件中即可?
spring的主配置文件插入如下代碼

<import resource="mongodb-context.xml"/>

(3) 編寫基礎類

3.1 Dao 基礎操作類 MongodbDao

其他的dao類都可以繼承改類

import java.util.List;import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.domain.Sort; import org.springframework.data.domain.Sort.Direction; import org.springframework.data.mongodb.core.MongoTemplate; import org.springframework.data.mongodb.core.query.Criteria; import org.springframework.data.mongodb.core.query.Query; import org.springframework.data.mongodb.core.query.Update; import org.springframework.stereotype.Repository;import com.github.pagehelper.PageInfo;/*** mongodb 基礎操作類* @author chenpengye 2015年12月21日下午11:33:06* @param <T>*/ @Repository public class MongodbDao<T extends IdEntity> {private static final Logger logger = LoggerFactory.getLogger(MongodbDao.class);private static final int DEFAULT_SKIP = 0;private static final int DEFAULT_LIMIT = 200;@Autowiredprotected MongoTemplate mongoTemplate;// ＝＝＝＝＝＝＝增＝＝＝＝＝＝＝＝＝＝＝＝public void save(T t) {mongoTemplate.save(t);logger.debug("save entity: {}", t);}public void insertAll(List<T> list) {mongoTemplate.insertAll(list);}// ＝＝＝＝＝＝＝刪＝＝＝＝＝＝＝＝＝＝＝＝/*** 刪除對象* * @param t*/public void delete(T t) {mongoTemplate.remove(t);}/*** 根據id 刪除對象* * @param id*/public void deleteById(String id) {Criteria criteria = Criteria.where("id").is(id);Query query = new Query(criteria);mongoTemplate.remove(query, this.getEntityClass());}/*** 根據條件刪除*/public void delete(Query query) {mongoTemplate.remove(query, this.getEntityClass());}/*** 刪除該collection 的所有的數據*/public void deleteAll() {mongoTemplate.dropCollection(this.getEntityClass());}// ＝＝＝＝＝＝＝改＝＝＝＝＝＝＝＝＝＝＝＝public void update(Query query, Update update) {mongoTemplate.findAndModify(query, update, this.getEntityClass());}// ＝＝＝＝＝＝＝查＝＝＝＝＝＝＝＝＝＝＝＝public List<T> findAll(){return mongoTemplate.findAll(this.getEntityClass());}/*** 根據查詢query 查找list* * @param query* @return*/public List<T> find(Query query) {return mongoTemplate.find(query, this.getEntityClass());}/*** 按照字段排序－順序 * @param query 查詢條件 * @param properties 排序字段 * @return*/public List<T> findWithOrderAsc(Query query, String... properties){Sort sort = new Sort(Direction.ASC, properties);query.with(sort);return mongoTemplate.find(query, this.getEntityClass());}/*** 按照字段排序－逆序 * @param query 查詢條件 * @param properties 排序字段 * @return*/public List<T> findWithOrderDesc(Query query, String... properties){Sort sort = new Sort(Direction.DESC, properties);query.with(sort);return mongoTemplate.find(query, this.getEntityClass());}/*** 根據查詢query 查找一個對象* * @param query* @return*/public T findOne(Query query) {return mongoTemplate.findOne(query, this.getEntityClass());}/*** 根據 id 查詢對象* * @param id* @return*/public T findById(String id) {return mongoTemplate.findById(id, this.getEntityClass());}/*** 根據id 和集合名字查詢對象* * @param id* @param collectionName* @return*/public T findById(String id, String collectionName) {return mongoTemplate.findById(id, this.getEntityClass(), collectionName);}/*** 查詢分頁 tips：［不要skip 太多的頁數，如果跳過太多會嚴重影響效率。最大不要skip 20000頁］* @param page* @param query* @return*/public PageInfo<T> findPage(PageInfo<T> page, Query query) {long count = this.count(query);page.setTotal(count);int pageNumber = page.getPageNum();int pageSize = page.getPageSize();query.skip((pageNumber - 1) * pageSize).limit(pageSize);List<T> list = this.find(query);page.setList(list);return page;}public long count(Query query) {return mongoTemplate.count(query, this.getEntityClass());}/*** 獲取需要操作的實體類class * 例如: StudentScoreDao extends MongodbDao <StudentScore> * 返回的是 StudentScore 的Class* * @return*/private Class<T> getEntityClass() {return ReflectionUtils.getSuperClassGenricType(getClass());}/*** 獲取collection的名字，默認是dao范型T的名字 * 例如: StudentScoreDao extends MongodbDao <StudentScore> * 則返回的名字是：StudentScore* * @return*/private String getCollectionName() {return getEntityClass().getSimpleName();}}

由于現行項目使用mybatis，并且分頁采用了pagehelper:pagehelper:4.0.3，因此這里的分頁類也采用里pagehelper里面的分頁類。如果要分頁，請也引入pagehelper的jar包?
gradle坐標

compile 'com.github.jsqlparser:jsqlparser:0.9.4'compile 'com.github.pagehelper:pagehelper:4.0.3'

maven坐標

<dependency><groupId>com.github.jsqlparser</groupId><artifactId>jsqlparser</artifactId><version>0.9.4</version> </dependency><dependency><groupId>com.github.pagehelper</groupId><artifactId>pagehelper</artifactId><version>4.0.3</version> </dependency>

3.2 工具類 ReflectionUtils

import java.lang.reflect.Field; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.lang.reflect.ParameterizedType; import java.lang.reflect.Type;import org.apache.commons.lang.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.util.Assert;/*** 反射工具類.* * 提供訪問私有變量,獲取泛型類型Class, 提取集合中元素的屬性, 轉換字符串到對象等Util函數.* */ public class ReflectionUtils {private static Logger logger = LoggerFactory.getLogger(ReflectionUtils.class);/*** 調用Getter方法.*/public static Object invokeGetterMethod(Object obj, String propertyName) {String getterMethodName = "get" + StringUtils.capitalize(propertyName);return invokeMethod(obj, getterMethodName, new Class[] {}, new Object[] {});}/*** 調用Setter方法.使用value的Class來查找Setter方法.*/public static void invokeSetterMethod(Object obj, String propertyName, Object value) {invokeSetterMethod(obj, propertyName, value, null);}/*** 調用Setter方法.* * @param propertyType 用于查找Setter方法,為空時使用value的Class替代.*/public static void invokeSetterMethod(Object obj, String propertyName, Object value, Class<?> propertyType) {Class<?> type = propertyType != null ? propertyType : value.getClass();String setterMethodName = "set" + StringUtils.capitalize(propertyName);invokeMethod(obj, setterMethodName, new Class[] { type }, new Object[] { value });}/*** 直接讀取對象屬性值, 無視private/protected修飾符, 不經過getter函數.*/public static Object getFieldValue(final Object obj, final String fieldName) {Field field = getAccessibleField(obj, fieldName);if (field == null) {throw new IllegalArgumentException("Could not find field [" + fieldName + "] on target [" + obj + "]");}Object result = null;try {result = field.get(obj);} catch (IllegalAccessException e) {logger.error("不可能拋出的異常{}", e.getMessage());}return result;}/*** 直接設置對象屬性值, 無視private/protected修飾符, 不經過setter函數.*/public static void setFieldValue(final Object obj, final String fieldName, final Object value) {Field field = getAccessibleField(obj, fieldName);if (field == null) {throw new IllegalArgumentException("Could not find field [" + fieldName + "] on target [" + obj + "]");}try {field.set(obj, value);} catch (IllegalAccessException e) {logger.error("不可能拋出的異常:{}", e.getMessage());}}/*** 循環向上轉型, 獲取對象的DeclaredField, 并強制設置為可訪問.* * 如向上轉型到Object仍無法找到, 返回null.*/public static Field getAccessibleField(final Object obj, final String fieldName) {Assert.notNull(obj, "object不能為空");Assert.hasText(fieldName, "fieldName");for (Class<?> superClass = obj.getClass(); superClass != Object.class; superClass = superClass.getSuperclass()) {try {Field field = superClass.getDeclaredField(fieldName);field.setAccessible(true);return field;} catch (NoSuchFieldException e) {//NOSONAR// Field不在當前類定義,繼續向上轉型}}return null;}/*** 直接調用對象方法, 無視private/protected修飾符.* 用于一次性調用的情況.*/public static Object invokeMethod(final Object obj, final String methodName, final Class<?>[] parameterTypes,final Object[] args) {Method method = getAccessibleMethod(obj, methodName, parameterTypes);if (method == null) {throw new IllegalArgumentException("Could not find method [" + methodName + "] on target [" + obj + "]");}try {return method.invoke(obj, args);} catch (Exception e) {throw convertReflectionExceptionToUnchecked(e);}}/*** 循環向上轉型, 獲取對象的DeclaredMethod,并強制設置為可訪問.* 如向上轉型到Object仍無法找到, 返回null.* * 用于方法需要被多次調用的情況. 先使用本函數先取得Method,然后調用Method.invoke(Object obj, Object... args)*/public static Method getAccessibleMethod(final Object obj, final String methodName,final Class<?>... parameterTypes) {Assert.notNull(obj, "object不能為空");for (Class<?> superClass = obj.getClass(); superClass != Object.class; superClass = superClass.getSuperclass()) {try {Method method = superClass.getDeclaredMethod(methodName, parameterTypes);method.setAccessible(true);return method;} catch (NoSuchMethodException e) {//NOSONAR// Method不在當前類定義,繼續向上轉型}}return null;}/*** 通過反射, 獲得Class定義中聲明的父類的泛型參數的類型.* 如無法找到, 返回Object.class.* eg.* public UserDao extends HibernateDao<User>** @param clazz The class to introspect* @return the first generic declaration, or Object.class if cannot be determined*/@SuppressWarnings({ "unchecked", "rawtypes" })public static <T> Class<T> getSuperClassGenricType(final Class clazz) {return getSuperClassGenricType(clazz, 0);}/*** 通過反射, 獲得Class定義中聲明的父類的泛型參數的類型.* 如無法找到, 返回Object.class.* * 如public UserDao extends HibernateDao<User,Long>** @param clazz clazz The class to introspect* @param index the Index of the generic ddeclaration,start from 0.* @return the index generic declaration, or Object.class if cannot be determined*/@SuppressWarnings("rawtypes")public static Class getSuperClassGenricType(final Class clazz, final int index) {Type genType = clazz.getGenericSuperclass();if (!(genType instanceof ParameterizedType)) {logger.warn(clazz.getSimpleName() + "'s superclass not ParameterizedType");return Object.class;}Type[] params = ((ParameterizedType) genType).getActualTypeArguments();if (index >= params.length || index < 0) {logger.warn("Index: " + index + ", Size of " + clazz.getSimpleName() + "'s Parameterized Type: "+ params.length);return Object.class;}if (!(params[index] instanceof Class)) {logger.warn(clazz.getSimpleName() + " not set the actual class on superclass generic parameter");return Object.class;}return (Class) params[index];}/*** 將反射時的checked exception轉換為unchecked exception.*/public static RuntimeException convertReflectionExceptionToUnchecked(Exception e) {if (e instanceof IllegalAccessException || e instanceof IllegalArgumentException|| e instanceof NoSuchMethodException) {return new IllegalArgumentException("Reflection Exception.", e);} else if (e instanceof InvocationTargetException) {return new RuntimeException("Reflection Exception.", ((InvocationTargetException) e).getTargetException());} else if (e instanceof RuntimeException) {return (RuntimeException) e;}return new RuntimeException("Unexpected Checked Exception.", e);} }

3.3 基礎實體類 IdEntity

import java.io.Serializable;/*** mongodb 基礎id類，id都是字符串型的* @author chenpengye* 2015年12月21日下午4:53:45*/ public class IdEntity implements Serializable {private static final long serialVersionUID = 33633625616087044L;private String id;public String getId() {return id;}public void setId(String id) {this.id = id;}}

3.4 實體類 StudentScore

import java.io.Serializable; import java.util.List;/*** 測試實體類* @author chenpengye* 2015年12月21日下午11:59:02*/ public class StudentScore extends IdEntity implements Serializable {private static final long serialVersionUID = 8743196073520676022L;/*** 學生姓名*/private String username;/*** 學生成績*/private List<Double> scoreList;public String getUsername() {return username;}public void setUsername(String username) {this.username = username;}public List<Double> getScoreList() {return scoreList;}public void setScoreList(List<Double> scoreList) {this.scoreList = scoreList;}}

3.5 實體類的dao操作類 StudentScoreDao

import org.springframework.stereotype.Repository;/*** 繼承MongodbDao * 此類對StudentScore對增刪改查和分頁方法都已經有了 * @author chenpengye* 2016年1月4日下午10:04:25*/ @Repository public class StudentScoreDao extends MongodbDao<StudentScore> {}

有需要的同學可以參考我的上一篇博客，關于mongodb的安裝?
－－－（1）在ubuntu上安裝mongodb?－－－－－－

歡迎探討，如有疑問請發郵件到chenpengye1861@163.com

總結

以上是生活随笔為你收集整理的大数据之mongodb -- （2）java集成 MongoDB 3.2,使用Spring-data-mongodb进行集成的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。