56 lines
2.0 KiB
Java
56 lines
2.0 KiB
Java
package eu.univento.commons.database;
|
|
|
|
import eu.univento.commons.Commons;
|
|
import eu.univento.commons.configuration.ConfigurationHandler;
|
|
|
|
/**
|
|
* @author joethei
|
|
* @version 0.1
|
|
*/
|
|
public class DatabaseManager {
|
|
|
|
private MongoDB mongoDB;
|
|
private AsyncMongoDB asyncMongoDB;
|
|
private MySQL mySQL;
|
|
private AsyncMySQL asyncMySQL;
|
|
private AsyncMySQL boardSQL;
|
|
|
|
public DatabaseManager(Commons commons) {
|
|
ConfigurationHandler config = commons.getConfigurationHandler();
|
|
//TODO: remove hardcoded variables
|
|
mongoDB = new MongoDB(config.getString("MongoDB.Host"), config.getInteger("MongoDB.Port"), config.getString("MongoDB.Username"), config.getString("MongoDB.Password"), config.getString("MongoDB.Database"));
|
|
asyncMongoDB = new AsyncMongoDB(config.getString("MongoDB.Host"), config.getInteger("MongoDB.Port"), config.getString("MongoDB.Username"), config.getString("MongoDB.Password"), config.getString("MongoDB.Database"));
|
|
mySQL = new MySQL(config.getString("MySQL.Host"), config.getString("MySQL.Port"), config.getString("MySQL.Database"), config.getString("MySQL.Username"), config.getString("MySQL.Password"));
|
|
asyncMySQL = new AsyncMySQL(config.getString("MySQL.Host"), config.getString("MySQL.Port"), config.getString("MySQL.Database"), config.getString("MySQL.Username"), config.getString("MySQL.Password"));
|
|
boardSQL = new AsyncMySQL("univento.eu", "3306", "forum", "forum", "2Ogxk6$5Yvsr4*24");
|
|
|
|
}
|
|
|
|
public void closeConnections() {
|
|
mongoDB.closeConnection();
|
|
asyncMongoDB.closeConnection();
|
|
mySQL.close();
|
|
asyncMySQL.getMySQL().close();
|
|
boardSQL.getMySQL().close();
|
|
}
|
|
|
|
public MongoDB getMongoDB() {
|
|
return mongoDB;
|
|
}
|
|
|
|
public AsyncMongoDB getAsyncMongoDB() {
|
|
return asyncMongoDB;
|
|
}
|
|
|
|
public MySQL getMySQL() {
|
|
return mySQL;
|
|
}
|
|
|
|
public AsyncMySQL getAsyncMySQL() {
|
|
return asyncMySQL;
|
|
}
|
|
|
|
public AsyncMySQL getBoardSQL() {
|
|
return boardSQL;
|
|
}
|
|
} |