Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- PreparedStatement queryStatement = connection
- .prepareStatement(sql,
- ResultSet.TYPE_SCROLL_INSENSITIVE,
- ResultSet.CONCUR_UPDATABLE,
- ResultSet.CLOSE_CURSORS_AT_COMMIT);
- insertContacts(queryStatement,"Jubin","Kuriakose","jtk","+65 846864607",
- "jubintk@gmail.com","Mars, Milkyway");
- logger.info("Insert {} row ", queryStatement.executeUpdate());
- connection.setSavepoint("saveInsert");
- insertContacts(queryStatement,"Feba","James","fj","+65 91804961",
- "feba.james@ymail.com","Venus, Milkyway");
- logger.info("Insert {} row ", queryStatement.executeUpdate());
- Savepoint beforeLastInsert = connection.setSavepoint("beforeLastInsert");
- insertContacts(queryStatement,"Ben","Thomas","ben","+65 2333344",
- "ben.thomas@ymail.com","Mars, Milkyway");
- logger.info("Insert {} row ", queryStatement.executeUpdate());
- Statement stmt = connection
- .createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
- ResultSet.CONCUR_READ_ONLY,
- ResultSet.CLOSE_CURSORS_AT_COMMIT);
- logger.info("result set holdability {}", stmt.getResultSetHoldability());
- logger.info("result set scroll sensitivity {}", stmt.getResultSetType());
- logger.info("result set concur {}", stmt.getResultSetConcurrency());
- ResultSet contactsRs = stmt.executeQuery("Select * from Contacts");
- readContacts(contactsRs);
- logger.info("rollback to beforeSecondInsert and commit...");
- connection.rollback(beforeLastInsert);
- connection.commit();
- logger.info("===================================================================================");
- contactsRs.beforeFirst();
- readContacts(contactsRs);
- Statement stmt = connection
- .createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
- ResultSet.CONCUR_READ_ONLY,
- ResultSet.CLOSE_CURSORS_AT_COMMIT);
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement