springboot內建spring-data-elasticsearch 完成對es的操作

一、內建spring-data-elasticsearch

1. 在springboot中內建spring-data-elasticsearch 非常的簡單隻需要引入下面的start：

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
        </dependency>
           

1. 在 application.properties l檔案配置以下參數：

# es叢集的名字
spring.data.elasticsearch.cluster-name=elasticsearch
# es機器的可用節點
spring.data.elasticsearch.cluster-nodes=127.0.0.1:9300
           

二、将mysql中資料導入es

本文使用了lombok 加快開發效率，同時使實體類代碼看上去更簡潔，修改起來也友善1.使用lombok也很簡單具體可參考以下連接配接：一篇文章搞懂Lombok

1. 編寫實體類

@Data
@ToString
@NoArgsConstructor
@AllArgsConstructor
@Document(indexName="myes",type="myuser",refreshInterval="-1")
public class User {
    @Id // 這個id加不加都不影響導入
    private Integer id;
    private String firstName;
    private String lastName;
    private  Integer age;
    //type 為字段類型
    @Field(type = FieldType.Keyword)
    private String About;
}
           

1. 編寫導入的Controller

RestController
@RequestMapping("user")
public class UserController {

    private static final Logger log= LoggerFactory.getLogger(UserController.class);
    @Autowired
    private UserRepository userRepository;
    @Autowired
    private ElasticsearchTemplate estemplate;

    @RequestMapping("queryString")
    public Object queryString(String key, @PageableDefault Pageable pageable){
        return userRepository.queryString(key, pageable);
    }


    /**
     * 模拟将mysql的資料導入es中
     * @return
     */
    @RequestMapping("mysqlToEs")
    public String mysqlToEs(){

        log.info("開始将資料導入es");
        long startTime = System.currentTimeMillis();
        //模拟從mysql中取到user的集合
        List<User> userListMysql = getUserListForMysql();
        try {
            int count = 0;
            if (estemplate.indexExists(User.class)) {
                // 如果存在index則先删除，避免資料備援或者資料重新整理不完整
                estemplate.deleteIndex(User.class);
                log.info("删除舊index");
            }
            estemplate.createIndex(User.class);
            //解決高版本的@Field注解失效問題
            estemplate.putMapping(User.class);

            log.info("建立index");
            ArrayList<IndexQuery> queries = new ArrayList<>();

            for (User entity : userListMysql ) {
                IndexQuery indexQuery = new IndexQuery();
                //這個地方就是設定主鍵id，目前你也可以換成其他字段,或者uuid，這個地方預設使用id作為_id的值，即使實體類上不加@Id注解
                //indexQuery.setId(UUID.randomUUID().toString());
                indexQuery.setId(entity.getId().toString());
                indexQuery.setObject(entity);
                indexQuery.setIndexName("myes");
                indexQuery.setType("myuser");
                queries.add(indexQuery);
                if (count % 500 == 0) {
                    estemplate.bulkIndex(queries);
                    queries.clear();
                }
                count++;
            }
            if (queries.size() > 0) {
                estemplate.bulkIndex(queries);
                log.info("導入完成，耗時：" + (System.currentTimeMillis() - startTime) + "ms"+"導入總條數："+count);
            }
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("導入失敗");
        }
        return "導入成功！";
    }

    public List<User> getUserListForMysql(){
        ArrayList<User> userListMysql = new ArrayList<>();
        for (int i = 1001; i <1060 ; i++) {
           userListMysql.add(new User(i,"張","三"+i,i,"簡介"+i)) ;
        }
        return userListMysql;
    }

    @RequestMapping("/flushByIndex")
    public String flushEsByIndex(){
        DeleteQuery deleteQuery = new DeleteQuery();
        deleteQuery.setIndex("myes");
        deleteQuery.setType("myuser");
        //這個查詢一定要有，查詢中不設定任何條件即認為是删除目前索引的所有記錄
        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
        deleteQuery.setQuery(boolQueryBuilder);
        estemplate.delete(deleteQuery);
        return "清空es資料成功";
    }

}


           

1. 使用postman通路連接配接：localhost:8090/user/mysqlToEs

   

2. 使用kibana檢視是否導入成功

   

三、使用ElasticsearchTemplate操作es

本文以下代碼測試主要來源于以下連接配接具體可以參考一下連接配接：

ElasticsearchTemplate的詳細使用，完成多條件查詢、比對度查詢

四、github源碼位址

為了友善各位朋友的測試，使用，學習特将源碼釋出到了github，歡迎下載下傳學習，交流，共同進步！

https://github.com/Dr-Water/springdata-es-action

ElasticSearch實戰 之 es，kibana 的安裝和使用

springboot 、spring-data-elasticsearch、elasticserach的版本對應關系

優秀的elasticsearch學習參考文章合集