Elasticsearch（二）：使用JAVA API實現簡單查詢、聚合查詢
阿新 • • 發佈：2019-02-15
ES版本：2.3.1
JDK：1.8
所需要的jar包請在ES安裝路徑下的jars包中獲得，不要使用其他的jar否則容易出現版本問題！
注意：程式碼中TransportClient client=ESLink.getTransportClient();連線在上一篇
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse 測試程式碼：
import org.junit.Test;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public class ESTest {
@Test
public void testqueryByFilterr_Accept() {
try {
ESUtils utils = new ESUtils();
List docList = utils.queryByFilter_Accept("order", "order", "create_date", "2011-11-10", 10);
for (Object doc : docList) {
System.out.println(doc);
}
} catch (Exception ex) {
System.err.println(ex);
}
}
@Test
public void testqueryByFilter() {
try {
ESUtils utils = new ESUtils();
List docList = utils.queryByFilter("order", "order", 15);
for (Object doc : docList) {
System.out.println(doc);
}
} catch (Exception ex) {
System.err.println(ex);
}
}
@Test
public void testDeleteDoc() {
try {
ESUtils utils = new ESUtils();
boolean deleteDoc = utils.deleteDoc("order", "order", "AWKO26k95Sm1nfyWQa83");
System.out.print(deleteDoc);
} catch (Exception ex) {
System.err.println(ex);
}
}
@Test
public void testMinDoc() {
try {
ESUtils utils = new ESUtils();
double min = utils.minDoc("order", "order", "buyer_id");
System.out.print(min);
} catch (Exception ex) {
System.err.println(ex);
}
}
@Test
public void testMaxDoc() {
try {
ESUtils utils = new ESUtils();
double max = utils.maxDoc("order", "order", "buyer_id");
System.out.print(max);
} catch (Exception ex) {
System.err.println(ex);
}
}
/**
* 非巢狀查詢的測試
*/
@Test
public void testGroup() {
try {
long startTime = System.currentTimeMillis(); //獲取開始時間
ESUtils utils = new ESUtils();
utils.testSumGroupBy("order", "order", "buyer_id", 10);
long endTime = System.currentTimeMillis(); //獲取結束時間
System.out.println("程式執行時間： " + (endTime - startTime) + "ms");
} catch (Exception ex) {
System.err.println(ex);
}
}
/**
* 列印結果測試
*/
@Test
public void testPrint() {
long startTime = System.currentTimeMillis(); //獲取開始時間
ESUtils utils = new ESUtils();
utils.getGroupPrint("order", "order", "buyer_id", "order_id", 10, "600ms");
long endTime = System.currentTimeMillis(); //獲取結束時間
System.out.println("程式執行時間： " + (endTime - startTime) + "ms");
try {
} catch (Exception ex) {
System.err.println(ex);
}
}
/**
* 巢狀查詢獲取結果的測試
*/
@Test
public void testGroup2() {
try {
long startTime = System.currentTimeMillis(); //獲取開始時間
ESUtils utils = new ESUtils();
utils.getGroupPrint("item", "item", "order_id", "goods_price", 10, "600ms");
long endTime = System.currentTimeMillis(); //獲取結束時間
System.out.println("程式執行時間： " + (endTime - startTime) + "ms");
} catch (Exception ex) {
System.err.println(ex);
}
}
/**
* 巢狀查詢獲取結果的測試
* hashMap1 最外層map <序號，Buyer_Map>
* hashMap2 Buyer_Map <Buyer_id,Order_Map>
* hashMap3 Order_Map < key,value>
*
*/
@Test
public void testGroupOrderItem() {
try {
long startTime = System.currentTimeMillis();
HashMap hashMap1 = new ESUtils().getGroupByMap("order", "order", "buyer_id", "order_id", 10, "6000ms");
for (Object h : hashMap1.keySet()) {
HashMap hashMap2 = (HashMap) hashMap1.get(h);
HashMap hashMap3 = (HashMap) hashMap2.get("Buckets");
double sum=0.0;
for (Object key : hashMap3.keySet()) {
sum+= new ESUtils().getGroupSum("item", "item","order_id", key.toString(),"goods_price", "6000ms");
}
System.out.println("buyer_id:"+hashMap2.get("Key")+"\t\tgoods_amount:"+sum);
}
long endTime = System.currentTimeMillis();
System.out.println("程式執行時間： " + (endTime - startTime) + "ms");
} catch (Exception ex) {
System.err.println(ex);
}
}
}