当前位置:首页 > 开发 > 数据库 > 正文

[Spring Data Mongo一]Spring Mongo Template操作MongoDB

发表于: 2014-08-11   作者:bit1129   来源:转载   浏览:
摘要: 什么是Spring Data Mongo Spring Data MongoDB项目对访问MongoDB的Java客户端API进行了封装,这种封装类似于Spring封装Hibernate和JDBC而提供的HibernateTemplate和JDBCTemplate,主要能力包括 1. 封装客户端跟MongoDB的链接管理 2. 文档-对象映射,通过注解:@Document(collectio

什么是Spring Data Mongo

Spring Data MongoDB项目对访问MongoDB的Java客户端API进行了封装,这种封装类似于Spring封装Hibernate和JDBC而提供的HibernateTemplate和JDBCTemplate,主要能力包括

1. 封装客户端跟MongoDB的链接管理

2. 文档-对象映射,通过注解:@Document(collection="collectionName")

3.对模版式的代码,进行了封装,类似于JDBCTemplate和HibernateTemplate

 

Spring Data Mongo在Spring中的基本配置

 

<?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:mongo="http://www.springframework.org/schema/data/mongo"
       xsi:schemaLocation="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 replica-set="localhost:27018,localhost:27017,localhost:27019">
        <mongo:options connections-per-host="200"
                       threads-allowed-to-block-for-connection-multiplier="100"
                       connect-timeout="1000"
                       max-wait-time="1500"
                       auto-connect-retry="true"
                       socket-keep-alive="true"
                       socket-timeout="1500"
                       slave-ok="true"
                       write-number="1"
                       write-timeout="0"
                       write-fsync="true"/>
    </mongo:mongo>
    <mongo:db-factory dbname="foolbar" username="" password="" mongo-ref="mongo"/>
    <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
        <constructor-arg name="mongoDbFactory" ref="mongoDbFactory"/>
    </bean>
</beans>

 说明:

1.其中的mongoTemplate是客户端操作MongoDB的主要类,它包含了增删改查功能以及其它一些操作,这些操作在以后的篇幅中会讲到

2.replica-set是副本集集群的MongoDB服务器的链接地址,以逗号分开,如果仅有一台服务器,使用host="localhost:27017”或者replica-set="localhost:27017"都可以,

3.mongo:options定义了链接属性和读写相关属性,以后再来完善这部分

 

Document和Collection注解

 

package com.tom.user.model;

import org.bson.types.ObjectId;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;

@Document(collection = "users")
public class User {
    @Id
    private ObjectId userId;
    private String name;
    private String passwd;

    public ObjectId getUserId() {
        return userId;
    }

    public void setUserId(ObjectId userId) {
        this.userId = userId;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getPasswd() {
        return passwd;
    }

    public void setPasswd(String passwd) {
        this.passwd = passwd;
    }
}

 上面的代码定义了一个类似于Hibernate实体Bean的POJO,在Hibernate它可以和数据库的一个表建立映射关系,但是在MongoDB中,一个集合中的文档的Field是任意的,因此POJO必须映射到文档一级(@Document),同时注解中指明这个文档属于哪个集合(一个文档只能属于一个集合)。当使用MongoDBTemplate对POJO进行操作时,可以根据POJO的类型得到它要往那个集合中写文档

 

 MongoDBTemplate简单CRUD操作

 

package com.tom.user.storage;

import com.tom.user.model.User;
import org.junit.Assert;
import org.junit.Before;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
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 java.util.List;

/*
http://www.tuicool.com/articles/EFnyye
http://www.mkyong.com/mongodb/spring-data-mongodb-hello-world-example/

 */
public class UserMongoDBStorageServiceTest2 {

    private ApplicationContext cxt  = null;

    @Before
    public void setup() {
        cxt = new ClassPathXmlApplicationContext("applicationContext.xml");

    }

    private void create() {
        drop();
        MongoTemplate template = cxt.getBean("mongoTemplate", MongoTemplate.class);
        User user = new User();
        user.setName("abc");
        user.setPasswd("def");
        template.insert(user);
    }

    public void query() {
        Query query = new Query(new Criteria("name").is("abc"));
        MongoTemplate template = cxt.getBean("mongoTemplate", MongoTemplate.class);
        List<User> users = template.find(query, User.class);
        Assert.assertEquals(1, users.size());
        User user = users.get(0);
        Assert.assertEquals("abc", user.getName());
        Assert.assertEquals("def", user.getPasswd());
    }

    public void update() {
        Query query = new Query(new Criteria("name").is("abc"));
        MongoTemplate template = cxt.getBean("mongoTemplate", MongoTemplate.class);
        List<User> users = template.find(query, User.class);
        Assert.assertEquals(1, users.size());
        User user = users.get(0);
        user.setPasswd("def-updated");
        Update update = new Update();
        update.set("passwd",user.getPasswd());
        template.updateFirst(query, update, User.class);

        Assert.assertEquals("abc", user.getName());
    }

    public void queryUpdate() {
        MongoTemplate template = cxt.getBean("mongoTemplate", MongoTemplate.class);
        List<User> users = template.findAll(User.class);
        Assert.assertEquals(1, users.size());
        User user = users.get(0);
        Assert.assertEquals("abc", user.getName());
        Assert.assertEquals("def-updated",user.getPasswd());
    }

    public void drop() {
        MongoTemplate template = cxt.getBean("mongoTemplate", MongoTemplate.class);
        template.dropCollection(User.class);
    }

    @org.junit.Test
    public void testCRUD() {
        create();
        query();
        update();
        queryUpdate();
        drop();
    }
}

 

 

只对Update操作做下说明:

 

 

    public void update() {
        Query query = new Query(new Criteria("name").is("abc"));
        MongoTemplate template = cxt.getBean("mongoTemplate", MongoTemplate.class);
        List<User> users = template.find(query, User.class);
        Assert.assertEquals(1, users.size());
        User user = users.get(0);
        user.setPasswd("def-updated");
        Update update = new Update();
        update.set("passwd",user.getPasswd());
        template.updateFirst(query, update, User.class);

        Assert.assertEquals("abc", user.getName());
    }

 

 

User两个字段name和passwd,Update中只通过Update.set方法对passwd进行了更改,那么name这个属性在更新操作完成后是从文档中被删除了还是保留下来了?答案是保留下来了,并且值保持不变,这就为更新操作提供了很大的便利性,要改什么就在Update中指定什么,

 

Spring Data Mongo连接MongoDB服务器的参数

 

[Spring Data Mongo一]Spring Mongo Template操作MongoDB

  • 0

    开心

    开心

  • 0

    板砖

    板砖

  • 0

    感动

    感动

  • 0

    有用

    有用

  • 0

    疑问

    疑问

  • 0

    难过

    难过

  • 0

    无聊

    无聊

  • 0

    震惊

    震惊

编辑推荐
【MongoDB for Java】Java操作MongoDB 上一篇文章: http://www.cnblogs.com/hoojo/archive/2011/06/
本文章根据: http://us.php.net/manual/en/class.mongocollection.php http://www.cnblogs.com/xffy
1.以下从官方下载示例,下载地址如下所示: http://www.springsource.org/samples 2.排错, 刚下载
Preface The Spring Data MongoDB project applies core Spring concepts to the development of so
之前尝试在windows下c++直接调用mongo,但是出现各种问题,后来只好作罢。 现尝试用c++调用python来
STEP 1: Create new webapp project, I will use maven for this. (Note: I am on my macbook with
在阅读本文前需要以下先决条件 电脑上安装了jdk1.7或以上版本 安装了maven3以上版本 安装了eclipse
目前MongoDB针对各种语言都已经有了相应的驱动,但是写好一个驱动的关键是理解MongoDB提供的协议,
Replica Sets(复制集)是在mongodDB1.6版本号開始新增的功能。它能够实现故障自己主动切换和自己主
Replica Sets(复制集)是在mongodDB1.6版本开始新增的功能,它可以实现故障自动切换和自动修复功能
版权所有 IT知识库 CopyRight © 2009-2015 IT知识库 IT610.com , All Rights Reserved. 京ICP备09083238号