springboot项目注入elasticsearch实现es的批量从mysql数据库查出当天数据写入es的代码详细例子

Spring Boot项目中，可以使用Elasticsearch的客户端库如`spring-data-elasticsearch`配合JPA（Java Persistence API）从MySQL数据库获取数据并批量写入Elasticsearch。以下是一个简单的示例：

首先，确保你在pom.xml文件中添加了相关的依赖：

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    </dependency>
    <dependency>
        <groupId>com.querydsl</groupId>
        <artifactId>querydsl-jpa</artifactId>
    </dependency>
    <!-- 如果使用MySQL JPA -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-jpa</artifactId>
    </dependency>
    <!-- MySQL驱动 -->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
    </dependency>
</dependencies>

然后，创建一个Repository接口，继承自ElasticsearchRepository:

import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.stereotype.Repository;

@Repository
public interface MyDataRepository extends ElasticsearchRepository<MyEntity, String> {
}

假设你有一个名为`MyEntity`的实体类对应MySQL表，它有一个日期字段`dateField`：

import javax.persistence.Entity;
import java.util.Date;

@Entity
public class MyEntity {
    private String id;
    private Date dateField; // 这里假设日期字段名

    // getters and setters...
}

在Service层，你可以使用JPA查询MySQL的数据，并利用`saveAll()`方法批量写入Elasticsearch:

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.stereotype.Service;

@Service
public class DataService {

    @Autowired
    private MyDataRepository myDataRepository;

    public void batchImportFromMysqlToEs() {
        Page<MyEntity> page = myDataRepository.findAll(new PageRequest(0, 100, Sort.by(Sort.Direction.DESC, "dateField"))); // 查询最近一天的数据
        myDataRepository.saveAll(page); // 批量保存到Elasticsearch
    }
}

注意，这个例子假设每天只处理100条数据。你可以根据实际需求调整分页查询的数量。另外，为了简化起见，这里未涉及错误处理和日志记录，实际应用中应加入适当的异常处理。