摘要:开始前,建议大家去了解以下文章,当然不看也没问题: MongoDB从入门到“精通”之简介和如何安装 MongoDB从入门到“精通”之如何优雅的安装 MongoDB从入门到“精通”之整合JavaWeb项目 开发环境 JDK1.
开始前,建议大家去了解以下文章,当然不看也没问题:
开发环境
JDK1.7、Maven、Eclipse、SpringBoot1.5.2、mongodb3.4,Robomongo(可视化工具)
项目结构
相关配置
pom.xml:
4.0.0com.itstyle.mongodbspring-boot-mongodbjar0.0.1-SNAPSHOTspring-boot-mongodbhttp://maven.apache.orgUTF-81.7版本号 -->org.springframework.bootspring-boot-starter-parent1.5.2.RELEASEorg.springframework.bootspring-boot-starterorg.springframework.bootspring-boot-starter-weborg.springframework.bootspring-boot-starter-testtestorg.springframework.bootspring-boot-starter-data-mongodborg.springframework.bootspring-boot-maven-pluginorg.springframeworkspringloaded1.4.0.RELEASE
实体类 Users.java:
packagecom.itstyle.mongodb.model;importjava.io.Serializable;importorg.springframework.data.annotation.Transient;importorg.springframework.data.mongodb.core.index.CompoundIndex;importorg.springframework.data.mongodb.core.index.CompoundIndexes;importorg.springframework.data.mongodb.core.index.Indexed;importorg.springframework.data.mongodb.core.mapping.Document;@Document(collection="users")@CompoundIndexes({@CompoundIndex(name ="age_idx", def ="{'name': 1, 'age': -1}")})publicclassUsersimplementsSerializable{privatestaticfinallongserialVersionUID =1L;@IndexedprivateString uid;privateString name;privateintage;@TransientprivateString address;publicUsers(String uid, String name,intage){super();this.uid = uid;this.name = name;this.age = age; }publicStringgetUid(){returnuid; }publicvoidsetUid(String uid){this.uid = uid; }publicStringgetName(){returnname; }publicvoidsetName(String name){this.name = name; }publicintgetAge(){returnage; }publicvoidsetAge(intage){this.age = age; }publicStringgetAddress(){returnaddress; }publicvoidsetAddress(String address){this.address = address; }@OverridepublicStringtoString(){returnString.format("Customer[name='%s', age='%s']", name, age); }}
业务接口 IUserService.java:
packagecom.itstyle.mongodb.service;importjava.util.List;importcom.itstyle.mongodb.model.Users;/**
* mongodb 案例
* 创建者 小柒
* 创建时间 2017年7月19日
*
*/publicinterfaceIUserService{publicvoidsaveUser(Users users);publicUsersfindUserByName(String name);publicvoidremoveUser(String name);publicvoidupdateUser(String name, String key, String value);publicListlistUser();}
业务实现UserServiceImpl.java:
package com.itstyle.mongodb.service.impl;importjava.util.List;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.data.mongodb.core.MongoOperations;importorg.springframework.data.mongodb.core.query.Criteria;importorg.springframework.data.mongodb.core.query.Query;importorg.springframework.data.mongodb.core.query.Update;importorg.springframework.stereotype.Component;importcom.itstyle.mongodb.model.Users;importcom.itstyle.mongodb.service.IUserService;@Component("userService")publicclassUserServiceImplimplementsIUserService{@AutowiredMongoOperations mongoTemplate; publicvoidsaveUser(Users users) { mongoTemplate.save(users); } public Users findUserByName(Stringname) {returnmongoTemplate.findOne(newQuery(Criteria.where("name").is(name)), Users.class); } publicvoidremoveUser(Stringname) { mongoTemplate.remove(newQuery(Criteria.where("name").is(name)), Users.class); } publicvoidupdateUser(Stringname,Stringkey,Stringvalue) { mongoTemplate.updateFirst(newQuery(Criteria.where("name").is(name)), Update.update(key, value), Users.class); } publicList listUser() {returnmongoTemplate.findAll(Users.class); }}
启动类Application.java:
packagecom.itstyle.mongodb;importorg.apache.log4j.Logger;importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.EnableAutoConfiguration;importorg.springframework.context.annotation.ComponentScan;@EnableAutoConfiguration@ComponentScan(basePackages={"com.itstyle.mongodb"})publicclassApplication{privatestaticfinalLogger logger = Logger.getLogger(Application.class);publicstaticvoidmain(String[] args)throwsInterruptedException { SpringApplication.run(Application.class, args); logger.info("项目启动 "); }}
基础配置application.properties:
# 项目contextPath,一般在正式发布版本中server.context-path=/mongodb# 服务端口server.port=8080# session最大超时时间(分钟),默认为30server.session-timeout=60# 该服务绑定IP地址,启动服务器时如本机不是该IP地址则抛出异常启动失败,只有特殊需求的情况下才配置# server.address=192.168.16.11# tomcat最大线程数,默认为200server.tomcat.max-threads=800# tomcat的URI编码server.tomcat.uri-encoding=UTF-8#mongo2.x支持以上两种配置方式 mongo3.x仅支持uri方式#mongodb note:mongo3.x will not use host and port,only use uri#spring.data.mongodb.host=192.168.1.180#spring.data.mongodb.port=27017#spring.data.mongodb.database=itstyle#没有设置密码#spring.data.mongodb.uri=mongodb://192.168.1.180:27017/itstyle#设置了密码spring.data.mongodb.uri=mongodb://itstyle:itstyle@192.168.1.180:27017/itstyle
测试类SpringbootMongodbApplication.java:
packagecom.itstyle.mongodb.test;importjava.util.List;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.boot.CommandLineRunner;importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.context.annotation.ComponentScan;importcom.itstyle.mongodb.model.Users;importcom.itstyle.mongodb.service.IUserService;@SpringBootApplication@ComponentScan(basePackages={"com.itstyle.mongodb"})publicclassSpringbootMongodbApplicationimplementsCommandLineRunner{@AutowiredprivateIUserService userService;publicstaticvoidmain(String[] args){ SpringApplication.run(SpringbootMongodbApplication.class, args); }@Overridepublicvoidrun(String... args)throwsException{try{ Users users =newUsers("1","小明",10); users.setAddress("青岛市"); userService.saveUser(users); List list = userService.listUser(); System.out.println("一共这么多人:"+list.size()); }catch(Exception e) { e.printStackTrace(); } }}
最后,运行测试类,使用可视化工具Robomongo查看:
注解说明
@Document
标注在实体类上,与hibernate异曲同工。
@Document(collection="users")publicclassUsersimplementsSerializable{privatestaticfinallongserialVersionUID =1L; ...省略代码
@CompoundIndex
复合索引,加复合索引后通过复合索引字段查询将大大提高速度。
@Document(collection="users")@CompoundIndexes({@CompoundIndex(name ="age_idx",def="{'name': 1, 'age': -1}")})publicclassUsersimplementsSerializable{privatestaticfinallongserialVersionUID =1L; ...省略代码
@Id
MongoDB默认会为每个document生成一个 _id 属性,作为默认主键,且默认值为ObjectId,可以更改 _id 的值(可为空字符串),但每个document必须拥有 _id 属性。
当然,也可以自己设置@Id主键,不过官方建议使用MongoDB自动生成。
@Indexed
声明该字段需要加索引,加索引后以该字段为条件检索将大大提高速度。
唯一索引的话是@Indexed(unique = true)。
也可以对数组进行索引,如果被索引的列是数组时,mongodb会索引这个数组中的每一个元素。
@IndexedprivateStringuid;
@Transient
被该注解标注的,将不会被录入到数据库中。只作为普通的javaBean属性。
@TransientprivateStringaddress;
@Field
代表一个字段,可以不加,不加的话默认以参数名为列名。
@Field("firstName")privateString name;
当然了,以上的以上,可能仅仅是冰山一角,还有很多特性等待大家去挖掘。
代码:http://git.oschina.net/52itstyle/spring-boot-mongodb
作者: 小柒
本文版权归作者和云栖社区所有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出, 如有问题, 可邮件(345849402@qq.com)咨询。