作为IT届的小弟，本篇作为本人的第一篇手记，还希望各位大牛多多指点，以下均为个人学习所得，如有错误，敬请指正。本着服务IT小白的原则，该手记比较详细。由于最近使用postgre开发大型项目，发现了关系型数据库的弊端及查询效率之慢，苦心钻研之下，对nosql的mongoDB从无知到有了初步了解。

项目环境：win10+IntelliJ IDEA2016+maven3.3.9+MongoDB 3.2+JDK1.7+spring4.1.7

推荐网站（适合学习各种知识的基础）：http://www.runoob.com/
mongo安装请参考http://www.runoob.com/mongodb/mongodb-window-install.html

由于最近osChina的maven仓库挂掉，推荐大家使用阿里的镜像，速度快的飞起
maven配置：F:.m2repository

alimavenaliyun mavenhttp://maven.aliyun.com/nexus/content/groups/public/central

这里不实用idea自带maven插件，改用3.3.9

项目结构：
这里dao与mongoDao分别为mongoDB的两种查询方式：
dao为JPA的查询方式（请参考springdataJPA）
mongoDao使用mongoTemplate，类似于关系型数据库使用的jdbcTemplate

不罗嗦，上代码
先看配置文件
spring-context.xm为最基本的spring配置

<!--扫描service包嗲所有使用注解的类型--><!-- 导入mongodb的配置文件 --><!-- 开启注解 -->

spring-web.xml为springmvc的基本配置

<!--配置springmvc--><!--1.开启springmvc注解模式--><!--简化配置：
        (1)主动注册DefaultAnnotationHandlerMapping,AnnotationMethodHandlerAdapter
        (2)提供一系列功能：数据绑定，数字和日期的format @NumberFormt @DataTimeFormat，xml json默认的读写支持--><!--servlet-mapping--><!--2静态资源默认的servlet配置，（1）允许对静态资源的处理：js，gif    （2）允许使用“/”做整体映射--><!-- 容器默认的DefaultServletHandler处理 所有静态内容与无RequestMapping处理的URL--><!--3:配置jsp 显示viewResolver--><!-- 4自动扫描且只扫描@Controller --><!-- 定义无需Controller的url<->view直接映射 -->

spring-mongo.xml为mongo配置

<!-- 加载mongodb的属性配置文件 --><!-- spring连接mongodb数据库的配置 --><!-- mongo的工厂，通过它来取得mongo实例,dbname为mongodb的数据库名，没有的话会自动创建 --><!-- 只要使用这个调用相应的方法操作 --><!-- mongodb bean的仓库目录，会自动扫描扩展了MongoRepository接口的接口进行注入 -->

mongo.properties

#mongoDB连接配置
mongo.hostport=127.0.0.1:27017
mongo.connectionsPerHost=8
mongo.threadsAllowedToBlockForConnectionMultiplier=4
#连接超时时间
mongo.connectTimeout=1000
#等待时间
mongo.maxWaitTime=1500
#Socket超时时间
mongo.socketTimeout=1500

pom.xml

4.0.0com.liadmongowar1.0-SNAPSHOTmongo Maven Webapphttp://maven.apache.org<!--使用junit4，注解的方式测试-->junitjunit4.11test<!--日志--><!--日志 slf4j,log4j,logback,common-logging--><!--slf4j是规范/接口--><!--log4j,logback,common-logging是日志实现 本项目使用slf4j + logback -->org.slf4jslf4j-api1.7.12<!--实现slf4j并整合-->ch.qos.logbacklogback-core1.1.1ch.qos.logbacklogback-classic1.1.1<!--数据库相关-->mysqlmysql-connector-java5.1.22<!--maven工作范围   驱动在真正工作的时候使用，故生命周期改为runtime-->runtime<!--servlet web相关-->taglibsstandard1.1.2jstljstl1.2com.fasterxml.jackson.corejackson-databind2.5.4<!--spring--><!--spring核心-->org.springframeworkspring-core4.1.7.RELEASEorg.springframeworkspring-beans4.1.7.RELEASEorg.springframeworkspring-context4.1.7.RELEASE<!--spring dao-->org.springframework.dataspring-data-mongodb1.8.0.RELEASEorg.mongodbmongo-java-driver3.2.2org.springframeworkspring-tx4.1.7.RELEASE<!--spring web-->org.springframeworkspring-web4.1.7.RELEASEorg.springframeworkspring-webmvc4.1.7.RELEASE<!--spring test-->org.springframeworkspring-test4.1.7.RELEASEcommons-collectionscommons-collections3.2.2commons-fileuploadcommons-fileupload1.3.2commons-codeccommons-codec1.10org.springframeworkspring-framework-bom${spring.version}pomimportnet.sf.ehcacheehcache-core2.6.9mongoorg.apache.maven.pluginsmaven-compiler-plugin1.61.6

