devbox
IT小白
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

ssm(spring+springMVC+Mybatis)框架集成Mongodb_mybatis 增加 mongodb

作者：IT小白 | 2024-03-26 21:09:21

赞

踩

mybatis 增加 mongodb

1、开发环境

JDK：1.6

ssm框架关联jar包：

  1. aopalliance.jar
  2. aspectjrt.jar
  3. aspectjweaver.jar
  4. commons-beanutils-1.9.2.jar
  5. commons-codec-1.9.jar
  6. commons-collections-3.2.1.jar
  7. commons-dbcp-1.4.jar
  8. commons-fileupload-1.3.1.jar
  9. commons-io-2.4.jar
  10. commons-lang-2.6.jar
  11. commons-logging-1.2.jar
  12. commons-net-3.1.jar
  13. commons-pool-1.6.jar
  14. commons-pool2-2.2.jar
  15. druid-1.0.9.jar
  16. fastjson-1.1.39.jar
  17. freemarker-2.3.19.jar
  18. hamcrest-core-1.3.jar
  19. jackson-all-1.9.5.jar
  20. jboss-logging-3.1.0.CR2.jar
  21. jettison-1.0.1.jar
  22. jstl-1.1.2.jar
  23. junit-4.11.jar
  24. log4j-1.2.17.jar
  25. log4j-over-slf4j-1.7.7.jar
  26. mybatis-3.2.6.jar
  27. mybatis-spring-1.2.2.jar
  28. mysql-connector-java-5.1.30-bin.jar
  29. servlet-api.jar
  30. slf4j-api-1.7.7.jar
  31. slf4j-ext-1.7.7.jar
  32. spring-aop-4.0.2.RELEASE.jar
  33. spring-aspects-4.0.2.RELEASE.jar
  34. spring-beans-4.0.2.RELEASE.jar
  35. spring-context-4.0.2.RELEASE.jar
  36. spring-context-support-4.0.2.RELEASE.jar
  37. spring-core-4.0.2.RELEASE.jar
  38. spring-expression-4.0.2.RELEASE.jar
  39. spring-jdbc-4.0.2.RELEASE.jar
  40. spring-oxm-4.0.2.RELEASE.jar
  41. spring-test-4.0.2.RELEASE.jar
  42. spring-tx-4.0.2.RELEASE.jar
  43. spring-web-4.0.4.RELEASE.jar
  44. spring-webmvc-4.0.2.RELEASE.jar
  45. standard-1.1.2.jar

mongodb 关联jar文件 

  1. mongo-java-driver-2.10.1.jar
  2. spring-data-commons-core-1.4.0.RELEASE.jar
  3. spring-data-mongodb-1.1.0.RELEASE.jar


项目结构图：


2、配置文件和实列代码

