使用weblogic连接池来得到数据库连接(通过配置文件进行读取的优化方案)

技术2022-05-11 107

package com.etong.system;

import java.io.File;import java.io.FileInputStream;import java.util.Properties;

import javax.naming.Context;import javax.naming.InitialContext;

import com.etong.hr.DatabaseHRFactory;import com.etong.hr.HRFactory;import com.etong.statetaxbureau.workflow.BureauFactory;import com.etong.workflow.DatabaseWorkflowFactory;import com.etong.workflow.WorkflowFactory;import com.roger.database.DBPersistence;

public class ResourceFactory { private static LogRelated lg = new LogRelated("D:/log","lgConnOracle"); private static int no = 0; private static InitialContext JNDI_Context = null; private static final java.sql.Connection getSQLServerConnection() {

java.sql.Connection con = null; try { Context ctx = getInitialContext(); javax.sql.DataSource ds = (javax.sql.DataSource) ctx.lookup("SQLDS"); con = ds.getConnection(); if (con == null) { throw new WorkflowConnectionException("SQL数据库连接不上"); } } catch (Exception e) { e.printStackTrace(); throw new WorkflowConnectionException("SQL数据库连接不上"); } return con;

}

private static synchronized final java.sql.Connection getOracleConnection() {

java.sql.Connection con = null; try { if(no >= Integer.MAX_VALUE){ no = 0; } no++; lg.log("no = " + no +";上下文初始前!---Context"); Context ctx = getInitialContext(); lg.log("no = " + no +";获得数据源前!----DataSource"); javax.sql.DataSource ds = (javax.sql.DataSource) ctx.lookup("workflowDS"); lg.log("no = " + no +";获得连接前!---getConnection"); con = ds.getConnection(); lg.log("no = " + no +";获得连接后!---conn"); if (con == null) { lg.log("no = " + no +";获得连接为空!"); throw new WorkflowConnectionException("工作流数据库连接不上"); }else{ lg.log("no = " + no + ";数据库连接成功!"); } } catch (Exception e) { e.printStackTrace(); e.printStackTrace(lg.getLogPW()); throw new WorkflowConnectionException("工作流数据库连接不上"); } return con;

}

private static Context getInitialContext() throws Exception { //采用静态JNDI_Context来第一次读取上下文信息 if(JNDI_Context != null){ return JNDI_Context; } lg.log("no = " + no +";getInitialContext!---getInitialContext");

Properties pro = new Properties(); FileInputStream fileInputStream = new FileInputStream(new File("C:/pro.properties")); pro.load(fileInputStream); String url = pro.getProperty("url"); String user = pro.getProperty("username"); String password = pro.getProperty("password"); fileInputStream.close();

//结束 Properties properties = new Properties(); properties.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory"); properties.put(Context.PROVIDER_URL, url); if (user != null) { properties.put(Context.SECURITY_PRINCIPAL, user); properties.put(Context.SECURITY_CREDENTIALS, password == null ? "" : password); } JNDI_Context = new InitialContext(properties); return JNDI_Context;

}

public static final java.sql.Connection getCTAISConnection() { java.sql.Connection con = null;

try { Context ctx = getInitialContext(); javax.sql.DataSource ds = (javax.sql.DataSource) ctx.lookup("ctaisDS"); con = ds.getConnection(); if (con == null) { throw new CtaisConnectionException("CTAIS数据库连接不上"); } } catch (Exception e) { throw new CtaisConnectionException("CTAIS数据库连接不上"); } return con; }

public static final java.sql.Connection getConnection() { if (isSQLServer()) { return getSQLServerConnection(); } else if (isOracle()) { return getOracleConnection(); } else { throw new WorkflowConnectionException("工作流数据库连接不上"); }

}

public static final DBPersistence createDBPersistence() { DBPersistence db = new DBPersistence(); if (isSQLServer()) { db.setConnection(getSQLServerConnection()); } else if (isOracle()) { db.setConnection(getOracleConnection()); } else { throw new WorkflowConnectionException("工作流数据库连接不上"); } return db; }

public static final DBPersistence createCTAISPersistence() { DBPersistence db = new DBPersistence(); if (isSQLServer()) { db.setConnection(getSQLServerConnection()); } else if (isOracle()) { db.setConnection(getCTAISConnection()); } else { throw new CtaisConnectionException("CTAIS数据库连接不上"); } return db;

}

/** * 创建一个人事工厂类 * @return 人事工厂类 */ public static final HRFactory createHRFactory() { return new DatabaseHRFactory(); }

/** * 创建一个工作流工厂类 * @return 工作流工厂类 */ public static final WorkflowFactory createWorkflowFactory() { return new DatabaseWorkflowFactory(); }

/** * 创建一个系统工厂类 * @return 系统工厂类 */ public static final SystemFactory createSystemFactory() { if (isSQLServer()) { return new SQLServerSystemFactory(); } else if (isOracle()) { return new OracleSystemFactory(); } else { throw new IllegalArgumentException("工作流数据库连接不上"); }

}

public static final BureauFactory createBureauFactory() { return new BureauFactory(); }

/** * 得到用户自定义的字段类型 * @return 字段类型 */ public static final String[] getUserField() { String[] s = { "整型", "小数", "字符型", "日期型"}; return s; }

public static final boolean isSQLServer() { return false; }

public static final boolean isOracle() { return true; }

public static void main(String[] args) throws Exception { }}

