ssm(spring+springMVC+Mybatis)框架集成Mongodb

水深无声 2023-10-16 23:46 28阅读 0赞

1、开发环境

JDK：1.6

ssm框架关联jar包：

aopalliance.jar
    aspectjrt.jar
    aspectjweaver.jar
    commons-beanutils-1.9.2.jar
    commons-codec-1.9.jar
    commons-collections-3.2.1.jar
    commons-dbcp-1.4.jar
    commons-fileupload-1.3.1.jar
    commons-io-2.4.jar
    commons-lang-2.6.jar
    commons-logging-1.2.jar
    commons-net-3.1.jar
    commons-pool-1.6.jar
    commons-pool2-2.2.jar
    druid-1.0.9.jar
    fastjson-1.1.39.jar
    freemarker-2.3.19.jar
    hamcrest-core-1.3.jar
    jackson-all-1.9.5.jar
    jboss-logging-3.1.0.CR2.jar
    jettison-1.0.1.jar
    jstl-1.1.2.jar
    junit-4.11.jar
    log4j-1.2.17.jar
    log4j-over-slf4j-1.7.7.jar
    mybatis-3.2.6.jar
    mybatis-spring-1.2.2.jar
    mysql-connector-java-5.1.30-bin.jar
    servlet-api.jar
    slf4j-api-1.7.7.jar
    slf4j-ext-1.7.7.jar
    spring-aop-4.0.2.RELEASE.jar
    spring-aspects-4.0.2.RELEASE.jar
    spring-beans-4.0.2.RELEASE.jar
    spring-context-4.0.2.RELEASE.jar
    spring-context-support-4.0.2.RELEASE.jar
    spring-core-4.0.2.RELEASE.jar
    spring-expression-4.0.2.RELEASE.jar
    spring-jdbc-4.0.2.RELEASE.jar
    spring-oxm-4.0.2.RELEASE.jar
    spring-test-4.0.2.RELEASE.jar
    spring-tx-4.0.2.RELEASE.jar
    spring-web-4.0.4.RELEASE.jar
    spring-webmvc-4.0.2.RELEASE.jar
    standard-1.1.2.jar

mongodb 关联jar文件

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

项目结构图：

2、配置文件和实列代码

web.xml文件

