Pinot JDBC Client Connection Exception

[Arpita030125]

I have been trying to connect to authenticated Pinot Controller : sample only
final String dB_URL = "jdbc:pinot://hostname:port";
through JDBC Client with the following set of properties:samples only
properties.setProperty("username", "user");
properties.setProperty("password", "pass");

When I am trying to access the controller URL directly with the same set of credentials I am able to do so.
But when I am trying to connect to URL through JDBC client in my code it is throwing the below exception:
PinotClientException: Pinot returned HTTP status 403, expected 200

I have tried the same code and was able to connect to local Pinot and execute queries which does not contain any authentication.

Expectation: I want to connect to authenticated pinot UI through JDBC client in my code and execute queries and fetch results.

[Jackie-Jiang]

@apucher Can you please take a look?

[kbastani]

@Arpita030125 Can you try the following in your JDBC client? (not recommended for production code)

final String username = "user";
final String password = "password";

// Concatenate username and password and use base64 to encode the concatenated string
String plainCredentials = username + ":" + password;
String base64Credentials = new String(Base64.getEncoder().encode(plainCredentials.getBytes()));

// Create authorization header
String authorizationHeader = "Basic " + base64Credentials;
Properties connectionProperties = new Properties();
connectionProperties.setProperty("headers.Authorization", authorizationHeader);

// Register new Pinot JDBC driver
DriverManager.registerDriver(new PinotDriver());

// Get a client connection and set the encoded authorization header
Connection connection = DriverManager.getConnection(DB_URL, connectionProperties);

// Test that your query successfully authenticates
Statement statement = connection.createStatement();
ResultSet rs = statement.executeQuery("SELECT count(*) FROM baseballStats LIMIT 1;");

while (rs.next()) {
    String result = rs.getString("count(*)");
    System.out.println(result);
}

I've confirmed that this works in the latest 0.10.0-SNAPSHOT but will not work in any earlier releases (including 0.9.3).

@Jackie-Jiang you can close the issue.

[kbastani]

The fix for this issue is here: #7824

Previously, no headers would have been passed along to the controller which would cause a 403 unauthorized response when attempting to select an available broker to query.

[kbastani]

I've updated the Pinot docs with the relevant details on how to securely connect and query with JDBC. https://docs.pinot.apache.org/users/clients/java#authentication