Spring Data MongoDB 一：入門篇（環境搭建、簡單的CRUD操作）

原文：http://blog.csdn.net/congcong68/article/details/44545253

 

 

一.簡介

     Spring Data  MongoDB 項目提供與MongoDB文檔數據庫的集成。Spring Data MongoDB POJO的關鍵功能區域為中心的模型與MongoDB的DBCollection輕松地編寫一個存儲庫交互數據訪問。

二.Spring Data MongoDB的配置以及下載對應的Jar

  1.安裝MongoDb數據庫，我們在上一篇就已經介紹過了，這邊就不在介紹了，MongoDB 入門（安裝與配置）

   2.下載spring的spring-data的子項目兩個jar，分別是spring-data-commons和spring-data-mongodb

           http://projects.spring.io/spring-data-mongodb/

           我這邊下載是兩個jar分別是：

          spring-data-commons-1.7.2.RELEASE.jar

         spring-data-mongodb-1.4.2.RELEASE.jar

   3.下載mongoDb的java驅動jar包

       http://central.maven.org/maven2/org/mongodb/mongo-java-driver/

       這邊有很多版本，下載自己對應得版本，我下載是：

        mongo-java-driver-2.9.3.jar

         

 

 

   4.用Java測試一下MongoDB是否能正常連接

 

public class TestMongodb {
    @Test
    public void testMongodb()
    {
      try{
            // 連接到 mongodb 服務
             Mongo mongo = new Mongo("127.0.0.1", 27017);
            //根據mongodb數據庫的名稱獲取mongodb對象 ,
             DB db = mongo.getDB( "test" );
             Set<String> collectionNames = db.getCollectionNames();
               // 打印出test中的集合
              for (String name : collectionNames) {
                    System.out.println("collectionName==="+name);
              }

          }catch(Exception e){
             e.printStackTrace();
          }

  運行能獲取test數據庫下的集合，說明能正常連接數據庫

 

     

5.Spring的配置文件

   1）applicationContext-mongo.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:aop="http://www.springframework.org/schema/aop"
    xmlns:tx="http://www.springframework.org/schema/tx" xmlns:util="http://www.springframework.org/schema/util"
    xmlns:context="http://www.springframework.org/schema/context" 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/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
    http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
    http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-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/context http://www.springframework.org/schema/context/spring-context-3.0.xsd">
    <context:component-scan base-package="com.mongo" />
    <!-- 獲取配置資源 -->
    <context:property-placeholder location="classpath:jdbc.properties" />

    <bean class="cn.mongo.util.SpringContextUtil"></bean>

    <mongo:mongo id="mongo"  replica-set="${mongo.replicaSet}">
      <!--
         connections-per-host: 每個主機答應的連接數（每個主機的連接池大小），當連接池被用光時，會被阻塞住
         max-wait-time: 被阻塞線程從連接池獲取連接的最長等待時間（ms）
         connect-timeout:在建立（打開）套接字連接時的超時時間（ms）
         socket-timeout:套接字超時時間;該值會被傳遞給Socket.setSoTimeout(int)
         slave-ok:指明是否答應驅動從次要節點或者奴隸節點讀取數據
         -->
    <mongo:options
        connections-per-host="${mongo.connectionsPerHost}"
        threads-allowed-to-block-for-connection-multiplier="${mongo.threadsAllowedToBlockForConnectionMultiplier}"
        connect-timeout="${mongo.connectTimeout}"
        max-wait-time="${mongo.maxWaitTime}"
        auto-connect-retry="${mongo.autoConnectRetry}"
        socket-keep-alive="${mongo.socketKeepAlive}"
        socket-timeout="${mongo.socketTimeout}"
        slave-ok="${mongo.slaveOk}"
        write-number="${mongo.writeNumber}"
        write-timeout="${mongo.riteTimeout}"
        write-fsync="${mongo.writeFsync}"/>
    </mongo:mongo>
       <!-- 設置使用的數據庫 名-->
      <mongo:db-factory dbname="test" mongo-ref="mongo"/>
      <!-- mongodb的模板 -->
     <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
        <constructor-arg name="mongoDbFactory" ref="mongoDbFactory"/>
     </bean>
</beans>

  

 

 2）jdbc.properties

 

mongo.replicaSet=127.0.0.1:27017
mongo.connectionsPerHost=8
mongo.threadsAllowedToBlockForConnectionMultiplier=4
mongo.connectTimeout=1000
mongo.maxWaitTime=1500
mongo.autoConnectRetry=true
mongo.socketKeepAlive=true
mongo.socketTimeout=1500
mongo.slaveOk=true
mongo.writeNumber=1
mongo.riteTimeout=0
mongo.writeFsync=true

說明：

 

 我們可以上官方網查看文檔http://docs.spring.io/spring-data/data-mongo/docs/1.7.0.RC1/reference/html/#mongodb-connectors，這里面有說明怎么配置

   

三.Spring 實現MongoDB的CRUD操作

    1.實現一個基礎接口，是比較通用的 MongoBase.java類

 

public interface MongoBase<T> {
    //添加
    public void insert(T object,String collectionName);
    //根據條件查找
    public T findOne(Map<String,Object> params,String collectionName);
    //查找所有
    public List<T> findAll(Map<String,Object> params,String collectionName);
    //修改
    public void update(Map<String,Object> params,String collectionName);
    //創建集合
    public void createCollection(String collectionName);
    //根據條件刪除
    public void remove(Map<String,Object> params,String collectionName);

}

  

 

   2.實現一個實體類，我這邊實現了User類

 

  @Document注解，表示這個POJO最終要持久化為MongoDB中的document

 

@Document
public class User implements Serializable {
    /**
     *
     */
    private static final long serialVersionUID = 1L;
    private String id;
    private String name;
    private int age;
    private String password;

    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;
    }
    public String getPassword() {
        return password;
    }
    public void setPassword(String password) {
        this.password = password;
    }
    public String getId() {
        return id;
    }
    public void setId(String id) {
        this.id = id;
    }



}

