使用SQL接口连接Druid报错求助（附Avatica Jar连接代码）

咱们一步步来排查你用Avatica JDBC连接Druid时遇到的问题，先从几个最常见的方向入手：

1. 确认Druid Avatica端点的可达性 #

首先得确保Druid Broker服务正常运行，并且Avatica的接口能被访问到：

• 直接在浏览器或者终端里访问 http://localhost:8082/druid/v2/sql/avatica，如果服务正常，你会看到Avatica相关的错误（因为这是GET请求，Avatica需要POST），但至少能返回响应，说明端点是通的；
• 如果连不上，检查Druid Broker是否启动，8082端口有没有被占用，或者本地防火墙是否拦截了该端口。

2. 确保客户端与Druid服务器的版本兼容 #

Avatica客户端的版本必须和Druid服务器的版本严格匹配，否则会出现协议不兼容、序列化失败等问题：

• 比如Druid 28.0.0对应的Avatica版本是1.23.0，Druid 27.0.0对应Avatica 1.22.0，你可以在Druid的官方文档里找到对应的版本映射；
• 检查你的项目依赖，确保avatica-core和druid-jdbc（如果用到）的版本和Druid服务器一致。

3. 检查认证配置（如果Druid开启了安全认证） #

如果你的Druid集群开启了Basic Auth或者其他认证方式，需要在连接属性里添加认证信息：

connectionProperties.setProperty("user", "你的Druid用户名");
connectionProperties.setProperty("password", "你的Druid密码");

如果没开启认证，这一步可以跳过，但如果开启了却没配置，肯定会连接失败。

4. 验证SQL语句和数据源的正确性 #

你的查询语句SELECT COUNT(*) as rowcount FROM wikiticker需要满足两个条件：

• 确认wikiticker这个Druid数据源（表）确实存在，并且名称拼写完全正确（Druid的表名是大小写敏感的）；
• 确保Druid支持该SQL语法——COUNT(*)是支持的，但如果表不存在或者权限不足，会返回对应的错误。

5. 捕获并查看具体错误信息 #

你当前的代码没有捕获具体的SQLException，建议加上错误处理，打印详细的错误日志，这能帮你快速定位问题：

catch (SQLException e) {
    System.err.println("连接或查询出错:");
    e.printStackTrace();
    System.err.println("错误代码: " + e.getErrorCode());
    System.err.println("SQL状态: " + e.getSQLState());
}

比如如果是表不存在，会返回类似Table 'wikiticker' not found的错误；如果是版本不兼容，会出现序列化相关的异常。

优化后的测试代码 #

这里给你一份带完整错误处理的测试代码，方便你排查：

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

public class DruidAvaticaConnector {
    public static void main(String[] args) {
        String url = "jdbc:avatica:remote:url=http://localhost:8082/druid/v2/sql/avatica";
        Properties connectionProperties = new Properties();

        // 开启认证时取消注释并填写正确信息
        // connectionProperties.setProperty("user", "admin");
        // connectionProperties.setProperty("password", "your-password");

        try (Connection connection = DriverManager.getConnection(url, connectionProperties)) {
            System.out.println("成功连接到Druid Avatica服务!");

            try (Statement statement = connection.createStatement();
                 ResultSet resultSet = statement.executeQuery("SELECT COUNT(*) as rowcount FROM wikiticker")) {

                while (resultSet.next()) {
                    int rowCount = resultSet.getInt("rowcount");
                    System.out.println("wikiticker表的总行数: " + rowCount);
                }
            }
        } catch (SQLException e) {
            System.err.println("=== 错误详情 ===");
            e.printStackTrace();
            System.err.println("错误代码: " + e.getErrorCode());
            System.err.println("SQL状态码: " + e.getSQLState());
        }
    }
}

如果按照上面的步骤排查后还是有问题，把具体的错误日志贴出来，咱们再进一步分析！

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