import java.sql.*;
public class TransactionExample {
public static void main(String[] args) {
try {
Connection connection = DriverManager.getConnection("jdbc:kinetica://localhost:9191/database_name");
connection.setAutoCommit(false);
Statement statement = connection.createStatement();
statement.executeUpdate("INSERT INTO table_name (column1, column2) VALUES ('value1', 'value2')");
connection.commit();
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
import java.sql.*;
public class BatchExample {
public static void main(String[] args) {
try {
Connection connection = DriverManager.getConnection("jdbc:kinetica://localhost:9191/database_name");
Statement statement = connection.createStatement();
statement.addBatch("INSERT INTO table_name (column1, column2) VALUES ('value1', 'value2')");
statement.addBatch("UPDATE table_name SET column1 = 'new_value' WHERE column2 = 'some_condition'");
statement.addBatch("DELETE FROM table_name WHERE column1 = 'some_condition'");
int[] results = statement.executeBatch();
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
