【ElasticSearch実戦】——ES常用照会条件とmysql比較
6774 ワード
クラス比mysqlは、=、>、>=、and、in、like、count、sum、group by、order by、limitが必要です.
高バージョンのESではboolqueryを使用してfilterを置き換えました
1、等号=
1
2
2、より小さい
1
2
3
4
5
6
3、or、and
1
2
3
4
4、in
1
2
5、like
1
2
3
4
5
6、sum&&count
1
2
3
7、order by and limit
1
2
3
4
5
6
7
8
9
10
8、一括挿入
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
9、....更新は続きます
高バージョンのESではboolqueryを使用してfilterを置き換えました
1、等号=
QueryBuilders.termQuery("isDel",1));
//termQuery =, isDel=1
1
2
2、より小さい
QueryBuilders.rangeQuery("overdueStartTime").lte(startDate.getTime())
//rangeQuery
//lte <=
//lt <
//gte >=
//gt >
1
2
3
4
5
6
3、or、and
boolQueryBuilder.must(QueryBuilders.termQuery("isDel",req.getIs_del()));
//must and
caseStatusQuery.should(QueryBuilders.termQuery("caseStatus",s));
//should or
1
2
3
4
4、in
QueryBuilders.termsQuery("clientCompanyId",req.getClientCompanyIdList())
//termQuery in, list
1
2
5、like
QueryBuilders.wildcardQuery("phone1", "*" + req.getTelephone() + "*")
//wildcard
QueryBuilders.matchPhraseQuery("debtorName", req.getDebtor_name())
//matchPhrase ,
1
2
3
4
5
6、sum&&count
AggregationBuilder debtTotalSum = AggregationBuilders.sum(DEBT_TOTAL_SUM_KEY).field("debtTotal");
AggregationBuilder debtTotalCount = AggregationBuilders.count(DEBT_TOTAL_COUNT_KEY).field("debtTotal");
1
2
3
7、order by and limit
SearchResponse searchResponse = client.prepareSearch(ElasticSearchUtil.getIndexName())
.setTypes(ElasticSearchUtil.TYPE_NAME)
.setQuery(boolQueryBuilder)
//
.addStoredField("id")
.addSort(order, sortOrder)
//
.setFrom((currentPage - 1) * limit).setSize(limit)
.execute()
.actionGet();
1
2
3
4
5
6
7
8
9
10
8、一括挿入
public void batchInsert(List list,Client client) {
LOGGER.info("--------- --------");
BulkRequestBuilder bulkRequest = client.prepareBulk();
long start = System.currentTimeMillis();
BulkRequestBuilder delRequest = client.prepareBulk();
for (CaseTable caseTable :list){
IndexRequestBuilder ir = client.prepareIndex()
.setIndex(ElasticSearchUtil.INDEX_NAME_CASE)
.setType(ElasticSearchUtil.TYPE_NAME_CASE)
.setId(caseTable.getId().toString())
.setSource(JSON.toJSONString(caseTable));
bulkRequest.add(ir);
start = System.currentTimeMillis();
BulkResponse bulkResponse = bulkRequest.execute().actionGet();
LOGGER.info(" search time:{}ms", System.currentTimeMillis() - start);
if (!bulkResponse.hasFailures()) {
LOGGER.info("---------- ------------");
}
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
9、....更新は続きます