diff options
Diffstat (limited to 'dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/database/MysqlConnection.java')
-rw-r--r-- | dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/database/MysqlConnection.java | 16 |
1 files changed, 15 insertions, 1 deletions
diff --git a/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/database/MysqlConnection.java b/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/database/MysqlConnection.java index f1e5e075..4ca91f40 100644 --- a/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/database/MysqlConnection.java +++ b/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/database/MysqlConnection.java @@ -52,7 +52,11 @@ public class MysqlConnection implements AutoCloseable { @Override public void close() { if (hasPendingQueries) { - LOGGER.warn("Mysql connection had uncommited queries on .close()", new RuntimeException("Stack trace")); + LOGGER.warn("Mysql connection had uncommited queries on .close()", + new RuntimeException("Stack trace")); + for (MysqlStatement s : openStatements) { + LOGGER.info(s.getQuery()); + } hasPendingQueries = false; } try { @@ -66,6 +70,12 @@ public class MysqlConnection implements AutoCloseable { } openStatements.clear(); } + try { + rawConnection.rollback(); + rawConnection.setAutoCommit(true); + } catch (SQLException e) { + LOGGER.warn("Rolling back uncommited queries failed!", e); + } Database.returnConnection(this); } @@ -77,4 +87,8 @@ public class MysqlConnection implements AutoCloseable { } } + void setAutoCommit(boolean b) throws SQLException { + rawConnection.setAutoCommit(b); + } + } |