jdbcconpool.java

JDBC的使用类,使用方式和delphi相同

/*==============================================================================
 || @公司名称: In-net Corp.
 || @作者姓名: Viking.Liu  
 || @生成时间: 2007-1-15
 || @单元名称: JConPool.java
 || @单元作用: JDBC的连接池,生成/持有Connection.
 || @注意事项: 
 =============================================================================*/
package com.liuhaomiao.VkJDBC;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;
import org.apache.commons.dbcp.BasicDataSource;

public class JDBCConPool
{
	// 连接数据库的设置.从配置文件读出
	private String strDriver_m = "";
	private String strUrl_m = "";
	private String strUser_m = "";
	private String strPswd_m = "";

	// 读取数据库的对象
	private BasicDataSource dataSource_m = null;



	/***************************************************************************
	 * @throws IOException
	 * @throws FileNotFoundException
	 * @函数名称: JdbcConnection()
	 * @函数用途: 构造函数:
	 * @参数列表: strCnfgFile[保存配置的文件名]
	 * @注意事项:
	 **************************************************************************/
	public JDBCConPool(String strCnfgFile) throws FileNotFoundException,
				IOException
	{
		// 从文件中读取配置
		File fCnfg = new File(strCnfgFile);
		Properties prop = new Properties();
		prop.load(new FileInputStream(fCnfg));

		strDriver_m = prop.getProperty("dbdriver");
		strUrl_m = prop.getProperty("dburl");
		strUser_m = prop.getProperty("dbuser");
		strPswd_m = prop.getProperty("dbpassword");

		// 设置数据源
		if (dataSource_m == null)
		{
			dataSource_m = new BasicDataSource();
		}

		dataSource_m.setDriverClassName(strDriver_m);
		dataSource_m.setUrl(strUrl_m);
		dataSource_m.setUsername(strUser_m);
		dataSource_m.setPassword(strPswd_m);
	}



	/***************************************************************************
	 * @throws SQLException
	 * @函数名称: GetConnetion()
	 * @函数用途: 根据dataSource获取连接
	 * @参数列表:
	 * @注意事项:
	 **************************************************************************/
	public Connection GetConnetion() throws SQLException
	{
		Connection conRet = dataSource_m.getConnection();
		return conRet;
	}



	/***************************************************************************
	 * @throws SQLException
	 * @函数名称: Close()
	 * @函数用途: 关闭所有数据库连接:
	 * @参数列表: isCloseDs[是否要关闭数据源]
	 * @注意事项:
	 **************************************************************************/
	public void Close()
	{
		try
		{
			dataSource_m.close();
		}
		catch (SQLException e)
		{
			e.printStackTrace();
		}
	}



	/***************************************************************************
	 * @函数名称: main
	 * @函数用途: 测试主函数
	 * @参数列表:
	 * @注意事项:
	 **************************************************************************/
	public static void main(String[] args)
	{
		JDBCConPool jcp = null;

		try
		{
			jcp = new JDBCConPool("D://JavaWork//SuperCring//SuperCring.db");
			if (jcp.GetConnetion() != null)
			{
				System.out.println("get one connection");
			}
		}
		catch (Exception e)
		{
			e.printStackTrace();
		}
		finally
		{
			jcp.Close();
		}
	}
}