同步操作将从 bboss/bboss-elasticsearch 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
Bboss is a good elasticsearch Java rest client. It operates and accesses elasticsearch in a way similar to mybatis.
https://esdoc.bbossgroups.com/#/README
JDK requirement: JDK 1.7+ Elasticsearch version requirements: 1.X,2.X,5.X,6.X,7.x,+
First Get source code from https://github.com/bbossgroups/bboss-elasticsearch
Then change to cmd window under directory bboss-elasticsearch and run gradle build command:
gradle install
Build from source code guide:
https://esdoc.bbossgroups.com/#/bboss-build
First add the maven dependency of BBoss to your pom.xml:
<dependency>
<groupId>com.bbossgroups.plugins</groupId>
<artifactId>bboss-elasticsearch-rest-jdbc</artifactId>
<version>5.9.6</version>
</dependency>
If it's a spring boot project, you can replace the Maven coordinate above with the following Maven coordinate:
<dependency>
<groupId>com.bbossgroups.plugins</groupId>
<artifactId>bboss-elasticsearch-spring-boot-starter</artifactId>
<version>5.9.6</version>
</dependency>
Next, add the Elasticsearch addresses to the application.properties file under the project resource directory, and create a new one if the file does not exist:
elasticsearch.rest.hostNames=10.21.20.168:9200
#Cluster addresses are separated by commas
#elasticsearch.rest.hostNames=10.180.211.27:9200,10.180.211.28:9200,10.180.211.29:9200
And last create a jsp file named testElasticsearch.jsp :
<%@ page import="org.frameworkset.elasticsearch.ElasticSearchHelper" %>
<%@ page import="org.frameworkset.elasticsearch.client.ClientInterface" %>
<%@ page import="org.frameworkset.elasticsearch.entity.ESDatas" %>
<%@ page import="org.frameworkset.elasticsearch.scroll.ScrollHandler" %>
<%@ page import="java.util.List" %>
<%@ page import="java.util.Map" %>
<%@ page import="com.frameworkset.common.poolman.SQLExecutor" %>
<%@ page language="java" pageEncoding="UTF-8"%>
<%@ page import="org.frameworkset.elasticsearch.scroll.HandlerInfo" %>
<%
ClientInterface clientUtil = ElasticSearchHelper.getRestClientUtil();
//get elasticsearch cluster state
String result = clientUtil.executeHttp("_cluster/state?pretty",ClientInterface.HTTP_GET);
//check indice twitter and index type tweet exist or not.
boolean exist1 = clientUtil.existIndiceType("twitter","tweet");
out.println("twitter tweet type exist:"+exist1);
//check indice twitter exist or not
exist1 = clientUtil.existIndice("twitter");
out.println("twitter exist:"+exist1);
//count documents in indice twitter
long count = clientUtil.countAll("twitter");
out.println(count);
//Get All documents of indice twitter,DEFAULT_FETCHSIZE is 5000
ESDatas<Map> esDatas = clientUtil.searchAll("twitter", Map.class);
//Get All documents of indice twitter,Set fetchsize to 10000, Using ScrollHandler to process each batch of datas.
clientUtil.searchAll("twitter",10000,new ScrollHandler<Map>() {
public void handle(ESDatas<Map> esDatas, HandlerInfo handlerInfo) throws Exception {
List<Map> dataList = esDatas.getDatas();
System.out.println("TotalSize:"+esDatas.getTotalSize());
if(dataList != null) {
System.out.println("dataList.size:" + dataList.size());
}
else
{
System.out.println("dataList.size:0");
}
//do something other such as do a db query.
//SQLExecutor.queryList(Map.class,"select * from td_sm_user");
}
},Map.class);
//Use slice parallel scoll query all documents of indice twitter by 2 thread tasks. DEFAULT_FETCHSIZE is 5000
//You can also use ScrollHandler to process each batch of datas on your own.
esDatas = clientUtil.searchAllParallel("twitter", Map.class,2);
out.println("searchAllParallel:ok");
%>
Put the file into the web project that has been connected to pinpoint, run the program, log on pinpoint to see the execution effect of bboss plugin.
The following Demo and related documentation is compatible with Elasticsearch 2. X,5. X,6. X,+ versions
https://github.com/bbossgroups/elasticsearch-example
https://github.com/bbossgroups/es_bboss_web
https://github.com/bbossgroups/elasticsearch-springboot-example
Spring boot integration ElasticSearch case sharing
Quickly integrate Elasticsearch Restful API case sharing
High-performance elasticsearch ORM library bboss use introduction
不错的elasticsearch客户端工具包,bboss es开发套件采用类似于mybatis的方式操作elasticsearch
jdk要求: jdk 1.7+
elasticsearch版本要求:1.X,2.X,5.X,6.X,+
Spring boot integration ElasticSearch case sharing
Quickly integrate Elasticsearch Restful API case sharing
elastic search配置和使用参考文档
High-performance elasticsearch ORM library bboss use introduction
https://github.com/bbossgroups/eshelloword-booter
https://github.com/bbossgroups/eshelloword-spring-boot-starter
https://github.com/bbossgroups/elasticsearchdemo
https://esdoc.bbossgroups.com/#/README
v5.0.5.7及后续版本废弃@PrimaryKey注解,改用@ESId注解来标注索引_id的值
v5.0.6.0及后续版本的dsl配置变量语法变更:
$xxx模式变量将直接输出变量的原始值,不会对变量进行特殊字符转义处理,也不会对变量进行日期格式化处理
请在代码中自行对$xxx模式变量进行特殊转移字符处理和日期格式化处理
只有#[xxx]格式的变量才会对特殊字符进行自动转义处理和日期格式化处理,同时为其增加escape布尔值属性,
用来控制是否对#[xxx]模式变量进行自动化转义处理,false禁用转义处理,true启用,默认启用
增加定时任务,增量导入导出功能,目前提供了全量导入功能
The BBoss Framework is released under version 2.0 of the Apache License.
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。