基于Morphia实现MongoDB按小时、按天聚合操作方法

下面是详细讲解基于Morphia实现MongoDB按小时、按天聚合操作的完整攻略：

1. 安装Morphia

首先需要安装Morphia，可以通过以下方式进行安装：

    <dependency>
        <groupId>org.mongodb.morphia</groupId>
        <artifactId>morphia</artifactId>
        <version>1.7.8</version>
    </dependency>

2. 按小时聚合操作

2.1 创建数据源

首先需要创建数据源，引入MongoDB和Morphia，以及设置MongoDB连接信息和数据库信息：

    private static final String HOST = "localhost";
    private static final int PORT = 27017;
    private static final String USERNAME = "admin";
    private static final String PASSWORD = "password";
    private static final String DATABASE = "test";

    private MongoClient mongoClient;
    private final Morphia morphia = new Morphia();
    private Datastore datastore;

    public void init() {
        // 创建MongoDB连接
        List<MongoCredential> credentialsList = new ArrayList<>();
        credentialsList.add(MongoCredential.createCredential(USERNAME, DATABASE, PASSWORD.toCharArray()));
        ServerAddress serverAddress = new ServerAddress(HOST, PORT);
        MongoClientOptions.Builder builder = MongoClientOptions.builder().connectTimeout(3000).socketTimeout(10000);
        mongoClient = new MongoClient(serverAddress, credentialsList, builder.build());
        // 创建Morphia数据源
        morphia.mapPackage("com.example.model");
        datastore = morphia.createDatastore(mongoClient, DATABASE);
        datastore.ensureIndexes();
    }

2.2 聚合操作

按小时聚合操作使用MongoDB的聚合框架，下面是聚合操作的示例代码：

    List<Document> queryList = new ArrayList<>();
    queryList.add(new Document("$match", new Document("time", new Document("$gt", startHour).append("$lte", endHour))));
    queryList.add(new Document("$project", new Document("hour", new Document("$hour", "$time")).append("count", 1)));
    queryList.add(new Document("$group", new Document("_id", "$hour").append("count", new Document("$sum", "$count"))));
    List<Document> result = datastore.getCollection("collectionName").aggregate(queryList).into(new ArrayList<>());

代码中queryList列表中是按照聚合操作的步骤依次添加的，步骤包括：匹配条件、指定属性、分组统计。其中，$match指定匹配条件，$project指定属性，$group指定分组和统计操作。

需要注意的是，聚合操作中需要指定时间段，可以使用下面的代码获取时间段的起始和结束时间：

    private long startHour = Instant.now().truncatedTo(ChronoUnit.HOURS).toEpochMilli();
    private long endHour = Instant.ofEpochMilli(startHour).plus(1, ChronoUnit.HOURS).toEpochMilli();

这里以当前时间为例，获取当前的小时数，然后将时间戳精确到小时（通过truncatedTo函数），再加上一小时（通过plus函数）得到结束时间。

2.3 聚合结果处理

聚合之后得到的结果是Document类型的列表，需要对结果进行处理，将结果转换为Java Bean对象，代码如下：

    List<HourData> dataList = new ArrayList<>();
    for (Document doc : result) {
        HourData data = new HourData();
        data.setHour(doc.getInteger("_id"));
        data.setCount(doc.getInteger("count"));
        dataList.add(data);
    }

其中，HourData是一个Java Bean对象，包含了hour和count两个属性，需要自行在代码中进行定义。

2.4 示例说明

以下是一条按小时聚合操作的示例代码，假设collectionName是需要聚合的集合名称：

    // 初始化数据源
    init();
    // 聚合操作
    List<Document> queryList = new ArrayList<>();
    queryList.add(new Document("$match", new Document("time", new Document("$gt", startHour).append("$lte", endHour))));
    queryList.add(new Document("$project", new Document("hour", new Document("$hour", "$time")).append("count", 1)));
    queryList.add(new Document("$group", new Document("_id", "$hour").append("count", new Document("$sum", "$count"))));
    List<Document> result = datastore.getCollection("collectionName").aggregate(queryList).into(new ArrayList<>());
    // 结果处理
    List<HourData> dataList = new ArrayList<>();
    for (Document doc : result) {
        HourData data = new HourData();
        data.setHour(doc.getInteger("_id"));
        data.setCount(doc.getInteger("count"));
        dataList.add(data);
    }

上面的代码中，startHour和endHour是如上所述获取的时间段的起始和结束时间，可以根据需要自行替换。最终的结果保存在dataList列表中。

3. 按天聚合操作

3.1 聚合操作

按天聚合操作也是使用MongoDB的聚合框架，下面是聚合操作的示例代码：

    final String key = new SimpleDateFormat("yyyy-MM-dd").format(new Date(time));
    final BasicDBObject query = new BasicDBObject("_id", key);
    final BasicDBObject condition = new BasicDBObject("$inc", new BasicDBObject("count", 1));
    datastore.getCollection("collectionName").update(query, condition, true, false);

代码中需要提供按天聚合的键值，key的生成可以自行根据需求进行更改。"$inc"是一个关键字，表示按照键值进行计数，每次操作对该计数器进行加1操作。

3.2 示例说明

以下是一条按天聚合操作的示例代码，假设collectionName是需要聚合的集合名称：

    // 初始化数据源
    init();
    // 聚合操作
    final String key = new SimpleDateFormat("yyyy-MM-dd").format(new Date(System.currentTimeMillis()));
    final BasicDBObject query = new BasicDBObject("_id", key);
    final BasicDBObject condition = new BasicDBObject("$inc", new BasicDBObject("count", 1));
    datastore.getCollection("collectionName").update(query, condition, true, false);

上面的代码中，按天聚合操作没有聚合的过程，每次操作都是对指定键值进行计数。最终的结果存放在MongoDB中，可以根据需要在程序中读取并进行使用。