809      阿里云  技术社区[云栖]

spring boot集成mongodb最简单版

通过spring tools suite新建一个spring project。带maven的即可

pom.xml文件配置

新建实体类 SysUser

 
package entity;

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

@Document
public class SysUser  {
	//mongodb需要指定ID
	 @Id
	private long seqid;
	
	private String name;

	private String password;
	
	private long roleId;

	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public String getPassword() {
		return password;
	}
	public void setPassword(String password) {
		this.password = password;
	}
	public long getRoleId() {
		return roleId;
	}
	public void setRoleId(long roleId) {
		this.roleId = roleId;
	}

	public long getSeqid() {
		return seqid;
	}
	public void setSeqid(long seqid) {
		this.seqid = seqid;
	}

}

建立接口SysUserRepository extends MongoRepository

package mapper;
import org.springframework.data.mongodb.repository.MongoRepository;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Transactional;
import entity.SysUser;

@Component
public interface SysUserRepository extends MongoRepository {
	SysUser findByName(String name); //自定义的方法
}

建立service类，写业务逻辑方法

SysUserService
package service;
import java.util.List;
import mapper.SysUserRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.RequestMapping;
import entity.SysUser;

@Service
@EnableMongoRepositories(basePackages="mapper" ) //扫描指定目录下面的MongoRepositories接口
public class SysUserService{

	@Autowired
   private SysUserRepository sysUserRepository;
   
    @RequestMapping("save")
    public  String save(){
    	SysUser sysUser = new SysUser();
    	sysUser.setName("张三");
    	sysUser.setPassword("123456");
    	sysUser.setSeqid(1L);
    	sysUserRepository.save(sysUser);
      
       sysUser = new SysUser();
       sysUser.setName("李四");
       sysUser.setPassword("123456");
       sysUser.setSeqid(2L);
       sysUserRepository.save(sysUser);
      
       return "ok";
    }
   
    @RequestMapping("find")
    public List find(){
       return sysUserRepository.findAll();
    }
   
    @RequestMapping("findByName")
    public SysUser findByName(){
       return sysUserRepository.findByName("张三");
    }
	
}

最后是控制器

package controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.context.embedded.EmbeddedServletContainerFactory;
import org.springframework.boot.context.embedded.tomcat.TomcatEmbeddedServletContainerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Import;
import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.servlet.ModelAndView;

import service.SysUserService;


import entity.SysUser;
/**
 * Created by wenchao.ren on 2014/4/26.
 */
@SpringBootApplication  
//启注解事务管理  
@Controller
@Import (SysUserService.class )
public class SimpleController {

	@Autowired
	private SysUserService sysUserService;

	@RequestMapping(value ="/hello", method = RequestMethod.GET)
    @ResponseBody
    public String hello(){
		SysUser sysUser = new SysUser();
		sysUserService.save();
		SysUser sysUser2= sysUserService.findByName();
        return sysUser2.getName();
    }
 
   public static void main(String[] args) {
        SpringApplication.run(SimpleController.class, args);
    }
    
}

还有applicationContext.properties

# mongodb note:mongo3.x will not use host and port,only use uri
spring.data.mongodb.host=localhost
spring.data.mongodb.port=27017
spring.data.mongodb.uri=mongodb://localhost:27017/springbootdb
server.port=8011

最后更新：2017-05-19 10:25:23

  上一篇：  CGLIB动态代理介绍

  下一篇：  SDCC 2017·深圳站，业内顶尖架构师于数据技术专家分享干货实料