好程序员Java学习路线分享创建Java class，首先通过Transport Client获取ES的连接
private Client client;
//通过Transport Client获取ES的连接
@Before
public void getClient() throws Exception{
//ES服务的JavaAPI的port为9300
//注意:如果请求一个ES集群,可以多添几个节点
//为了避免在一个节点出现网络问题导致的请求失败问题,可以自动切换另外一个节点
client = TransportClient.builder().build()
.addTransportAddress(new InetSocketTransportAddress(
InetAddress.getByName("localhost"),9300));
//.addTransportAddress(...);
}
操作命令
----------------------------------------新建文档------------------------------------
@Test
public void createDocument1(){
// json格式的数据
//json "需要转义 -> \
String source = "{" +
"\"id\":\"1\"," +
"\"title\":\"Lucene是一套用于全文检索和搜寻的开源程式库\"," +
"\"content\":\"Lucene提供了一个简单却强大的应用程式接口，能够做全文索引和搜寻\"" +
"}";
//创建文档, 定义索引名称,文档类型,主键唯一标识ID
//execute().actionGet() == get() 代表立刻执行
IndexResponse indexResponse =
client.prepareIndex("blog", "article", "1")
.setSource(source).get(); //加载数据并触发
this.getResponse(indexResponse); //对应下面封装信息
client.close();
}
将打印信息封装成类,方便this调用
//获取响应信息
private void getResponse(IndexResponse indexResponse) {
System.out.println("索引名称: " + indexResponse.getIndex());
System.out.println("文档类型: "+indexResponse.getType());
System.out.println("ID: "+indexResponse.getId());
System.out.println("版本: "+indexResponse.getVersion());
System.out.println("是否创建成功: "+indexResponse.isCreated());
}
@Test
public void createDocument2(){
// map类型的数据
Map
source.put("id","2");
source.put("title","ElasticSearch");
source.put("content","是一个分布式的 RESTful 风格的搜索和数据分析引擎");
//创建文档
IndexResponse indexResponse = client.prepareIndex("blog", "article", "2")
.setSource(source).get();
this.getResponse(indexResponse);
client.close();
}
使用ES帮助类(执行类),创建文档
@Test
public void createDocument3() throws Exception{
XContentBuilder source = XContentFactory.jsonBuilder()
.startObject() //封装数据
.field("id","3")
.field("title","ES的核心")
.field("content","集中的是巴拉巴拉")
.endObject();
System.out.println(source.toString());
//创建文档
IndexResponse indexResponse = client.prepareIndex("blog", "article", "3")
.setSource(source).get();
this.getResponse(indexResponse);
client.close();
}
----------------------------------------搜索文档------------------------------------
输出格式为json格式
搜索文档数据 -- 单个索引 prepareGet
@Test
public void testGetData1(){
GetResponse getResponse = client.prepareGet("blog", "article", "1").get();
System.out.println(getResponse.getSourceAsString());
client.close(); //输出格式为json格式
}
搜索文档数据 -- 多个索引 prepareMultiGet
@Test
public void testGetData2(){
MultiGetResponse multiGetResponse = client.prepareMultiGet()
.add("blog", "article", "1")
.add("blog", "article", "2", "3")
.get();
for (MultiGetItemResponse itemResponse : multiGetResponse){
GetResponse response = itemResponse.getResponse();
if (response.isExists()){
System.out.println(response.getSourceAsString());
}
}
client.close();
}
----------------------------------------更新文档------------------------------------
doc更新
创建更新对象
@Test
public void testUpdate1() throws Exception{
UpdateRequest request = new UpdateRequest();
request.index("blog");
request.type("article");
request.id("1");
request.doc(XContentFactory.jsonBuilder() //doc 更新方法
.startObject()
.field("id","1")
.field("title","更新:1")
.field("content","更新:1")
.endObject());
UpdateResponse updateResponse = client.update(request).get();
System.out.println("索引名称: " + updateResponse.getIndex());
System.out.println("文档类型: "+updateResponse.getType());
System.out.println("ID: "+updateResponse.getId());
System.out.println("版本: "+updateResponse.getVersion());
System.out.println("是否创建成功: "+updateResponse.isCreated()); //false
client.close();
}
直接调用client.update
@Test
public void testUpdate2() throws Exception{
UpdateResponse updateResponse =
client.update(new UpdateRequest("blog", "article", "2")
.doc(XContentFactory.jsonBuilder() //doc 更新方法
.startObject()
.field("id", "2")
.field("title", "更新:2")
.field("content", "更新:2")
.endObject()))
.get();
System.out.println("索引名称: " + updateResponse.getIndex());
System.out.println("文档类型: "+updateResponse.getType());
System.out.println("ID: "+updateResponse.getId());
System.out.println("版本: "+updateResponse.getVersion());
System.out.println("是否创建成功: "+updateResponse.isCreated()); //false
client.close();
}
创建并更新
@Test
public void testUpdate3() throws Exception{
// 设置一个查询的条件,使用ID查询,如果查不到数据,则添加IndexRequest的文档数据
IndexRequest indexRequest = new IndexRequest("blog1", "article", "4")
.source(XContentFactory.jsonBuilder()
.startObject()
.field("id", "4")
.field("title", "李雪静加油")
.field("content", "Fighting!")
.endObject());
//设置更新的数据,使用ID查询,如果能查到,则更新UpdateRequest的数据
UpdateRequest updateRequest = new UpdateRequest("blog1", "article", "4")
.doc(XContentFactory.jsonBuilder()
.startObject()
.field("title", "new fighting~")
.endObject())
.upsert(indexRequest);
UpdateResponse updateResponse = client.update(updateRequest).get();
System.out.println("索引名称: " + updateResponse.getIndex());
System.out.println("文档类型: "+updateResponse.getType());
System.out.println("ID: "+updateResponse.getId());
System.out.println("版本: "+updateResponse.getVersion());
System.out.println("是否创建成功: "+updateResponse.isCreated()); //false
client.close();
}
----------------------------------------删除文档------------------------------------
prepareDelete
@Test
public void deleteData(){
DeleteResponse deleteResponse = client.prepareDelete("blog", "article", "3").get();
System.out.println("索引名称: " + deleteResponse.getIndex());
System.out.println("文档类型: "+deleteResponse.getType());
System.out.println("ID: "+deleteResponse.getId());
System.out.println("版本: "+deleteResponse.getVersion());
System.out.println("是否删除成功: "+deleteResponse.isFound());
client.close();
}
----------------------------------------查询文档------------------------------------
安装分词器之前的查询
es提供了queryStringQuery查询
针对多字短的query_string查询
@Test
public void testSearch(){
SearchResponse searchResponse = client.prepareSearch("blog")
.setTypes("article")
//默认分词器只能查找单个字,并没有把中文进行分词,需要我们安装一个分词器,IK分词器
.setQuery(QueryBuilders.queryStringQuery("更新"))
.get();
//获取数据的结果对象
SearchHits hits = searchResponse.getHits();
//获取命中次数
System.out.println("查询的结果数据有"+hits.getTotalHits()+"条");
//遍历所有数据
Iterator
while (iterator.hasNext()){
SearchHit hit = iterator.next();
//获取整条数据
System.out.println(hit.getSourceAsString());
//获取单个字段
System.out.println("id: "+ hit.getSource().get("id"));
System.out.println("title: "+ hit.getSource().get("title"));
System.out.println("content: "+ hit.getSource().get("content"));
}
client.close();
}
创新互联www.cdcxhl.cn，专业提供香港、美国云服务器，动态BGP最优骨干路由自动选择，持续稳定高效的网络助力业务部署。公司持有工信部办法的idc、isp许可证， 机房独有T级流量清洗系统配攻击溯源，准确进行流量调度，确保服务器高可用性。佳节活动现已开启，新人活动云服务器买多久送多久。
