springBoot（22）：集成mongodb
package com.example.demo.utils.component;import com.example.demo.pojo.User;
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;
/**
* Mongodb工具类
*
* @Author: 我爱大金子
* @Description: Mongodb工具类
* @Date: Create in 13:48 2017/7/5
*/
@Component
public class MongodbComponent {
@Autowired
private MongoTemplate mongoTemplate;
public void insert(User user) {
mongoTemplate.insert(user);
}
public void deleteById(int id) {
Criteria criteria = Criteria.where("id").in(id);
Query query = new Query(criteria);
mongoTemplate.remove(query, User.class);
}
public void updateById(User user) {
Criteria criteria = Criteria.where("id").in(user.getId());
Query query = new Query(criteria);
Update update = new Update();
update.set("name", user.getName());
update.set("createTime", user.getCreateTime());
mongoTemplate.updateMulti(query, update, User.class);
}
public User selectById(int id) {
Criteria criteria = Criteria.where("id").in(id);
Query query = new Query(criteria);
return mongoTemplate.findOne(query, User.class);
}
}
页:
[1]