?? jdbcconpool.java
字號:
/*==============================================================================
|| @公司名稱: 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();
}
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -