Lindorm搜索引擎支持SQL JDBC访问,本文介绍如何使用开源的Solr JDBC访问Lindorm搜索引擎。

前提条件

  • 已开通Lindorm搜索引擎,具体操作请参见开通指南
  • 已将客户端的IP地址加入到Lindorm实例的白名单中,具体操作请参见设置白名单
  • 已获取Lindorm实例的私网地址,具体操作请参见查看连接地址

添加Maven依赖

在您的Java应用pom.xml中添加如下依赖:

<dependency> 
  <groupId>com.aliyun.lindorm</groupId>  
  <artifactId>lindorm-all-client</artifactId>
  <version>2.0.5</version>
</dependency>

创建索引

可通过集群管理页面创建索引表,具体操作请参见索引管理

连接代码示例

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Properties;

public class SqlDemo {
  public static void main(String[] args) {
    Connection pconn = null;
    Statement stmt = null;
    try {
      Class.forName("com.aliyun.lindorm.search.client.Driver");

      String url = "Lindorm实例的私网地址";

      Properties props = new Properties();
      props.put("user", "root");
      props.put("password", "root");
      pconn = DriverManager.getConnection(url, props);
      pconn.setAutoCommit(true);

      stmt = pconn.createStatement();
      ResultSet rs = stmt.executeQuery("select * from collection1 where a_s='hello0' and a_f=2.0");
      while (rs.next()) {
        
      }

    } catch (Throwable e) {
      e.printStackTrace();
    } finally {
      try {
        if (stmt != null) {
          stmt.close();
        }
        if (pconn != null) {
          pconn.close();
        }
      } catch (Throwable e) {
        e.printStackTrace();
      }
    }
  }
}