赞
踩
在前面的文章中,我们详细地介绍了 MongoDB 的配置和使用,如果你对 MongoDB 还不是很了解,也没关系,在 MongoDB 中有三个比较重要的名词:数据库、集合、文档!
搞懂这三个名词,基本就可以上手了,今天我们以 Java 语言为例,详细地介绍 Java 客户端改如何操作 MongoDB !
话不多说,直接开撸!
Java 连接 MongoDB 服务器,与我们常用的连接关系型数据库方式类似!
标准 URI 连接语法:
mongodb://username:password@host1:port1,host2:port2,...,hostN:portN/database?options
参数说明:
例如,无密码连接 MongoDB
mongodb://127.0.0.1:27017
使用用户名test,密码test登录 MongoDB 的test_db数据库
mongodb://test:test@127.0.0.1:27017/test_db
无密码连接指定三台服务器 (端口 27017, 27018, 和27019)
mongodb://127.0.0.1:27017,127.0.0.1:27018,127.0.0.1:27019
和关系型数据库操作一样,在 Java 程序中如果要使用 MongoDB,先要添加对应的 MongoDB JDBC 驱动器,然后才能继续操作!
在选择的版本号的时候,注意需要和服务器中的安装版本匹配,具体的版本号选择可以从如下地址中获取到最新的版本:mongo-java-driver
- <dependency>
- <groupId>org.mongodb</groupId>
- <artifactId>mongo-java-driver</artifactId>
- <version>3.12.7</version>
- </dependency>
连接数据库的 Java 代码如下:
- private static MongoClient mongoClient;
-
- static {
- try {
- //连接到MongoDB服务 如果是远程连接可以替换“localhost”为服务器所在IP地址
- mongoClient = MongoClients.create("mongodb://test:test@127.0.0.1:27017/test_db");
- System.out.println("Connect to database successfully");
- } catch (Exception e) {
- System.err.println( e.getClass().getName() + ": " + e.getMessage() );
- }
- }
上文中采用的是用户名和密码方式登录数据库,因为数据库已经开启了权限验证,因此需要通过用户名和密码才能登录。
com.mongodb.client包里面都帮我们集成好了大部分常用的 api,我们可以通过MongoDatabase类中的createCollection()方法来创建集合。
创建一个tb_role集合,代码片段如下:
- /**
- * 创建集合
- * @param args
- */
- public static void main(String[] args) {
- // 连接到数据库
- MongoDatabase mongoDatabase = mongoClient.getDatabase("test_db");
- System.out.println("Connect to database successfully");
- mongoDatabase.createCollection("tb_role");
- System.out.println("集合创建成功");
- }
如果想删除集合,操作也很简单!
- /**
- * 删除集合
- * @param args
- */
- public static void main(String[] args) {
- // 连接到数据库
- MongoDatabase mongoDatabase = mongoClient.getDatabase("test_db");
- System.out.println("Connect to database successfully");
- mongoDatabase.getCollection("tb_role").drop();
- System.out.println("集合 tb_role 删除成功");
- }
我们可以通过MongoCollection类中的insertMany()方法来插入一个文档。
向tb_role集合中插入文档,代码片段如下:
- /**
- * 插入文档
- * @param args
- */
- public static void main(String[] args) {
- // 连接到数据库
- MongoDatabase mongoDatabase = mongoClient.getDatabase("test_db");
- System.out.println("Connect to database successfully");
- //获取集合
- MongoCollection<Document> collection = mongoDatabase.getCollection("tb_role");
-
- //向集合中插入文档
- Document document = new Document("name", "管理员").
- append("code", "manager").
- append("sort", 100);
- List<Document> documents = new ArrayList<>();
- documents.add(document);
- collection.insertMany(documents);
- System.out.println("文档插入成功");
- }
我们可以通过MongoCollection类中的updateMany()方法来更新集合中的文档。
更新tb_role集合中的指定文档信息,代码片段如下:
- /**
- * 更新文档
- * @param args
- */
- public static void main(String[] args) {
- // 连接到数据库
- MongoDatabase mongoDatabase = mongoClient.getDatabase("test_db");
- System.out.println("Connect to database successfully");
- //获取集合
- MongoCollection<Document> collection = mongoDatabase.getCollection("tb_role");
-
- //更新文档
- collection.updateMany(Filters.eq("code", "manager"), new Document("$set",new Document("name","经理")));
-
- //遍历所有文档
- FindIterable<Document> findIterable = collection.find();
- MongoCursor<Document> mongoCursor = findIterable.iterator();
- while(mongoCursor.hasNext()){
- System.out.println(mongoCursor.next());
- }
- }
上文操作类似于 SQL语句中的update tb_role set name = '经理' where code = 'manager'!
我们可以通过MongoCollection类中的deleteOne()或者deleteMany方法来删除集合中的文档。
删除tb_role集合中的指定文档信息,代码片段如下:
- /**
- * 删除文档
- * @param args
- */
- public static void main(String[] args) {
- // 连接到数据库
- MongoDatabase mongoDatabase = mongoClient.getDatabase("test_db");
- System.out.println("Connect to database successfully");
- //获取集合
- MongoCollection<Document> collection = mongoDatabase.getCollection("tb_role");
-
- //删除符合条件的第一个文档
- collection.deleteOne(Filters.eq("code", "manager"));
- //删除所有符合条件的文档
- collection.deleteMany (Filters.eq("code", "manager"));
-
- //遍历所有文档
- FindIterable<Document> findIterable = collection.find();
- MongoCursor<Document> mongoCursor = findIterable.iterator();
- while(mongoCursor.hasNext()){
- System.out.println(mongoCursor.next());
- }
- }
在这里需要注意一下,在删除的时候,官方推荐尽可能先查询一下这个数据是否存在,如果存在,然后在执行删除操作,可以调用findOneAndDelete()方法进行删除!
MongoCollection类中提供了非常丰富的检索文档的方法,例如,我们可以通过find()方法来获取集合中的所有文档。
检索tb_role集合中的文档信息,代码片段如下:
- /**
- * 查询文档
- * @param args
- */
- public static void main(String[] args) {
- // 连接到数据库
- MongoDatabase mongoDatabase = mongoClient.getDatabase("test_db");
- System.out.println("Connect to database successfully");
- //获取集合
- MongoCollection<Document> collection = mongoDatabase.getCollection("tb_role");
-
- //遍历所有文档
- FindIterable<Document> findIterable = collection.find();
- MongoCursor<Document> mongoCursor = findIterable.iterator();
- while(mongoCursor.hasNext()){
- System.out.println(mongoCursor.next());
- }
-
- //查询当前集合所有文档数量
- long count = collection.countDocuments();
- System.out.println("当前文档数量:" + count);
-
- //带条件遍历文档
- FindIterable<Document> documentFindIterable = collection.find(Filters.eq("code", "manager"));
- MongoCursor<Document> documentMongoCursor = documentFindIterable.iterator();
- while(documentMongoCursor.hasNext()){
- System.out.println(documentMongoCursor.next());
- }
- }
采用 SpringBoot 来对接 MongoDB,可以说极其简单,下面就以常用的几个操作为例来介绍,过程如下!
- <!-- 引入springboot -->
- <parent>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-parent</artifactId>
- <version>2.1.0.RELEASE</version>
- </parent>
-
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-data-mongodb</artifactId>
- </dependency>
在application.properties文件中添加mongodb配置
- #配置数据库连接地址
- spring.data.mongodb.uri=mongodb://test123:test123@127.0.0.1:27017/test_db
创建用于示例中测试的实体类Person。
其中注解@Document(collection="persons")用于指定当前文档属于集合persons。
注解@Id表示当前id字段属于主键类型。
- /**
- * 使用@Document注解指定集合名称
- */
- @Document(collection="persons")
- public class Person implements Serializable {
- private static final long serialVersionUID = -3258839839160856613L;
-
- /**
- * 使用@Id注解指定MongoDB中的 _id 主键
- */
- @Id
- private Long id;
-
- private String userName;
-
- private String passWord;
-
- private Integer age;
-
- private Date createTime;
-
- //...get/set
-
- @Override
- public String toString() {
- return "Person{" +
- "id=" + id +
- ", userName='" + userName + '\'' +
- ", passWord='" + passWord + '\'' +
- ", age=" + age +
- ", createTime=" + createTime +
- '}';
- }
- }
Springboot 操作 MongoDB 有两种方式。
本文将采用第二种方式进行介绍!
MongoTemplate提供了insert()方法,用于插入文档,示例代码如下:
没指定集合名称时,会取@Document注解中的集合名称
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 插入文档
- * @throws Exception
- */
- @Test
- public void insert() throws Exception {
- Person person =new Person();
- person.setId(1l);
- person.setUserName("张三");
- person.setPassWord("123456");
- person.setCreateTime(new Date());
- mongoTemplate.insert(person);
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 自定义集合,插入文档
- * @throws Exception
- */
- @Test
- public void insertCustomCollection() throws Exception {
- Person person =new Person();
- person.setId(1l);
- person.setUserName("张三");
- person.setPassWord("123456");
- person.setCreateTime(new Date());
- mongoTemplate.insert(person, "custom_person");
- }
- }
如果采用批量插入文档,必须指定集合名称
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 自定义集合,批量插入文档
- * @throws Exception
- */
- @Test
- public void insertBatch() throws Exception {
- List<Person> personList = new ArrayList<>();
- Person person1 =new Person();
- person1.setId(10l);
- person1.setUserName("张三");
- person1.setPassWord("123456");
- person1.setCreateTime(new Date());
- personList.add(person1);
-
- Person person2 =new Person();
- person2.setId(11l);
- person2.setUserName("李四");
- person2.setPassWord("123456");
- person2.setCreateTime(new Date());
- personList.add(person2);
-
- mongoTemplate.insert(personList, "custom_person");
- }
- }
MongoTemplate提供了save()方法,用于存储文档。
在存储文档的时候会通过主键ID进行判断,如果存在就更新,否则就插入,示例代码如下:
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 存储文档,如果没有插入,否则更新
- * @throws Exception
- */
- @Test
- public void save() throws Exception {
- Person person =new Person();
- person.setId(13l);
- person.setUserName("八八");
- person.setPassWord("123456");
- person.setAge(40);
- person.setCreateTime(new Date());
- mongoTemplate.save(person);
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 自定义集合,存储文档
- * @throws Exception
- */
- @Test
- public void saveCustomCollection() throws Exception {
- Person person =new Person();
- person.setId(1l);
- person.setUserName("张三");
- person.setPassWord("123456");
- person.setCreateTime(new Date());
- mongoTemplate.save(person, "custom_person");
- }
- }
MongoTemplate提供了updateFirst()和updateMulti()方法,用于更新文档,示例代码如下:
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 更新文档,匹配查询到的文档数据中的第一条数据
- * @throws Exception
- */
- @Test
- public void updateFirst() throws Exception {
- //更新对象
- Person person =new Person();
- person.setId(1l);
- person.setUserName("张三123");
- person.setPassWord("123456");
- person.setCreateTime(new Date());
-
- //更新条件
- Query query= new Query(Criteria.where("id").is(person.getId()));
-
- //更新值
- Update update= new Update().set("userName", person.getUserName()).set("passWord", person.getPassWord());
- //更新查询满足条件的文档数据(第一条)
- UpdateResult result =mongoTemplate.updateFirst(query,update, Person.class);
- if(result!=null){
- System.out.println("更新条数:" + result.getMatchedCount());
- }
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 更新文档,匹配查询到的文档数据中的所有数据
- * @throws Exception
- */
- @Test
- public void updateMany() throws Exception {
- //更新对象
- Person person =new Person();
- person.setId(1l);
- person.setUserName("张三");
- person.setPassWord("123456");
- person.setCreateTime(new Date());
-
- //更新条件
- Query query= new Query(Criteria.where("id").is(person.getId()));
-
- //更新值
- Update update= new Update().set("userName", person.getUserName()).set("passWord", person.getPassWord());
- //更新查询满足条件的文档数据(全部)
- UpdateResult result = mongoTemplate.updateMulti(query, update, Person.class);
- if(result!=null){
- System.out.println("更新条数:" + result.getMatchedCount());
- }
- }
- }
MongoTemplate提供了remove()、findAndRemove()和findAllAndRemove()方法,用于删除文档,示例代码如下:
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 删除符合条件的所有文档
- * @throws Exception
- */
- @Test
- public void remove() throws Exception {
- Person person =new Person();
- person.setId(1l);
- person.setUserName("张三");
- person.setPassWord("123456");
- person.setCreateTime(new Date());
-
- Query query = new Query(Criteria.where("userName").is(person.getUserName()));
- DeleteResult result = mongoTemplate.remove(query, Person.class);
- System.out.println("删除条数:" + result.getDeletedCount());
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 删除符合条件的单个文档,并返回删除的文档
- * @throws Exception
- */
- @Test
- public void findAndRemove() throws Exception {
- Person person =new Person();
- person.setId(1l);
- person.setUserName("张三");
- person.setPassWord("123456");
- person.setCreateTime(new Date());
-
- Query query = new Query(Criteria.where("id").is(person.getId()));
- Person result = mongoTemplate.findAndRemove(query, Person.class);
- System.out.println("删除的文档数据:" + result.toString());
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 删除符合条件的所有文档,并返回删除的文档
- * @throws Exception
- */
- @Test
- public void findAllAndRemove() throws Exception {
- Person person =new Person();
- person.setId(1l);
- person.setUserName("张三");
- person.setPassWord("123456");
- person.setCreateTime(new Date());
-
- Query query = new Query(Criteria.where("id").is(person.getId()));
- List<Person> result = mongoTemplate.findAllAndRemove(query, Person.class);
- System.out.println("删除的文档数据:" + result.toString());
- }
- }
MongoTemplate提供了非常多的文档查询方法,日常开发中用的最多的就是find()方法,示例代码如下:
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 查询集合中的全部文档数据
- * @throws Exception
- */
- @Test
- public void findAll() throws Exception {
- List<Person> result = mongoTemplate.findAll(Person.class);
- System.out.println("查询结果:" + result.toString());
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 查询集合中指定的ID文档数据
- * @throws Exception
- */
- @Test
- public void findById() {
- long id = 1l;
- Person result = mongoTemplate.findById(id, Person.class);
- System.out.println("查询结果:" + result.toString());
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 根据条件查询集合中符合条件的文档,返回第一条数据
- */
- @Test
- public void findOne() {
- String userName = "张三";
- Query query = new Query(Criteria.where("userName").is(userName));
- Person result = mongoTemplate.findOne(query, Person.class);
- System.out.println("查询结果:" + result.toString());
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 根据条件查询集合中符合条件的文档
- */
- @Test
- public void findByCondition() {
- String userName = "张三";
- Query query = new Query(Criteria.where("userName").is(userName));
- List<Person> result = mongoTemplate.find(query, Person.class);
- System.out.println("查询结果:" + result.toString());
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 根据【AND】关联多个查询条件,查询集合中的文档数据
- */
- @Test
- public void findByAndCondition() {
- // 创建条件
- Criteria criteriaUserName = Criteria.where("userName").is("张三");
- Criteria criteriaPassWord = Criteria.where("passWord").is("123456");
- // 创建条件对象,将上面条件进行 AND 关联
- Criteria criteria = new Criteria().andOperator(criteriaUserName, criteriaPassWord);
- // 创建查询对象,然后将条件对象添加到其中
- Query query = new Query(criteria);
- List<Person> result = mongoTemplate.find(query, Person.class);
- System.out.println("查询结果:" + result.toString());
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 根据【OR】关联多个查询条件,查询集合中的文档数据
- */
- @Test
- public void findByOrCondition() {
- // 创建条件
- Criteria criteriaUserName = Criteria.where("userName").is("张三");
- Criteria criteriaPassWord = Criteria.where("passWord").is("123456");
- // 创建条件对象,将上面条件进行 OR 关联
- Criteria criteria = new Criteria().orOperator(criteriaUserName, criteriaPassWord);
- // 创建查询对象,然后将条件对象添加到其中
- Query query = new Query(criteria);
- List<Person> result = mongoTemplate.find(query, Person.class);
- System.out.println("查询结果:" + result.toString());
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 根据【IN】关联多个查询条件,查询集合中的文档数据
- */
- @Test
- public void findByInCondition() {
- // 设置查询条件参数
- List<Long> ids = Arrays.asList(1l, 10l, 11l);
- // 创建条件
- Criteria criteria = Criteria.where("id").in(ids);
- // 创建查询对象,然后将条件对象添加到其中
- Query query = new Query(criteria);
- List<Person> result = mongoTemplate.find(query, Person.class);
- System.out.println("查询结果:" + result.toString());
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 根据【逻辑运算符】查询集合中的文档数据
- */
- @Test
- public void findByOperator() {
- // 设置查询条件参数
- int min = 20;
- int max = 35;
- Criteria criteria = Criteria.where("age").gt(min).lte(max);
- // 创建查询对象,然后将条件对象添加到其中
- Query query = new Query(criteria);
- List<Person> result = mongoTemplate.find(query, Person.class);
- System.out.println("查询结果:" + result.toString());
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 根据【正则表达式】查询集合中的文档数据
- */
- @Test
- public void findByRegex() {
- // 设置查询条件参数
- String regex = "^张*";
- Criteria criteria = Criteria.where("userName").regex(regex);
- // 创建查询对象,然后将条件对象添加到其中
- Query query = new Query(criteria);
- List<Person> result = mongoTemplate.find(query, Person.class);
- System.out.println("查询结果:" + result.toString());
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 根据条件查询集合中符合条件的文档,获取其文档列表并排序
- */
- @Test
- public void findByConditionAndSort() {
- String userName = "张三";
- Query query = new Query(Criteria.where("userName").is(userName)).with(Sort.by("age"));
- List<Person> result = mongoTemplate.find(query, Person.class);
- System.out.println("查询结果:" + result.toString());
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 根据单个条件查询集合中的文档数据,并按指定字段进行排序与限制指定数目
- */
- @Test
- public void findByConditionAndSortLimit() {
- String userName = "张三";
- //从第一行开始,查询2条数据返回
- Query query = new Query(Criteria.where("userName").is(userName)).with(Sort.by("createTime")).limit(2).skip(1);
- List<Person> result = mongoTemplate.find(query, Person.class);
- System.out.println("查询结果:" + result.toString());
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 统计集合中符合【查询条件】的文档【数量】
- */
- @Test
- public void countNumber() {
- // 设置查询条件参数
- String regex = "^张*";
- Criteria criteria = Criteria.where("userName").regex(regex);
- // 创建查询对象,然后将条件对象添加到其中
- Query query = new Query(criteria);
- long count = mongoTemplate.count(query, Person.class);
- System.out.println("统计结果:" + count);
- }
- }
索引在所有的数据库中,暂居的位置非常重要,例如当你检索一张上百万的数据表的时候,如果没走索引,查询效率会极其缓慢,对于 MongoDB 来说,同样如此。
示例如下:
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 创建升序索引
- */
- @Test
- public void createAscendingIndex() {
- // 设置字段名称
- String field = "userName";
- // 创建索引
- mongoTemplate.getCollection("persons").createIndex(Indexes.ascending(field));
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 根据索引名称移除索引
- */
- @Test
- public void removeIndex() {
- // 设置字段名称
- String field = "userName";
- // 删除索引
- mongoTemplate.getCollection("persons").dropIndex(field);
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest
- public class PersonServiceTest {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- /**
- * 查询集合中所有的索引
- */
- @Test
- public void getIndexAll() {
- // 获取集合中所有列表
- ListIndexesIterable<Document> indexList = mongoTemplate.getCollection("persons").listIndexes();
- // 获取集合中全部索引信息
- for (Document document : indexList) {
- System.out.println("索引列表:" + document);
- }
- }
- }
- /**
- * 使用@Document注解指定集合名称
- */
- @Document(collection="persons")
- public class Person implements Serializable {
- private static final long serialVersionUID = -3258839839160856613L;
-
- /**
- * 使用@Id注解指定MongoDB中的 _id 主键
- */
- @Id
- private Long id;
-
- private String userName;
-
- private String passWord;
-
- private Integer age;
-
- /**
- * 创建一个5秒之后文档自动删除的索引
- */
- @Indexed(expireAfterSeconds=5)
- private Date createTime;
-
- //...get/set
-
- @Override
- public String toString() {
- return "Person{" +
- "id=" + id +
- ", userName='" + userName + '\'' +
- ", passWord='" + passWord + '\'' +
- ", age=" + age +
- ", createTime=" + createTime +
- '}';
- }
- }
单节点 mongodb 不支持事务,需要搭建 MongoDB 复制集。
- /**
- * 配置事务管理器
- *
- */
- @Configuration
- public class TransactionConfig {
-
- @Bean
- MongoTransactionManager transactionManager(MongoDatabaseFactory dbFactory) {
- return new MongoTransactionManager(dbFactory);
- }
-
- }
事务服务测试!
- @Service
- public class TransactionExample {
-
- @Autowired
- private MongoTemplate mongoTemplate;
-
- @Transactional(rollbackFor = Exception.class)
- public Object transactionTest(){
- Person person =new Person();
- person.setId(1l);
- person.setUserName("张三");
- person.setPassWord("123456");
- person.setCreateTime(new Date());
- Person newPerson = mongoTemplate.insert(person);
- // 抛出异常,观察数据是否进行回滚
- if(1 == 1){
- throw new RuntimeException("异常");
- }
- return newPerson;
- }
- }
本文主要围绕 MongoDB 的 Java 客户端使用进行基本的增删改查操作介绍,在实际的业务场景中,可能还需要用到聚合函数等高级查询,大家如果有这种需求,可以访问如下地址获取更加详细的api 文档介绍:MongoDB 文档查询api 介绍
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。