MongoTemplate的基本使用方法_青青草原我最穷_mongotemplate

网络 02-07 3444

1、MongoDB简介

MongoDB是一个基于分布式文件存储的数据库。由C++语言编写。旨在为WEB应用提供可扩展的高性能数据存储解决方案。

MongoDB是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的，它支持的数据结构非常松散，是类似json的bson格式，因此可以存储比较复杂的数据类型。

MongoDB最大的特点是它支持的查询语言非常强大，其语法有点类似于面向对象的查询语言，几乎可以实现类似关系数据库单表查询的绝大部分功能，而且还支持对数据建立索引。

2、pxm.xml依赖  <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-mongodb</artifactId> </dependency>  <dependency> <groupId>org.mongodb</groupId> <artifactId>mongodb-driver-sync</artifactId> <version>3.9.1</version> </dependency> 3、配置文件 # MongoDB数据库 spring.data.mongodb.uri=mongodb://127.0.0.1:27017/testMongoDB # 设置了密码的MongoDB配置方式 # MongoDB服务器连接地址 #spring.data.mongodb.host=127.0.0.1 # MongoDB服务器连接端口 #spring.data.mongodb.port=27017 # MongoDB的验证数据库 #spring.data.mongodb.authentication-database=admin # MongoDB数据库用户 #spring.data.mongodb.username=root # MongoDB数据库密码 #spring.data.mongodb.password=123456 # 带连接的数据库 #spring.data.mongodb.database=testMongoDB 4、MongoTemplate的基本方法

首先使用@Autowired注入MongoTemplate（后面直接使用，就不特殊说明）

@Autowired private MongoTemplate mongoTemplate;

1.检索数据

// 查询name=zs Query query = Query.query(Criteria.where("name").is("zs")); mongoTemplate.find(query,User.class); mongoTemplate.find(query,User.class,"mongodb_user"); // 查询所有 mongoTemplate.findAll(User.class); mongoTemplate.findAll(User.class,"mongodb_user"); // 分页查询 page页码，pageSize每页展示几个 Pageable pageable = PageRequest.of(page - 1, pageSize, Sort.by(Sort.Order.desc("date"))); Query query = new Query().with(pageable); return this.mongoTemplate.find(query, User.class,"mongodb_user"); // 查询多个 Query query= Query.query(Criteria.where("id").in("id1","id2","id3")).with(Sort.by(Sort.Order.desc("date"))); List<Publish> list= this.mongoTemplate.find(query, User.class); // 查询数量 Criteria criteria = Criteria.where("userId").is("12345") .and("name").is(new ObjectId("张三")) .and("address").is("上海"); Query query = Query.query(criteria); long count = this.mongoTemplate.count(query, User.class);

2.插入数据

List<User> list = new ArrayList<>(); User user= new User();// user.setName("admin"); user.setAddress("测试"); list.add(user); // 保存对象到mongodb mongoTemplate.save(user); mongoTemplate.insert(user); // 根据集合名称保存对象到mongodb mongoTemplate.save(user,"mongodb_user"); mongoTemplate.insert(user,"mongodb_user"); // 根据集合名称保存list到mongodb mongoTemplate.save(list,"mongodb_user"); mongoTemplate.insert(list,"mongodb_user"); mongoTemplate.insert(list,User.class);

3.更新数据

User user = new User(); user.setId("5d1312aeb1829c279c6c256b"); user.setName("admin"); user.setAddress("测试"); Query query = Query.query(Criteria.where("_id").is("5d1312aeb1829c279c6c256b")); Update update = Update.update("name","zs"); // 更新一条数据 mongoTemplate.updateFirst(query,update, User.class); mongoTemplate.updateFirst(query,update, "mongodb_user"); mongoTemplate.updateFirst(query,update, User.class,"mongodb_user"); // 更新多条数据 mongoTemplate.updateMulti(query,update, User.class); mongoTemplate.updateMulti(query,update,"mongodb_user"); mongoTemplate.updateMulti(query,update, User.class,"mongodb_user"); // 更新数据，如果数据不存在就新增 mongoTemplate.upsert(query,update, User.class); mongoTemplate.upsert(query,update,"mongodb_user"); mongoTemplate.upsert(query,update, User.class,"mongodb_user");

4.删除数据

List<MongoDbJavaTest> list = new ArrayList<>(); User user= new User(); user.setId("5d1312aeb1829c279c6c256b"); list.add(user); Query query = Query.query(Criteria.where("_id").in("5d1312aeb1829c279c6c256b","5d13133ab1829c29d02ce29c")); // 根据条件删除 mongoTemplate.remove(query); mongoTemplate.remove(user); mongoTemplate.remove(User.class); // 根据条件删除（可删除多条） mongoTemplate.remove(query,User.class,"mongodb_user");