如何在OpenDistro中执行参数化SQL查询

可以实现你需要的单次编译、多次替换参数执行的需求，OpenDistro SQL引擎支持参数化预编译查询，以下是具体实现方式：

1. 通过REST API实现预编译与执行 #

第一步：预编译带占位符的SQL #

发送POST请求到_opendistro/_sql/_prepare端点，提交带?占位符的SQL语句：

POST _opendistro/_sql/_prepare
{
  "query": "SELECT * FROM employee WHERE name = ?"
}

接口响应会返回唯一的statement_id，将这个ID缓存下来，后续执行查询时复用。

第二步：传入参数执行预编译查询 #

使用缓存的statement_id，每次执行仅传入对应参数即可，无需重新编译SQL：

POST _opendistro/_sql/_execute
{
  "statement_id": "预编译返回的ID",
  "parameters": ["abc"]
}

下次执行时只需修改parameters数组中的值，比如传入["def"]就能查询name为def的数据。

2. 通过客户端SDK实现（以Java为例） #

OpenDistro的JDBC驱动支持标准JDBC的PreparedStatement语法，和常规数据库操作逻辑一致：

// 初始化连接
Connection conn = DriverManager.getConnection("jdbc:elasticsearch://localhost:9200");

// 预编译SQL语句
String sql = "SELECT * FROM employee WHERE name = ?";
PreparedStatement pstmt = conn.prepareStatement(sql);

// 多次执行，仅替换参数
pstmt.setString(1, "abc");
ResultSet rs1 = pstmt.executeQuery();

pstmt.setString(1, "def");
ResultSet rs2 = pstmt.executeQuery();

// 关闭资源
rs1.close();
rs2.close();
pstmt.close();
conn.close();

注意事项 #

• 预编译生成的statement_id默认有效期为5分钟，可通过修改集群配置sql.query.prepare_statement.ttl调整时长；
• 参数传递的顺序必须和SQL中?占位符的顺序完全对应。

内容的提问来源于stack exchange，提问作者Ravik