Skip to content
Snippets Groups Projects
Commit fe10028f authored by Ellen Seifert's avatar Ellen Seifert
Browse files

implemented logger

parent 7170cebc
No related branches found
No related tags found
1 merge request!22Resolve "Implement Logger in DB"
......@@ -38,7 +38,7 @@ public class DBConnectionImpl implements DBConnection {
ds.setPassword(password);
}
//TODO: Null-Werte, Modularisierung( getFilesInTransaction)
//TODO: Null-Werte
/**
*
......@@ -48,7 +48,7 @@ public class DBConnectionImpl implements DBConnection {
*/
@Override
public Transaction insertTransaction(Transaction transaction) throws SQLException {
logger.info("Inserting a new transaction into database");
logger.info("Inserting new transaction with id "+transaction.getTransactionId()+" into database");
Connection connection = dataSource.getConnection();
PreparedStatement statement = connection.prepareStatement("insert into transactions(startingTime,transactionType,username) values(?, ?, ?);");
statement.setTimestamp(1, Timestamp.valueOf(transaction.getStartingTime()));
......@@ -85,7 +85,7 @@ public class DBConnectionImpl implements DBConnection {
*/
@Override
public Session insertSession(Session session) throws SQLException {
logger.info("Inserting a new ssh session into database");
logger.info("Inserting new ssh session with id "+session.getSessionId()+" into database");
Connection connection = dataSource.getConnection();
PreparedStatement statement = connection.prepareStatement("insert into sessions(startingTime,username,sshHostname,sshPort,sessionStatus) values(?, ?, ?, ?, ?);");
statement.setTimestamp(1, Timestamp.valueOf(session.getStartingTime()));
......@@ -110,7 +110,7 @@ public class DBConnectionImpl implements DBConnection {
*/
@Override
public void insertTransactionSessionConn(Session session, Transaction transaction) throws SQLException {
logger.info("Inserting relation between session and transaction into database");
logger.info("Inserting relation between session with id "+session.getSessionId()+" and transaction with id "+transaction.getTransactionId()+" into database");
Connection connection = dataSource.getConnection();
PreparedStatement statement = connection.prepareStatement("insert into sessionsWithTransactions(sessionId,transactionId) values(?, ?);");
statement.setInt(1, session.getSessionId());
......@@ -125,7 +125,7 @@ public class DBConnectionImpl implements DBConnection {
*/
@Override
public void updateTransaction(Transaction transaction) throws SQLException {
logger.info("Updating transaction in database");
logger.info("Updating transaction with id "+transaction.getTransactionId()+"in database");
Connection connection = dataSource.getConnection();
PreparedStatement statement = connection.prepareStatement("update transactions set startingTime=?,finishingTime=?,transactionType=?,username=? where transactionId=?;");
statement.setTimestamp(1, Timestamp.valueOf(transaction.getStartingTime()));
......@@ -151,7 +151,7 @@ public class DBConnectionImpl implements DBConnection {
*/
@Override
public void updateSession(Session session) throws SQLException {
logger.info("Updating session in database");
logger.info("Updating session with id "+session.getSessionId()+" in database");
Connection connection = dataSource.getConnection();
PreparedStatement statement = connection.prepareStatement("update sessions set startingTime=?, finishingTime=?,username=?,sshHostname=?,sshPort=?,sessionStatus=? where sessionId=?;");
statement.setTimestamp(1, Timestamp.valueOf(session.getStartingTime()));
......@@ -200,7 +200,7 @@ public class DBConnectionImpl implements DBConnection {
*/
@Override
public List<Transaction> getIncompleteTransactions(String user) throws SQLException {
logger.info("Requesting incomplete transaction from a specific user");
logger.info("Requesting incomplete transactions belonging to user "+user+" from database");
Connection connection= dataSource.getConnection();
PreparedStatement statement= connection.prepareStatement("select t.* from transactions t where exists(select null from files f where f.transactionId = t.transactionId and f.fileStatus=? and t.username=?);");
statement.setInt(1,FileStatus.STARTED.toInt());
......@@ -217,7 +217,7 @@ public class DBConnectionImpl implements DBConnection {
*/
@Override
public List<Transaction> getTransactionsInSession(Session session) throws SQLException {
logger.info("Requesting transactions which were executed during a given ssh session");
logger.info("Requesting transactions which were executed during ssh session with id "+session.getSessionId());
Connection connection= dataSource.getConnection();
PreparedStatement statement= connection.prepareStatement("select t.* from transactions as t inner join transactionsWithSessions as ts on t.transactionId = ts.transactionId where ts.sessionId = ?;");
statement.setInt(1,session.getSessionId());
......@@ -233,7 +233,7 @@ public class DBConnectionImpl implements DBConnection {
*/
@Override
public List<Session> getSessionsInTransaction(Transaction transaction) throws SQLException{
logger.info("Requesting sessions during which a given transaction was executed");
logger.info("Requesting sessions during which transaction with id "+transaction.getTransactionId()+" was executed");
Connection connection= dataSource.getConnection();
PreparedStatement statement= connection.prepareStatement("select s.* from sessions as s inner join transactionsWithSessions as ts on s.sessionId = ts.sessionId where ts.transactionId = ?;");
statement.setInt(1,transaction.getTransactionId());
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment