SpringBoot中简单使用mongodb

SpringBoot中简单使用mongodb

  配置application.properties 应该放最前面

#单机

spring.data.mongodb.uri=mongodb://name:pass@localhost:27017/test

#集群 还没测试

spring.data.mongodb.uri=mongodb://ip1:port1,ip2:port2/database

1. 构建一个entity class: Movie

import org.springframework.data.annotation.Id;

public class Movie {

    @Id

    private String id;

    private String name;

    private String title;

    public Movie(String id, String name, String title) {

        this.id = id;

        this.name = name;

        this.title = title;

    }

    public Movie() {

    }

    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 getTitle() {

        return title;

    }

    public void setTitle(String title) {

        this.title = title;

    }

    @Override

    public String toString() {

        return "Movie{" +

                "id='" + id + '\'' +

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

                ", title='" + title + '\'' +

                '}';

    }

}

实体类Movie 映射到mongodb 中某一个Collection中某一个具体Document， 其中    

@Id表示 对应Document中的主键，也就是objectId

ref: https://spring.io/guides/gs/accessing-data-mongodb/
MongoDB stores data in collections. Spring Data MongoDB will map the

class Movie into a collection called Movie. If you want to change

the name of the collection, you can use Spring Data MongoDB’s @Document annotation on the class.

2.  在mapper/dao层定义一个接口，访问mongodb 

import com.zhou.spring.springboot.sudy1.model.Movie;

import org.springframework.data.mongodb.repository.MongoRepository;

public interface MovieRepository extends MongoRepository<Movie, String> {  

    public  Movie findByName(String name);

    @Override

    Movie findOne(String s);

}

MongoRepository<T, ID extends Serializable>, T对应实体类， TD表示对应主键id

3. service 层可以再封装一层， 根据具体业务进行进一步处理

创建class MovieService

import com.zhou.spring.springboot.sudy1.mapper.MovieRepository;

import com.zhou.spring.springboot.sudy1.model.Movie;

import org.springframework.stereotype.Service;

import javax.annotation.Resource;

import java.util.List;

@Service

public class MovieService {

    @Resource

    MovieRepository movRes;

    public Movie findByName(String name) {

        return  movRes.findByName( name );

    }

    public Movie findById(String id) {

        return movRes.findOne(id );

    }

    public List<Movie> findMoveList( ){

        return movRes.findAll();

    }

}

4. 测试

import com.zhou.spring.springboot.sudy1.model.Movie;

import org.junit.Assert;

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 Sudy1ApplicationTests {

@Autowired
private MovieRepository movRes;

@Test
public void test() throws Exception {
// 创建三个User，并验证User总数

movRes.save(new Movie("1", "fast", "fast") );

        Movie m2 = new Movie("2", "faster", "faster");
movRes.save( m2 );

//Assert.assertEquals(3, movRes.findAll().size());

        Assert.assertEquals( m2.getId(), movRes.findByName( "faster" ).getId());

        Assert.assertEquals( m2.getName(), movRes.findByName( "faster" ).getName());

        Assert.assertEquals( m2.getTitle(), movRes.findByName( "faster" ).getTitle());
}

    @Test

    public void test2() throws Exception {

        // 创建三个User，并验证User总数

        Movie mov = movRes.findOne( "5982e265468ac80e8f771b02") ;

        System.out.println( mov );

    }

}

5. controller层可定义接口， 通过web端对数据进行远程访问

@RestController

public class QueryMovie {

    @Resource

    private MovieService movieService;

    //http://localhost:8080/api/hello

    @RequestMapping("/api/hello")

    public String index() {

        return "Hello World!!The World is beautiful!!!!!!!";

    }

    //http://localhost:8080/api/getMovieById?id=1

    //curl http://localhost:8080/api/getUserById?id=1&name=xiaohong
    @RequestMapping(value = "/api/getMovieById",

            method={RequestMethod.POST, RequestMethod.GET} )

    public Movie getMoveById(@RequestParam String id ) {

        return movieService.findById( id );

    }

    //http://localhost:8080/api/getMovieByName?name=fast

    //curl -d "name=xiaohong&id=1" "http://localhost:8080/api/getUserByName"

    @RequestMapping(value = "/api/getMovieByName",

            method={RequestMethod.POST, RequestMethod.GET} )

    public Movie getMoveByName(@RequestParam String name ) {

        return movieService.findByName( name );

    }

    //http://localhost:8080/api/findAllMovies

    @RequestMapping(value = "/api/findAllMovies",

            method={RequestMethod.POST, RequestMethod.GET} )

    public List<Movie> findAllUsers(  ) {

        return  movieService.findMoveList();

    }

}

ref:  https://spring.io/guides/gs/accessing-data-mongodb/

      http://blog.didispace.com/springbootmongodb/
      http://blog.scottlogic.com/2016/11/22/spring-boot-and-mongodb.html
      http://www.jianshu.com/p/fe3b9532b852
      https://docs.spring.io/spring-boot/docs/current/reference/html/boot-features-nosql.html
      http://www.ityouknow.com/springboot/2017/05/08/springboot-mongodb.html