import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class DataInsertionExample {
public static void main(String[] args) {
Connection connection = null;
try {
connection = DriverManager.getConnection("jdbc:kinetica://localhost:9191",
"username", "password");
String insertQuery = "INSERT INTO table_name (column1, column2) VALUES (?, ?)";
PreparedStatement preparedStatement = connection.prepareStatement(insertQuery);
preparedStatement.setString(1, "value1");
preparedStatement.setString(2, "value2");
preparedStatement.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
if (connection != null) {
connection.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class DataUpdateExample {
public static void main(String[] args) {
Connection connection = null;
try {
connection = DriverManager.getConnection("jdbc:kinetica://localhost:9191",
"username", "password");
String updateQuery = "UPDATE table_name SET column1 = ? WHERE column2 = ?";
PreparedStatement preparedStatement = connection.prepareStatement(updateQuery);
preparedStatement.setString(1, "new_value");
preparedStatement.setString(2, "condition_value");
int rowsAffected = preparedStatement.executeUpdate();
System.out.println(rowsAffected + " rows updated successfully.");
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
if (connection != null) {
connection.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
