import org.springframework.data.annotation.Id;public class User  {@Idprivate Long id;private String name;private Integer userage;public Long getId() {return id;}public void setId(Long id) {this.id = id;}public String getName() {return name;}public void setName(String name) {this.name = name;}public Integer getUserage() {return userage;}public void setUserage(Integer userage) {this.userage = userage;}public User(Long id, String name, Integer userage) {super();this.id = id;this.name = name;this.userage = userage;}}

import org.springframework.data.mongodb.repository.MongoRepository;public interface UserMongodbJPA extends MongoRepository<User, Long>{
/*** * 单个条件查询，通过名字到数据* 方法名字定义规则：*  find +By+条件字段（必须是User中的属性）*/List<User> findByName(String name);/** * 多个条件查询，通过年龄和名字找到数据* 方法名字定义规则：* * ind +By+条件字段（必须是User中的属性）+AND+条件字段（必须是User中的属性）*/List<User>  findByUserageAndName(Integer userage,String name );
}

private MongoTemplate mongoTemplate;/*** insert方法，会新增一条数据*/public void insert(){User u = new User("1","zhangsan",18);mongoTemplate.insert(u);}/*** save方法，如果主键重复，则修改原来的数据*/public void save() {User u = new User("1","小明",19);mongoTemplate.save(u);}

/*** 要使用原生的mongodb方式，就要创建MongoTemplate ，*他的方法来实现SQL*/
private MongoTemplate mongoTemplate;/*** 更新对象*/public void updateTest() {//用来封装所有条件的对像Query query = new Query();//用来构建条件Criteria criteria = new Criteria();//criteria.and("你MongoDB中的key").is("你的条件")      criteria.and("name").is("小明");//把条件封装起来　　　
        query.addCriteria(criteria) ;//  Update 中构建更新的内容Update update= new Update().set("userage", "15").set("name", "小红");//更新查询返回结果集的第一条mongoTemplate.updateFirst(query,update,MongoTest.class);//更新查询返回结果集的所有mongoTemplate.updateMulti(query,update,User.class);
}

*** 删除对象*、*/public void deleteTestById() {Query query=new Query(Criteria.where("name").is("小红"));mongoTemplate.remove(query,User.class);}、

    public AggregationResults<T> aggregation(int pageNum, int pageSize, Criteria criteria,String name, String sortName, Sort sort,String tableName)throws BbsException {Aggregation aggregation = Aggregation.newAggregation(Aggregation.match(criteria),//用于过滤数据，只输出符合条件的文档Aggregation.group(name);//将集合中的文档根据fileID分组，可用于统计结果。Aggregation.sort(sort), //将输入文档根据sort排序后输出。Aggregation.skip(pageNum - 1) * pageSize),//在聚合管道中跳过指定数量的文档，并返回余下的文档。Aggregation.limit(pageSize),//用来限制MongoDB聚合管道返回的文档数。Aggregation.sum(userage)//用来求和，求出userage字段值的和
              )；return mongoTemplate.aggregate(aggregation, tableName, user.class);//tableName表示表的名字