 3.實現UserDao類，就是實現User自己操作數據庫的接口，這個UserDao也繼承了MongoBase接口，我們這邊UserDao沒實現其他額外的接口

    

public interface UserDao extends MongoBase<User>{

}

 

 4.實現UserDaoImpl具體類，這邊是實際操作數據庫

     

@Repository("userDaoImpl")
public class UserDaoImpl implements UserDao {

    @Resource
    private MongoTemplate mongoTemplate;

    @Override
    public void insert(User object,String collectionName) {
        mongoTemplate.insert(object, collectionName);
    }

    @Override
    public User findOne(Map<String,Object> params,String collectionName) {
         return mongoTemplate.findOne(new Query(Criteria.where("id").is(params.get("id"))), User.class,collectionName);
    }

    @Override
    public List<User> findAll(Map<String,Object> params,String collectionName) {
        List<User> result = mongoTemplate.find(new Query(Criteria.where("age").lt(params.get("maxAge"))), User.class,collectionName);
        return result;
    }

    @Override
    public void update(Map<String,Object> params,String collectionName) {
        mongoTemplate.upsert(new Query(Criteria.where("id").is(params.get("id"))), new Update().set("name", params.get("name")), User.class,collectionName);
    }

    @Override
    public void createCollection(String name) {
        mongoTemplate.createCollection(name);
    }


    @Override
    public void remove(Map<String, Object> params,String collectionName) {
        mongoTemplate.remove(new Query(Criteria.where("id").is(params.get("id"))),User.class,collectionName);
    }

 

  說明：

       我們可以上官方網查看文檔http://docs.spring.io/spring-data/data-mongo/docs/1.7.0.RC1/reference/html/#mongodb-connectors

        mongoTemplate.upsert

             

              這邊update里面提供了很多功能，可以根據條件進行修改，Criteria這個類也提供了where 、and、lt等，我們在查詢年齡大於30的查出來，mongoTemplate.find(new Query(Criteria.where("age").lt(params.get("maxAge"))), User.class,collectionName);Criteria還很多

   如圖所示：

                

   4.實現測試類

      我們這邊為了節省時間，就沒寫服務類，我們直接調用dao就可以了，實現了TestUser.java類

      1）添加並根據條件查找列表

         

public class TestUser {

    private static UserDao userDaoImpl;
    private static  ClassPathXmlApplicationContext  app;
    private static String collectionName;
    @BeforeClass
    public static void initSpring() {
        try {
         app = new ClassPathXmlApplicationContext(new String[] { "classpath:applicationContext-mongo.xml",
                "classpath:spring-dispatcher.xml" });
        userDaoImpl = (UserDao) app.getBean("userDaoImpl");
        collectionName ="users";
        } catch (Exception e) {
            e.printStackTrace();
        }
           }

        @Test
        public void testAdd()
        {

            //添加一百個user
            for(int i=0;i<100;i++){
                User user =new User();
                user.setId(""+i);
                user.setAge(i);
                user.setName("zcy"+i);
                user.setPassword("zcy"+i);
                userDaoImpl.insert(user,collectionName);
            }
            Map<String,Object> params=new HashMap<String,Object>();
            params.put("maxAge", 50);
            List<User> list=userDaoImpl.findAll(params,collectionName);
            System.out.println("user.count()=="+list.size());
        }

   運行一下，我們能正常查找年齡大於50的

 

        

    2）根據ID進行修改

         

           @Test
ublic void testUdate(){
Map<String,Object> params=new HashMap<String,Object>();
params.put("id", "1");
User user=userDaoImpl.findOne(params, collectionName);
System.out.println("user.name==="+user.getName());
System.out.println("=============update==================");
params.put("name", "hello");
userDaoImpl.update(params, collectionName);
 user=userDaoImpl.findOne(params, collectionName);
System.out.println("user.name==="+user.getName());

 

     3）根據ID刪除對應的數據

         

            @Test
ublic void testRemove(){
Map<String,Object> params=new HashMap<String,Object>();
params.put("id", "2");
userDaoImpl.remove(params, collectionName);
User user=userDaoImpl.findOne(params, collectionName);
System.out.println("user=="+user);