+ * ES常量池 + *
+ * + * @package: com.xkcoding.elasticsearch.constants + * @description: ES常量池 + * @author: yangkai.shen + * @date: Created in 2018-12-20 17:30 + * @copyright: Copyright (c) 2018 + * @version: V1.0 + * @modified: yangkai.shen + */ +public interface EsConsts { + /** + * 索引名称 + */ + String INDEX_NAME = "person"; + + /** + * 类型名称 + */ + String TYPE_NAME = "person"; +} diff --git a/spring-boot-demo-elasticsearch/src/main/java/com/xkcoding/elasticsearch/model/Person.java b/spring-boot-demo-elasticsearch/src/main/java/com/xkcoding/elasticsearch/model/Person.java new file mode 100644 index 0000000..614af61 --- /dev/null +++ b/spring-boot-demo-elasticsearch/src/main/java/com/xkcoding/elasticsearch/model/Person.java @@ -0,0 +1,67 @@ +package com.xkcoding.elasticsearch.model; + +import com.xkcoding.elasticsearch.constants.EsConsts; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; +import org.springframework.data.annotation.Id; +import org.springframework.data.elasticsearch.annotations.Document; +import org.springframework.data.elasticsearch.annotations.Field; +import org.springframework.data.elasticsearch.annotations.FieldType; + +import java.util.Date; + +/** + *+ * 用户实体类 + *
+ * + * @package: com.xkcoding.elasticsearch.model + * @description: 用户实体类 + * @author: yangkai.shen + * @date: Created in 2018-12-20 17:29 + * @copyright: Copyright (c) 2018 + * @version: V1.0 + * @modified: yangkai.shen + */ +@Document(indexName = EsConsts.INDEX_NAME, type = EsConsts.TYPE_NAME, shards = 1, replicas = 0) +@Data +@NoArgsConstructor +@AllArgsConstructor +public class Person { + /** + * 主键 + */ + @Id + private Long id; + + /** + * 名字 + */ + @Field(type = FieldType.Keyword) + private String name; + + /** + * 国家 + */ + @Field(type = FieldType.Keyword) + private String country; + + /** + * 年龄 + */ + @Field(type = FieldType.Integer) + private Integer age; + + /** + * 生日 + */ + @Field(type = FieldType.Date) + private Date birthday; + + /** + * 介绍 + */ + @Field(type = FieldType.Text, analyzer = "ik_smart") + private String remark; +} diff --git a/spring-boot-demo-elasticsearch/src/main/java/com/xkcoding/elasticsearch/repository/PersonRepository.java b/spring-boot-demo-elasticsearch/src/main/java/com/xkcoding/elasticsearch/repository/PersonRepository.java new file mode 100644 index 0000000..5158d33 --- /dev/null +++ b/spring-boot-demo-elasticsearch/src/main/java/com/xkcoding/elasticsearch/repository/PersonRepository.java @@ -0,0 +1,31 @@ +package com.xkcoding.elasticsearch.repository; + +import com.xkcoding.elasticsearch.model.Person; +import org.springframework.data.elasticsearch.repository.ElasticsearchRepository; + +import java.util.List; + +/** + *+ * 用户持久层 + *
+ * + * @package: com.xkcoding.elasticsearch.repository + * @description: 用户持久层 + * @author: yangkai.shen + * @date: Created in 2018-12-20 19:00 + * @copyright: Copyright (c) 2018 + * @version: V1.0 + * @modified: yangkai.shen + */ +public interface PersonRepository extends ElasticsearchRepository+ * 测试 Repository 操作ES + *
+ * + * @package: com.xkcoding.elasticsearch.repository + * @description: 测试 Repository 操作ES + * @author: yangkai.shen + * @date: Created in 2018-12-20 19:03 + * @copyright: Copyright (c) 2018 + * @version: V1.0 + * @modified: yangkai.shen + */ +@Slf4j +public class PersonRepositoryTest extends SpringBootDemoElasticsearchApplicationTests { + @Autowired + private PersonRepository repo; + + /** + * 测试新增 + */ + @Test + public void save() { + Person person = new Person(1L, "刘备", "蜀国", 18, DateUtil.parse("1990-01-02 03:04:05"), "刘备（161年－223年6月10日），即汉昭烈帝（221年－223年在位），又称先主，字玄德，东汉末年幽州涿郡涿县（今河北省涿州市）人，西汉中山靖王刘胜之后，三国时期蜀汉开国皇帝、政治家。\n刘备少年时拜卢植为师；早年颠沛流离，备尝艰辛，投靠过多个诸侯，曾参与镇压黄巾起义。先后率军救援北海相孔融、徐州牧陶谦等。陶谦病亡后，将徐州让与刘备。赤壁之战时，刘备与孙权联盟击败曹操，趁势夺取荆州。而后进取益州。于章武元年（221年）在成都称帝，国号汉，史称蜀或蜀汉。《三国志》评刘备的机权干略不及曹操，但其弘毅宽厚，知人待士，百折不挠，终成帝业。刘备也称自己做事“每与操反，事乃成尔”。\n章武三年（223年），刘备病逝于白帝城，终年六十三岁，谥号昭烈皇帝，庙号烈祖，葬惠陵。后世有众多文艺作品以其为主角，在成都武侯祠有昭烈庙为纪念。"); + Person save = repo.save(person); + log.info("【save】= {}", save); + } + + /** + * 测试批量新增 + */ + @Test + public void saveList() { + List+ * 测试 ElasticTemplate 的创建/删除 + *
+ * + * @package: com.xkcoding.elasticsearch.template + * @description: 测试 ElasticTemplate 的创建/删除 + * @author: yangkai.shen + * @date: Created in 2018-12-20 17:46 + * @copyright: Copyright (c) 2018 + * @version: V1.0 + * @modified: yangkai.shen + */ +public class TemplateTest extends SpringBootDemoElasticsearchApplicationTests { + @Autowired + private ElasticsearchTemplate esTemplate; + + /** + * 测试 ElasticTemplate 创建 index + */ + @Test + public void testCreateIndex() { + // 创建索引，会根据Item类的@Document注解信息来创建 + esTemplate.createIndex(Person.class); + + // 配置映射，会根据Item类中的id、Field等字段来自动完成映射 + esTemplate.putMapping(Person.class); + } + + /** + * 测试 ElasticTemplate 删除 index + */ + @Test + public void testDeleteIndex() { + esTemplate.deleteIndex(Person.class); + } +}