import java.sql.*;
public class ExploreJdbcExample {
public static void main(String[] args) {
String url = "jdbc:cdapexplore://localhost:11015";
String user = "username";
String password = "password";
try (Connection connection = DriverManager.getConnection(url, user, password);
Statement statement = connection.createStatement()) {
String sql = "SELECT * FROM my_dataset.my_table";
ResultSet resultSet = statement.executeQuery(sql);
while (resultSet.next()) {
String column1 = resultSet.getString("column1");
int column2 = resultSet.getInt("column2");
System.out.println(column1 + "\t" + column2);
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
<dependencies>
<dependency>
<groupId>com.cask.cdap</groupId>
<artifactId>cdap-explore-jdbc-driver</artifactId>
<version>2.0.0</version>
</dependency>
</dependencies>
<property>
<name>explore.jdbc.enabled</name>
<value>true</value>
</property>
