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