两个实体类：


/**
 * Created by DuLida on 2016/10/20.
 */
public class Address {

    private String city;
    private String street;
    private int num;

    public Address() {
    }

    public Address(String city, String street, int num) {
        this.city = city;
        this.street = street;
        this.num = num;
    }

    public String getCity() {
        return city;
    }

    public void setCity(String city) {
        this.city = city;
    }

    public String getStreet() {
        return street;
    }

    public void setStreet(String street) {
        this.street = street;
    }

    public int getNum() {
        return num;
    }

    public void setNum(int num) {
        this.num = num;
    }

    @Override
    public String toString() {
        return "Address{" +
                "city='" + city + ''' +
                ", street='" + street + ''' +
                ", num=" + num +
                '}';
    }
}


/**
 * Created by DuLida on 2016/10/20.
 */
@Document(collection="person")
public class Person implements Serializable {

    @Id
    private ObjectId id;
    private String name;
    private int age;
    private Address address;

    public Person() {
    }

    public Person( String name, int age, Address address) {
        this.name = name;
        this.age = age;
        this.address = address;
    }

    public ObjectId getId() {
        return id;
    }

    public void setId(ObjectId 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;
    }

    public Address getAddress() {
        return address;
    }

    public void setAddress(Address address) {
        this.address = address;
    }

    @Override
    public String toString() {
        return "Person{" +
                "id=" + id +
                ", name='" + name + ''' +
                ", age=" + age +
                ", address=" + address +
                '}';
    }
}

JPA的dao，注意这里只要继承MongoRepository不用写注解spring就能认识这是个Repository，MongoRepository提供了基本的增删改查，不用实现便可直接调用，例如testMongo的personDao.save(persons);

public interface PersonDao extends MongoRepository {

    @Query(value = "{'age' : {'$gte' : ?0, '$lte' : ?1}, 'name':?2 }",fields="{ 'name' : 1, 'age' : 1}")
    List findByAge(int age1, int age2, String name);

}

mongoTemplate的dao

/**
 * Created by DuLida on 2016/10/21.
 */
public interface PersonMongoDao {
     List findAll();
     void insertPerson(Person user);
     void removePerson(String userName);
     void updatePerson();
     List findForRequery(String userName);
}

@Repository("personMongoImpl")
public class PersonMongoImpl implements PersonMongoDao {

    @Resource
    private MongoTemplate mongoTemplate;

    @Override
    public List findAll() {
        return mongoTemplate.findAll(Person.class,"person");
    }

    @Override
    public void insertPerson(Person person) {
        mongoTemplate.insert(person,"person");
    }

    @Override
    public void removePerson(String userName) {
        mongoTemplate.remove(Query.query(Criteria.where("name").is(userName)),"person");
    }

    @Override
    public void updatePerson() {
        mongoTemplate.updateMulti(Query.query(Criteria.where("age").gt(3).lte(5)), Update.update("age",3),"person");
    }

    @Override
    public List findForRequery(String userName) {
        return mongoTemplate.find(Query.query(Criteria.where("name").is(userName)),Person.class);
    }
}

JPA查询的测试类：

/**
 * Created by DuLida on 2016/10/20.
 */
@RunWith(SpringJUnit4ClassRunner.class)
//告诉junit spring配置文件
@ContextConfiguration({"classpath:spring/spring-context.xml","classpath:spring/spring-mongo.xml"})
public class PersonDaoTest {

    @Resource
    private PersonDao personDao;

    /*先往数据库中插入10个person*/
    @Test
    public void testMongo() {
        List persons = new ArrayList();
        for (int i = 0; i

mongoTemplate查询的测试类

/**
 * Created by DuLida on 2016/10/21.
 */
@RunWith(SpringJUnit4ClassRunner.class)
//告诉junit spring配置文件
@ContextConfiguration({"classpath:spring/spring-context.xml","classpath:spring/spring-mongo.xml"})
public class MongoTemplateTest {

    @Resource
    private PersonMongoImpl personMongo;

    @Test
    public void testMongoTemplate() {

        //personMongo.insertPerson(new Person("wukong",24,new Address("石家庄","鑫达路",20)));
        //personMongo.removePerson("name3");
        //personMongo.updatePerson();
        //System.out.println(personMongo.findAll());
        System.out.println(personMongo.findForRequery("wukong"));
    }
}

注意测试前请先通过testMongo()向数据库中插入数据。
项目源码Git地址，仅供学习使用：https://github.com/dreamSmile/mongo.git
参考资料http://docs.spring.io/spring-data/mongodb/docs/current/reference/html/

ITPub博客

史上最全，最详idea搭建springdata+mongoDB+mav

最新文章