import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class DatabricksJDBCDemo { public static void main(String[] args) { String jdbcUrl = "jdbc:databricks://hostname:port"; String user = "username"; String password = "password"; try (Connection connection = DriverManager.getConnection(jdbcUrl, user, password); Statement statement = connection.createStatement()) { String sql = "SELECT * FROM table_name"; ResultSet resultSet = statement.executeQuery(sql); while (resultSet.next()) { String column1 = resultSet.getString("column_name_1"); int column2 = resultSet.getInt("column_name_2"); System.out.println("column1: " + column1 + ", column2: " + column2); } resultSet.close(); } catch (SQLException e) { e.printStackTrace(); } } }


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