MongoDB数据库，在最近使用越来越广泛，在这里和Java的开发者一起分享一下在Java中使用Mongodb的相关笔记。希望大家喜欢。关于MongoDB查询指令，请看我的上一篇文章。

Spring Data MongoDB提供了一些方便的映射注释供我们使用，下面列出官方说明地址以供参考

官方说明文档：
https://docs.spring.io/spring-data/mongodb/docs/2.1.3.RELEASE/reference/html/#mapping-usage

Spring Data MongoDB 支持的注解

@Document   : 文档标识，将 java 类与 Collection 文档对应
@Id         : 文档的唯一标识，在 mongodb 中为 ObjectID，生成规则：时间戳+机器标识+进程ID+自增计数器(确保同一时间内ID不会冲突)
@Field      : 属性注解
@Indexed    : 索引
@CompoundIndex  : 混合索引
@GeoSpatialIndexed  : 声明该字段为地理信息的索引
@Transient  : 映射忽略的字段 (即不会保存到 mongodb)
@Query      ：查询

SpringDataMongoDB的配置

server:
  port: 9006
spring:
  application:
    name: tensquare‐spit #指定服务名
  data:
    mongodb:
      host: localhost:40000
      database: spitdb
  redis:
    host: 127.0.0.1

依赖

在使用 SpringDataMongoDB 之前，需要先声明对 SpringData 模块的依赖关系。

既然 SpringData 存储库抽象中的中央接口是 Repository 。 该接口的子类 CrudRepository 实现了实体类的 CRUD 功能，如果需要的话，也可以通过继承该接口来拓展 ：

public interface CrudRepository<T, ID extends Serializable>
  extends Repository<T, ID> {

  <S extends T> S save(S entity);      

  Optional<T> findById(ID primaryKey); 

  Iterable<T> findAll();               

  long count();                        

  void delete(T entity);               

  boolean existsById(ID primaryKey);   

  // … more functionality omitted.
}

除了 CrudRepository 之外，还有 JpaRepository 和 MongoRepository。在 CrudRepository 中，有许多抽象方法添加了额外的方法来简化对实体的分页访问。

1.简单的CRUD查询。

定一个一个实体类。

public class Spit implements Serializable {

    @Id
    private String _id;
    private String content;
    private Date publishtime;
    private String userid;
    private String nickname;
    private Integer visits;
    private Integer thumbup;
    private Integer share;
    private Integer comment;
    private String state;
    private String parentid;
}

对于简单的查询，我们只需要继承MongoRepository即可。

Dao层

public interface SpitDao extends MongoRepository<Spit,String> {
    public Page<Spit> findByParentid(String parentid, Pageable pageable);
}

Service层

@Service
@Transactional
public class SpitService {

    @Autowired
    private SpitDao spitDao;

    @Autowired
    private IdWorker idWorker;

    @Autowired
    private MongoTemplate mongoTemplate;

    public List<Spit> findAll(){
        List<Spit> list = mongoTemplate.findAll(Spit.class);

        return spitDao.findAll();
    }

    public Spit findById(String id){
        Spit s = spitDao.findById(id).get();
        return spitDao.findById(id).get();
    }

    public void save(Spit spit){
        spit.set_id(idWorker.nextId()+"");
        spitDao.save(spit);
    }

//分页查询
public Page<Spit> findByParentid(String parentid,int page,int size){
        Pageable pageable = PageRequest.of(page-1,size);

        return spitDao.findByParentid(parentid,pageable);

    }
}

复杂的查询：mongoTemplate

由于查询相对于其他增删改的操作要复杂一些，所以在这里单独说一下查询。还看上面的例子就可以。

首先我们先介绍一下几个和查询有关的类Query、Criteria、Sort、PageRequest、PageImpl

Query

查询对象定义一个查询的所有要素，其中包括筛选条件、排序、起始行、返回条数等内容

1. query(CriteriaDefinition criteriaDefinition): 静态方法通过注入一个CriteriaDefinition条件对象获得Query查询对象。在简单查询时使用此方法将非常的方便。
   例如：mongoTemplate.find(Query.query(Criteria.where("parameter3").lt(new Date())
2. addCriteria(CriteriaDefinition criteriaDefinition) :添加一个CriteriaDefinition查询条件类到本次查询
3. skip(long skip) :跳过文档的数量，可以与limit配合使用实现分页效果
4. limit(int limit) :查询返回的文档数量。
5. with(Sort sort) : 添加一个Sort排序对象
6. with(Pageable pageable):添加一个Pageable分页对象。Pageable可以注入一个Sort，所以分页和排序可以一起添加。
   例如：Pageable pageable = new PageRequest(1,3,sort);

Criteria

查询条件类，使用此类定义查询时的查询条件相当于SQL的where。

Sort

查询排序类，使用此类可以创建查询排序。

public void thumbup(String spitId) {

        Query query = new Query();
        query.addCriteria(Criteria.where("_id").is("1"));
        Update update = new Update();
        update.inc("thumbup",1);
        mongoTemplate.updateFirst(query,update,"spit");
    }

    public void add(Spit spit){
        spit.set_id(idWorker.nextId()+"");
        spit.setPublishtime(new Date());
        spit.setVisits(0);
        spit.setShare(0);
        spit.setThumbup(0);
        spit.setComment(0);
        spit.setState("1");
        if (spit.getParentid() != null&& "".equals(spit.getParentid())){
            //如果存在上级ID,评论
            Query query = new Query();
            query.addCriteria(Criteria.where("_id").is(spit.getParentid()));
            Update update = new Update();
            update.inc("comment",1);
            mongoTemplate.updateFirst(query,update,"spit");

        }
        spitDao.save(spit);


    }

通过以上的例子基本可以解决的Mongodb的复杂的查询了。关于Mongodb的多表联查。我将在下一篇文章来深入的探讨。