_datasource.java

hibernate处理缓存.提高运行速度.

package com.holpe.database;

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.Connection;

import javax.sql.DataSource;

/**
 * 数据源对象的接管，由于Struts本身使用的是dbcp连接池
 * 此类就是接管DataSource接口
 * @author liuxb
 */
public class _DataSource implements InvocationHandler {

	private DataSource dataSource;
	private boolean encoding;

	public _DataSource(DataSource ds, boolean encoding) {
		dataSource = ds;
		this.encoding = encoding;
	}

	/**
	 * 获取DataSource的代理
	 * @return
	 */
	public DataSource getDataSource() {
		Class[] infs = dataSource.getClass().getInterfaces();
		if(infs==null||infs.length==0)
			infs = IDS;
		return (DataSource) Proxy.newProxyInstance(
			dataSource.getClass().getClassLoader(), infs, this);
	}

	public Object invoke(Object proxy, Method m, Object args[])	throws Throwable
	{
		if (METHOD_NAME.equals(m.getName())){
			try {
				Connection conn = (Connection) m.invoke(dataSource, args);
				return (conn==null)?null:(new _Connection(conn,encoding)).getConnection();
			} catch (InvocationTargetException e) {
				throw e.getTargetException();
			}
		}
		try {
			return m.invoke(dataSource, args);
		} catch (InvocationTargetException e) {
			throw e.getTargetException();
		}
	}

	private final static String METHOD_NAME = "getConnection";

	private final static Class[] IDS = new Class[]{DataSource.class};

}