文章目錄

• 準(zhǔn)備數(shù)據(jù)庫
• • • 切換/創(chuàng)建數(shù)據(jù)庫
    • 創(chuàng)建一個集合（table)
    • 得到指定名稱的集合（table )
    • 插入
• 準(zhǔn)備環(huán)境
• 一、基于MongoTemplate 開發(fā)CRUD
• • • 添加、查詢所有
    • 其他查詢
    • 修改
    • 刪除
• 二、基于MongoRepository開發(fā)CRUD
• • • 添加
    • 查詢
    • 修改
    • 刪除

準(zhǔn)備數(shù)據(jù)庫

切換/創(chuàng)建數(shù)據(jù)庫

use test

如果數(shù)據(jù)庫不存在，則創(chuàng)建數(shù)據(jù)庫，否則切換到指定數(shù)據(jù)庫

創(chuàng)建一個集合（table)

db.createCollection( "collName");

得到指定名稱的集合（table )

db.getCollection("user");

插入

db.User.save({name:‘zhangsan’,age:21,sex:true})
db.User.find()
{"_id": Objectld(“4f69e680c9106ee2ec95da66”), “name”: “zhangsan”, “age”: 21,
“sex”: true}

準(zhǔn)備環(huán)境

引入依賴
添加配置
實體類

@Data @Document("User") public class User {@Idprivate String id;private String name;private Integer age;private String email;private String createDate; }

一、基于MongoTemplate 開發(fā)CRUD

添加、查詢所有

@SpringBootTest class MongodbApplicationTests {@Autowiredprivate MongoTemplate mongoTemplate;//添加@Testpublic void createUser() {User user = new User();user.setAge(20);user.setName("test");user.setEmail("4932200@qq.com");User user1 = mongoTemplate.insert(user);System.out.println(user1);}//查詢所有@Testpublic void findUser() {List<User> userList = mongoTemplate.findAll(User.class);System.out.println(userList);}}

結(jié)果

其他查詢

//根據(jù)id查詢@Testpublic void getById() {User user = mongoTemplate.findById("5ffbfa2ac290f356edf9b5aa", User.class);System.out.println(user);}//條件查詢@Testpublic void findUserList() {Query query = new Query(Criteria.where("name").is("test").and("age").is(20));List<User> userList = mongoTemplate.find(query, User.class);System.out.println(userList);}//模糊查詢@Testpublic void findUsersLikeName() {String name = "est";String regex = String.format("%s%s%s", "^.*", name, ".*$");Pattern pattern = Pattern.compile(regex, Pattern.CASE_INSENSITIVE);Query query = new Query(Criteria.where("name").regex(pattern));List<User> userList = mongoTemplate.find(query, User.class);System.out.println(userList);}//分頁查詢@Testpublic void findUsersPage() {String name = "est";int pageNo = 1;int pageSize = 10;Query query = new Query();String regex = String.format("%s%s%s", "^.*", name, ".*$");Pattern pattern = Pattern.compile(regex, Pattern.CASE_INSENSITIVE);query.addCriteria(Criteria.where("name").regex(pattern));int totalCount = (int) mongoTemplate.count(query, User.class);List<User> userList = mongoTemplate.find(query.skip((pageNo - 1) * pageSize).limit(pageSize), User.class);Map<String, Object> pageMap = new HashMap<>();pageMap.put("list", userList);pageMap.put("totalCount",totalCount);System.out.println(pageMap);}

修改

//修改@Testpublic void updateUser() {User user = mongoTemplate.findById("5ffbfa2ac290f356edf9b5aa", User.class);user.setName("test_1");user.setAge(25);user.setEmail("493220990@qq.com");Query query = new Query(Criteria.where("_id").is(user.getId()));Update update = new Update();update.set("name", user.getName());update.set("age", user.getAge());update.set("email", user.getEmail());UpdateResult result = mongoTemplate.upsert(query, update, User.class);long count = result.getModifiedCount();System.out.println(count);}

刪除

//刪除操作@Testpublic void delete() {Query query = new Query(Criteria.where("_id").is("5ffbfa2ac290f356edf9b5aa"));DeleteResult result = mongoTemplate.remove(query, User.class);long count = result.getDeletedCount();System.out.println(count);}

二、基于MongoRepository開發(fā)CRUD

添加

//添加@Testpublic void createUser() {User user = new User();user.setAge(20);user.setName("張三");user.setEmail("3332200@qq.com");User user1 = userRepository.save(user);}

查詢

//查詢所有@Testpublic void findUser() {List<User> userList = userRepository.findAll();System.out.println(userList);}//id查詢@Testpublic void getById() {User user = userRepository.findById("5ffbfe8197f24a07007bd6ce").get();System.out.println(user);}//條件查詢@Testpublic void findUserList() {User user = new User();user.setName("張三");user.setAge(20);Example<User> userExample = Example.of(user);List<User> userList = userRepository.findAll(userExample);System.out.println(userList);}//模糊查詢@Testpublic void findUsersLikeName() {//創(chuàng)建匹配器，即如何使用查詢條件ExampleMatcher matcher = ExampleMatcher.matching() //構(gòu)建對象.withStringMatcher(ExampleMatcher.StringMatcher.CONTAINING) //改變默認(rèn)字符串匹配方式：模糊查詢.withIgnoreCase(true); //改變默認(rèn)大小寫忽略方式：忽略大小寫User user = new User();user.setName("三");Example<User> userExample = Example.of(user, matcher);List<User> userList = userRepository.findAll(userExample);System.out.println(userList);}//分頁查詢@Testpublic void findUsersPage() {Sort sort = Sort.by(Sort.Direction.DESC, "age"); //0為第一頁Pageable pageable = PageRequest.of(0, 10, sort); //創(chuàng)建匹配器，即如何使用查詢條件ExampleMatcher matcher = ExampleMatcher.matching() //構(gòu)建對象.withStringMatcher(ExampleMatcher.StringMatcher.CONTAINING) //改變默認(rèn)字符串匹配方式：模糊查詢.withIgnoreCase(true); //改變默認(rèn)大小寫忽略方式：忽略大小寫User user = new User();user.setName("三");Example<User> userExample = Example.of(user, matcher); //創(chuàng)建實例Example<User> example = Example.of(user, matcher);Page<User> pages = userRepository.findAll(example, pageable);System.out.println(pages);}

修改

//修改@Testpublic void updateUser() {User user = userRepository.findById("5ffbfe8197f24a07007bd6ce").get();user.setName("張三_1");user.setAge(25);user.setEmail("883220990@qq.com");User save = userRepository.save(user);System.out.println(save);}

刪除

//刪除@Testpublic void delete() {userRepository.deleteById("5ffbfe8197f24a07007bd6ce");}

總結(jié)

以上是生活随笔為你收集整理的Spring boot集成mongodb的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。