<?xml version="1.0" encoding="UTF-8"?>
 <web-app version="2.5" 
 	xmlns="http://java.sun.com/xml/ns/javaee" 
 	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
 	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee 
 	http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
 <display-name></display-name>	
 
 <context-param>
 <param-name>contextConfigLocation</param-name>
 <param-value>classpath:spring/spring-context.xml</param-value>
 </context-param>
 
 <filter>
 <filter-name>encodingFilter</filter-name>
 <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
 <init-param>
 <param-name>encoding</param-name>
 <param-value>UTF-8</param-value>
 </init-param>
 <init-param>
 <param-name>forceEncoding</param-name>
 <param-value>true</param-value>
 </init-param>
 </filter>
 <filter-mapping>
 <filter-name>encodingFilter</filter-name>
 <url-pattern>/*</url-pattern>
 </filter-mapping>
 
 <listener>
 <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
 </listener>
 
 <servlet>
 <servlet-name>springMVC</servlet-name>
 <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
 <init-param>
 <param-name>contextConfigLocation</param-name>
 <param-value>classpath:spring-mvc.xml</param-value>
 </init-param>
 <load-on-startup>1</load-on-startup>
 </servlet>
 <servlet-mapping>
 <servlet-name>springMVC</servlet-name>
 <url-pattern>/</url-pattern>
 </servlet-mapping>
 
 
 </web-app>

spring-mvc.xml

<beans xmlns="http://www.springframework.org/schema/beans"
 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xmlns:p="http://www.springframework.org/schema/p"
 xmlns:context="http://www.springframework.org/schema/context"
 xmlns:mvc="http://www.springframework.org/schema/mvc"
 xsi:schemaLocation="
 http://www.springframework.org/schema/beans
 http://www.springframework.org/schema/beans/spring-beans.xsd
 http://www.springframework.org/schema/context
 http://www.springframework.org/schema/context/spring-context.xsd
 http://www.springframework.org/schema/mvc
 http://www.springframework.org/schema/mvc/spring-mvc.xsd">
 
 
 
 
 
 <context:component-scan base-package="cn.zetark.oauth2.**.web.controller" use-default-filters="false">
 <context:include-filter type="annotation"
 expression="org.springframework.stereotype.Controller"/>
 <context:include-filter type="annotation"
 expression="org.springframework.web.bind.annotation.ControllerAdvice"/>
 </context:component-scan>
 	
 <mvc:annotation-driven>
 </mvc:annotation-driven>
 
 
 <mvc:default-servlet-handler/>
 
 
 <mvc:resources mapping="/static/**" location="/WEB-INF/static/"/>
 
 
 <bean id="defaultViewResolver" class="org.springframework.web.servlet.view.InternalResourceViewResolver"
 p:order="1">
 <property name="viewClass" value="org.springframework.web.servlet.view.JstlView"/>
 <property name="contentType" value="text/html"/>
 <property name="prefix" value="/WEB-INF/jsp/"/>
 <property name="suffix" value=".jsp"/>
 </bean>
 
 
 	<bean id="mappingJacksonHttpMessageConverter"
 		class="org.springframework.http.converter.json.MappingJacksonHttpMessageConverter">
 		<property name="supportedMediaTypes">
 			<list>
 				<value>text/html;charset=UTF-8</value>
 			</list>
 		</property>
 	</bean>
 	
 	<bean
 		class="org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter">
 		<property name="messageConverters">
 			<list>
 				<ref bean="mappingJacksonHttpMessageConverter" />	
 			</list>
 		</property>
 	</bean>
 
 
 
 
 
 </beans>

spring-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:p="http://www.springframework.org/schema/p"
 	xmlns:context="http://www.springframework.org/schema/context"
 	xmlns:mvc="http://www.springframework.org/schema/mvc"
 	xmlns:tx="http://www.springframework.org/schema/tx"
 	xmlns:aop="http://www.springframework.org/schema/aop"
 	xsi:schemaLocation="http://www.springframework.org/schema/beans 
 http://www.springframework.org/schema/beans/spring-beans-3.1.xsd 
 http://www.springframework.org/schema/context 
 http://www.springframework.org/schema/context/spring-context-3.1.xsd 
 http://www.springframework.org/schema/tx
 http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
 http://www.springframework.org/schema/mvc 
 http://www.springframework.org/schema/mvc/spring-mvc-3.1.xsd
 http://www.springframework.org/schema/aop 
 http://www.springframework.org/schema/aop/spring-aop-3.1.xsd"> 
 	
 	<bean id="propertyConfigurer"
 		class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
 		<property name="location" value="classpath:jdbc.properties" />
 	</bean>
 
 	<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
 		destroy-method="close">
 		<property name="driverClassName" value="${driver}" />
 		<property name="url" value="${url}" />
 		<property name="username" value="${username}" />
 		<property name="password" value="${password}" />
 		
 		<property name="initialSize" value="${initialSize}"></property>
 		
 		<property name="maxActive" value="${maxActive}"></property>
 		
 		<property name="maxIdle" value="${maxIdle}"></property>
 		
 		<property name="minIdle" value="${minIdle}"></property>
 		
 		<property name="maxWait" value="${maxWait}"></property>
 	</bean>
 
 	
 	<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
 		<property name="dataSource" ref="dataSource" />
 		
 		<property name="mapperLocations" value="classpath:com/wlsq/oauth/mapper/*.xml"></property>
 	</bean>
 
 	
 	<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
 		<property name="basePackage" value="com.wlsq.oauth.dao" />
 		<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property>
 	</bean>
 
 	
 	<bean id="transactionManager"
 		class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
 		<property name="dataSource" ref="dataSource" />
 	</bean>
 	
 	 
 <tx:advice id="tx"
 transaction-manager="transactionManager">
 <tx:attributes>
 <tx:method name="delete*" propagation="REQUIRED" />
 <tx:method name="insert*" propagation="REQUIRED" />
 <tx:method name="update*" propagation="REQUIRED" />
 <tx:method name="find*" read-only="true" />
 <tx:method name="get*" read-only="true" />
 <tx:method name="select*" read-only="true" />
 </tx:attributes>
 </tx:advice>
 
 <aop:config>
 <aop:pointcut id="pc" expression="execution(* com.common.service.*.*(..))" />
 
 <aop:advisor pointcut-ref="pc" advice-ref="tx" />
 </aop:config>
 
 
 <import resource="classpath:spring/spring-mongodb.xml"/>
 
 </beans>

spring-mongodb.xml

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

package com.wlsq.oauth.dao.support;
    
    import org.springframework.beans.BeansException;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.ApplicationContextAware;
    import org.springframework.data.mongodb.core.MongoTemplate;
    
    public class AbstractBaseMongoTemplete implements ApplicationContextAware {
    	protected MongoTemplate mongoTemplate;
    	
    	/**
    	 * 设置mongoTemplate
    	 * @param mongoTemplate the mongoTemplate to set
    	 */
    	public void setMongoTemplate(MongoTemplate mongoTemplate) {
    		this.mongoTemplate = mongoTemplate;
    	}
    	
    	public void setApplicationContext(ApplicationContext applicationContext)
    			throws BeansException {
    		// TODO Auto-generated method stub
    		MongoTemplate mongoTemplate = applicationContext.getBean("mongoTemplate", MongoTemplate.class);
    		setMongoTemplate(mongoTemplate);
    	}
    
    }

