相关文章推荐
高大的豆浆  ·  php中查询数据库含通配符时需要转义的问题_ ...·  7 月前    · 
不羁的小刀  ·  Serialization, ...·  11 月前    · 
博学的山寨机  ·  C++通过类型的字符串名称获取该类型的对象- ...·  1 年前    · 
礼貌的消防车  ·  txt转json python-掘金·  1 年前    · 
才高八斗的数据线  ·  Pandas循环提速 7 ...·  2 年前    · 
Code  ›  elasticsearch jdbc问题及解决_shadow.org.elasticsearch.xpack.sql.client.clientex_woloqun的博客
string elasticsearch jdbc
https://blog.csdn.net/woloqun/article/details/84834595
大气的剪刀
2 年前
org.elasticsearch.plugin x-pack-sql-jdbc 6.4.0

问题1：
目前最新的版本是6.5.1，使用这个版本的jdbc会报如下错误 

java.lang.NoClassDefFoundError: org/elasticsearch/xpack/sql/client/Version

这是一个bug，会在6.5.2版本解决，折腾了好久，太激进终究不是好事，所以最好使用低版本的jdbc
 issues:https://github.com/elastic/elasticsearch/issues/35786
 

问题2：
 异常
 

current license is non-compliant for [jdbc]

原因：JDBC需要一个白金（或试用）许可证。
 

解决办法：
 修改XPackBuild.java 和LicenseVerifier.java 重新编译elasticsearch；
 下载源码
 

git clone https://github.com/elastic/elasticsearch.git
切换到6.5.1分支
git checkout v6.5.1

修改源码：
 

vi LicenseVerifier.java
 

