<dependency>
    <groupId>net.hasor</groupId>
    <artifactId>dbvisitor</artifactId>
    <version>6.4.0</version>
</dependency>
<dependency>
    <groupId>net.hasor</groupId>
    <artifactId>jdbc-elastic</artifactId>
    <version>6.4.0</version>
</dependency>

// 1. 获取 ElasticSearch 连接
Connection esConn = ...; // 参考文档：驱动适配器 > JDBC Elastic > 安装与配置
JdbcTemplate jdbc = new JdbcTemplate(esConn);

// 2. 插入数据
jdbc.execute("POST /my_index/_doc/1 { \"name\": \"mali\", \"age\": 26 }");

// 3. 查询数据
List<Map<String, Object>> list = jdbc.queryForList(
    "POST /my_index/_search { \"query\": { \"match_all\": {} } }");

// 4. 更新数据
jdbc.execute("POST /my_index/_update/1 { \"doc\": { \"age\": 27 } }");

// 5. 删除数据
jdbc.execute("DELETE /my_index/_doc/1");

// 1. 定义实体类
@Table("my_index")
public class UserInfo {
    @Column(value = "uid", primary = true)
    private String uid;
    @Column("name")
    private String name;
    // getters and setters
}

// 2. 定义 Mapper 接口
@SimpleMapper
public interface UserInfoMapper extends BaseMapper<UserInfo> {
    @Insert("POST /my_index/_doc { \"uid\": #{user.uid}, \"name\": #{user.name} }")
    int saveUser(@Param("user") UserInfo user);

    @Query("POST /my_index/_search { \"query\": { \"term\": { \"uid\": #{uid} } } }")
    UserInfo loadUser(@Param("uid") String uid);
}

// 3. 使用 Mapper
try (Session session = config.newSession(esConn)) {
    UserInfoMapper mapper = session.createMapper(UserInfoMapper.class);

    // 保存
    UserInfo user = new UserInfo();
    user.setUid("1111");
    user.setName("mali");
    mapper.saveUser(user);

    // 查询
    UserInfo loaded = mapper.loadUser("1111");
}

// 1. 获取 ElasticSearch 连接
LambdaTemplate lambda = new LambdaTemplate(esConn);

// 2. 插入数据
UserInfo user = new UserInfo();
user.setUid("1001");
user.setName("test_user");
lambda.insert(user);

// 3. 查询数据
UserInfo loaded = lambda.query(UserInfo.class)
                        .eq(UserInfo::getUid, "1001")
                        .queryForObject();