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); } }