<dependency> <groupId>co.cask.cdap</groupId> <artifactId>cdap-explore-jdbc-driver</artifactId> <version>6.0.0</version> </dependency> explore.jdbc.enabled=true explore.jdbc.additional.connectors=com.company.jdbc.CustomJDBCConnector import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class ExploreJDBCDemo { public static void main(String[] args) { String jdbcUrl = "jdbc:cdap://localhost:11015/default"; String username = "admin"; String password = "admin"; try (Connection connection = DriverManager.getConnection(jdbcUrl, username, password); Statement statement = connection.createStatement(); ResultSet resultSet = statement.executeQuery("SELECT * FROM my_table")) { while (resultSet.next()) { System.out.println(resultSet.getString(1)); } } catch (SQLException e) { e.printStackTrace(); } } }


上一篇:
下一篇:
切换中文