<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
spring:
data:
# MongoDB数据库
mongodb:
host: 127.0.0.1 # 连接地址
port: 27017 # 端口
database: test # 连接数据库
username: root # 用户名
password: "123456" # 密码
authentication-database: admin # 验证数据库(可选)
@Autowired
private MongoTemplate mongoTemplate;
Criteria criteria = Criteria.where("key").is("测试");
Query query = Query.query(criteria);
MongoTest one = mongoTemplate.findOne(query, MongoTest.class);
Query query = Query.query(new Criteria()).skip(0).limit(10);
List<MongoTest> mongoTests = mongoTemplate.find(query, MongoTest.class);
查询从第0条数据起的10个数据。
MongoTest test = new MongoTest();
test.setKey("测试1");
test.setValue("值1");
MongoTest test1 = mongoTemplate.insert(test, "test");
插入一条key为‘测试1’,value为‘值1’的数据到集合‘test’。
Criteria criteria = new Criteria();
criteria.orOperator(Criteria.where("key").is("测试"), Criteria.where("key").is("测试1"));
Query query = Query.query(criteria);
Update update1 = Update.update("value", "批量更新");
UpdateResult test = mongoTemplate.updateMulti(query, update1, "test");
将key为‘测试’或者‘测试1’的数据value改为‘批量更新’。
Criteria criteria = Criteria.where("key").is("测试").and("value").is("批量更新");
Query query = Query.query(criteria);
DeleteResult remove = mongoTemplate.remove(query,"test");
将集合名称为test中的key为'测试'并且value为‘批量更新’的数据删除。
mongoTemplate.createCollection("createCollection");
mongoTemplate.dropCollection("createCollection");
boolean exists = mongoTemplate.collectionExists("createCollection");
long count = mongoTemplate.count(new Query(), "test");