Add `DatabaseManager` class and initialize database connection

- Introduced `DatabaseManager` class to manage database connections.
- Updated `MediaManagerApplication` to initialize `DatabaseManager` using configuration properties.
This commit is contained in:
Gustavo Henrique Santos Souza de Miranda 2025-11-13 03:59:31 -03:00
parent 885d5c95a4
commit 22476abb27
2 changed files with 37 additions and 0 deletions

View File

@ -7,9 +7,12 @@ import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
import com.mediamanager.service.database.DatabaseManager;
public class MediaManagerApplication {
private static final Logger logger = LogManager.getLogger(MediaManagerApplication.class);
private static Properties config;
private static DatabaseManager databaseManager;
public static void main(String[] args) {
logger.info("Starting MediaManager Core Application...");
@ -17,6 +20,8 @@ public class MediaManagerApplication {
try {
// Load configuration
loadConfiguration();
databaseManager = new DatabaseManager(config);
databaseManager.init();
// TODO: Initialize database connection
// TODO: Initialize IPC server with named pipes

View File

@ -0,0 +1,32 @@
package com.mediamanager.service.database;
import java.sql.Connection;
import java.sql.DriverManager;
import java.util.Properties;
public class DatabaseManager {
private final Properties configuration;
private Connection connection;
public DatabaseManager(Properties config) {
this.configuration = config;
}
public void init() throws Exception {
String databaseType = configuration.getProperty("database.type");
String databaseUrl = configuration.getProperty("database.url");
String databaseUsername = configuration.getProperty("database.username");
String databasePassword = configuration.getProperty("database.password");
String databasePort = configuration.getProperty("database.port");
String databaseName = configuration.getProperty("database.name");
String connectionString = String.format("jdbc:postgresql://%s:%s/%s", databaseUrl, databasePort, databaseName);
connection = DriverManager.getConnection(connectionString, databaseUsername, databasePassword);
}
public Connection getConnection() {
return connection;
}
}