[server] On mah way (lots of restructuring, some early db classes, sql dump of current schema)

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
-		}
-	}
-
-}