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

implemented logger

parent 3b04e8a6
No related branches found
No related tags found
1 merge request!22Resolve "Implement Logger in DB"
......@@ -9,6 +9,7 @@ import java.sql.*;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;
import java.util.logging.Logger;
/**
* implements DBConnection
......@@ -16,7 +17,7 @@ import java.util.List;
* basiert auf HikariDataSource (ConnectionPool), welches automatisch nach login Verbindungen zur DB bereitstellt
*/
public class DBConnectionImpl implements DBConnection {
private static final Logger logger = Logger.getLogger(DBConnectionImpl.class.getName());
private static DBConnectionImpl instance = new DBConnectionImpl();
private HikariDataSource dataSource;
......@@ -30,6 +31,7 @@ public class DBConnectionImpl implements DBConnection {
*/
public void login(String username, String password, String url) {
logger.info("Initiating login process for creating connection pool for database access");
HikariDataSource ds = new HikariDataSource();
ds.setJdbcUrl(url);
ds.setUsername(username);
......@@ -46,6 +48,7 @@ public class DBConnectionImpl implements DBConnection {
*/
@Override
public Transaction insertTransaction(Transaction transaction) throws SQLException {
logger.info("Inserting a new transaction into database");
Connection connection = dataSource.getConnection();
PreparedStatement statement = connection.prepareStatement("insert into transactions(startingTime,transactionType,username) values(?, ?, ?);");
statement.setTimestamp(1, Timestamp.valueOf(transaction.getStartingTime()));
......@@ -82,6 +85,7 @@ public class DBConnectionImpl implements DBConnection {
*/
@Override
public Session insertSession(Session session) throws SQLException {
logger.info("Inserting a new ssh session 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()));
......@@ -106,6 +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");
Connection connection = dataSource.getConnection();
PreparedStatement statement = connection.prepareStatement("insert into sessionsWithTransactions(sessionId,transactionId) values(?, ?);");
statement.setInt(1, session.getSessionId());
......@@ -120,6 +125,7 @@ public class DBConnectionImpl implements DBConnection {
*/
@Override
public void updateTransaction(Transaction transaction) throws SQLException {
logger.info("Updating transaction 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()));
......@@ -145,6 +151,7 @@ public class DBConnectionImpl implements DBConnection {
*/
@Override
public void updateSession(Session session) throws SQLException {
logger.info("Updating session 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()));
......@@ -164,6 +171,7 @@ public class DBConnectionImpl implements DBConnection {
*/
@Override
public List<Session> getSessions() throws SQLException {
logger.info("Requesting all ssh sessions from database");
Connection connection= dataSource.getConnection();
Statement statement= connection.createStatement();
ResultSet resultSet=statement.executeQuery("select (sessionId,startingTime,finishingTime,username,sshHostname,sshPort,sessionStatus) from sessions;");
......@@ -177,6 +185,7 @@ public class DBConnectionImpl implements DBConnection {
*/
@Override
public List<Transaction> getTransactions() throws SQLException {
logger.info("Requesting all transactions from database");
Connection connection= dataSource.getConnection();
Statement statement= connection.createStatement();
ResultSet resultSet=statement.executeQuery("select (transactionId,startingTime,finishingTime,transactionType,username) from transactions;");
......@@ -191,6 +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");
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());
......@@ -207,6 +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");
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());
......@@ -222,6 +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");
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