Elasticsearch7使用jdbc连接

Elasticsearch7.0.1 使用jdbc连接

项目中添加maven依赖

  
  
elastic.co  
https://artifacts.elastic.co/maven  
  
  
  org.elasticsearch.plugin  x-pack-sql-jdbc  7.0.1  
  

使用测试代码连接

package com.hts;  
import java.sql.Connection;  
import java.sql.DriverManager;  
import java.sql.ResultSet;  
import java.sql.Statement;  
import java.util.Properties;  public class ESJdbcTest {  static String driver = "org.elasticsearch.xpack.sql.jdbc.jdbc.JdbcDriver";  
static String elasticsearchAddress = "192.168.79.128:9200";  public static Properties connectionProperties(){  
Properties properties = new Properties();  //如果集群设置了密码//properties.put("user", "test_admin");  //properties.put("password", "x-pack-test-password");  
return properties;  
}  
public static void main(String[] args) {  String address = "jdbc:es://http://" + elasticsearchAddress;  
Properties connectionProperties = connectionProperties();  
try {
Connection connection = DriverManager.getConnection(address, connectionProperties);  
Statement statement = connection.createStatement();  
ResultSet results = statement.executeQuery(
"SELECT firstname, account_number FROM bank ORDER BY account_number DESC LIMIT 5");  
while(results.next()){  
System.out.println(results.getString("firstname"));  
}  
}catch (Exception e){  
e.printStackTrace();  
}  }  }  

异常：发现Exception in thread “main” java.sql.SQLInvalidAuthorizationSpecException: current license is non-compliant for [jdbc] 的错误需要破解xpth，更新白金许可；

• 在/elasticsearch-7.0.1/modules/x-pack-core目录下找到x-pack-core-7.0.1.jar复制一份出来

• 新建两个java文件分别命名为LicenseVerifier.java和XPackBuild.java，将下面代码黏贴

  ①：LicenseVerifier.java
  package org.elasticsearch.license;
  import java.nio.;
  import org.elasticsearch.common.bytes.;
  import java.util.;
  import java.security.;
  import org.elasticsearch.common.xcontent.;
  import org.apache.lucene.util.;
  import org.elasticsearch.core.internal.io.;
  import java.io.;
  public class LicenseVerifier{
  public static boolean verifyLicense(final License license, final byte[] encryptedPublicKeyData) {
  return true;
  }
  public static boolean verifyLicense(final License license) {
  return true;
  }
  }

  ②：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);
  }
  }

• 使用javac 编译这两个java文件，需要引入import的依赖，使用-cp参数（对应的jar包在elasticsearch安装包中都有）

  javac -cp “F:\es\x-pack-core-7.0.1.jar;F:\es\lucene-core-8.0.0.jar;F:\es\elasticsearch-7.0.1.jar;F:\es\elasticsearch-core-7.0.1.jar” F:esLicenseVerifier.java
  javac -cp “F:\es\x-pack-core-7.0.1.jar;F:\es\lucene-core-8.0.0.jar;F:\es\elasticsearch-7.0.1.jar;F:\es\elasticsearch-core-7.0.1.jar” F:esXPackBuild.java

• 将编译生成的LicenseVerifier.class覆盖复制出来的x-pack-core-7.0.1.jar中目录org/elasticsearch/license下的LicenseVerifier.class，将生成的XPackBuild.class覆盖org/elasticsearch/xpack/core目录下的XPackBuild.class

• 将覆盖成功后的x-pack-core-7.0.1.jar复制回/elasticsearch-7.0.1/modules/x-pack-core目录下覆盖原来的

• 获取 license 证书
  ①：https://license.elastic.co/registration填些用户名，邮箱（重要，获取下载链接），Country选择China，其他信息随意填写，点击Send
  ②打开邮箱获取的地址，将下载后的文件改名为license.json
  
  
  ③修改文件中的内容，将两个属性改为以下
  将 “type”:“basic” 替换为 “type”:“platinum” # 基础班变更为铂金版
  将 “expiry_date_in_millis”:1561420799999替换为
  ④使用curl替换 license(license.json指的是刚刚下载修改属性后的证书，要开启elasticsearch服务)
  curl -XPUT ‘http://127.0.0.1:9200/_xpack/licenseacknowledge=true’ -d @license.json
  

  ⑤可能遇到Cannot install a [PLATINUM] license unless TLS is configured or security is disabled的错误，解决方法在elasticsearch.yml新增：
  xpack.security.enabled: false
  ⑥上传后查看证书时间http://127.0.0.1:9200/_license

  

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！