web.xml文件 

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <web-app version="2.5" 
  3. 	xmlns="http://java.sun.com/xml/ns/javaee" 
  4. 	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
  5. 	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee 
  6. 	http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
  7.   <display-name></display-name>	
  8.   
  9.   <context-param>
  10.         <param-name>contextConfigLocation</param-name>
  11.         <param-value>classpath:spring/spring-context.xml</param-value>
  12.     </context-param>
  13.  
  14.     <filter>
  15.         <filter-name>encodingFilter</filter-name>
  16.         <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
  17.         <init-param>
  18.             <param-name>encoding</param-name>
  19.             <param-value>UTF-8</param-value>
  20.         </init-param>
  21.         <init-param>
  22.             <param-name>forceEncoding</param-name>
  23.             <param-value>true</param-value>
  24.         </init-param>
  25.     </filter>
  26.     <filter-mapping>
  27.         <filter-name>encodingFilter</filter-name>
  28.         <url-pattern>/*</url-pattern>
  29.     </filter-mapping>
  30.  
  31.     <listener>
  32.         <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
  33.     </listener>
  34.  
  35.     <servlet>
  36.         <servlet-name>springMVC</servlet-name>
  37.         <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
  38.         <init-param>
  39.             <param-name>contextConfigLocation</param-name>
  40.             <param-value>classpath:spring-mvc.xml</param-value>
  41.         </init-param>
  42.         <load-on-startup>1</load-on-startup>
  43.     </servlet>
  44.     <servlet-mapping>
  45.         <servlet-name>springMVC</servlet-name>
  46.         <url-pattern>/</url-pattern>
  47.     </servlet-mapping>
  48.   
  49.  
  50. </web-app>

spring-mvc.xml

  1. <beans xmlns="http://www.springframework.org/schema/beans"
  2.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.        xmlns:p="http://www.springframework.org/schema/p"
  4.        xmlns:context="http://www.springframework.org/schema/context"
  5.        xmlns:mvc="http://www.springframework.org/schema/mvc"
  6.        xsi:schemaLocation="
  7.        http://www.springframework.org/schema/beans
  8.        http://www.springframework.org/schema/beans/spring-beans.xsd
  9.        http://www.springframework.org/schema/context
  10.        http://www.springframework.org/schema/context/spring-context.xsd
  11.        http://www.springframework.org/schema/mvc
  12.        http://www.springframework.org/schema/mvc/spring-mvc.xsd">
  13.  
  14.     
  15.  
  16.     <!-- 开启controller注解支持 -->
  17.     <!-- 注意事项请参考：http://jinnianshilongnian.iteye.com/blog/1762632 -->
  18.     <context:component-scan base-package="cn.zetark.oauth2.**.web.controller" use-default-filters="false">
  19.         <context:include-filter type="annotation"
  20.                                 expression="org.springframework.stereotype.Controller"/>
  21.         <context:include-filter type="annotation"
  22.                                 expression="org.springframework.web.bind.annotation.ControllerAdvice"/>
  23.     </context:component-scan>
  24. 	<!--注解标签驱动  -->
  25.     <mvc:annotation-driven>
  26.     </mvc:annotation-driven>
  27.  
  28.     <!-- 当在web.xml 中   DispatcherServlet使用 <url-pattern>/</url-pattern> 映射时，能映射静态资源 -->
  29.     <mvc:default-servlet-handler/>
  30.  
  31.     <!-- 静态资源映射 -->
  32.     <mvc:resources mapping="/static/**" location="/WEB-INF/static/"/>
  33.  
  34.     <!-- 默认的视图解析器 在上边的解析错误时使用 (默认使用html)- -->
  35.     <bean id="defaultViewResolver" class="org.springframework.web.servlet.view.InternalResourceViewResolver"
  36.           p:order="1">
  37.         <property name="viewClass" value="org.springframework.web.servlet.view.JstlView"/>
  38.         <property name="contentType" value="text/html"/>
  39.         <property name="prefix" value="/WEB-INF/jsp/"/>
  40.         <property name="suffix" value=".jsp"/>
  41.     </bean>
  42.     
  43.     <!--避免IE执行AJAX时，返回JSON出现下载文件 -->
  44. 	<bean id="mappingJacksonHttpMessageConverter"
  45. 		class="org.springframework.http.converter.json.MappingJacksonHttpMessageConverter">
  46. 		<property name="supportedMediaTypes">
  47. 			<list>
  48. 				<value>text/html;charset=UTF-8</value>
  49. 			</list>
  50. 		</property>
  51. 	</bean>
  52. 	<!-- 启动SpringMVC的注解功能，完成请求和注解POJO的映射 -->
  53. 	<bean
  54. 		class="org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter">
  55. 		<property name="messageConverters">
  56. 			<list>
  57. 				<ref bean="mappingJacksonHttpMessageConverter" />	<!-- JSON转换器 -->
  58. 			</list>
  59. 		</property>
  60. 	</bean>
  61.  
  62.    
  63.  
  64.   
  65.  
  66. </beans>

spring-context.xml 

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. 	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
  4. 	xmlns:context="http://www.springframework.org/schema/context"
  5. 	xmlns:mvc="http://www.springframework.org/schema/mvc"
  6. 	xmlns:tx="http://www.springframework.org/schema/tx"
  7. 	xmlns:aop="http://www.springframework.org/schema/aop"
  8. 	xsi:schemaLocation="http://www.springframework.org/schema/beans  
  9.                         http://www.springframework.org/schema/beans/spring-beans-3.1.xsd  
  10.                         http://www.springframework.org/schema/context  
  11.                         http://www.springframework.org/schema/context/spring-context-3.1.xsd  
  12.                         http://www.springframework.org/schema/tx
  13.                         http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
  14.                         http://www.springframework.org/schema/mvc  
  15.                         http://www.springframework.org/schema/mvc/spring-mvc-3.1.xsd
  16.                         http://www.springframework.org/schema/aop 
  17.                         http://www.springframework.org/schema/aop/spring-aop-3.1.xsd">   
  18. 	<!-- 引入配置文件 -->
  19. 	<bean id="propertyConfigurer"
  20. 		class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
  21. 		<property name="location" value="classpath:jdbc.properties" />
  22. 	</bean>
  23.  
  24. 	<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
  25. 		destroy-method="close">
  26. 		<property name="driverClassName" value="${driver}" />
  27. 		<property name="url" value="${url}" />
  28. 		<property name="username" value="${username}" />
  29. 		<property name="password" value="${password}" />
  30. 		<!-- 初始化连接大小 -->
  31. 		<property name="initialSize" value="${initialSize}"></property>
  32. 		<!-- 连接池最大数量 -->
  33. 		<property name="maxActive" value="${maxActive}"></property>
  34. 		<!-- 连接池最大空闲 -->
  35. 		<property name="maxIdle" value="${maxIdle}"></property>
  36. 		<!-- 连接池最小空闲 -->
  37. 		<property name="minIdle" value="${minIdle}"></property>
  38. 		<!-- 获取连接最大等待时间 -->
  39. 		<property name="maxWait" value="${maxWait}"></property>
  40. 	</bean>
  41.  
  42. 	<!-- spring和MyBatis完美整合，不需要mybatis的配置映射文件 -->
  43. 	<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
  44. 		<property name="dataSource" ref="dataSource" />
  45. 		<!-- 自动扫描mapping.xml文件 -->
  46. 		<property name="mapperLocations" value="classpath:com/wlsq/oauth/mapper/*.xml"></property>
  47. 	</bean>
  48.  
  49. 	<!-- DAO接口所在包名，Spring会自动查找其下的类 -->
  50. 	<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
  51. 		<property name="basePackage" value="com.wlsq.oauth.dao" />
  52. 		<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property>
  53. 	</bean>
  54.  
  55. 	<!-- (事务管理)transaction manager, use JtaTransactionManager for global tx -->
  56. 	<bean id="transactionManager"
  57. 		class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  58. 		<property name="dataSource" ref="dataSource" />
  59. 	</bean>
  60. 	
  61. 	 <!-- 通知 -->
  62.     <tx:advice id="tx"
  63.         transaction-manager="transactionManager">
  64.         <tx:attributes>
  65.             <tx:method name="delete*" propagation="REQUIRED" />
  66.             <tx:method name="insert*" propagation="REQUIRED" />
  67.             <tx:method name="update*" propagation="REQUIRED" />
  68.             <tx:method name="find*" read-only="true" />
  69.             <tx:method name="get*" read-only="true" />
  70.             <tx:method name="select*" read-only="true" />
  71.         </tx:attributes>
  72.     </tx:advice>
  73.  
  74.     <aop:config>
  75.         <aop:pointcut id="pc" expression="execution(* com.common.service.*.*(..))" />
  76.         <!--把事务控制在Service层-->
  77.         <aop:advisor pointcut-ref="pc" advice-ref="tx" />
  78.     </aop:config>
  79.     
  80.     <!--ssm 集成 mongodb  -->
  81.     <import resource="classpath:spring/spring-mongodb.xml"/>
  82.  
  83. </beans>

spring-mongodb.xml 

  1. <?xml version="1.0" encoding="UTF-8"?>  
  2. <beans xmlns="http://www.springframework.org/schema/beans"  
  3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"   
  4.     xmlns:p="http://www.springframework.org/schema/p"   
  5.     xmlns:mongo="http://www.springframework.org/schema/data/mongo"    
  6.     xsi:schemaLocation="http://www.springframework.org/schema/beans   
  7.             http://www.springframework.org/schema/beans/spring-beans-3.0.xsd  
  8.             http://www.springframework.org/schema/data/mongo  
  9.             http://www.springframework.org/schema/data/mongo/spring-mongo.xsd
  10.             http://www.springframework.org/schema/data/repository
  11.             http://www.springframework.org/schema/data/repository/spring-repository-1.4.xsd ">  
  12.                   
  13.     <!-- Default bean name is 'mongo' -->  
  14.     <mongo:mongo host="120.25.56.93" port="27017"/>  
  15.       
  16.     <!--mongodb 数据库账号和密码信息  -->
  17.  
  18.     <bean id="userCredentials" class="org.springframework.data.authentication.UserCredentials">
  19. 		<constructor-arg name="username"  value="admin"/>
  20. 		<constructor-arg name="password"  value="123456"/>
  21. 	</bean> 
  22.     
  23.     <!-- Offers convenience methods and automatic mapping between MongoDB JSON documents and your domain classes. -->  
  24.     <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">  
  25.             <constructor-arg ref="mongo"/>  
  26.             <constructor-arg name="databaseName" value="admin"/>  
  27.             <constructor-arg ref="userCredentials"/> 
  28.     </bean>  
  29.     
  30.     <bean id="userDao" class="com.wlsq.oauth.dao.impl.UserDao" />
  31.       
  32. </beans>

mongodb 逻辑封装代码（mongodbTemplate 封装） 

  1. package com.wlsq.oauth.dao.support;
  2.  
  3. import org.springframework.beans.BeansException;
  4. import org.springframework.context.ApplicationContext;
  5. import org.springframework.context.ApplicationContextAware;
  6. import org.springframework.data.mongodb.core.MongoTemplate;
  7.  
  8. public class AbstractBaseMongoTemplete implements ApplicationContextAware {
  9. 	protected MongoTemplate mongoTemplate;
  10. 	
  11. 	/**
  12. 	 * 设置mongoTemplate
  13. 	 * @param mongoTemplate the mongoTemplate to set
  14. 	 */
  15. 	public void setMongoTemplate(MongoTemplate mongoTemplate) {
  16. 		this.mongoTemplate = mongoTemplate;
  17. 	}
  18. 	
  19. 	public void setApplicationContext(ApplicationContext applicationContext)
  20. 			throws BeansException {
  21. 		// TODO Auto-generated method stub
  22. 		MongoTemplate mongoTemplate = applicationContext.getBean("mongoTemplate", MongoTemplate.class);
  23. 		setMongoTemplate(mongoTemplate);
  24. 	}
  25.  
  26. }

