Spring Boot 中应用Spring data mongdb

2022-07-13 09:39:34

摘要

本文主要简单介绍下如何在Spring Boot 项目中使用Spring data mongdb.没有深入探究，仅供入门参考。

文末有代码链接

准备

安装mongodb

需要连接mongodb，所以需要提前安装mongodb.在本地安装

安装完mongodb后配置环境变量。创建目录“C:\data\db”作为mongo 数据存储的默认文件

注意本篇文章代码连接的mongo3.2.

在window7 64 bit 上安装mongo，可以选择Windows Server 2008 R2 64-bit

例程

配置数据库连接

在main/resource/ 下添加application.yml文件

spring:
        data:
             mongodb:
               host: localhost
               port: 27017
               database: test

Spring boot 会检测MongoDb中是否存在db test。如果没有会创建

model

创建一个person document 类。作为Mongodb的document 映射。加上@Document 注解

@Document(collection="personDocument")
public class PersonDocument {
        @Id
        String id;
        String name;
        String description;
       }

repository

repository 就是DAO,将域类型和它的ID类型作为类型参数。Spring Data JPA 在JPA(Java Persistence Api)又做了一层封装。因此我们可以看到，只需要编写repository 接口即可。

@Repository
public interface PersonRepository extends MongoRepository<PersonDocument,String>{
    PersonDocument findByName(String name);
}

这些接口会通过Proxy来自动实现。所以接口里面的方法名不是随意写。需要遵循一定的规范。像上面的 “findByName”是查询语句，Name必须是PersonDocument中的字段，否则会报错。

And 关键字表示的就是SQL中的and

LessThan 关键词表示的就是SQL 中的 <

等等，还有许多基本的SQL实现

service

service 层和之前的写法没什么不同，调用repository，实现业务逻辑

@EnableMongoRepositories(basePackages = "com.example.dao.repository")
@Service
public class PersonServiceImpl  implements PersonService{

    @Autowired
    private PersonRepository personRepo;

    public PersonDocument getPersonDocumentByName(String name) {
        PersonDocument doc = personRepo.findByName(name);
        return doc;
    }

    public PersonDocument create(PersonDocument personDoc) {
        personDoc = personRepo.save(personDoc);
        return personDoc;
    }

}

test

@SpringBootApplication
public class DemoApplication implements CommandLineRunner {

    @Autowired
    private PersonService personService;

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }

    @Override
    public void run(String... arg0) throws Exception {
        PersonDocument doc = new PersonDocument("tom", "student");
        personService.create(doc);
        PersonDocument doc2 = personService.getPersonDocumentByName("tom");
        System.out.println("result:" + doc2.getName());

    }

完整代码 github source code