import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class KineticaJDBCExample { public static void main(String[] args) { String url = "jdbc:kinetica://localhost:9191/mydatabase"; String user = "username"; String password = "password"; try { Class.forName("com.kinetica.jdbc.Driver"); } catch (ClassNotFoundException e) { e.printStackTrace(); } try (Connection connection = DriverManager.getConnection(url, user, password)) { Statement statement = connection.createStatement(); String sql = "SELECT * FROM mytable"; ResultSet resultSet = statement.executeQuery(sql); while (resultSet.next()) { String column1 = resultSet.getString("column1"); int column2 = resultSet.getInt("column2"); System.out.println("Column 1: " + column1 + ", Column 2: " + column2); } } catch (SQLException e) { e.printStackTrace(); } } }


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