String jdbcUrl = "jdbc:kinetica://localhost:9191;DB_CONNECTION_TIME=60000"; String username = "admin"; String password = "password"; Class.forName("com.kinetica.jdbc.Driver"); Connection connection = DriverManager.getConnection(jdbcUrl, username, password); Statement statement = connection.createStatement(); ResultSet resultSet = statement.executeQuery("SELECT * FROM my_table"); while (resultSet.next()) { String column1Value = resultSet.getString("column1"); int column2Value = resultSet.getInt("column2"); // ... } PreparedStatement preparedStatement = connection.prepareStatement("INSERT INTO my_table (column1, column2) VALUES (?, ?)"); preparedStatement.setString(1, "value1"); preparedStatement.setInt(2, 123); int rowsAffected = preparedStatement.executeUpdate(); resultSet.close(); statement.close(); connection.close();


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