SpringBoot整合Mongodb

1、pom.xml文件引入jar

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>

2、application.yml文件

3、测试代码

 

package com.ldd.cross.mongodb.dao;

import com.ldd.cross.entitys.Member;
import com.mongodb.client.result.UpdateResult;
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.data.mongodb.core.query.Update;
import org.springframework.stereotype.Component;
/**
 * Created by ldd on 2019/3/24.
 */
@Component
public class MemberDao {
    @Autowired
    MongoTemplate  mongoTemplate;

    /** 创建对象*/
    public void  save(Member member){

        mongoTemplate.save(member);
    }
    /** 根据用户名查询*/
    public Member findByUserName(String userName){
        Query  query = new Query(Criteria.where("userName").is(userName));
        Member member = mongoTemplate.findOne(query, Member.class);
        return member;
    }
    /** 更新*/
    public void update(Member member){
      Query query = new Query(Criteria.where("id").is(member.getId()));
      Update update = new Update();
      update.set("userName",member.getUserName());
      update.set("passWord",member.getPassWord());
      UpdateResult result = mongoTemplate.updateFirst(query, update, Member.class);
    }

    /**
     *
     * 删除
     */
    public void deleteTestById(Long id) {
        Query query=new Query(Criteria.where("id").is(id));
        mongoTemplate.remove(query,Member.class);
    }

}

package com.ldd.cross.mongodb.service;

import com.ldd.cross.entitys.Member;

/**
 * Created by ldd on 2019/3/24.
 */
public interface MemberService {

    /** 创建对象*/
    public void  save(Member member);

    /** 根据用户名查询*/
    public Member findByUserName(String userName);

    /** 更新*/
    public void update(Member member);
    /**
     *
     * 删除
     */
    public void deleteTestById(Long id);
}

package com.ldd.cross.mongodb.service.impl;

import com.ldd.cross.entitys.Member;
import com.ldd.cross.mongodb.dao.MemberDao;
import com.ldd.cross.mongodb.service.MemberService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * Created by ldd on 2019/3/24.
 */
@Service
public class MemberServiceImpl implements MemberService{

    @Autowired
    MemberDao memberDao;

    @Override
    public void save(Member member) {
       memberDao.save(member);
    }

    @Override
    public Member findByUserName(String userName) {
        return memberDao.findByUserName(userName);
    }

    @Override
    public void update(Member member) {
       memberDao.update(member);
    }

    @Override
    public void deleteTestById(Long id) {
      memberDao.deleteTestById(id);
    }
}

 

package com.ldd.cross.controller;

import com.ldd.cross.entitys.Member;
import com.ldd.cross.mongodb.service.MemberService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * Created by ldd on 2019/3/24.
 */
@RequestMapping("/mong")
@RestController
public class MongController {

    @Autowired
    MemberService memberService;

    @RequestMapping("/save")
    public void save(){
        Member member = new Member();
        member.setId(1L);
        member.setUserName("王二狗");
        member.setPassWord("123456");
        memberService.save(member);
    }

    @RequestMapping("/find/{name}")
    public Member findByUserName(@PathVariable(name = "name") String name){
        return memberService.findByUserName(name);
    }

    @RequestMapping("/update")
    public void  updateMember(){
       Member member = new Member();
       member.setId(1L);
       member.setUserName("如梦");
       member.setPassWord("你大爷的");
       memberService.update(member);
    }

    @RequestMapping("/delete/{id}")
    public void delete(@PathVariable(name="id") Long id){
      memberService.deleteTestById(id);
    }

}