package org.elasticsearch.license;
public class LicenseVerifier
    public static boolean verifyLicense(final License license, final byte[] encryptedPublicKeyData) {
        return true;
    public static boolean verifyLicense(final License license) {
        return true;

vi XPackBuild.java
 

package org.elasticsearch.xpack.core;
import org.elasticsearch.common.io.*;
import java.net.*;
import org.elasticsearch.common.*;
import java.nio.file.*;
import java.io.*;
import java.util.jar.*;
public class XPackBuild
    public static final XPackBuild CURRENT;
    private String shortHash;
    private String date;
    @SuppressForbidden(reason = "looks up path of xpack.jar directly")
    static Path getElasticsearchCodebase() {
        final URL url = XPackBuild.class.getProtectionDomain().getCodeSource().getLocation();
        try {
            return PathUtils.get(url.toURI());
        catch (URISyntaxException bogus) {
            throw new RuntimeException(bogus);
    XPackBuild(final String shortHash, final String date) {
        this.shortHash = shortHash;
        this.date = date;
    public String shortHash() {
        return this.shortHash;
    public String date() {
        return this.date;
    static {
        final Path path = getElasticsearchCodebase();
        String shortHash = null;
        String date = null;
        Label_0157: {
            shortHash = "Unknown";
            date = "Unknown";
        CURRENT = new XPackBuild(shortHash, date);

jdk-11.0.1(jdk需要时10以上版本)

配置阿里云仓库
 

cd elasticsearch-6.5.1
vi build.gradle
在文件最后加上
allprojects{
    repositories {
        def REPOSITORY_URL = 'http://maven.aliyun.com/nexus/content/groups/public/'
        all { ArtifactRepository repo ->
            if(repo instanceof MavenArtifactRepository){
                def url = repo.url.toString()
                if (url.startsWith('https://repo1.maven.org/maven2') || url.startsWith('https://jcenter.bintray.com/')) {
                    project.logger.lifecycle "Repository ${repo.url} replaced by $REPOSITORY_URL."
                    remove repo
        maven {
            url REPOSITORY_URL

./gradlew assemble

包生成路径
 

elasticsearch-6.5.1/distribution/archives/tar/build/distributions/elasticsearch-6.5.1-SNAPSHOT.tar.gz

https://blog.csdn.net/woloqun/article/details/84770233

配置文件和之前不同的是添加：xpack.security.enabled: false，贴下完整的
 

cluster.name: myes
node.name: node2
path.data: /home/qun/data/es/data
path.logs: /home/qun/data/es/log
http.port: 9200
network.host: 0.0.0.0
discovery.zen.ping.unicast.hosts: ["192.168.120.5", "192.168.120.6","192.168.120.7"] 
discovery.zen.minimum_master_nodes: 2
http.cors.enabled: true 
http.cors.allow-origin: "*"
xpack.security.enabled: false

接下来是申请license，地址
 

https://license.elastic.co/registration

注册完后会给邮箱发邮件，邮件里有license文件下载地址，文件大致像下面这样
 

xxx-xxx-42c7a741-db4e-492e-8cc1-ac1b8b40defe-v5.json

重命名文件
 

mv xxx-xxx-42c7a741-db4e-492e-8cc1-ac1b8b40defe-v5.json license.json

修改license.json 文件
 

"type":"platinum"   #白金版
"expiry_date_in_millis":2524579200999   #截止日期 2050年

导入license.json文件
 

curl -XPUT -u elastic 'http://192.168.120.5:9200/_xpack/license' -H "Content-Type: application/json" -d @license.json
Enter host password for user 'elastic':
{"acknowledged":true,"license_status":"valid"}

使用elastic用户[elasticsearch自带的]，会提是输入密码，默认为：changeme；到这里，elasticsearch配置就结束了，启动
 

bin/elasticsearch

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Properties;
public class Test {
    public static void main(String[] args) throws Exception{
        Class.forName("org.elasticsearch.xpack.sql.jdbc.jdbc.JdbcDriver");
        String elasticsearchAddress = "192.168.120.5:9200";
        String address = "jdbc:es://http://" + elasticsearchAddress;
        Properties properties = new Properties();
        Connection connection =
                DriverManager.getConnection(address, properties);
        Statement statement = connection.createStatement();
        String sql = "select about,content,message,title,user from blog";
        ResultSet results = statement.executeQuery(sql);
        while (results.next()){
             System.out.println(results.getString(1)+"\t"+results.getString(2)+
                    "\t"+results.getString(3)+"\t"+results.getString(4));

i'd like to play	asdf	null	红楼梦
null	null	trying out Elasticsearch	null
about	使用okhttp的put方式增加index	message	title

其实可以直接使用okhttp3发起get，post，put请求elasticsearch，如果是sql语句的话可以使用接口
 

http://192.168.120.5:9200/_xpack/sql?format=json

伪代码如下
 

String url = "http://192.168.120.5:9200/_xpack/sql?format=json";
        Map<String,Object> map = new HashMap<String,Object>();
        map.put("query", "select * from  mess limit 3");
        String result = OkHttpUtil.postOrPutOrDelete(url,map,null,OkHttpUtil.OkHttpMethod.POST);
        String[] split = result.split("\n");
        int i = 0;
        for(String s:split){
            System.out.println(++i+"\t"+s);

返回结果json结果
 
    "columns":[
            "name":"dddd",
            "type":"text"
            "name":"field",
            "type":"text"
            "name":"message",
            "type":"text"
            "name":"postDate",
            "type":"date"
            "name":"user",
            "type":"text"
    "rows":[
            null,
            null,
            "trying out Elasticsearch2",
            "2018-12-04T06:54:32.234Z",
            "kimchy2"
            null,
            null,
            "trying out Elasticsearch8",
            "2018-12-04T06:54:32.235Z",
            "kimchy8"
            null,
            null,
            "trying out Elasticsearch1",
            "2018-12-04T06:54:32.119Z",
            "kimchy1"

java系统源码
elasticsearch-jdbc
2.0.x版本最先是在的的基础上修改而来,修改和补充了部分jdbc规范，使之能够和mybatis结合，sql支持度可参考elasticsearch-sql，引入了，实现了mybatis+rest
api的方式操作elasticsearch。提供了Java
api的工具类ESUtil和rest
api工具类JestUtil。
由于和Druid数据库连接池耦合太大，在使用过程中发现了一系列问题，决定将JDBC和数据库连接池解耦。添加ElasticSearchDriver类可以直接使用Class.forName加载驱动。
3.0.0版本不再使用elasticsearch-sql实验项目关于数据库连接池的部分，依旧沿用sql解析部分的代码
Upgrade
3.0.1
TransportClient
增加心跳监测，解决连接超时的问题。增加集群名配置
maven依赖
wjj-maven-repo
https://raw.github.com/
导入程序，但当前的解决方案侧重于相当简单的表格数据流。
假设您有一个名称orders表，在列id有一个主键，您可以从命令行发出此命令
bin=$JDBC_IMPORTER_HOME/bin
lib=$JDBC_IMPORTER_HOME/lib
"type"
"jdbc",
"jdbc"
"url"
"jdbc:mysql://localhost:3306/test",
"user"
"password"
"sql"
"select
es: 7.6.2
ide: dbeaver 6.2.3
通过 dbeaver 配置 jdbc 连接 es时报错 current license is non-compliant for [jdbc]
在官网 https://www.elastic.co/cn/subscriptions 搜索后发现需要白金级别
查看服务器es的license信息，发现 “type” : “basic”
# curl -XGET http://localhost:9200/_li
                                    使用客户端连接Elasticsearch 7.1 SQL，使用官方的jdbc驱动报错：
current license is non-compliant for [jdbc]
https://license.elastic.co/registration
https://www.elastic.co/guide/en/elasticsearch/reference/current/sql-...
对人工智能感兴趣的同学，可以点击以下链接：
现在人工智能非常火爆，很多朋友都想学，但是一般的教程都是为博硕生准备的，太难看懂了。最近发现了一个非常适合小白入门的教程，不仅通俗易懂而且还很风趣幽默。所以忍不住分享一下给大家。点这里可以跳转...
在阿里云部署了一台 ElasticSearch 节点，9200 端口直接暴露在了公网下，结果三天两头受到攻击，访问 kibana 老出现 redirect 重定向问题不能访问，查看日志索引都被人删除了，所以怀疑可能是因为被人恶意删除了，由此决定使用 xpack安全组件来保护 ElasticSearch。
ElasticSearch 默认安装后，本身不提供任何安全保障，这也是被人攻击的原因之一
我们为了公网可以访问，配置了 server.host 为 0.0.0.0 这也是被人攻击的原因之一
                                    本篇教程探讨了大数据技术之elasticsearch5.3安装kibana、x-pack插件、elasticsearch-an，希望阅读本篇文章以后大家有所收获，帮助大家对相关内容的理解更加深入。<1.安装Kibana1.1安装KibanaKibana是一个强大的es图形化组件,可以通过http的方式来查看es集群的状态,操作数据等.当前es官方推荐的拓展组件为Kibana和X-Pack...
 
推荐文章
高大的豆浆  ·  php中查询数据库含通配符时需要转义的问题_php 通配符 数据库 %-CSDN博客
7 月前
不羁的小刀  ·  Serialization, Deserialization, and Message Conversion :: Spring Kafka
11 月前
博学的山寨机  ·  C++通过类型的字符串名称获取该类型的对象--注册机制_c++ 从类型名称获取类型_一身骄傲小小裴的博客-CSDN博客
1 年前
礼貌的消防车  ·  txt转json python-掘金
1 年前
才高八斗的数据线  ·  Pandas循环提速 7 万多倍是怎么实现的？_R语言中文社区的博客-CSDN博客
2 年前
今天看啥   ·   Py中国   ·   codingpro   ·   小百科   ·   link之家   ·   卧龙AI搜索
删除内容请联系邮箱 2879853325@qq.com
Code - 代码工具平台
© 2024 ~ 沪ICP备11025650号