QueryTest.java 文件源码

@Test
public void dateBetweenSearch() throws IOException, SqlParseException, SQLFeatureNotSupportedException {
    DateTimeFormatter formatter = DateTimeFormat.forPattern(DATE_FORMAT);

    DateTime dateLimit1 = new DateTime(2014, 8, 18, 0, 0, 0);
    DateTime dateLimit2 = new DateTime(2014, 8, 21, 0, 0, 0);

    SearchHits response = query(String.format("SELECT insert_time FROM %s/online WHERE insert_time BETWEEN '2014-08-18' AND '2014-08-21' LIMIT 3", TEST_INDEX));
    SearchHit[] hits = response.getHits();
    for(SearchHit hit : hits) {
        Map<String, Object> source = hit.getSource();
        DateTime insertTime = formatter.parseDateTime((String) source.get("insert_time"));

        boolean isBetween =
                (insertTime.isAfter(dateLimit1) || insertTime.isEqual(dateLimit1)) &&
                (insertTime.isBefore(dateLimit2) || insertTime.isEqual(dateLimit2));

        Assert.assertTrue("insert_time must be between 2014-08-18 and 2014-08-21", isBetween);
    }
}