首先在官网下载elasticsearch8.9版本,以及8.9版本的kibana。
解压,点击es8.9bin目录下的elasticsearch.bat文件启动es
如图所示即为成功。
启动之后打开idea,添加依赖
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.13.2</version>
</dependency>
<dependency>
<groupId>org.glassfish</groupId>
<artifactId>jakarta.json</artifactId>
<version>2.0.1</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-configuration-processor</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>co.elastic.clients</groupId>
<artifactId>elasticsearch-java</artifactId>
<version>8.9.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<version>2.7.10</version>
</dependency>
之后配置配置文件
@Configuration
public class ElasticSearchConfig {
@Bean
public ElasticsearchClient elasticsearchClient(){
RestClient client = RestClient.builder(new HttpHost("localhost", 9200,"http")).build();
ElasticsearchTransport transport = new RestClientTransport(client,new JacksonJsonpMapper());
return new ElasticsearchClient(transport);
}
}
这时候就已经可以使用了基本使用操作如下代码块
@SpringBootTest
class SpringDataJpaApplicationTests {
@Autowired
private ElasticsearchClient client;
/*创建索引*/
@Test
void test01() throws Exception {
//写法比RestHighLevelClient更加简洁
CreateIndexResponse indexResponse = client.indices().create(c -> c.index("user"));
}
//查询数据
@Test
public void queryTest() throws IOException {
GetIndexResponse getIndexResponse = client.indices().get(i -> i.index("user"));
System.out.println(getIndexResponse);
}
//判断索引是否存在
@Test
public void existsTest() throws IOException {
BooleanResponse booleanResponse = client.indices().exists(e -> e.index("user"));
System.out.println(booleanResponse.value());
}
//删除索引
@Test
public void deleteTest() throws IOException {
DeleteIndexResponse deleteIndexResponse = client.indices().delete(d -> d.index("user"));
System.out.println(deleteIndexResponse.acknowledged());
}
//插入document
@Test
public void addDocumentTest() throws IOException {
User user = new User(1, "张三","123123123");
IndexResponse indexResponse = client.index(i -> i
.index("user")
//设置id
.id("1")
//传入user对象
.document(user));
}
//更新document
@Test
public void updateDocumentTest() throws IOException {
UpdateResponse<User> updateResponse = client.update(u -> u
.index("user")
.id("1")
.doc(new User(1,"user2","123132131"))
, User.class);
}
//查询document
@Test
public void queryDocumentTest() throws IOException {
GetResponse<User> response = client.get(g -> g
.index("user")
.id("1")
, User.class);
System.out.println(response);
System.out.println(response.source());
}
//删除document
@Test
public void deleteDocumentTest() throws IOException {
DeleteResponse response = client.delete(d -> d
.index("user")
.id("1")
);
System.out.println(response);
}
//批量插入document
@Test
public void bulkTest() throws IOException {
List<User> users=new CopyOnWriteArrayList<>();
users.add(new User(1,"张1","1233"));
users.add(new User(2,"张2","1234"));
users.add(new User(3,"张3","1235"));
users.add(new User(4,"张4","1236"));
users.add(new User(5,"张5","1237"));
List< BulkOperation> bulkOperationCopyOnWriteArrayList =new CopyOnWriteArrayList<>();
//遍历插入bulk中
users.stream().forEach(u->{
bulkOperationCopyOnWriteArrayList.add(BulkOperation.of(o ->o
.index(i->i.document(u))));
});
System.out.println(bulkOperationCopyOnWriteArrayList);
BulkResponse response=client.bulk(b->b
.index("user")
.operations(bulkOperationCopyOnWriteArrayList));
System.out.println(response);
}
//查询
/* @Test
public void searchTest() throws IOException {
SearchResponse<User> search = client.search(s -> s
.index("user")
//查询name字段包含hello的document(不使用分词器精确查找)
.query(q -> q
.term(t -> t
.field("name")
.value(v -> v.stringValue("hello"))
))
//分页查询,从第0页开始查询3个document
.from(0)
.size(3)
//按age降序排序
.sort(f->f.field(o->o.field("age").order(SortOrder.Desc))),User.class
);
for (Hit<User> hit : search.hits().hits()) {
System.out.println(hit.source());
}
}*/
}