RollUpPurgeSteps.java 文件源码

@Then("^the rolled up point on \"([^\"]*)\" (\\d+) \"([^\"]*)\" will be purged$")
public void theRolledUpPointOnWillBePurged(String timestampState,
                                           long timestampDiff,
                                           String timestampUnit) throws Throwable {
    String sql = ""
            + " SELECT * FROM point_" + rollUp.getTargetGranularity()
            + " WHERE \"metric_id\" = ?   "
            + " AND   \"timestamp\" = ?   "
            + " AND   \"aggregation\" = ? ";

    Timestamp timestamp = resolveTimestamp(timestampState, timestampDiff, timestampUnit);

    try (Connection connection = pugTSDB.getDataSource().getConnection();
         PreparedStatement statement = connection.prepareStatement(sql)) {
        statement.setInt(1, metric.getId());
        statement.setTimestamp(2, timestamp);
        statement.setString(3, aggregation.getName());
        ResultSet resultSet = statement.executeQuery();

        assertFalse(resultSet.next());
    }
}