summaryrefslogtreecommitdiffstats
path: root/dozentenmodulserver/src/main/java/sql/MysqlConnection.java
diff options
context:
space:
mode:
Diffstat (limited to 'dozentenmodulserver/src/main/java/sql/MysqlConnection.java')
-rw-r--r--dozentenmodulserver/src/main/java/sql/MysqlConnection.java74
1 files changed, 0 insertions, 74 deletions
diff --git a/dozentenmodulserver/src/main/java/sql/MysqlConnection.java b/dozentenmodulserver/src/main/java/sql/MysqlConnection.java
deleted file mode 100644
index dbbddfe1..00000000
--- a/dozentenmodulserver/src/main/java/sql/MysqlConnection.java
+++ /dev/null
@@ -1,74 +0,0 @@
-package sql;
-
-import java.sql.Connection;
-import java.sql.SQLException;
-import java.util.ArrayList;
-import java.util.List;
-
-import org.apache.log4j.Logger;
-
-public class MysqlConnection implements AutoCloseable {
-
- private static final Logger LOGGER = Logger.getLogger(MysqlConnection.class);
-
- private static final int CONNECTION_TIMEOUT_MS = 5 * 60 * 1000;
-
- private final long deadline = System.currentTimeMillis() + CONNECTION_TIMEOUT_MS;
-
- private final Connection rawConnection;
-
- private boolean hasPendingQueries = false;
-
- private List<MysqlStatement> openStatements = new ArrayList<>();
-
- MysqlConnection(Connection rawConnection) {
- this.rawConnection = rawConnection;
- }
-
- public MysqlStatement prepareStatement(String sql) throws SQLException {
- hasPendingQueries = true;
- MysqlStatement statement = new MysqlStatement(rawConnection, sql);
- openStatements.add(statement);
- return statement;
- }
-
- public void commit() throws SQLException {
- rawConnection.commit();
- hasPendingQueries = false;
- }
-
- public void rollback() throws SQLException {
- rawConnection.rollback();
- hasPendingQueries = false;
- }
-
- boolean isValid() {
- return System.currentTimeMillis() < deadline;
- }
-
- @Override
- public void close() {
- if (hasPendingQueries) {
- LOGGER.warn("Mysql connection had uncommited queries on .close()");
- try {
- rawConnection.rollback();
- } catch (SQLException e) {
- LOGGER.warn("Rolling back uncommited queries failed!", e);
- }
- for (MysqlStatement statement : openStatements) {
- statement.close();
- }
- openStatements.clear();
- }
- SQL.returnConnection(this);
- }
-
- void release() {
- try {
- rawConnection.close();
- } catch (SQLException e) {
- // Nothing meaningful to do
- }
- }
-
-}