mongodb dao层数据库接口基类

package com.wlsq.oauth.dao.impl;
 
 import java.util.List;
 
 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 com.wlsq.oauth.dao.IUserDao;
 import com.wlsq.oauth.dao.support.AbstractBaseMongoTemplete;
 import com.wlsq.oauth.entity.User;
 
 public class UserDao extends AbstractBaseMongoTemplete implements IUserDao {
 	/**
 	 * 新增
 	 * ------------------------------ 
 	 * @param user
 	 */ 
 	public void insert(User user) {
 		// TODO Auto-generated method stub
 		mongoTemplate.insert(user);
 	}
 	/**
 	 * 批量新增
 	 * ------------------------------ 
 	 * @param users
 	 */
 	public void insertAll(List<User> users) {
 		// TODO Auto-generated method stub
 		mongoTemplate.insertAll(users);
 	}
 	/**
 	 * 删除,按主键id, 如果主键的值为null,删除会失败
 	 * ------------------------------ 
 	 * @param id
 	 */
 	public void deleteById(String id) {
 		// TODO Auto-generated method stub
 		User user = new User(id, null, 0);
 		mongoTemplate.remove(user);
 	}
 	/**
 	 * 按条件删除
 	 * ------------------------------ 
 	 * @param criteriaUser
 	 */
 	public void delete(User criteriaUser) {
 		// TODO Auto-generated method stub
 		Criteria criteria = Criteria.where("age").gt(criteriaUser.getAge());;
 		Query query = new Query(criteria);
 		mongoTemplate.remove(query, User.class);
 	}
 	/**
 	 * 删除全部
 	 * ------------------------------ 
 	 */
 	public void deleteAll() {
 		// TODO Auto-generated method stub
 		mongoTemplate.dropCollection(User.class);
 	}
 	/**
 	 * 按主键修改,
 	 * 如果文档中没有相关key 会新增 使用$set修改器
 	 * ------------------------------ 
 	 * @param user
 	 */
 	public void updateById(User user) {
 		// TODO Auto-generated method stub
 		Criteria criteria = Criteria.where("id").is(user.getId());
 		Query query = new Query(criteria);
 		Update update = Update.update("age", user.getAge()).set("name", user.getName());
 		mongoTemplate.updateFirst(query, update, User.class);
 	}
 	/**
 	 * 修改多条
 	 * ------------------------------ 
 	 * @param criteriaUser
 	 * @param user
 	 */
 	public void update(User criteriaUser, User user) {
 		// TODO Auto-generated method stub
 		Criteria criteria = Criteria.where("age").gt(criteriaUser.getAge());;
 		Query query = new Query(criteria);
 		Update update = Update.update("name", user.getName()).set("age", user.getAge());
 		mongoTemplate.updateMulti(query, update, User.class);
 	}
 	/**
 	 * 根据主键查询
 	 * ------------------------------ 
 	 * @param id
 	 * @return
 	 */
 	public User findById(String id) {
 		// TODO Auto-generated method stub
 		return mongoTemplate.findById(id, User.class);
 	}
 	/**
 	 * 查询全部
 	 * ------------------------------ 
 	 * @return
 	 */
 	public List<User> findAll() {
 		// TODO Auto-generated method stub
 		return mongoTemplate.findAll(User.class);
 	}
 	/**
 	 * 按条件查询, 分页
 	 * ------------------------------ 
 	 * @param criteriaUser
 	 * @param skip
 	 * @param limit
 	 * @return
 	 */
 	public List<User> find(User criteriaUser, int skip, int limit) {
 		// TODO Auto-generated method stub
 		Query query = getQuery(criteriaUser);
 		query.skip(skip);
 		query.limit(limit);
 		return mongoTemplate.find(query, User.class);
 	}
 	/**
 	 * 根据条件查询出来后 再去修改
 	 * ------------------------------ 
 	 * @param criteriaUser 查询条件
 	 * @param updateUser 修改的值对象
 	 * @return
 	 */
 	public User findAndModify(User criteriaUser, User updateUser) {
 		// TODO Auto-generated method stub
 		Query query = getQuery(criteriaUser);
 		Update update = Update.update("age", updateUser.getAge()).set("name", updateUser.getName());
 		return mongoTemplate.findAndModify(query, update, User.class);
 	}
 	/**
 	 * 查询出来后 删除
 	 * ------------------------------ 
 	 * @param criteriaUser
 	 * @return
 	 */
 	public User findAndRemove(User criteriaUser) {
 		// TODO Auto-generated method stub
 		Query query = getQuery(criteriaUser);
 		return mongoTemplate.findAndRemove(query, User.class);
 	}
 	/**
 	 * count
 	 * ------------------------------ 
 	 * @param criteriaUser
 	 * @return
 	 */
 	public long count(User criteriaUser) {
 		// TODO Auto-generated method stub
 		Query query = getQuery(criteriaUser);
 		return mongoTemplate.count(query, User.class);
 	}
 	/**
 	 *
 	 * ------------------------------ 
 	 * @param criteriaUser
 	 * @return
 	 */
 	private Query getQuery(User criteriaUser) {
 		if (criteriaUser == null) {
 			criteriaUser = new User();
 		}
 		Query query = new Query();
 		if (criteriaUser.getId() != null) {
 			Criteria criteria = Criteria.where("id").is(criteriaUser.getId());
 			query.addCriteria(criteria);
 		}
 		if (criteriaUser.getAge() > 0) {
 			Criteria criteria = Criteria.where("age").gt(criteriaUser.getAge());
 			query.addCriteria(criteria);
 		}
 		if (criteriaUser.getName() != null) {
 			Criteria criteria = Criteria.where("name").regex("^" + criteriaUser.getName());
 			query.addCriteria(criteria);
 		}
 		return query;
 	}
 
 }

