JDBC 连接 ElasticSearch

柔光的暖阳◎ 2022-04-24 13:36 208阅读 0赞

# JDBC 连接 ElasticSearch #

1、Maven依赖

2、测试连接

3、破解x-pack-core（使ElasticSearch支持JDBC）

对人工智能感兴趣的同学，可以点击以下链接：

[现在人工智能非常火爆，很多朋友都想学，但是一般的教程都是为博硕生准备的，太难看懂了。最近发现了一个非常适合小白入门的教程，不仅通俗易懂而且还很风趣幽默。所以忍不住分享一下给大家。点这里可以跳转到教程。][Link 1]

[https://www.cbedai.net/u014646662][Link 1]

首先确认自己的版本，ElasticSearch6.3之后才支持JDBC连接，但是6.3和之后的JDBC驱动包并不一样（目前最高版本是7.1，超过这个版本后自己去官网查看连接方式）

白金版支持JDBC连接，基础版是不支持的，你可以申请一个白金版，也可以像我一样破解x-pack-core，破解方式下面有

## 1、Maven依赖 ##

6.3版本

<repositories>
    		<repository>
    			<id>elastic.co</id>
    			<url>https://artifacts.elastic.co/maven</url>
    		</repository>
    	</repositories>
    
    	<dependencies>
    		<dependency>
    			<groupId>org.elasticsearch.plugin</groupId>
    			<artifactId>jdbc</artifactId>
    			<version>6.3.2</version>
    		</dependency>
    
    		<dependency>
    			<groupId>junit</groupId>
    			<artifactId>junit</artifactId>
    			<version>4.12</version>
    			<scope>test</scope>
    		</dependency>
    
    	</dependencies>

6.4及6.4之后版本

<repositories>
    		<repository>
    			<id>elastic.co</id>
    			<url>https://artifacts.elastic.co/maven</url>
    		</repository>
    	</repositories>
    
    	<dependencies>
    
    		<dependency>
    			<groupId>org.elasticsearch.plugin</groupId>
    			<artifactId>x-pack-sql-jdbc</artifactId>
    			<version>6.7.1</version>
    		</dependency>
    
    		<dependency>
    			<groupId>junit</groupId>
    			<artifactId>junit</artifactId>
    			<version>4.12</version>
    			<scope>test</scope>
    		</dependency>
    
    	</dependencies>

## 2、测试连接 ##

表的名字就是ES的索引名，看完整篇博客在执行java代码（白金版可以运行，无需破解）

//    6.3  driver = "org.elasticsearch.xpack.sql.jdbc.jdbc.JdbcDriver";  
//    6.3之后  driver = "org.elasticsearch.xpack.sql.jdbc.EsDriver";

import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.Statement;
    
    
    public class ESJdbcTest {
    
    //虽然程序未直接使用驱动，但是不保证在其他地方用不到
    //    6.3  driver = "org.elasticsearch.xpack.sql.jdbc.jdbc.JdbcDriver";
    //    6.3之后  driver = "org.elasticsearch.xpack.sql.jdbc.EsDriver";
    
        public static void main(String[] args) {
            try  {
                Connection connection = DriverManager.getConnection("jdbc:es://http://ES-IP:9200");//将ES-IP换位ES服务器的IP
                Statement statement = connection.createStatement();
                ResultSet results = statement.executeQuery(
                        "select * from rep  LIMIT 5");
              while(results.next()){
                  System.out.println(results.getString("request"));
              }
            }catch (Exception e){
                  e.printStackTrace();
            }
    
        }
    
    }

# 3、破解x-pack-core #

白金版支持JDBC连接，基础版是不支持的，你可以申请一个白金版，也可以像我一样破解x-pack-core

接下来操作是以6.7.1版本为例，其他版本基本一样

x-pack-core.6.7.1.jar位置：$ES\_HOME/modules/x-pack-core/x-pack-core.6.7.1.jar

### 3.1 创建一个Java项目（我用的是eclipse） ###

1、创建一个java项目

2、引入Jar包

$ES\_HOME/modules/x-pack-core/ 目录下：

x-pack-core-6.7.1.jar

$ES\_HOME/lib 目录下：

elasticsearch-6.7.1.jar；elasticsearch-core-6.7.1.jar；lucene-core-7.7.0.jar；

3、创建两个java类

org.elasticsearch.license.LicenseVerifier

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;
        }
    }

org.elasticsearch.xpack.core.XPackBuild

package org.elasticsearch.xpack.core;
     
    import java.net.URISyntaxException;
    import java.net.URL;
    import java.nio.file.Path;
    
    import org.elasticsearch.common.SuppressForbidden;
    import org.elasticsearch.common.io.PathUtils;
     
    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);
        }
    }

4、编译

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ2NDY2NjI_size_16_color_FFFFFF_t_70][]

编译好的.class文件在项目的bin目录下

5、替换x-pack-core-6.7.1.jar的.class文件

可以用好压打开x-pack-core-6.7.1.jar，将两个刚刚编译的.class放到x-pack-core-6.7.1.jar中对应的位置（覆盖替换）

6、将修改好的x-pack-core-6.7.1.jar替换ElasticSearch中的x-pack-core-6.7.1.jar（覆盖替换）

7、获取 license 证书

[https://license.elastic.co/registration][https_license.elastic.co_registration]

邮箱和国家要正确填写，其他随便

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ2NDY2NjI_size_16_color_FFFFFF_t_70 1][]

根据你邮件收到的地址下载，下载后更名为license.json

将 "type":"basic" 替换为 "type":"platinum" \# 基础班变更为白金版

将 "expiry\_date\_in\_millis":1561420799999替换为 "expiry\_date\_in\_millis":3107746200000\# 1年变为50年

8、上传

curl -H "Content-Type: application/json" -XPUT   'http://ES-IP:9200/_xpack/license?acknowledge=true' -d @license.json

9、在ES的配置文件在elasticsearch.yml新增中

xpack.security.enabled: false

10、上传后查看证书时间http://ES-IP:9200/\_license

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ2NDY2NjI_size_16_color_FFFFFF_t_70 2][]

破解结束，可以运行你的程序了

[Link 1]: https://www.cbedai.net/u014646662
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ2NDY2NjI_size_16_color_FFFFFF_t_70]: /images/20220214/21084a437f764b358e8e44d704729918.png
[https_license.elastic.co_registration]: https://license.elastic.co/registration
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ2NDY2NjI_size_16_color_FFFFFF_t_70 1]: /images/20220214/5157ac34329c4f168a85f7228b09a01e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ2NDY2NjI_size_16_color_FFFFFF_t_70 2]: /images/20220214/41bb1082b3e74c879795206134f91b47.png