springBoot（22）：集成mongodb

q986

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