往es中插入数据,springboot代码
时间: 2023-06-19 18:09:55 浏览: 116
以下是使用 Spring Boot 往 Elasticsearch 中插入数据的示例代码:
1. 首先需要在 `pom.xml` 文件中添加 Elasticsearch 和 Spring Data Elasticsearch 的依赖:
```xml
<!-- Elasticsearch -->
<dependency>
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
<version>7.8.0</version>
</dependency>
<!-- Spring Data Elasticsearch -->
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-elasticsearch</artifactId>
<version>4.0.0.RELEASE</version>
</dependency>
```
2. 在 `application.properties` 文件中配置 Elasticsearch 的连接信息:
```properties
spring.data.elasticsearch.cluster-nodes=localhost:9200
spring.data.elasticsearch.cluster-name=my-application
```
3. 创建一个实体类,用于映射 Elasticsearch 中的一个文档:
```java
@Document(indexName = "my_index", type = "my_type")
public class MyDocument {
@Id
private String id;
@Field(type = FieldType.Keyword)
private String title;
@Field(type = FieldType.Text)
private String content;
// 省略 getter 和 setter 方法
}
```
4. 创建一个 Elasticsearch 的操作类,用于实现数据的插入、更新、查询等操作:
```java
@Repository
public class MyDocumentRepository {
@Autowired
private ElasticsearchRestTemplate elasticsearchRestTemplate;
public void save(MyDocument myDocument) {
elasticsearchRestTemplate.save(myDocument);
}
// 可以添加其他操作方法,如查询、更新等
}
```
5. 在业务代码中调用 `MyDocumentRepository` 中的 `save` 方法,即可将数据插入到 Elasticsearch 中:
```java
MyDocument myDocument = new MyDocument();
myDocument.setTitle("Hello Elasticsearch");
myDocument.setContent("Elasticsearch is a distributed, open source search and analytics engine.");
myDocumentRepository.save(myDocument);
```
以上就是往 Elasticsearch 中插入数据的 Spring Boot 示例代码。注意,这里使用了 Spring Data Elasticsearch 来操作 Elasticsearch,简化了操作流程。
阅读全文