elasticsearch 创建索引,以及检索一条数据

时间:2021-07-31 03:38:16

elasticsearch的重要概念

我们可以把elasticsearch当做数据库来理解:

  • index:索引库名称,相当于关系型数据库中的表名,一个elasticsearch集群中可以有多个索引库。
  • type:索引库中索引数据类型,为索引类型,是用来区分同索引库下不同类型的数据的,一个索引库下可以有多个索引类型。
  • id:索引库中索引数据主键,唯一。

创建json document

elasticsearch有多种创建json document的方式

1. 手写,比如

String json = "{" +
"\"user\":\"kimchy\"," +
"\"postDate\":\"2013-01-30\"," +
"\"message\":\"trying out Elasticsearch\"" +
"}";

2. 使用map

Map<String, Object> json = new HashMap<String, Object>();
json.put("user","kimchy");
json.put("postDate",new Date());
json.put("message","trying out Elasticsearch");

3. 序列化bean

For example,use jackson

<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.1.3</version>
</dependency>

然后我们可以使用jackson来序列化我们的bean

import com.fasterxml.jackson.databind.*;

// instance a json mapper
ObjectMapper mapper = new ObjectMapper(); // create once, reuse // generate json
String json = mapper.writeValueAsString(yourbeaninstance);

4.使用elasticsearch的帮助类

Elasticsearch 提供帮助类来生成JSON.

import static org.elasticsearch.common.xcontent.XContentFactory.*;

XContentBuilder builder = jsonBuilder()
.startObject()
.field("user", "kimchy")
.field("postDate", new Date())
.field("message", "trying out Elasticsearch")
.endObject()

创建索引

举个例子,比如索引名字叫blog,type是post,id为1

IndexResponse response = client.prepareIndex("blog", "post", "1")
.setSource(XContentFactory.jsonBuilder().startObject()
.field("title", "test")
.field("content", "here is content")
.field("tag", "test")
.endObject() ).execute().actionGet();

如果我们不指定id,ES会为我们生成id,setSource方法有几种形式,可以传入json字符串,map等,差不多就是上面指出的几种形式

IndexResponse返回一些信息:

// Index name
String _index = response.getIndex();
// Type name
String _type = response.getType();
// Document ID (generated or not)
String _id = response.getId();
// Version (if it's the first time you index this document, you will get: 1)
long _version = response.getVersion();
//是否创建成功
boolean isCreated = response.isCreated()

检索一条记录

在创建索引时,我们根据IndexResponse,得到了index、type和id,检索一条记录的方法很简单,它可以用来判断指定index,type,id的索引是否存在

GetResponse getResponse = client.prepareGet("blog", "post","1")
.execute()
.actionGet();

GetResponse中常用的方法有isExists(),getSourceAsString()等,前者判断指定索引是否存在,后面用来得到返回的json。我们可以根据json反序列化得到我们要的对象

Post post = mapper.readValue(getResponse.getSourceAsString(),Post.class);