dbconnection.java

一个真实项目的源代码。有一个比较优秀的时间类

package com.work.db;

import java.sql.Connection;
import java.sql.SQLException;
import java.sql.DriverManager;
import java.util.Properties;

import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

public class DbConnection {
	private static Log log = LogFactory.getLog(DbConnection.class);

	private static String URL = "jdbc:jtds:sqlserver://127.0.0.1:1433;DatabaseName=ebuilderNew;SelectMethod=cursor;charset=GBK";

	private static String USERNAME = "sa";

	private static String PASSWORD = "sa";

	private static String DRIVERCLASS = "net.sourceforge.jtds.jdbc.Driver";

	private static boolean useDataSource = false;//true使用数据源，false不使用

	/**
	 * 通过数据源来连接数据库。失败返回null对象。
	 * 
	 * @return
	 */
	private static Connection getDSConn() {
		Connection conn = null;
		try {
//	        Properties h = new Properties();
//	        h.put(javax.naming.Context.INITIAL_CONTEXT_FACTORY,
//	                    "weblogic.jndi.WLInitialContextFactory");
//	              h.put(javax.naming.Context.PROVIDER_URL,
//	              WebConfig.getProperties("appserver.provider_url"));
//	        intx = new javax.naming.InitialContext(h);
//	        Properties h = new Properties();
//	        h.put(javax.naming.Context.INITIAL_CONTEXT_FACTORY,
//	                    "org.jnp.interfaces.NamingContextFactory");
//	        h.put(javax.naming.Context.PROVIDER_URL,"localhost:1099");	  
//	        h.put("java.naming.factory.url.pkgs","org.jboss.naming:org.jnp.interfaces"); 

			InitialContext init = new InitialContext();
			DataSource ds = (DataSource) init.lookup("java:/eBuilder"); // 获取连接池对象
			conn = ds.getConnection();
		} catch (NamingException e) {
			log.fatal("获取数据源出错，请您仔细查看mssql-ds.xml配置！程序中使用的是“java:/eBuilder”。",
					e);
		} catch (SQLException sqle) {
			log.fatal("获取数据库连接的时候出现错误！", sqle);
		}

		return conn;
	}

	/**
	 * 通过jdbc来连接数据库。失败返回null对象。
	 * 
	 * @return
	 */
	private static Connection getJDBCConn() {
		Connection conn = null;
		try {
			Class.forName(DRIVERCLASS);
			conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
		} catch (ClassNotFoundException e) {
			log.fatal("加载驱动程序" + DRIVERCLASS + "出错！请检查是否存在相应数据库的驱动程序。", e);
		} catch (SQLException sqle) {
			log.fatal("获取数据库连接的时候出现错误！", sqle);
		}
		
		return conn;
	}

	/**
	 * 获取数据库连接，失败返回null。
	 * @return 返回一个数据库连接，失败返回null空对象。
	 */
	public static Connection getConn() {
		if (useDataSource) {
			return getDSConn();
		} else {
			return getJDBCConn();
		}
	}
}