package com.wlsq.oauth.dao;
 
 import java.util.List;
 
 import com.wlsq.oauth.entity.User;
 
 public interface IUserDao {
 	/**
 	 * 新增
 	 * ------------------------------ 
 	 * @param user
 	 */
 	void insert(User user);
 	
 	/**
 	 * 新增
 	 * ------------------------------ 
 	 * @param users
 	 */
 	void insertAll(List<User> users);
 	
 	/**
 	 * 删除,主键id, 如果主键的值为null,删除会失败
 	 * ------------------------------ 
 	 * @param id
 	 */
 	void deleteById(String id);
 	
 	/**
 	 * 按条件删除
 	 * ------------------------------ 
 	 * @param criteriaUser
 	 */
 	void delete(User criteriaUser);
 	
 	/**
 	 * 删除全部
 	 * ------------------------------ 
 	 */
 	void deleteAll();
 	
 	/**
 	 * 修改
 	 * ------------------------------ 
 	 * @param user
 	 */
 	void updateById(User user);
 	
 	/**
 	 * 更新多条
 	 * ------------------------------ 
 	 * @param criteriaUser
 	 * @param user
 	 */
 	void update(User criteriaUser, User user);
 	
 	/**
 	 * 根据主键查询
 	 * ------------------------------ 
 	 * @param id
 	 * @return
 	 */
 	User findById(String id);
 	
 	/**
 	 * 查询全部
 	 * ------------------------------ 
 	 * @return
 	 */
 	List<User> findAll();
 	
 	/**
 	 * 按条件查询
 	 * ------------------------------ 
 	 * @param criteriaUser
 	 * @param skip
 	 * @param limit
 	 * @return
 	 */
 	List<User> find(User criteriaUser, int skip, int limit);
 	
 	/**
 	 * 根据条件查询出来后 在去修改
 	 * ------------------------------ 
 	 * @param criteriaUser 查询条件
 	 * @param updateUser 修改的值对象
 	 * @return
 	 */
 	User findAndModify(User criteriaUser, User updateUser);
 	
 	/**
 	 * 查询出来后 删除
 	 * ------------------------------ 
 	 * @param criteriaUser
 	 * @return
 	 */
 	User findAndRemove(User criteriaUser);
 	
 	/**
 	 * count
 	 * ------------------------------ 
 	 * @param criteriaUser
 	 * @return
 	 */
 	long count(User criteriaUser);
 
 }

mongodb 实体类

package com.wlsq.oauth.entity;
    
    import java.io.Serializable;
    
    public class User implements Serializable {
    
    	/**
    	 * 
    	 */
    	private static final long serialVersionUID = -2634064977259616340L;
    	private String id;	
    	private String name;	
    	private int age;
    	
    	public User() {		
    	}
    
    	public User(String id, String name, int age) {
    		super();
    		this.id = id;
    		this.name = name;
    		this.age = age;
    	}
    
    	public String getId() {
    		return id;
    	}
    
    	public void setId(String id) {
    		this.id = id;
    	}
    
    	public String getName() {
    		return name;
    	}
    
    	public void setName(String name) {
    		this.name = name;
    	}
    
    	public int getAge() {
    		return age;
    	}
    
    	public void setAge(int age) {
    		this.age = age;
    	}
    	
    	
    	
    	
    	
    }