3 changed files with 36 additions and 1 deletions
@ -1,8 +1,30 @@ |
|||||||
package org.leolo.nrdatad.db.mariadb; |
package org.leolo.nrdatad.db.mariadb; |
||||||
|
|
||||||
|
import org.apache.logging.log4j.LogManager; |
||||||
|
import org.apache.logging.log4j.Logger; |
||||||
|
import org.leolo.nrdatad.ConfigurationManager; |
||||||
|
import org.mariadb.jdbc.MariaDbPoolDataSource; |
||||||
|
|
||||||
public class DatabaseManager implements org.leolo.nrdatad.db.DatabaseManager{ |
public class DatabaseManager implements org.leolo.nrdatad.db.DatabaseManager{ |
||||||
|
Logger logger = LogManager.getLogger(); |
||||||
|
private MariaDbPoolDataSource ds; |
||||||
@Override |
@Override |
||||||
public void initPool() { |
public void initPool() { |
||||||
|
logger.atDebug().log("Start initialize the database pool"); |
||||||
|
ConfigurationManager conf = ConfigurationManager.getInstance(); |
||||||
|
if( |
||||||
|
!conf.containsKey("db.host")|| |
||||||
|
!conf.containsKey("db.user")|| |
||||||
|
!conf.containsKey("db.pwd")|| |
||||||
|
!conf.containsKey("db.name") |
||||||
|
) { |
||||||
|
logger.atFatal().log("Missing required property"); |
||||||
|
System.exit(1); |
||||||
|
return; |
||||||
|
} |
||||||
|
String url = "jdbc:mariadb://"+conf.getProperty("db.host")+ |
||||||
|
":"+conf.getProperty("db.port", "3306")+ |
||||||
|
"/"+conf.getProperty("db.name"); |
||||||
|
logger.atDebug().log("URL={}",url); |
||||||
} |
} |
||||||
} |
} |
||||||
|
|||||||
Loading…
Reference in new issue