diff --git a/Sda2/P/account/src/main/java/de/hdm_stuttgart/mi/sda2/account/TransferDriver.java b/Sda2/P/account/src/main/java/de/hdm_stuttgart/mi/sda2/account/TransferDriver.java index 7ff65a6f2ddab0fc7f259ac21156eac424f78825..13abde372dbe27b080ec88f2c2084d09b117c7af 100644 --- a/Sda2/P/account/src/main/java/de/hdm_stuttgart/mi/sda2/account/TransferDriver.java +++ b/Sda2/P/account/src/main/java/de/hdm_stuttgart/mi/sda2/account/TransferDriver.java @@ -1,5 +1,6 @@ package de.hdm_stuttgart.mi.sda2.account; +import java.sql.Connection; import java.sql.SQLException; import javafx.application.Application; @@ -69,7 +70,7 @@ public class TransferDriver extends Application { @Override public void start(final Stage primaryStage) throws SQLException { - dbh.connect(); + dbh.connect(Connection.TRANSACTION_SERIALIZABLE); primaryStage.setTitle("Account transfer!"); diff --git a/Sda2/P/account/src/main/java/de/hdm_stuttgart/mi/sda2/account/sql/DbHandler.java b/Sda2/P/account/src/main/java/de/hdm_stuttgart/mi/sda2/account/sql/DbHandler.java index 5fbfe3870c958b9d5353cc3709f95ec362c47a66..4807fa16a0bf226578fa5343ae02bf6e758a8753 100644 --- a/Sda2/P/account/src/main/java/de/hdm_stuttgart/mi/sda2/account/sql/DbHandler.java +++ b/Sda2/P/account/src/main/java/de/hdm_stuttgart/mi/sda2/account/sql/DbHandler.java @@ -21,14 +21,14 @@ public class DbHandler { return Conf.get("DbHandler.user") + '@' + Conf.get("DbHandler.jdbcUrl"); } - public boolean connect() { + public boolean connect(final int isolationLevel) { try { conn = DriverManager.getConnection( Conf.get("DbHandler.jdbcUrl"), Conf.get("DbHandler.user"), Conf.get("DbHandler.password")); conn.setAutoCommit(false); - conn.setTransactionIsolation(Connection.TRANSACTION_SERIALIZABLE); + conn.setTransactionIsolation(isolationLevel); updateAccount = conn.prepareStatement("UPDATE Account SET balance = balance + ? WHERE number = ?"); log.info("Connection '" + getConnectionName() + "' established" ); return true;