Class.forName("com.kinetica.jdbc.Driver");
String url = "jdbc:kinetica://localhost:9191/mydatabase";
String username = "your_username";
String password = "your_password";
try(Connection connection = DriverManager.getConnection(url, username, password)) {
} catch (SQLException e) {
e.printStackTrace();
}
String query = "SELECT * FROM mytable";
try(Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery(query)) {
while (resultSet.next()) {
String value = resultSet.getString("column_name");
System.out.println(value);
}
} catch (SQLException e) {
e.printStackTrace();
}
String insertQuery = "INSERT INTO mytable (column1, column2) VALUES (?, ?)";
try(PreparedStatement statement = connection.prepareStatement(insertQuery)) {
statement.setString(1, "value1");
statement.setInt(2, 2);
int rowsInserted = statement.executeUpdate();
System.out.println(rowsInserted + " rows inserted.");
} catch (SQLException e) {
e.printStackTrace();
}
