Fetch the repository succeeded.
2.0.x版本最先是在elasticsearch-sql的实验特性项目的基础上修改而来,修改和补充了部分jdbc规范，使之能够和mybatis结合，sql支持度可参考elasticsearch-sql，引入了jest，实现了mybatis+rest api的方式操作elasticsearch。提供了Java api的工具类ESUtil和rest api工具类JestUtil。
由于和Druid数据库连接池耦合太大，在使用过程中发现了一系列问题，决定将JDBC和数据库连接池解耦。添加ElasticSearchDriver类可以直接使用Class.forName加载驱动。
3.0.0版本不再使用elasticsearch-sql实验项目关于数据库连接池的部分，依旧沿用sql解析部分的代码
3.0.1 TransportClient 增加心跳监测，解决连接超时的问题。增加集群名配置
<repositories>
<repository>
<id>wjj-maven-repo</id>
<url>https://raw.github.com/zhanyingf15/maven-repo/master</url>
</repository>
</repositories>
上面是在GitHub上搭建的私人仓库
<dependency>
<groupId>com.wjj</groupId>
<artifactId>elasticsearch-jdbc</artifactId>
<version>3.0.0</version>
</dependency>
<bean id="defaulteDataSource-es" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
<property name="driverClassName" value="com.wjj.jdbc.elasticsearch.ElasticSearchDriver" />
<property name="url" value="${java.url}" />
<property name="initialSize" value="2" />
<property name="minIdle" value="2" />
<property name="maxActive" value="${maxActive}" />
<property name="maxWait" value="60000" />
<property name="timeBetweenEvictionRunsMillis" value="60000" />
<property name="minEvictableIdleTimeMillis" value="300000" />
<property name="validationQuery" value="select 1 from dual" />
<property name="testWhileIdle" value="true" />
<property name="testOnBorrow" value="false" />
<property name="testOnReturn" value="false" />
<property name="poolPreparedStatements" value="false" />
<property name="maxPoolPreparedStatementPerConnectionSize" value="20" />
<property name="removeAbandoned" value="true" />
<property name="removeAbandonedTimeout" value="1800" />
<property name="logAbandoned" value="true" />
<property name="filters" value="stat,log4j" />
<property name="connectionProperties" value="druid.stat.slowSqlMillis=5000" />
</bean>
<bean id="defaultSQLSessionFactory-es" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="defaulteDataSource-es" />
<property name="configLocation" value="classpath:mybatis-config.xml"></property>
<property name="mapperLocations">
<array>
<value>classpath*:com/**/model/es/*.xml</value>
</array>
</property>
</bean>
<bean id="defaultSQLSessionTemplate-es" class="org.mybatis.spring.SqlSessionTemplate">
<constructor-arg index="0" ref="defaultSQLSessionFactory-es" />
</bean>
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name = "dataSource" ref="defaulteDataSource-es"/>
</bean>
elasticsearch.properties配置文件是必须的，可以直接如上面代码引入到spring配置文件中。java.url是TransportClient的地址，http.url是REST接口地址
#es java TransportClient address，split by "," if have multi address,eg.jdbc:elasticsearch://ip1:port,ip2:port
java.url=jdbc:elasticsearch://192.168.70.128:9300
#es rest http address，split by "," if have multi address.eg http://ip1:port,http://ip2:port
http.url=http://192.168.70.128:9200
#max connection number
maxActive=20
#cluster name，ignored if you not setting
cluster.name=elasticsearch
<!-- query data from oracle database -->
<select id="qryOracleList" parameterType="java.lang.Object" resultType="java.util.HashMap">
SELECT * FROM testTable
</select>
<!--query or update data by rest api -->
<!--add-->
<insert id="jestInsert" parameterType="java.lang.Object">
PUT ${index}/${type}/${_id}?op_type=create
{
"id":"${id}",
"name":"${name}"
}
</insert>
<!--search-->
<select id="qryTest2" parameterType="java.lang.Object" resultType="java.util.HashMap">
POST ${index}/${type}/_search?
{
"query": {
"prefix": {
"name": "te"
}
}
}
</select>
<!--query demo2，query data by _id-->
<select id="qryTest2" parameterType="java.lang.Object" resultType="java.util.HashMap">
GET ${index}/${type}/${id}
</select>
<!--update-->
<update id="jestUpdate" parameterType="java.lang.Object">
POST ${index}/${type}/${id}/_update?
{
"doc": {
"name": "${name}"
}
}
</update>
<!--delete-->
<delete id="jestDeletee" parameterType="java.lang.Object">
DELETE ${index}/${type}/${id}
</delete>
上面基本列出了CRUD操作，为了方便描述，xml中的内容统称为restBody，以修改为例，POST为协议，index/type/id/_update为uri，?和第一个{间的内容为参数(即添加示例中的op_type=create，可选)，{xxx}为restMapping，这个就是发到elasticsearch的结构体（JSON字符串）。
协议的不同，uri也会不同，参数都是可选的，协议与uri的关系如下：
index/type/id/_update格式。id可以传入多个批量更新(如更新多个文档的state)，使用英文,分隔
如果是select，index/type都是可选，也可以传入多个index和type，用英文,分隔，如：index1,index2/type1,type2/_search，不能有id，必须带_search，所以select操作只能是下面几种uri
_search：不指定index和typeindex/_search：只指定indexindex/type/_search：同时指定index和typeindex/type/id这种格式。id可以传入多个批量删除，使用英文,分隔，不能根据条件删除，所以传入restMapping是无效的index/type/id格式，只能指定一个id，如果需要同时通过多个id查询，使用idsQuery，传入restMapping无效。协议不区分大小写，参数可选。但是无论是否有参数，只要有restMapping，
?必须带上
注意
所有的增删改查都可以包裹在<select>中，如果是包裹在<select>中，都可以在java中通过以下方式获取结果
Map result = session.selectOne("xxx",param);
//如果是增、删、改操作。
JestResult result = JestUtil.getExecuteResult(result);
//如果是查询
SearchResult result = JestUtil.getQueryResult(result);
如果增删改是包裹在对应的<insert>、<update>和<delete>中，通过session.insert、session.update、session.delete操作返回的整形数字不是关系型数据库中影响的行数，而是http状态码，2xx系列状态码表示操作成功，如果操作失败，并不会返回具体的错误信息，程序也不会报错。如果需要具体的操作信息，只能使用<select>包裹，返回JestResult对象，再调用相应的方法获取具体信息。
操作elasticsearch时，在mybatis的xml中只能使用
${}而不是#{}，因为elasticsearch并不是数据库，并没有数据库元数据，后续考虑会构建一个elasticsearch的元数据对象。
service业务层
@Resource(name = "defaultSQLSessionTemplate-es")
protected SqlSessionTemplate sessionES;
public Map<String,Object> qryJest(Map param){
Map result = new HashMap<>();
JestResult jestResult = JestUtil.getQueryResult(sessionES.selectOne("es.qryTest2",param));
result.put("data_list",jestResult.getSourceAsObjectList(Map.class));
return result;
}
main方法
ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext("classpath:applicationContext.xml");
ac.start();
SqlSessionTemplate esSession = SpringBeanUtil.getInstance().getBean("defaultSQLSessionTemplate-es",SqlSessionTemplate.class);
ESTestServiceImpl esTestService = SpringBeanUtil.getInstance().getBean("esTestService",ESTestServiceImpl.class);
Map param = new HashMap();
param.put("index","radiott");
param.put("type","artiststt");
param.put("name","te");
Map result = esTestService.qryJest(param);
JDBC测试
Class.forName("com.wjj.jdbc.elasticsearch.ElasticSearchDriver");
Connection conn = DriverManager.getConnection("jdbc:elasticsearch://192.168.70.128:9300");
PreparedStatement stmt = conn.prepareStatement("select * from bank");
ResultSet rs = stmt.executeQuery();
while (rs.next()){
System.out.println("firstname:"+rs.getString("firstname")+",balance:"+rs.getInt("balance"));
}
如果单独使用rest api时不需要创建连接，也可以不创建数据源(需要手动调用initJestClient()初始化客户端)
public static void testRest() throws Exception{
//properties就是elasticsearch.properties的配置内容，可以传null，默认从配置文件读取
JestUtil.initJestClient(properties);
String restStr = "{ " +
" \"query\":{" +
" \"term\":{ " +
" \"firstname\":\"effie\"" +
" }" +
" }" +
"}";
SearchResult result = JestUtil.query(restStr,new String[]{"bank"},new String[]{"account"});
List<SearchResult.Hit<Map,Void>> list = result.getHits(Map.class);
for(SearchResult.Hit<Map,Void> hit:list){
Iterator<Map.Entry<String,Object>> i = hit.source.entrySet().iterator();
while(i.hasNext()){
Map.Entry<String,Object> entry = i.next();
System.out.println(entry.getKey()+":"+entry.getValue());
}
}
}
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
马建仓 AI 助手