mongodb  dao层数据库接口基类 

  1. package com.wlsq.oauth.dao.impl;
  2.  
  3. import java.util.List;
  4.  
  5. import org.springframework.data.mongodb.core.query.Criteria;
  6. import org.springframework.data.mongodb.core.query.Query;
  7. import org.springframework.data.mongodb.core.query.Update;
  8.  
  9. import com.wlsq.oauth.dao.IUserDao;
  10. import com.wlsq.oauth.dao.support.AbstractBaseMongoTemplete;
  11. import com.wlsq.oauth.entity.User;
  12.  
  13. public class UserDao extends AbstractBaseMongoTemplete implements IUserDao {
  14. 	/**
  15. 	 * 新增
  16. 	 * <br>------------------------------<br>
  17. 	 * @param user
  18. 	 */ 
  19. 	public void insert(User user) {
  20. 		// TODO Auto-generated method stub
  21. 		mongoTemplate.insert(user);
  22. 	}
  23. 	/**
  24. 	 * 批量新增
  25. 	 * <br>------------------------------<br>
  26. 	 * @param users
  27. 	 */
  28. 	public void insertAll(List<User> users) {
  29. 		// TODO Auto-generated method stub
  30. 		mongoTemplate.insertAll(users);
  31. 	}
  32. 	/**
  33. 	 * 删除,按主键id, 如果主键的值为null,删除会失败
  34. 	 * <br>------------------------------<br>
  35. 	 * @param id
  36. 	 */
  37. 	public void deleteById(String id) {
  38. 		// TODO Auto-generated method stub
  39. 		User user = new User(id, null, 0);
  40. 		mongoTemplate.remove(user);
  41. 	}
  42. 	/**
  43. 	 * 按条件删除
  44. 	 * <br>------------------------------<br>
  45. 	 * @param criteriaUser
  46. 	 */
  47. 	public void delete(User criteriaUser) {
  48. 		// TODO Auto-generated method stub
  49. 		Criteria criteria = Criteria.where("age").gt(criteriaUser.getAge());;
  50. 		Query query = new Query(criteria);
  51. 		mongoTemplate.remove(query, User.class);
  52. 	}
  53. 	/**
  54. 	 * 删除全部
  55. 	 * <br>------------------------------<br>
  56. 	 */
  57. 	public void deleteAll() {
  58. 		// TODO Auto-generated method stub
  59. 		mongoTemplate.dropCollection(User.class);
  60. 	}
  61. 	/**
  62. 	 * 按主键修改,
  63. 	 * 如果文档中没有相关key 会新增 使用$set修改器
  64. 	 * <br>------------------------------<br>
  65. 	 * @param user
  66. 	 */
  67. 	public void updateById(User user) {
  68. 		// TODO Auto-generated method stub
  69. 		Criteria criteria = Criteria.where("id").is(user.getId());
  70. 		Query query = new Query(criteria);
  71. 		Update update = Update.update("age", user.getAge()).set("name", user.getName());
  72. 		mongoTemplate.updateFirst(query, update, User.class);
  73. 	}
  74. 	/**
  75. 	 * 修改多条
  76. 	 * <br>------------------------------<br>
  77. 	 * @param criteriaUser
  78. 	 * @param user
  79. 	 */
  80. 	public void update(User criteriaUser, User user) {
  81. 		// TODO Auto-generated method stub
  82. 		Criteria criteria = Criteria.where("age").gt(criteriaUser.getAge());;
  83. 		Query query = new Query(criteria);
  84. 		Update update = Update.update("name", user.getName()).set("age", user.getAge());
  85. 		mongoTemplate.updateMulti(query, update, User.class);
  86. 	}
  87. 	/**
  88. 	 * 根据主键查询
  89. 	 * <br>------------------------------<br>
  90. 	 * @param id
  91. 	 * @return
  92. 	 */
  93. 	public User findById(String id) {
  94. 		// TODO Auto-generated method stub
  95. 		return mongoTemplate.findById(id, User.class);
  96. 	}
  97. 	/**
  98. 	 * 查询全部
  99. 	 * <br>------------------------------<br>
  100. 	 * @return
  101. 	 */
  102. 	public List<User> findAll() {
  103. 		// TODO Auto-generated method stub
  104. 		return mongoTemplate.findAll(User.class);
  105. 	}
  106. 	/**
  107. 	 * 按条件查询, 分页
  108. 	 * <br>------------------------------<br>
  109. 	 * @param criteriaUser
  110. 	 * @param skip
  111. 	 * @param limit
  112. 	 * @return
  113. 	 */
  114. 	public List<User> find(User criteriaUser, int skip, int limit) {
  115. 		// TODO Auto-generated method stub
  116. 		Query query = getQuery(criteriaUser);
  117. 		query.skip(skip);
  118. 		query.limit(limit);
  119. 		return mongoTemplate.find(query, User.class);
  120. 	}
  121. 	/**
  122. 	 * 根据条件查询出来后 再去修改
  123. 	 * <br>------------------------------<br>
  124. 	 * @param criteriaUser  查询条件
  125. 	 * @param updateUser    修改的值对象
  126. 	 * @return
  127. 	 */
  128. 	public User findAndModify(User criteriaUser, User updateUser) {
  129. 		// TODO Auto-generated method stub
  130. 		Query query = getQuery(criteriaUser);
  131. 		Update update = Update.update("age", updateUser.getAge()).set("name", updateUser.getName());
  132. 		return mongoTemplate.findAndModify(query, update, User.class);
  133. 	}
  134. 	/**
  135. 	 * 查询出来后 删除
  136. 	 * <br>------------------------------<br>
  137. 	 * @param criteriaUser
  138. 	 * @return
  139. 	 */
  140. 	public User findAndRemove(User criteriaUser) {
  141. 		// TODO Auto-generated method stub
  142. 		Query query = getQuery(criteriaUser);
  143. 		return mongoTemplate.findAndRemove(query, User.class);
  144. 	}
  145. 	/**
  146. 	 * count
  147. 	 * <br>------------------------------<br>
  148. 	 * @param criteriaUser
  149. 	 * @return
  150. 	 */
  151. 	public long count(User criteriaUser) {
  152. 		// TODO Auto-generated method stub
  153. 		Query query = getQuery(criteriaUser);
  154. 		return mongoTemplate.count(query, User.class);
  155. 	}
  156. 	/**
  157. 	 *
  158. 	 * <br>------------------------------<br>
  159. 	 * @param criteriaUser
  160. 	 * @return
  161. 	 */
  162. 	private Query getQuery(User criteriaUser) {
  163. 		if (criteriaUser == null) {
  164. 			criteriaUser = new User();
  165. 		}
  166. 		Query query = new Query();
  167. 		if (criteriaUser.getId() != null) {
  168. 			Criteria criteria = Criteria.where("id").is(criteriaUser.getId());
  169. 			query.addCriteria(criteria);
  170. 		}
  171. 		if (criteriaUser.getAge() > 0) {
  172. 			Criteria criteria = Criteria.where("age").gt(criteriaUser.getAge());
  173. 			query.addCriteria(criteria);
  174. 		}
  175. 		if (criteriaUser.getName() != null) {
  176. 			Criteria criteria = Criteria.where("name").regex("^" + criteriaUser.getName());
  177. 			query.addCriteria(criteria);
  178. 		}
  179. 		return query;
  180. 	}
  181.  
  182. }

  1. package com.wlsq.oauth.dao;
  2.  
  3. import java.util.List;
  4.  
  5. import com.wlsq.oauth.entity.User;
  6.  
  7. public interface IUserDao {
  8. 	/**
  9. 	 * 新增
  10. 	 * <br>------------------------------<br>
  11. 	 * @param user
  12. 	 */
  13. 	void insert(User user);
  14. 	
  15. 	/**
  16. 	 * 新增
  17. 	 * <br>------------------------------<br>
  18. 	 * @param users
  19. 	 */
  20. 	void insertAll(List<User> users);
  21. 	
  22. 	/**
  23. 	 * 删除,主键id, 如果主键的值为null,删除会失败
  24. 	 * <br>------------------------------<br>
  25. 	 * @param id
  26. 	 */
  27. 	void deleteById(String id);
  28. 	
  29. 	/**
  30. 	 * 按条件删除
  31. 	 * <br>------------------------------<br>
  32. 	 * @param criteriaUser
  33. 	 */
  34. 	void delete(User criteriaUser);
  35. 	
  36. 	/**
  37. 	 * 删除全部
  38. 	 * <br>------------------------------<br>
  39. 	 */
  40. 	void deleteAll();
  41. 	
  42. 	/**
  43. 	 * 修改
  44. 	 * <br>------------------------------<br>
  45. 	 * @param user
  46. 	 */
  47. 	void updateById(User user);
  48. 	
  49. 	/**
  50. 	 * 更新多条
  51. 	 * <br>------------------------------<br>
  52. 	 * @param criteriaUser
  53. 	 * @param user
  54. 	 */
  55. 	void update(User criteriaUser, User user);
  56. 	
  57. 	/**
  58. 	 * 根据主键查询
  59. 	 * <br>------------------------------<br>
  60. 	 * @param id
  61. 	 * @return
  62. 	 */
  63. 	User findById(String id);
  64. 	
  65. 	/**
  66. 	 * 查询全部
  67. 	 * <br>------------------------------<br>
  68. 	 * @return
  69. 	 */
  70. 	List<User> findAll();
  71. 	
  72. 	/**
  73. 	 * 按条件查询
  74. 	 * <br>------------------------------<br>
  75. 	 * @param criteriaUser
  76. 	 * @param skip
  77. 	 * @param limit
  78. 	 * @return
  79. 	 */
  80. 	List<User> find(User criteriaUser, int skip, int limit);
  81. 	
  82. 	/**
  83. 	 * 根据条件查询出来后 在去修改
  84. 	 * <br>------------------------------<br>
  85. 	 * @param criteriaUser  查询条件
  86. 	 * @param updateUser    修改的值对象
  87. 	 * @return
  88. 	 */
  89. 	User findAndModify(User criteriaUser, User updateUser);
  90. 	
  91. 	/**
  92. 	 * 查询出来后 删除
  93. 	 * <br>------------------------------<br>
  94. 	 * @param criteriaUser
  95. 	 * @return
  96. 	 */
  97. 	User findAndRemove(User criteriaUser);
  98. 	
  99. 	/**
  100. 	 * count
  101. 	 * <br>------------------------------<br>
  102. 	 * @param criteriaUser
  103. 	 * @return
  104. 	 */
  105. 	long count(User criteriaUser);
  106.  
  107. }

