mysql數據庫連接池配置教程

2024-07-24 12:48:56

字體：大中小

來源：轉載

供稿：網友

第一步：寫javabean
復制代碼代碼如下:

package withouttears.jdbc.db;
import java.util.HashMap;
import java.sql.*;
//JNDI有兩個核心接口Context和DirContext，
//Context中包含了基本的名字操作，而DirContext則將這些操作擴展到目錄服務。
import javax.naming.Context;
import javax.naming.InitialContext;
//數據庫資源的連接工廠是javax.sql.DataSource對象，
//它可以創建java.sql.Connection數據庫連接對象。
import javax.sql.DataSource;
//目前您可以從Java開發者連接（http://java.sun.com/products/jdbc/download.html#rowsetcobundle1_0）
//下載CachedRowSet的實現。下載并解壓縮安裝文件后，將"rowset.jar"文件放到您的類目錄下。
//CachedRowSet在sun.jdbc.rowset包中。
import sun.jdbc.rowset.CachedRowSet;
/**
* 作者：wiThouTTears
* 時間：2006-12-13
* */
public class Database {
/**************************************************************/
/* 函數：localhost
* 功能：建立連接池
* */
private static DataSource localhost(){
DataSource ds=null;
//在HashMap中通過get()來獲取value，通過put()來插入value，
//ContainsKey()則用來檢驗對象是否已經存在
HashMap<Object,Object> cachedDs=new HashMap<Object,Object> ();
if(cachedDs.containsKey("ds"))//取出空閑狀態的數據庫連接
{
/* 在DataSource中事先建立了多個數據庫連接，
* 這些數據庫連接保存在連接池(Connect Pool)中。
* Java程序訪問數據庫時，只需要從連接池中取出空閑狀態的數據庫連接；
* 當程序訪問數據庫結束，再將數據庫連接放回連接池。
* */
ds = (DataSource)cachedDs.get("ds");
}
else
try
{
/*在javax.naming包中提供了Context接口，
* 該接口提供了將對象和名字綁定，以及通過名字檢索對象的方法。
* */
Context initCtx = new InitialContext();
//lookup(String name)：返回與指定的名字綁定的對象,獲得數據庫連接工廠
ds = (DataSource)initCtx.lookup("java:comp/env/jdbc/testdb");
cachedDs.put("ds", ds);
}
catch(Exception e)
{
e.printStackTrace();
}
return ds;
}
/**************************************************************/
/* 函數：getConnection
* 功能：庫的連接
* */
private static Connection getConnection(){
Connection conn = null;
try
{
DataSource ds = localhost();
conn = ds.getConnection();
}
catch(Exception e)
{
e.printStackTrace();
}
return conn;
}
/**************************************************************/
/* 函數：close
* 功能：關閉連接
* */
private static void close(Connection conn)
{
try
{
if(conn != null)
conn.close();
}
catch(SQLException e)
{
e.printStackTrace();
}
}
/**************************************************************/
/* 函數：executeQuery
* 功能：數據查詢
* */
public static CachedRowSet executeQuery(String sql)
{

上一篇：MySQL如何導入csv格式數據文件解決方案

下一篇：mysql 本地數據庫如何從遠程數據庫導數據

發表評論

共有條評論