orderser.zip_移动端web

package com.pei.order.db; import java.io.*; import java.sql.*; import java.util.*; import java.util.Date; public class DBConnManager { class DBConnectionPool { private int checkedOut; private Vector freeConnections; private int maxConn; private String name; private String password; private String URL; private String user; public synchronized void freeConnection(Connection connection) { freeConnections.addElement(connection); //System.out.println("(cn.gov.ahpc.db.DBConnManager)空闲链接总数:"+freeConnections.size()); if (freeConnections.size() > 250) { connection = (Connection) freeConnections.lastElement(); try { connection.close(); freeConnections.removeElementAt(freeConnections.size() - 1); log("Closed freed connection for pool " + name); } catch (SQLException sqlexception) { log(sqlexception, "Can't close connection for pool " + name); } } checkedOut--; notifyAll(); } public synchronized Connection getConnection() { Connection connection = null; // log("freeConnections.size= " + freeConnections.size()); // log("checkedOut= " + checkedOut); if (freeConnections.size() > 0) { connection = (Connection) freeConnections.firstElement(); freeConnections.removeElementAt(0); try { if (connection.isClosed()) { log("Removed bad connection from " + name); connection = getConnection(); } } catch (SQLException _ex) { log("Removed bad connection from " + name); connection = getConnection(); } } else if (maxConn == 0 || checkedOut < maxConn) connection = newConnection(); if (connection != null) checkedOut++; return connection; } public synchronized Connection getConnection(long l) { long l1 = (new Date()).getTime(); Connection connection; while ((connection = getConnection()) == null) { try { wait(l); } catch (InterruptedException _ex) { } if ((new Date()).getTime() - l1 >= l) return null; } return connection; } private Connection newConnection() { Connection connection = null; try { if (user == null) connection = DriverManager.getConnection(URL); else connection = DriverManager.getConnection(URL, user, password); log("Created a new connection in pool " + name); } catch (SQLException sqlexception) { log(sqlexception, "Can't create a new connection for " + URL); return null; } return connection; } public synchronized void release() { for (Enumeration enumeration = freeConnections.elements(); enumeration .hasMoreElements();) { Connection connection = (Connection) enumeration.nextElement(); try { connection.close(); log("Closed connection for pool " + name); } catch (SQLException sqlexception) { log(sqlexception, "Can't close connection for pool " + name); } } freeConnections.removeAllElements(); } public DBConnectionPool(String s, String s1, String s2, String s3, int i) { freeConnections = new Vector(10); name = s; URL = s1; user = s2; password = s3; maxConn = i; } } private static DBConnManager instance; private static int clients; private Vector drivers; private PrintWriter log; private Hashtable pools; private DBConnManager() { drivers = new Vector(); pools = new Hashtable(); init(); } private void createPools(Properties properties) { for (Enumeration enumeration = properties.propertyNames(); enumeration .hasMoreElements();) { String s = (String) enumeration.nextElement(); if (s.endsWith(".url")) { String s1 = s.substring(0, s.lastIndexOf(".")); String s2 = properties.getProperty(s1 + ".url"); if (s2 == null) { log("No URL specified for " + s1); } else { String s3 = properties.getProperty(s1 + ".user"); String s4 = properties.getProperty(s1 + ".password"); String s5 = properties.getProperty(s1 + ".maxconn", "0"); int i; try { i = Integer.valueOf(s5).intValue(); } catch (NumberFormatException _ex) { log("Invalid maxconn value " + s5 + " for " + s1); i = 0; } DBConnectionPool dbconnectionpool = new DBConnectionPool( s1, s2, s3, s4, i); pools.put(s1, dbconnectionpool); log("Initialized pool " + s1); } } } } public void freeConnection(String s, Connection connection) { DBConnectionPool dbconnectionpool = (DBConnectionPool) pools.get(s); if (dbconnectionpool != null) dbconnectionpool.freeConnection(connection); } public Connection getConnection(String s) { DBConnectionPool dbconnectionpool = (DBConnectionPool) pools.get(s); if (dbconnectionpool != null) return dbconnectionpool.getConnection(); else return null; } public Connection getConnection(String s, long l) { DBConnectionPool dbconnectionpool = (DBConnectionPool) pools.get(s); if (dbconnectionpool != null) return dbconnectionpool.getConnection(l); else return null; } public static synchronized DBConnManager getInstance() { if (instance == null) instance = new DBConnManager(); clients++; return instance; } private void init() { InputStream is = getClass().getResourceAsStream("db.properties"); Properties properties = new Properties(); try { properties.load(is); } catch (IOException e) { log(e,"load properties failed"); } String s = "DBConnManager.log"; try { log = new PrintWriter(new FileWriter(s, true), true); } catch (IOException _ex) { System.err.println("Can't open the log file: " + s); log = new PrintWriter(System.err); } loadDrivers(properties); createPools(properties); } private void loadDrivers(Properties properties) { String s = properties.getProperty("drivers"); for (StringTokenizer stringtokenizer = new StringTokenizer(s); stringtokenizer .hasMoreElements();) { String s1 = stringtokenizer.nextToken().trim(); try { Driver driver = (Driver) Class.forName(s1).newInstance(); DriverManager.registerDriver(driver); drivers.addElement(driver); log("Registered JDBC driver " + s1); } catch (Exception exception) { log("Can't register JDBC driver: " + s1 + ", Exception: " + exception); } } } private void log(String s) { log.println(String.valueOf(new Date()) + ": " + s); } private void log(Throwable throwable, String s) { log.println(String.valueOf(new Date()) + ": " + s); throwable.printStackTrace(log); } public synchronized void release() { if (--clients != 0) return; DBConnectionPool dbconnectionpool; for (Enumeration enumeration = pools.elements(); enumeration .hasMoreElements(); dbconnectionpool.release()) dbconnectionpool = (DBConnectionPool) enumeration.nextElement(); for (Enumeration enumeration1 = drivers.elements(); enumeration1 .hasMoreElements();) { Driver driver = (Driver) enumeration1.nextElement(); try { DriverManager.deregisterDriver(driver); log("Deregistered JDBC driver " + driver.getClass().getName()); } catch (SQLException sqlexception) { log(sqlexception, "Can't deregister JDBC driver: " + driver.getClass().getName()); } } } }