mongodb 实体类 

  1. package com.wlsq.oauth.entity;
  2.  
  3. import java.io.Serializable;
  4.  
  5. public class User implements Serializable {
  6.  
  7. 	/**
  8. 	 * 
  9. 	 */
  10. 	private static final long serialVersionUID = -2634064977259616340L;
  11. 	private String id;	
  12. 	private String name;	
  13. 	private int age;
  14. 	
  15. 	public User() {		
  16. 	}
  17.  
  18. 	public User(String id, String name, int age) {
  19. 		super();
  20. 		this.id = id;
  21. 		this.name = name;
  22. 		this.age = age;
  23. 	}
  24.  
  25. 	public String getId() {
  26. 		return id;
  27. 	}
  28.  
  29. 	public void setId(String id) {
  30. 		this.id = id;
  31. 	}
  32.  
  33. 	public String getName() {
  34. 		return name;
  35. 	}
  36.  
  37. 	public void setName(String name) {
  38. 		this.name = name;
  39. 	}
  40.  
  41. 	public int getAge() {
  42. 		return age;
  43. 	}
  44.  
  45. 	public void setAge(int age) {
  46. 		this.age = age;
  47. 	}
  48. 	
  49. 	
  50. 	
  51. 	
  52. 	
  53. }


声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/IT小白/article/detail/319716
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号