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 本地数据库如何从远程数据库导数据

发表评论

共有条评论