Spring boot中使用Mongodb

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

安装

使用Idea新建Spring boot工程时需要选择Mongodb

或者在工程中加入依赖

Maven：

<dependency>

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

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

</dependency>

Gradle：

dependencies {

  compile('org.springframework.boot:spring-boot-starter-data-mongodb')

}

目录结构

配置

在application.yml中配置

spring:

  data:

      mongodb:

        uri: mongodb://test:test@127.0.0.1:27017/test

或者在application.properties配置

spring.data.mongodb.uri=mongodb://test:test@127.0.0.1:27017/test

其中URL的格式是：mongodb://用户名:用户名@ip地址:端口/数据库

使用

在实体类中加入注解

package com.example.demo.domain;

import org.springframework.data.annotation.Id;

import org.springframework.data.mongodb.core.index.IndexDirection;

import org.springframework.data.mongodb.core.index.Indexed;

import org.springframework.data.mongodb.core.mapping.Document;

import java.io.Serializable;

/**

 * 用户模型

 *

 * @author hackyo

 * Created on 2017/12/3 11:53.

 */

@Document

public class User implements Serializable {

    @Id

    private String id;

    @Indexed(unique = true, direction = IndexDirection.DESCENDING, dropDups = true)

    private String username;

    public String getId() {

        return id;

    }

    public void setId(String id) {

        this.id = id;

    }

    public String getUsername() {

        return username;

    }

    public void setUsername(String username) {

        this.username = username;

    }

}

@Document表示该类为实体类

@Id表示该字段为自动生成的ID

@Indexed表示自动为该字段建立索引

编写查询接口

package com.example.demo.dao;

import com.example.demo.domain.User;

/**

 * 用户表操作接口

 *

 * @author hackyo

 * Created on 2017/12/3 11:53.

 */

public interface IUserRepository {

    /**

     * 通过用户名查找用户

     *

     * @param username 用户名

     * @return 用户信息

     */

    User findByUsername(String username);

}

查询接口实现

package com.example.demo.dao.impl;

import com.example.demo.dao.IUserRepository;

import com.example.demo.domain.User;

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.stereotype.Repository;

/**

 * 用户表操作接口实现

 *

 * @author hackyo

 * Created on 2017/12/3 11:53.

 */

@Repository

public class UserRepositoryImpl implements IUserRepository {

    private MongoTemplate mongoTemplate;

    @Autowired

    public UserRepositoryImpl(MongoTemplate mongoTemplate) {

        this.mongoTemplate = mongoTemplate;

    }

    @Override

    public User findByUsername(String username) {

        Query query = new Query(Criteria.where("username").is(username));

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

    }

}

测试

测试类

package com.example.demo;

import com.example.demo.dao.IUserRepository;

import com.example.demo.domain.User;

import org.junit.Test;

import org.junit.runner.RunWith;

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

import org.springframework.boot.test.context.SpringBootTest;

import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)

@SpringBootTest

public class DemoApplicationTests {

    @Autowired

    private IUserRepository userRepository;

    @Test

    public void contextLoads() {

    }

    @Test

    public void test() {

        User user = userRepository.findByUsername("test");

        System.out.println(user.getId());

    }

}

查询出结果即完成