ElasticsearchでJava APIを使ってインデックスに登録する

public class Department {

	

    　private int department_id;

    　private String name;

	

    　public int getDepartment_id() {

    　　　return department_id;

    　}

    

    　public void setDepartment_id(int department_id) {

    　　　this.department_id = department_id;

    　}

    

    　public String getName() {

    　　　return name;

    　}

    

    　public void setName(String name) {

    　　　this.name = name;

    　}

}

public class Employee {

　private Department department;
　private int employee_id;
　private String name;


　public int getEmployee_id() {
　　　return employee_id;
　}

　public void setEmployee_id(int employee_id) {
　　　this.employee_id = employee_id;
　}

　public String getName() {
　　　return name;
　}

　public void setName(String name) {
　　　this.name = name;
　}

　public Department getDepartment() {
　　　return department;
　}

　public void setDepartment(Department department) {
　　　this.department = department;
　}
}

import org.elasticsearch.action.bulk.BulkProcessor;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.xcontent.XContentType;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectM
apper;

import java.util.ArrayList;
import java.util.List;

public class Elasticsearch{


　public static void main(String[] args){
　　　Elasticsearch es = new Elasticsearch();
　　　List<String> data = es.createTestData();
　　　es.index2ES(data);
　}


　/**
　　* テストデータの作成。
　　* @return List<String>
　　*/　　　
　public List<String> createTestData(){
　　　Department department = new Department();
　　　department.setDepartment_id(1);
　　　department.setName("営業部");
　　　Employee employee = new Employee();
　　　employee.setDepartment(department);
　　　employee.setEmployee_id(1);
　　　employee.setName("山田康夫");

　　　Department department2 = new Department();
　　　department2.setDepartment_id(2);
　　　department2.setName("人事部");
　　　Employee employee2 = new Employee();
　　　employee2.setDepartment(department2);
　　　employee2.setEmployee_id(2);
　　　employee2.setName("大木戸博士");

　　　List<String> employees = new ArrayList<String>();
　　　ObjectMapper objectMapper = new ObjectMapper();
　　　try {
　　　　　String json = objectMapper.writeValueAsString(employee);
　　　　　String json2 = objectMapper.writeValueAsString(employee2);
　　　　　employees.add(json);
　　　　　employees.add(json2);
　　　} catch (JsonProcessingException e) {
　　　　　e.printStackTrace();
　　　}

　　　return employees;
}


　　/**
　　　* Elasticsearchへ接続する。
　　　*
　　　* @return
　　*/
　public TransportClient getESConnection(){
　　//elasticsearch.ymlでクラスターの名前を変更した場合には適宜変更してください。
　　Settings settings = Settings.builder().put("cluster.name", "elasticsearch").build();
　　TransportClient client = new PreBuiltTransportClient(settings);
　　try {
　　　　client.addTransportAddress(new 　　　　InetSocketTransportAddress(InetAddress.getByName("localhost"), 9300))
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("localhost"), 9300));
　　}
　　catch (UnknownHostException e) {
　　　　e.printStackTrace();
　　}
　　return client;
}


　　/**
　　　* Elasticsearchにデータを一括登録する。
　　　* @param jsons
　　*/
　public void index2ES(List<String> jsons){
　　　TransportClient client = getESConnection();
　　　BulkProcessor bulkProcessor = BulkProcessor.builder(client, new 　　BulkProcessor.Listener() {

　　　@Override
　　　public void afterBulk(long arg0, BulkRequest arg1, BulkResponse arg2) 　　　{
　　　}

　　　@Override
　　　public void afterBulk(long arg0, BulkRequest arg1, Throwable arg2)
　　　{
　　　}

　　　@Override
　　　public void beforeBulk(long arg0, BulkRequest arg1) {
　　　}

　　})
　　　.setBulkActions(10000)
　　　.setConcurrentRequests(0)
　　　.build();

　　for(String json : jsons){
　　　IndexRequest indexRequest = new IndexRequest("test","employees");
　　　indexRequest.source(json,XContentType.JSON);
　　　bulkProcessor.add(indexRequest);
　　}

　　bulkProcessor.flush();
　　bulkProcessor.close();
　　client.admin().indices().prepareRefresh().get();
　　client.prepareSearch().get();
　　client.close();
　}
}