其中:LogRelated只是为了便于找问题,创建的一个日志文件而已.其源代码为.

package com.etong.system;

import java.io.File;import java.io.IOException;import java.io.FileWriter;import java.io.PrintWriter;

public class LogRelated { private String logDirName = ""; private String logFileName = "";

private PrintWriter logPW = null;

private String strFileTime = new java.sql.Timestamp(System.currentTimeMillis()).toString().substring(0, 10);

public LogRelated(String logDirName, String logFileName) { initialLog(logDirName, logFileName); }

private void initialLog(String logDirName, String logFileName) { this.logDirName = logDirName; this.logFileName = logFileName; if (logDirName.indexOf("//") != -1) { System.out.println("Input logDirName is incorrect!Please input like UNIX Directory!"); return; } File logFile = null; if (logDirName == null || logDirName.equals("")) { logFile = new File(logFileName + "_" + this.strFileTime + ".txt"); } else { logFile = new File(logDirName + "/" + logFileName + "_" + this.strFileTime + ".txt"); } if (!logFile.isFile()) { logFile = logFile.getAbsoluteFile(); File parentDir = new File(logFile.getParent()); if (!parentDir.exists()) { parentDir.mkdirs(); } } try { logPW = new PrintWriter(new FileWriter(logFile, true), true); } catch (IOException e) { System.err.println("Cann't open log file: " + logFile); logPW = new PrintWriter(System.err); }

}

public void log(String logContent) { if (!new java.sql.Timestamp(System.currentTimeMillis()).toString().substring(0, 10).equals(this.strFileTime)) { this.strFileTime = new java.sql.Timestamp(System.currentTimeMillis()).toString().substring(0, 10); initialLog(this.logDirName, this.logFileName); } try { logPW.println(new java.sql.Timestamp(System.currentTimeMillis()) + ": " + logContent); } catch (Exception ex) { this.initialLog(this.logDirName, this.logFileName); ex.printStackTrace(logPW); this.log(logContent); } }

public String getLogFileName() { return logFileName; }

public void setLogDirName(String logDirName) { this.logDirName = logDirName; }

public void setLogFileName(String logFileName) { this.logFileName = logFileName; }

public void setLogPW(PrintWriter logPW) { this.logPW = logPW; }

public String getLogDirName() { return logDirName; }

public PrintWriter getLogPW() { return logPW; }}

专利

最新回复(0)