Made delete estate method atomic
Signed-off-by: Jim Martens <github@2martens.de>
This commit is contained in:
@ -692,12 +692,25 @@ public class ORM {
|
|||||||
return;
|
return;
|
||||||
} else {
|
} else {
|
||||||
// create query
|
// create query
|
||||||
String deleteSQL = "DELETE FROM HOUSE WHERE ID = ?";
|
try {
|
||||||
delete(deleteSQL, estate.getId());
|
_connection.setAutoCommit(false);
|
||||||
deleteSQL = "DELETE FROM APARTMENT WHERE ID = ?";
|
String deleteSQL = "DELETE FROM HOUSE WHERE ID = ?";
|
||||||
delete(deleteSQL, estate.getId());
|
delete(deleteSQL, estate.getId());
|
||||||
deleteSQL = "DELETE FROM ESTATE WHERE ID = ?";
|
deleteSQL = "DELETE FROM APARTMENT WHERE ID = ?";
|
||||||
delete(deleteSQL, estate.getId());
|
delete(deleteSQL, estate.getId());
|
||||||
|
deleteSQL = "DELETE FROM ESTATE WHERE ID = ?";
|
||||||
|
delete(deleteSQL, estate.getId());
|
||||||
|
_connection.commit();
|
||||||
|
_connection.setAutoCommit(true);
|
||||||
|
}
|
||||||
|
catch (SQLException e) {
|
||||||
|
try {
|
||||||
|
_connection.rollback();
|
||||||
|
} catch (SQLException e1) {
|
||||||
|
e1.printStackTrace();
|
||||||
|
}
|
||||||
|
e.printStackTrace();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
if (_estates.containsKey(estate.getId())) {
|
if (_estates.containsKey(estate.getId())) {
|
||||||
_estates.remove(estate.getId(), estate);
|
_estates.remove(estate.getId(), estate);
|
||||||
|
|||||||
Reference in New Issue
Block a user