es java api 创建索引结构_[搜索]ElasticSearch Java Api(一) －添加数据创建索引

冷不防 2022-11-03 11:53 54阅读 0赞

概要：

一、生成JSON

创建索引的第一步是要把对象转换为JSON字符串.官网给出了四种创建JSON文档的方法：

1.1手写方式生成

1 String json = "\{" +

2 "\\"user\\":\\"kimchy\\"," +

3 "\\"postDate\\":\\"2013-01-30\\"," +

4 "\\"message\\":\\"trying out Elasticsearch\\"" +

5 "\}";

手写方式很简单，但是要注意日期格式：Date Formate

1.2使用集合

集合是key:value数据类型，可以代表json结构.

1 Map json = new HashMap();2 json.put("user","kimchy");3 json.put("postDate","2013-01-30");4 json.put("message","trying out Elasticsearch");

1.3使用JACKSON序列化

ElasticSearch已经使用了jackson，可以直接使用它把javabean转为json.

1 //instance a json mapper

2 ObjectMapper mapper = new ObjectMapper(); //create once, reuse3

4 //generate json

5 byte\[\] json = mapper.writeValueAsBytes(yourbeaninstance);

1.4使用ElasticSearch 帮助类

1 import static org.elasticsearch.common.xcontent.XContentFactory.\*;2

3 XContentBuilder builder =jsonBuilder()4 .startObject()5 .field("user", "kimchy")6 .field("postDate", newDate())7 .field("message", "trying out Elasticsearch")8 .endObject()9

10 String json = builder.string();

二、创建索引

下面的例子把json文档写入所以，索引库名为twitter、类型为tweet,id为1：

1 import static org.elasticsearch.common.xcontent.XContentFactory.\*;2

3 IndexResponse response = client.prepareIndex("twitter", "tweet", "1")4 .setSource(jsonBuilder()5 .startObject()6 .field("user", "kimchy")7 .field("postDate", newDate())8 .field("message", "trying out Elasticsearch")9 .endObject()10 )11 .get();

也可以直接传人JSON字符串：

1 String json = "\{" +

2 "\\"user\\":\\"kimchy\\"," +

3 "\\"postDate\\":\\"2013-01-30\\"," +

4 "\\"message\\":\\"trying out Elasticsearch\\"" +

5 "\}";6

7 IndexResponse response = client.prepareIndex("twitter", "tweet")8 .setSource(json)9 .get();

可以调用response对象的方法获取返回信息：

1 //索引名称

2 String \_index =response.getIndex();3 //类型名称

4 String \_type =response.getType();5 //文档id

6 String \_id =response.getId();7 //版本(if it's the first time you index this document, you will get: 1)

8 long \_version =response.getVersion();9 //是否被创建is true if the document is a new one, false if it has been updated

10 boolean created = response.isCreated();

更简单的可以直接System.out.println(response)查看返回信息.

三、java实现

新建一个java项目，导入elasticsearch-2.3.3/lib目录下的jar文件.新建一个Blog类：

1 packagecom.cn.test.exaple1;2

3 public classBlog \{4

5 privateInteger id;6 privateString title;7 privateString posttime;8 privateString content;9

10 publicBlog() \{11 \}12

13 publicBlog(Integer id, String title, String posttime, String content) \{14 this.id =id;15 this.title =title;16 this.posttime =posttime;17 this.content =content;18 \}19

20 publicInteger getId() \{21 returnid;22 \}23

24 public voidsetId(Integer id) \{25 this.id =id;26 \}27

28 publicString getTitle() \{29 returntitle;30 \}31

32 public voidsetTitle(String title) \{33 this.title =title;34 \}35

36 publicString getPosttime() \{37 returnposttime;38 \}39

40 public voidsetPosttime(String posttime) \{41 this.posttime =posttime;42 \}43

44 publicString getContent() \{45 returncontent;46 \}47

48 public voidsetContent(String content) \{49 this.content =content;50 \}51

53 \}

创建java实体类转json工具类：

1 packagecom.cn.test.exaple1;2

3 importjava.io.IOException;4

5 importorg.elasticsearch.common.xcontent.XContentBuilder;6 importorg.elasticsearch.common.xcontent.XContentFactory;7

8 /\*\*

9 \* @ClassName: JsonUtil10 \* @Description: java实体类转json工具类11 \*@authorJinXing12 \* @date 2017年12月1日 下午1:48:2513 \*14 \*/

15 public classJsonUtil \{16

17 //Java实体对象转json对象

18 public staticString model2Json(Blog blog) \{19 String jsonData = null;20 try\{21 XContentBuilder jsonBuild =XContentFactory.jsonBuilder();22 jsonBuild.startObject().field("id", blog.getId()).field("title", blog.getTitle())23 .field("posttime", blog.getPosttime()).field("content",blog.getContent()).endObject();24

25 jsonData =jsonBuild.string();26 System.out.println(jsonData);27

28 \} catch(IOException e) \{29 e.printStackTrace();30 \}31

32 returnjsonData;33 \}34

35 \}

添加数据，返回一个list：

1 packagecom.cn.test.exaple1;2

3 importjava.util.ArrayList;4 importjava.util.List;5

6 /\*\*

7 \* @ClassName: DataFactory8 \* @Description: 添加数据，返回一个list：9 \*@authorJinXing10 \* @date 2017年12月1日 下午3:08:0211 \*12 \*/

13 public classDataFactory \{14

15 public static DataFactory dataFactory = newDataFactory();16

17 privateDataFactory() \{18 \}19

20 publicDataFactory getInstance() \{21 returndataFactory;22 \}23

24 //List 数据集

25 public static ListgetInitJsonData() \{26 List list = new ArrayList();27 String data1 = JsonUtil.model2Json(new Blog(1, "git简介", "2016-06-19", "SVN与Git最主要的区别..."));28 String data2 = JsonUtil.model2Json(new Blog(2, "Java中泛型的介绍与简单使用", "2016-06-19", "学习目标 掌握泛型的产生意义..."));29 String data3 = JsonUtil.model2Json(new Blog(3, "SQL基本操作", "2016-06-19", "基本操作：CRUD ..."));30 String data4 = JsonUtil.model2Json(new Blog(4, "Hibernate框架基础", "2016-06-19", "Hibernate框架基础..."));31 String data5 = JsonUtil.model2Json(new Blog(5, "Shell基本知识", "2016-06-19", "Shell是什么..."));32 list.add(data1);33 list.add(data2);34 list.add(data3);35 list.add(data4);36 list.add(data5);37 returnlist;38 \}39

40 \}

创建索引、添加数据：

1 packagecom.cn.test.exaple1;2

3 importjava.io.IOException;4 importjava.net.InetAddress;5 importjava.net.UnknownHostException;6 importjava.util.List;7

8 importorg.elasticsearch.action.index.IndexResponse;9 importorg.elasticsearch.client.Client;10 importorg.elasticsearch.client.transport.TransportClient;11 importorg.elasticsearch.common.transport.InetSocketTransportAddress;12

13 public classElasticSearchHandler \{14

15 public static voidmain(String\[\] args) \{16 try\{17 /\*创建客户端\*/

18 //client startup

19 Client client =TransportClient.builder().build()20 .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));21

22 //数据源

23 List jsonData =DataFactory.getInitJsonData();24

25 for (int i = 0; i < jsonData.size(); i++) \{26

27 //JSON文档写入索引，索引库名为blog、类型为article

28 IndexResponse response = client.prepareIndex("blog", "article")29 //写入JSON字符串

30 .setSource(jsonData.get(i)).get();31 if (response.isCreated()) \{//是否被创建is true if the document is a new one, false if it has been updated

32 System.out.println("创建成功!");33 \}34 \}35

36 client.close();37 \} catch(UnknownHostException e) \{38 e.printStackTrace();39 \} catch (@SuppressWarnings("hiding") IOException e) \{40 e.printStackTrace();41 \}42

43 \}44

46 \}

查看插入的数据：