[Java知识库]springBoot整合mongodb-jpa

第1步：基于maven新建springBoot工程

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.8.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.springcloud</groupId>
    <artifactId>mogodb_springboot_jpa</artifactId>
    <version>1.1.0</version>
    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <configuration>
                    <source>8</source>
                    <target>8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!-- Apache Lang3 -->
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
            <version>3.9</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-mongodb</artifactId>
            <version>2.2.2.RELEASE</version>
        </dependency>

        <!-- JSON 解析器和生成器 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.74</version>
        </dependency>


        <!--Jackson required包-->
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-core</artifactId>
            <version>2.11.2</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>2.11.2</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-annotations</artifactId>
            <version>2.11.2</version>
        </dependency>

        <dependency>
            <groupId>javax.servlet</groupId>
            <artifactId>servlet-api</artifactId>
            <version>2.5</version>
            <scope>provided</scope>
        </dependency>
    </dependencies>

第2步：配置application.properties文件

server.port=8090
spring.application.name=mongodb-8090
spring.data.mongodb.host=192.168.42.22
spring.data.mongodb.port=27017
spring.data.mongodb.database=db_resume

第3步：编写实体类，并在实体类上面加上注解 @Docment("集合名")

package com.springcloud.domian.bean;

import org.apache.commons.lang3.builder.ToStringBuilder;

import java.math.BigDecimal;
import java.util.Date;


public class Resume {

    private String id;

    private String name;

    private String city;

    private Date birthday;

    private BigDecimal expectSalary;

    public Resume() {
    }

    @Override
    public String toString() {
        return ToStringBuilder.reflectionToString(this);
    }

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

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

    public String getCity() {
        return city;
    }

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

    public Date getBirthday() {
        return birthday;
    }

    public void setBirthday(Date birthday) {
        this.birthday = birthday;
    }

    public BigDecimal getExpectSalary() {
        return expectSalary;
    }

    public void setExpectSalary(BigDecimal expectSalary) {
        this.expectSalary = expectSalary;
    }
}

第4步：编写Repository接口, 继承MongoRepository

package com.springcloud.repository;

import com.springcloud.domian.bean.Resume;
import org.springframework.data.mongodb.repository.MongoRepository;


public interface ResumeRepository extends MongoRepository<Resume, String> {
}

第5步： 从Spring容器中获取Repository对象进行数据操作

package com.springcloud.service.impl;

import com.springcloud.domian.bean.Resume;
import com.springcloud.repository.ResumeRepository;
import com.springcloud.service.IResumeService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Example;
import org.springframework.data.domain.ExampleMatcher;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Objects;

@Service
public class ResumeServiceImpl implements IResumeService {

    @Autowired
    private ResumeRepository resumeRepository;

    @Override
    public Resume findByName(String name) {
        Resume resume = new Resume();
        resume.setName(name);
        Example<Resume> resumeExample = Example.of(resume);

        return resumeRepository.findOne(resumeExample);
    }

    @Override
    public Resume insertResume(Integer no) throws ParseException {
        Resume resume = new Resume();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
        resume.setName("李" + no);
        resume.setCity("hk" + no);
        resume.setBirthday(sdf.parse("1996-03-14"));
        resume.setExpectSalary(new BigDecimal("15000"));
        resumeRepository.insert(resume);
        return resume;
    }

    @Override
    public Boolean updateResume(String id, String name) {
        Resume resume = resumeRepository.findOne(id);
        resume.setName(name);
        Resume save = resumeRepository.save(resume);
        return (Objects.nonNull(save) ? Boolean.TRUE : Boolean.FALSE);
    }

    @Override
    public Boolean deleteResume(String id) {
        resumeRepository.delete(id);
        return Boolean.TRUE;
    }

    /**
     * 分页查询
     *
     * @param name
     * @param currentPage
     * @param pageSize
     * @return
     */
    @Override
    public Page<Resume> listByName(String name, int currentPage, int pageSize) {
        Sort sort = new Sort(Sort.Direction.DESC, "city");
        Pageable pageable = new PageRequest(currentPage - 1, pageSize, sort);

        //创建匹配器，即如何使用查询条件
        ExampleMatcher matcher = ExampleMatcher.matching()
                .withStringMatcher(ExampleMatcher.StringMatcher.CONTAINING)
                .withIgnoreCase(true)
                .withMatcher("name", ExampleMatcher.GenericPropertyMatchers.contains())
                .withIgnorePaths("pageNum", "pageSize");

        //创建实例
        Resume resume = new Resume();
        resume.setName(name);
        Example<Resume> example = Example.of(resume, matcher);
        Page<Resume> resumes = resumeRepository.findAll(example, pageable);
        return resumes;
    }
}

测试结果：

????????① 查询document: http://localhost:8090/resume/query/document?name=李1

? ② 新增document： http://localhost:8090/resume/document/add?no=1

?③ 更新document：

??http://localhost:8090/resume/document/update?id=625533977654045b6ce01685&name=离家程

?

?

④ 删除document：

http://localhost:8090/resume/document/delete?id=625535e77654045b6ce01688

? ⑤ 分页查询document:

http://localhost:8090/resume/list/document?name=张三&currentPage=1&pageSize=10

?

总结

????????在进行分页查询的时候，需要特别注意的是，传递的分页参数的page是从0开始的，即0代表是第1页，要是不注意的话，就会造成查不到数据，或者是查询的数据不准确，需要做代码上的兼容，即：

Pageable pageable = new PageRequest(currentPage - 1, pageSize, sort);

源代码地址：springcloud-learn: 自建springcloud项目（练习） - Gitee.com

超强干货来袭

云风专访：近40年码龄，通宵达旦的技术人生