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);
+	}
+
 }