springBoot系列(集成mongodb)

《springBoot系列(集成mongodb)》要点:
本文介绍了springBoot系列(集成mongodb),希望对您有用。如果有疑问,可以联系我们。

《springBoot系列(集成mongodb)》是否对您有启发,欢迎查看更多与《springBoot系列(集成mongodb)》相关教程,学精学透。编程之家PHP学院为您提供精彩教程。

一、添加对应的依赖

<!-- mongodb -->

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-data-mongodb</artifactId>

</dependency>

二、配置属性文件application.properties

spring.data.mongodb.host=localhost

spring.data.mongodb.port=27018

spring.data.mongodb.database=mongodb_test

三、创建实体类

package com.example.demo.pojo;

import java.util.Date;

public class Person {

private int id;

private String name;

private Date createTime;

public int getId() {

return id;

}

public void setId(int id) {

this.id = id;

}

public String getName() {

return name;

}

public void setName(String name) {

this.name = name;

}

public Date getCreateTime() {

return createTime;

}

public void setCreateTime(Date createTime) {

this.createTime = createTime;

}

@Override

public String toString() {

return "Person{" +

"id=" + id +

",name='" + name + '\'' +

",createTime=" + createTime +

'}';

}

}

四、使用MongoTemplate实现

package com.example.demo.utils.component;

import com.example.demo.pojo.Person;

import org.springframework.beans.factory.annotation.Autowired;

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 org.springframework.stereotype.Component;

@Component

public class MongodbComponent {

@Autowired

private MongoTemplate mongoTemplate;

public void insert(Person p) {

mongoTemplate.insert(p);

}

public void deleteById(int id) {

Criteria criteria = Criteria.where("id").in(id);

Query query = new Query(criteria);

mongoTemplate.remove(query,Person.class);

}

public void updateById(Person p) {

Criteria criteria = Criteria.where("id").in(p.getId());

Query query = new Query(criteria);

Update update = new Update();

update.set("name",p.getName());

update.set("createTime",p.getCreateTime());

mongoTemplate.updateMulti(query,update,Person.class);

}

public Person selectById(int id) {

Criteria criteria = Criteria.where("id").in(id);

Query query = new Query(criteria);

return mongoTemplate.findOne(query,Person.class);

}

}

package com.example.demo;

import com.example.demo.pojo.Person;

import com.example.demo.utils.component.MongodbComponent;

import org.junit.Test;

import org.springframework.beans.factory.annotation.Autowired;

import java.util.Date;

public class MongoTemplateTest extends{ ApplicationTests {

@Autowired

private MongodbComponent mongodbComponent;

@Test

public void insert() {

Person p = new Person();

p.setId(1);

p.setName("哈哈");

p.setCreateTime(new Date());

mongodbComponent.insert(user);

}

@Test

public void select() {

System.out.println(mongodbComponent.selectById(1));

}

@Test

public void update() {

Person p = new Person();

p.setId(1);

p.setName("李四");

p.setCreateTime(new Date());

mongodbComponent.updateById(p);

System.out.println(mongodbComponent.selectById(1));

}

@Test

public void delete() {

mongodbComponent.deleteById(1);

}

}

springBoot系列(集成mongodb)

相关文章

解析思路 我们建立好一个SpringBoot的工程后,我们将从启动类,SpringBootApplication开始进行探究。 开...
问题现象 org.springframework.context.ApplicationContextException: Unable to start embedded conta...
异常信息 分析原因 1.该异常是如何产生的 我是通过postman,发送一个post请求,导致该异常的。 从上面的...
有时候会出现这种情况,看一下项目的pom中是否有这个插件配置,没有的话需要引入。
使用方式 在类上打上@slf4j注解 打上注解后可以操作log对象 增加配置文件 在resources下增加配置文件。...
一、概述 Spring框架是以 简化Java EE应用程序的开发 为目标而创建的。Spring可以实现很多功能,但是这...