import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class KineticaJdbcExample {
private static final String DATABASE_URL = "jdbc:kinetica://localhost:9191/kinetica_db";
private static final String USERNAME = "your_username";
private static final String PASSWORD = "your_password";
public static void main(String[] args) {
try {
Connection connection = DriverManager.getConnection(DATABASE_URL, USERNAME, PASSWORD);
insertData(connection, "John Doe", 25, "USA");
updateData(connection, "John Doe", 26);
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
private static void insertData(Connection connection, String name, int age, String country) throws SQLException {
String sql = "INSERT INTO table_name (name, age, country) VALUES (?, ?, ?)";
PreparedStatement preparedStatement = connection.prepareStatement(sql);
preparedStatement.setString(1, name);
preparedStatement.setInt(2, age);
preparedStatement.setString(3, country);
preparedStatement.executeUpdate();
preparedStatement.close();
}
private static void updateData(Connection connection, String name, int newAge) throws SQLException {
String sql = "UPDATE table_name SET age = ? WHERE name = ?";
PreparedStatement preparedStatement = connection.prepareStatement(sql);
preparedStatement.setInt(1, newAge);
preparedStatement.setString(2, name);
preparedStatement.executeUpdate();
preparedStatement.close();
}
}
