import java.util.Properties;\r
import java.util.Queue;\r
import java.util.Set;\r
-import org.apache.log4j.Logger;\r
+\r
+import com.att.eelf.configuration.EELFLogger;\r
+import com.att.eelf.configuration.EELFManager;\r
\r
/**\r
* Load the DB JDBC driver, and manage a simple pool of connections to the DB.\r
*/\r
public class DB {\r
\r
- private static Logger intlogger = Logger\r
- .getLogger("org.onap.dmaap.datarouter.provisioning.internal");\r
+ private static EELFLogger intlogger = EELFManager.getInstance().getLogger("InternalLog");\r
\r
private static String DB_URL;\r
private static String DB_LOGIN;\r
HTTP_PORT = (String) props.get("org.onap.dmaap.datarouter.provserver.http.port");\r
Class.forName(DB_DRIVER);\r
} catch (IOException e) {\r
- intlogger.fatal("PROV9003 Opening properties: " + e.getMessage());\r
+ intlogger.error("PROV9003 Opening properties: " + e.getMessage());\r
System.exit(1);\r
} catch (ClassNotFoundException e) {\r
- intlogger.fatal("PROV9004 cannot find the DB driver: " + e);\r
+ intlogger.error("PROV9004 cannot find the DB driver: " + e);\r
System.exit(1);\r
}\r
}\r
}\r
} catch (SQLException e) {\r
intlogger\r
- .fatal("PROV9000: The database credentials are not working: " + e.getMessage());\r
+ .error("PROV9000: The database credentials are not working: " + e.getMessage());\r
return false;\r
} finally {\r
if (connection != null) {\r
rs.close();\r
}\r
} catch (SQLException e) {\r
- intlogger.fatal("PROV9010: Failed to get TABLE data from DB: " + e.getMessage());\r
+ intlogger.error("PROV9010: Failed to get TABLE data from DB: " + e.getMessage());\r
}\r
return tables;\r
}\r
try {\r
String scriptFile = String.format("%s/sql_init_%02d.sql", scriptDir, scriptId);\r
if (!(new File(scriptFile)).exists()) {\r
- intlogger.fatal("PROV9005 Failed to load sql script from : " + scriptFile);\r
+ intlogger.error("PROV9005 Failed to load sql script from : " + scriptFile);\r
System.exit(1);\r
}\r
LineNumberReader lineReader = new LineNumberReader(new FileReader(scriptFile));\r
lineReader.close();\r
strBuilder.setLength(0);\r
} catch (Exception e) {\r
- intlogger.fatal("PROV9002 Error when initializing table: " + e.getMessage());\r
+ intlogger.error("PROV9002 Error when initializing table: " + e.getMessage());\r
System.exit(1);\r
}\r
}\r