使用spring连接及操作mongodb3.0实例

前边有一篇记录过不使用spring，直接在java代码中连接和操作mongodb数据库，这里就紧随其后记录一下使用spring的情况下，在java中简单操作mongodb。

maven导包配置：

因为涉及了sping以及springmvc，因此也需要导入它们相关的包：

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> 
 <modelVersion>4.0.0</modelVersion> 
 <groupId>spring_mongo</groupId> 
 <artifactId>spring_mongo</artifactId> 
 <packaging>war</packaging> 
 <version>0.0.1-SNAPSHOT</version> 
 <name>spring_mongo Maven Webapp</name> 
 <url>http://maven.apache.org</url> 
 <dependencies> 
  <dependency> 
    <groupId>org.springframework.data</groupId> 
    <artifactId>spring-data-mongodb</artifactId> 
    <version>1.8.0.RELEASE</version> 
  </dependency> 
  <dependency> 
    <groupId>org.mongodb</groupId> 
    <artifactId>mongo-java-driver</artifactId> 
    <version>3.0.3</version> 
  </dependency> 
  <dependency> 
    <groupId>commons-logging</groupId> 
    <artifactId>commons-logging</artifactId> 
    <version>1.2</version> 
  </dependency> 
  <dependency> 
    <groupId>org.springframework</groupId> 
    <artifactId>spring-test</artifactId> 
    <version>4.1.6.RELEASE</version> 
  </dependency> 
  <dependency> 
    <groupId>junit</groupId> 
    <artifactId>junit</artifactId> 
    <version>4.11</version> 
  </dependency> 
  <dependency> 
    <groupId>org.springframework</groupId> 
    <artifactId>spring-context</artifactId> 
    <version>4.1.7.RELEASE</version> 
  </dependency> 
  <dependency> 
    <groupId>org.springframework</groupId> 
    <artifactId>spring-context-support</artifactId> 
    <version>4.0.9.RELEASE</version> 
  </dependency> 
 </dependencies> 
 <build> 
 <plugins> 
      <plugin> 
        <artifactId>maven-compiler-plugin</artifactId> 
        <version>2.3.2</version> 
        <configuration> 
          <source>1.7</source> 
          <target>1.7</target> 
          <encoding>UTF-8</encoding> 
          <compilerArguments>  
           <verbose />  
           <bootclasspath>${java.home}/lib/rt.jar;${java.home}/lib/jce.jar</bootclasspath>  
          </compilerArguments>  
        </configuration> 
      </plugin> 
    </plugins> 
  <finalName>spring_mongo</finalName> 
 </build> 
</project> 

spring基础配置：

主要是开启注解扫描等：

<?xml version="1.0" encoding="UTF-8"?> 
<beans xmlns:task="http://www.springframework.org/schema/task" 
  xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
  xmlns:context="http://www.springframework.org/schema/context" 
  xsi:schemaLocation=" 
http://www.springframework.org/schema/beans 
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd 
http://www.springframework.org/schema/context 
http://www.springframework.org/schema/context/spring-context-3.0.xsd 
http://www.springframework.org/schema/task 
http://www.springframework.org/schema/task/spring-task-3.1.xsd"> 
 
  <!-- 自动扫描(自动注入) --> 
  <context:component-scan base-package="spring_mogo.dao.daoImp" /> 
 
  <!-- 导入mongodb的配置文件 --> 
  <import resource="spring-mongodb305.xml" /> 
 
  <!-- 开启注解 --> 
  <context:annotation-config /> 
 
</beans> 

spring连接mongodb以及建立相关工厂的配置：

<?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:mongo="http://www.springframework.org/schema/data/mongo" 
  xsi:schemaLocation="http://www.springframework.org/schema/beans  
        http://www.springframework.org/schema/beans/spring-beans-3.0.xsd 
        http://www.springframework.org/schema/data/mongo 
      http://www.springframework.org/schema/data/mongo/spring-mongo.xsd"> 
 
  <!-- spring连接mongodb数据库的配置 --> 
  <mongo:mongo-client host="192.168.0.201" port="27017" credentials="tuzongxun:123456@mongoTest" id="mongo">  
    <mongo:client-options write-concern="SAFE"/>  
  </mongo:mongo-client>  
 
  <mongo:db-factory id="mongoDbFactory" dbname="mongoTest" mongo-ref="mongo" />  
 
  <!-- 只要使用这个调用相应的方法操作 --> 
  <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">  
    <constructor-arg name="mongoDbFactory" ref="mongoDbFactory" />  
  </bean>   
 
