数据库连接类

数据库连接类

/*
 * Created on 2005-11-6
 *
 * TODO To change the template for this generated file go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
package com.yanek.test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Enumeration;
import java.util.Hashtable;
import java.util.PropertyResourceBundle;

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

/**
 * @author Administrator
 *
 * TODO To change the template for this generated type comment go to Window -
 * Preferences - Java - Code Style - Code Templates
 */
public class Database {
 /**
  * 数据库访问URL
  */
 private static String url;

 /**
  * 数据库驱动
  */
 private static String driver;

 /**
  * 数据库访问用户名
  */
 private static String username;

 /**
  * 数据库访问口令
  */
 private static String password;

 /**
  * 访问类型
  */
 private static String type;

 /**
  * 数据源名称
  */
 private static String datasource;

 /**
  * 配置文件名称
  */
 private final static String fileName = "database";

 private static ThreadLocal connection = new ThreadLocal();

 static {
  config();
 }

 private static void config() {
  // 读取系统配置
  PropertyResourceBundle resourceBundle = (PropertyResourceBundle) PropertyResourceBundle
    .getBundle(fileName);
  // 将系统设置赋值给类变量
  Enumeration enu = resourceBundle.getKeys();
  while (enu.hasMoreElements()) {
   String propertyName = enu.nextElement().toString();
   if (propertyName.equals("database.url"))
    url = resourceBundle.getString("database.url");
   if (propertyName.equals("database.driver"))
    driver = resourceBundle.getString("database.driver");
   if (propertyName.equals("database.username"))
    username = resourceBundle.getString("database.username");
   if (propertyName.equals("database.password"))
    password = resourceBundle.getString("database.password");
   if (propertyName.equals("database.type"))
    type = resourceBundle.getString("database.type");
   if (propertyName.equals("database.datasource"))
    datasource = resourceBundle.getString("database.datasource");
  }

 }

 /**
  * 取得数据库连接
  *
  * @return
  * @throws SQLException
  */
 public synchronized static java.sql.Connection getConnection()
   throws SQLException {
  Connection con = (Connection) connection.get();
  if (con != null && !con.isClosed()) {
   return con;
  }
  if ("pooled".equalsIgnoreCase(type)) {
   // 从JNDI中取得数据源
   try {
    // 此处对于不同的应用服务器，对env传入不同
    Hashtable env = new Hashtable();
    // 此处对于不同的应用服务器，对env传入不同
    Context ctx = new InitialContext(env); // 从命名系统中获取 DataSource
    // 工厂对象
    DataSource dataSource = (DataSource) ctx.lookup(datasource);
    con = dataSource.getConnection();
    connection.set(con);
    return con;
   } catch (NamingException e) {
    e.printStackTrace();
   }
  } else {
   // 直接使用JDBC驱动连接
   try {
    Class providerClass = Class.forName(driver);
    con = DriverManager.getConnection(url, username, password);
    con.setAutoCommit(false);
    connection.set(con);
    return con;

   } catch (ClassNotFoundException e) {
    e.printStackTrace();
   }
  }
  return null;
 }

 public static void commit() {
  Connection con = (Connection) connection.get();
  try {
   con.commit();
  } catch (SQLException e) {
   e.printStackTrace();
  }
 }

 public static void rollback() {
  Connection con = (Connection) connection.get();
  try {
   con.rollback();
  } catch (SQLException e) {
   e.printStackTrace();
  }
 }

 public synchronized static void releaseConnection(Connection connection) {

  try {
   if (connection != null && !connection.isClosed())
    connection.close();
  } catch (SQLException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
  connection = null;
 }

 public static void main(String[] args) {

  try {

   System.out.println("conn:" + Database.getConnection());

  } catch (SQLException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
 }
}

database.property文件

database.driver=com.mysql.jdbc.Driver
database.url=jdbc:mysql://localhost/test?user=root&password=root&useUnicode=true&characterEncoding=gbk