</beans> 

与数据库对应的实体类：

需要注意的是这里需要实现序列化的接口并设置uid的属性，否则不能在操作中直接把数据库返回结果转换成对象属性：

package spring_mongo.models; 
 
import java.io.Serializable; 
 
public class UserModel implements Serializable { 
 
  private static final long serialVersionUID = 1L; 
  private String userName; 
  private String password; 
 
  public UserModel(String userName,String password) { 
    super(); 
    this.userName = userName; 
    this.password = password; 
  } 
 
  public String getUserName() { 
    return userName; 
  } 
 
  public void setUserName(String userName) { 
    this.userName = userName; 
  } 
 
  public String getPassword() { 
    return password; 
  } 
 
  public void setPassword(String password) { 
    this.password = password; 
  } 
 
} 

根据spring配置获取操作mongodb的MongoTemplete，需要实现ApplicationContextAware接口：

package spring_mogo.dao.daoImp; 
 
import org.springframework.beans.BeansException; 
import org.springframework.context.ApplicationContext; 
import org.springframework.context.ApplicationContextAware; 
import org.springframework.data.mongodb.core.MongoTemplate; 
 
public abstract class AbstractBaseMongoTemplete implements 
    ApplicationContextAware { 
 
  protected MongoTemplate mongoTemplate; 
 
  /** 
   * @Description 根据配置文件设置mongoTemplate 
   * @param mongoTemplate 
   */ 
  public void setMongoTemplate(MongoTemplate mongoTemplate) { 
    this.mongoTemplate = mongoTemplate; 
  } 
 
  @Override 
  public void setApplicationContext(ApplicationContext applicationContext) 
      throws BeansException { 
    MongoTemplate mongoTemplate = applicationContext.getBean( 
        "mongoTemplate",MongoTemplate.class); 
    setMongoTemplate(mongoTemplate); 
  } 
} 

操作数据库的接口以及对应的实现类：

演示了最基础的增删改查，需要注意的地方在于参数的声明以及接收返回数据时和实体类的转换：

（1）接口：

package spring_mogo.dao; 
 
import java.util.List; 
 
import spring_mongo.models.UserModel; 
 
public interface UserDao { 
  /** 
   * 查询数据 
   * 
   * @author：tuzongxun 
   * @Title: findAll 
   * @param @return 
   * @return List<UserModel> 
   * @date May 13,2016 3:07:39 PM 
   * @throws 
   */ 
  public List<UserModel> findAll(); 
 
  /** 
   * 新增数据 
   * 
   * @author：tuzongxun 
   * @Title: insertUser 
   * @param @param user 
   * @return void 
   * @date May 13,2016 3:09:45 PM 
   * @throws 
   */ 
  public void insertUser(UserModel user); 
 
  /** 
   * 删除数据 
   * 
   * @author：tuzongxun 
   * @Title: removeUser 
   * @param @param userName 
   * @return void 
   * @date May 13,2016 3:09:55 PM 
   * @throws 
   */ 
  public void removeUser(String userName); 
 
  /** 
   * 修改数据 
   * 
   * @author：tuzongxun 
   * @Title: updateUser 
   * @param @param user 
   * @return void 
   * @date May 13,2016 3:10:06 PM 
   * @throws 
   */ 
  public void updateUser(UserModel user); 
 
  /** 
   * 按条件查询 
   * 
   * @author：tuzongxun 
   * @Title: findForRequery 
   * @param 
   * @return void 
   * @date May 13,2016 3:23:37 PM 
   * @throws 
   */ 
  public List<UserModel> findForRequery(String userName); 
 
}