一个效果非常不错的JAVA数据库连接池
虽然现在用APACHE COMMONS DBCP可以非常方便的建立数据库连接池，
但是像这篇文章把数据库连接池的内部原理写的这么透彻，注视这么完整，
真是非常难得，让开发人员可以更深层次的理解数据库连接池，真是非常感
谢这篇文章的作者。
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Enumeration;
import java.util.Vector;
public class ConnectionPool {
private String jdbcDriver = ""; // 数据库驱动
private String dbUrl = ""; // 数据 URL
private String dbUsername = ""; // 数据库用户名
private String dbPassword = ""; // 数据库用户密码
private String testTable = ""; // 测试连接是否可用的测试表名，默认没有测试表
private int initialConnections = 10; // 连接池的初始大小
private int incrementalConnections = 5;// 连接池自动增加的大小
private int maxConnections = 50; // 连接池最大的大小
private Vector connections = null; // 存放连接池中数据库连接的向量 , 初始时为 null
// 它中存放的对象为 PooledConnection 型
/**
* 构造函数
*
* @param jdbcDriver String JDBC 驱动类串
* @param dbUrl String 数据库 URL
* @param dbUsername String 连接数据库用户名
* @param dbPassword String 连接数据库用户的密码
*
*/
public ConnectionPool(String jdbcDriver,String dbUrl,String dbUsername,String dbPassword) {
this.jdbcDriver = jdbcDriver;
this.dbUrl = dbUrl;
this.dbUsername = dbUsername;
this.dbPassword = dbPassword;
}
/**
* 返回连接池的初始大小
*
* @return 初始连接池中可获得的连接数量
*/
public int getInitialConnections() {
return this.initialConnections;
}
* 设置连接池的初始大小
*
* @param 用于设置初始连接池中连接的数量
*/
public void setInitialConnections(int initialConnections) {
this.initialConnections = initialConnections;
}
/**
* 返回连接池自动增加的大小、
*
* @return 连接池自动增加的大小
*/
public int getIncrementalConnections() {
return this.incrementalConnections;
}
/**
* 设置连接池自动增加的大小
* @param 连接池自动增加的大小
*/
public void setIncrementalConnections(int incrementalConnections) { this.incrementalConnections = incrementalConnections;
/**
* 返回连接池中最大的可用连接数量
* @return 连接池中最大的可用连接数量
*/
public int getMaxConnections() {
return this.maxConnections;
}
/**
* 设置连接池中最大可用的连接数量
*
* @param 设置连接池中最大可用的连接数量值
*/
public void setMaxConnections(int maxConnections) { this.maxConnections = maxConnections;
}
/**
* 获取测试数据库表的名字
*
* @return 测试数据库表的名字
*/
public String getTestTable() {
return this.testTable;
}
/**
* 设置测试表的名字
* @param testTable String 测试表的名字
*/
public void setTestTable(String testTable) {
this.testTable = testTable;
}
/**
*
* 创建一个数据库连接池，连接池中的可用连接的数量采用类成员
* initialConnections 中设置的值
*/
public synchronized void createPool() throws Exception {
// 确保连接池没有创建
// 如果连接池己经创建了，保存连接的向量 connections 不会为空 if (connections != null) {
return; // 如果己经创建，则返回
}
// 实例化 JDBC Driver 中指定的驱动类实例
Driver driver = (Driver)
(Class.forName(this.jdbcDriver).newInstance());
DriverManager.registerDriver(driver); // 注册 JDBC 驱动程序
// 创建保存连接的向量 , 初始时有 0 个元素
connections = new Vector();
// 根据 initialConnections 中设置的值，创建连接。
createConnections(this.initialConnections);
System.out.println(" 数据库连接池创建成功！ ");
}
/**
* 创建由 numConnections 指定数目的数据库连接 , 并把这些连接
* 放入 connections 向量中
*
* @param numConnections 要创建的数据库连接的数目
*/
@SuppressWarnings("unchecked")
private void createConnections(int numConnections) throws SQLException {
// 循环创建指定数目的数据库连接
for (int x = 0; x < numConnections; x++) {
// 是否连接池中的数据库连接的数量己经达到最大？最大值由类成员 maxConnections
// 指出，如果 maxConnections 为 0 或负数，表示连接数量没有限制。
// 如果连接数己经达到最大，即退出。
if (this.maxConnections > 0 && this.connections.size() >=
this.maxConnections) {
break;
}
//add a new PooledConnection object to connections vector
// 增加一个连接到连接池中（向量 connections 中）
try{
connections.addElement(new
PooledConnection(newConnection()));
}catch(SQLException e){
System.out.println(" 创建数据库连接失败！ "+e.getMessage()); throw new SQLException();
}
System.out.println(" 数据库连接己创建 ......");
}
}
/**
* 创建一个新的数据库连接并返回它
*
* @return 返回一个新创建的数据库连接
*/
private Connection newConnection() throws SQLException {
// 创建一个数据库连接
Connection conn = DriverManager.getConnection(dbUrl,
dbUsername, dbPassword);
// 如果这是第一次创建数据库连接，即检查数据库，获得此数据库允许支持的
// 最大客户连接数目
//connections.size()==0 表示目前没有连接己被创建
if (connections.size() == 0) {
DatabaseMetaData metaData = conn.getMetaData();
int driverMaxConnections = metaData.getMaxConnections();
// 数据库返回的 driverMaxConnections 若为 0 ，表示此数据库没有最大
// 连接限制，或数据库的最大连接限制不知道
//driverMaxConnections 为返回的一个整数，表示此数据库允许客户连接的数目
// 如果连接池中设置的最大连接数量大于数据库允许的连接数目 , 则置连接池的最大
// 连接数目为数据库允许的最大数目
if (driverMaxConnections > 0 && this.maxConnections > driverMaxConnections) {
this.maxConnections = driverMaxConnections;
}
}
return conn; // 返回创建的新的数据库连接
}
/**
* 通过调用 getFreeConnection() 函数返回一个可用的数据库连接 ,
* 如果当前没有可用的数据库连接，并且更多的数据库连接不能创
* 建（如连接池大小的限制），此函数等待一会再尝试获取。
*
* @return 返回一个可用的数据库连接对象
*/
public synchronized Connection getConnection() throws SQLException {
// 确保连接池己被创建
if (connections == null) {
return null; // 连接池还没创建，则返回 null
}
Connection conn = getFreeConnection(); // 获得一个可用的数据库连接
// 如果目前没有可以使用的连接，即所有的连接都在使用中
while (conn == null){
// 等一会再试
wait(250);
conn = getFreeConnection(); // 重新再试，直到获得可用的连接，如果
//getFreeConnection() 返回的为 null
// 则表明创建一批连接后也不可获得可用连接
}
return conn;// 返回获得的可用的连接
}
/**
* 本函数从连接池向量 connections 中返回一个可用的的数据库连接，如果* 当前没有可用的数据库连接，本函数则根据 incrementalConnections 设置* 的值创建几个数据库连接，并放入连接池中。
* 如果创建后，所有的连接仍都在使用中，则返回 null
* @return 返回一个可用的数据库连接
*/
private Connection getFreeConnection() throws SQLException {
// 从连接池中获得一个可用的数据库连接
Connection conn = findFreeConnection();
if (conn == null) {
// 如果目前连接池中没有可用的连接
// 创建一些连接
createConnections(incrementalConnections);
// 重新从池中查找是否有可用连接
conn = findFreeConnection();
if (conn == null) {
// 如果创建连接后仍获得不到可用的连接，则返回 null
return null;
}
}
return conn;
}
/**
* 查找连接池中所有的连接，查找一个可用的数据库连接，
* 如果没有可用的连接，返回 null
*
* @return 返回一个可用的数据库连接
*/
private Connection findFreeConnection() throws SQLException { Connection conn = null;
PooledConnection pConn = null;
// 获得连接池向量中所有的对象
Enumeration enumerate = connections.elements();
// 遍历所有的对象，看是否有可用的连接
while (enumerate.hasMoreElements()) {
pConn = (PooledConnection) enumerate.nextElement(); if (!pConn.isBusy()) {
// 如果此对象不忙，则获得它的数据库连接并把它设为忙 conn = pConn.getConnection();
pConn.setBusy(true);
// 测试此连接是否可用
if (!testConnection(conn)) {
// 如果此连接不可再用了，则创建一个新的连接，
// 并替换此不可用的连接对象，如果创建失败，返回 null try{
conn = newConnection();
}catch(SQLException e){
System.out.println(" 创建数据库连接失败！
"+e.getMessage());
return null;
}
pConn.setConnection(conn);
}
break; // 己经找到一个可用的连接，退出
}
}
return conn;// 返回找到到的可用连接
}
/**
* 测试一个连接是否可用，如果不可用，关掉它并返回 false
* 否则可用返回 true
*
* @param conn 需要测试的数据库连接
* @return 返回 true 表示此连接可用， false 表示不可用
*/
private boolean testConnection(Connection conn) {
try {
// 判断测试表是否存在
if (testTable.equals("")) {
// 如果测试表为空，试着使用此连接的 setAutoCommit() 方法
// 来判断连接否可用（此方法只在部分数据库可用，如果不可用 , // 抛出异常）。注意：使用测试表的方法更可靠
conn.setAutoCommit(true);
} else {// 有测试表的时候使用测试表测试
//check if this connection is valid
Statement stmt = conn.createStatement();
stmt.execute("select count(*) from " + testTable);
}
} catch (SQLException e) {
// 上面抛出异常，此连接己不可用，关闭它，并返回 false;
closeConnection(conn);
return false;
}
// 连接可用，返回 true
return true;
}
/**
* 此函数返回一个数据库连接到连接池中，并把此连接置为空闲。
* 所有使用连接池获得的数据库连接均应在不使用此连接时返回它。
*
* @param 需返回到连接池中的连接对象
*/
public void returnConnection(Connection conn) {
// 确保连接池存在，如果连接没有创建（不存在），直接返回
if (connections == null) {
System.out.println(" 连接池不存在，无法返回此连接到连接池中 !");
return;
}
PooledConnection pConn = null;
Enumeration enumerate = connections.elements();
// 遍历连接池中的所有连接，找到这个要返回的连接对象
while (enumerate.hasMoreElements()) {
pConn = (PooledConnection) enumerate.nextElement();
// 先找到连接池中的要返回的连接对象
if (conn == pConn.getConnection()) {
// 找到了 , 设置此连接为空闲状态
pConn.setBusy(false);
break;
}
}
}
/**
* 刷新连接池中所有的连接对象
*
*/
public synchronized void refreshConnections() throws SQLException { // 确保连接池己创新存在
if (connections == null) {
System.out.println(" 连接池不存在，无法刷新 !");
return;
}
PooledConnection pConn = null;
Enumeration enumerate = connections.elements();
while (enumerate.hasMoreElements()) {
// 获得一个连接对象
pConn = (PooledConnection) enumerate.nextElement();
// 如果对象忙则等 5 秒 ,5 秒后直接刷新
if (pConn.isBusy()) {
wait(5000); // 等 5 秒
}
// 关闭此连接，用一个新的连接代替它。
closeConnection(pConn.getConnection());
pConn.setConnection(newConnection());
pConn.setBusy(false);
}
}
/**
* 关闭连接池中所有的连接，并清空连接池。
*/
public synchronized void closeConnectionPool() throws SQLException { // 确保连接池存在，如果不存在，返回
if (connections == null) {
System.out.println(" 连接池不存在，无法关闭 !");
return;
}
PooledConnection pConn = null;
Enumeration enumerate = connections.elements();
while (enumerate.hasMoreElements()) {
pConn = (PooledConnection) enumerate.nextElement();
// 如果忙，等 5 秒
if (pConn.isBusy()) {
wait(5000); // 等 5 秒
}
//5 秒后直接关闭它
closeConnection(pConn.getConnection());
// 从连接池向量中删除它
connections.removeElement(pConn);
}
// 置连接池为空
connections = null;
}
/**
* 关闭一个数据库连接
*
* @param 需要关闭的数据库连接
*/
private void closeConnection(Connection conn) {
try {
conn.close();
}catch (SQLException e) {
System.out.println(" 关闭数据库连接出错： "+e.getMessage()); }
}
/**
* 使程序等待给定的毫秒数
*
* @param 给定的毫秒数
*/
private void wait(int mSeconds) {
try {
Thread.sleep(mSeconds);
} catch (InterruptedException e) {
}
}
/**
*
* 内部使用的用于保存连接池中连接对象的类
* 此类中有两个成员，一个是数据库的连接，另一个是指示此连接是否
* 正在使用的标志。
*/
class PooledConnection {
Connection connection = null;// 数据库连接
boolean busy = false; // 此连接是否正在使用的标志，默认没有正在使用
// 构造函数，根据一个 Connection 构告一个 PooledConnection 对象
public PooledConnection(Connection connection) {
this.connection = connection;
}
// 返回此对象中的连接
public Connection getConnection() {
return connection;
}
// 设置此对象的，连接
public void setConnection(Connection connection) { this.connection = connection;
}
// 获得对象连接是否忙
public boolean isBusy() {
return busy;
}
// 设置对象的连接正在忙
public void setBusy(boolean busy) {
this.busy = busy;
}
}
}
=======================================
这个例子是根据POSTGRESQL数据库写的，
请用的时候根据实际的数据库调整。
调用方法如下：
①ConnectionPool connPool
= new ConnectionPool("org.postgresql.Driver"
,"jdbc:postgresql://dbURI:5432/DBName"
,"postgre"
,"postgre");
②connPool .createPool();
Connection conn = connPool .getConnection();
JDBC Java中JDBC定义了java与各种sql数据库之间的编程接口，JDBC API是一个统一的标准应用程序编程接口，这样可以屏蔽异种数据库之间的差异。 JDBC的工作原理 JDBC与ODBC（OpenData Base Connectivity，开放式数据库连接）的作用非常类似，它在应用程序和数据库之间起到了桥梁的作用。ODBC使用的特别广泛，在java中还提供了JDBC-ODBC桥，能够在JDBC与ODBC之间进行转换，这样可以通过ODBC屏蔽不同种数据库之间的差异。在JDK的包java.sql.*中定义了一系列的类、接口、异常以及这些类和接口中定义的属性和方法，java的开发人员通过一定的规则调用java.sql.*中的API就可以实现对数据库管理系统的访问。 JDBC的四种驱动 1.JDBC-ODBC Bridge JDBC-ODBC Bridge可以访问一个ODBC数据源，但在执行Java程序的机器上必须安装ODBC驱动，并作出配置，它的调用方式如下图： 因为中间有个JDBC-ODBC，所以影响了执行效率。 配置ODBC数据源的方法如下（以Mysql为例）： 第一步，打开控制面板—>管理工具--->数据源（ODBC） 选择系统DSN，这一项默认应该是空的，我这里是已经配置好了一个数据源。
第二步，点击添加 第三步，选择Mysql的ODBC驱动，点击完成。 注：MySQL的ODBC驱动在系统中一般是找不到的，因为它不是系统默认自带的驱动，所以，我们要自己安装我们所需要的MySQL的ODBC驱动。安装步骤如下： ①．下载安装包，https://www.doczj.com/doc/7712654237.html,/downloads/connector/odbc/ ②．我们下载与自己系统相应的ODBC驱动 这里我们选择
第一种：通过ODBC连接数据库 JAVA语言的跨平台的工作能力（Write Once ,Run Anywhere）、优秀的图像处理能力(我相信现在没有那种语言可以超过JAVA在网络上的图形处理能力)、网络通信功能、通过JDBC数据库访问技术等等，让我们谁都不可否认JAVA语言是SUN公司对于计算机界的一个巨大的贡献。笔者可以描述这样一个场景：有一天你上网完全可以不用IE 或者NETSCAPE,上网就像是玩游戏，你可以获得游戏那么精美的图像和互动的感觉，如果你玩过UO,也许你就知道那种感觉了，但是JAVA做成的东西一定会超过UO的，因为不单单是游戏，也不是单单是浏览器，如果你愿意（要你有钱，有时间，有优秀的JAVA人才）你可以把所有的这一切用Java完全集成出来！！！我不是夸大JAVA的功能，大家可以访问一下 https://www.doczj.com/doc/7712654237.html,的那个社区程序，你就能找到一种感觉了：相信我没有说什么假话。好了，不说废话了，现在我向你介绍JAVA的数据库访问技术 ----JDBC数据库访问技术（你可千万不要搞成ODBC了！）。 JDBC技术事实上是一种能通过JAVA语言访问任何结构化数据库的应用程序接口(API)(Sun这样说的，我也不知道是不是真的),而且现在的JDBC 3.0据Sun 说也能访问Execel等电子表格程序! JDBC对于数据库的访问有四种方式，我们这里只是介绍两种： 第一种是通过ODBC做为“桥”(Bridge)对数据库访问，第二种是直接对数据库访问。 我们先来看看第一种JDBC<-->ODBC访问的流程： JDBC Driver Mannager->JDBC<->ODBC桥->ODBC->数据库客户机驱动库->数据库服务器->返回查询结果，在这种访问中值的我们注意的是虽然JAVA是"Write Once ,Run Anywhere"，但是如果通过这种访问的话，需要客户端必须设置ODBC和有相应的数据库客户机的驱动，当你看了下面的另外一个流程的时候或许你会想：明明下一种更方面，为什么还要有这个东西的产生！呵呵，因为，未必所有的数据库服务器提供商都提供下面的JDBC驱动程序（给JDBC访问提供相应的接口），所以就有了JDBC<->ODBC Bridge。 接着再让我们来看看第二种访问流程： JDBC Driver Mannager->局部JDBC驱动->客户端数据库->数据库服务器->返回查询结果，这种访问事实上是转换JDBC调用为相应的数据库（Oracle, Sybase, Informix, DB2, 和其他的数据库数据库管理系统）的客户端API调用（这么说，不知道大家能不能懂，说简单点就好像ASP不是通过DSN对数据库访问而是通过OLEDB访问，说道这里我还是不知道大家能不能明白我的意思。哎呀，不要扔鸡蛋嘛!），这种方式的访问需要相应的数据库提供商提供相应的JDBC 驱动程序，但是有一种好处，可以独立于odbc用于可以随处可Run的客户端的浏览器中的Applet程序。
JAVA数据库连接池 ●基本概念及原理 ?数据库连接池是为了解决数据库对象 的共享出错问题。 ?实际就是建立一个缓冲池。 ?原理 预先在缓冲池中放入一定数量的连接， 当需要建立数据库连接时，只需从连接 池中取出一个，使用完毕之后再放回 去。 ?JDBC的API中没有提供连接池的方法。 ●连接池关键问题分析 ?使用线程同步来解决并发问题 ?使用一个单例模式的连接池管理类来 解决连接多个不同数据库。具体方法： ◆在连接池管理类的唯一实例被创建 时读取一个资源文件，其中资源文件 中存放着多个数据库的url地址()、 用户名()、密码()等信息。如 tx.url=172.21.15.123： 5000/tx_it，https://www.doczj.com/doc/7712654237.html,er=yang， tx.password=yang321。
◆根据资源文件提供的信息，创建多 个连接池类的实例，每一个实例都是 一个特定数据库的连接池。连接池管 理类实例为每个连接池实例取一个 名字，通过不同的名字来管理不同的 连接池。 ?使用资源文件来解决同一个数据库有多个用户使用不同的名称和密码访问的情况。具体方法： ◆资源文件中设置多个具有相同url 地址，但具有不同用户名和密码的数 据库连接信息。 ?可采用每一个事务独占一个连接来实现事务处理, 这种方法可以大大降低事务管理的复杂性。具体方法: ◆Connection类可以通过设置 Connection的AutoCommit属性为 false,然后显式的调用commit或 rollback方法来实现。 ?使用空闲池来解决连接池的分配与释放处理。具体办法:
◆把已经创建但尚未分配出去的连接按创建时间存放到一个空闲池中。 ◆每当用户请求一个连接时，系统首先检查空闲池内有没有空闲连接：●如果有就把建立时间最长(通过容 器的顺序存放实现)的那个连接分 配给他(实际是先做连接是否有效 的判断，如果可用就分配给用户， 如不可用就把这个连接从空闲池删 掉，重新检测空闲池是否还有连 接)。 ●如果没有则检查当前所建连接池是 否达到连接池所允许的最大连接数 (maxConn),如果没有达到，就新建 一个连接，如果已经达到，就等待 一定的时间(timeout)。如果在等 待的时间内有连接被释放出来就可 以把这个连接分配给等待的用户， 如果等待时间超过预定时间 timeout,则返回空值(null)。
完整java开发中JDBC连接数据库代码和步骤 JDBC连接数据库 ?创建一个以JDBC连接数据库的程序，包含7个步骤： 1、加载JDBC驱动程序： 在连接数据库之前，首先要加载想要连接的数据库的驱动到JVM（Java虚拟机），这通过https://www.doczj.com/doc/7712654237.html,ng.Class类的静态方法forName(String className)实现。 例如： try{ //加载MySql的驱动类 Class.forName("com.mysql.jdbc.Driver") ; }catch(ClassNotFoundException e){ System.out.println("找不到驱动程序类，加载驱动失败！"); e.printStackTrace() ; } 成功加载后，会将Driver类的实例注册到DriverManager类中。 2、提供JDBC连接的URL ?连接URL定义了连接数据库时的协议、子协议、数据源标识。 ?书写形式：协议：子协议：数据源标识 协议：在JDBC中总是以jdbc开始 子协议：是桥连接的驱动程序或是数据库管理系统名称。 数据源标识：标记找到数据库来源的地址与连接端口。 例如：（MySql的连接URL） jdbc:mysql: //localhost:3306/test?useUnicode=true&characterEncoding=gbk ; useUnicode=true：表示使用Unicode字符集。如果characterEncoding设置为 gb2312或GBK，本参数必须设置为true 。characterEncoding=gbk：字符编码方式。 3、创建数据库的连接 ?要连接数据库，需要向java.sql.DriverManager请求并获得Connection对象，该对象就代表一个数据库的连接。 ?使用DriverManager的getConnectin(String url , String username , String password )方法传入指定的欲连接的数据库的路径、数据库的用户名和密码来获得。 例如： //连接MySql数据库，用户名和密码都是root String url = "jdbc:mysql://localhost:3306/test" ; String username = "root" ; String password = "root" ; try{ Connection con = DriverManager.getConnection(url , username , password ) ; }catch(SQLException se){ System.out.println("数据库连接失败！"); se.printStackTrace() ; }
随笔- 6 文章- 0 评论- 1 Java连接各种数据库写法 # 示例配置参考，涵盖几乎所有的主流数据库 ############# Oracle数据库######################## # 数据库驱动名 driver=oracle.jdbc.driver.OracleDriver # 数据库URL(包括端口） dburl=jdbc:oracle:thin:@127.0.0.1:1521:zvfdb # 数据库用户名 user=root # 用户密码
password=zvfims ############# DB2数据库######################## # 数据库驱动名 driver=com.ibm.db2.jcc.DB2Driver # 数据库URL(包括端口） dburl=jdbc:db2://127.0.0.1:50000/zvfdb # 数据库用户名 user=root # 用户密码 password=zvfims ############# MySQL数据库######################## # 数据库驱动名
driver=com.mysql.jdbc.Driver # 数据库URL(包括端口） dburl=jdbc:mysql://127.0.0.1:3306/zvfdb # 数据库用户名 user=root # 用户密码 password=zvfims ############# PostgreSQL数据库数据库######################## # 数据库驱动名 driver=org.postgresql.Driver # 数据库URL(包括端口） dburl=jdbcostgresql://127.0.0.1/zvfdb
今天总结了java平时最常用的7种数据库连接方式，现在分享给大家 MySQL： String Driver="com.mysql.jdbc.Driver"; //驱动程序 String URL="jdbc:mysql://localhost:3306/db_name"; //连接的URL,db_name 为数据库名 String Username="username"; //用户名 String Password="password"; //密码 Class.forName(Driver).new Instance(); Connection con=DriverManager.getConnection(URL,Username,Password); Microsoft SQL Server: 1) String Driver="com.microsoft.jdbc.sqlserver.SQLServerDriver"; //连接SQL数据库的方法 String URL="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=db_name"; //db_name为数据库名 String Username="username"; //用户名 String Password="password"; //密码 Class.forName(Driver).new Instance(); //加载数据可驱动 Connection con=DriverManager.getConnection(URL,UserName,Password); // 2) String Driver="com.microsoft.sqlserver.jdbc.SQLServerDriver"; //连接SQL数据库的方法 String URL="jdbc:sqlserver://localhost:1433;DatabaseName=db_name"; //db_name为数据库名 String Username="username"; //用户名 String Password="password"; //密码 Class.forName(Driver).new Instance(); //加载数据可驱动 Connection con=DriverManager.getConnection(URL,UserName,Password); Sysbase: String Driver="com.sybase.jdbc.SybDriver"; //驱动程序 String URL="jdbc:Sysbase://localhost:5007/db_name"; //db_name为数据可名 String Username="username"; //用户名 String Password="password"; //密码 Class.forName(Driver).newInstance(); Connection con=DriverManager.getConnection(URL,Username,Password); Oracle(用thin模式): String Driver="oracle.jdbc.driver.OracleDriver"; //连接数据库的方法String URL="jdbc:oracle:thin:@loaclhost:1521:orcl"; //orcl为数据库的SID String Username="username"; //用户名 String Password="password"; //密码 Class.forName(Driver).newInstance(); //加载数据库驱动
Java数据库连接池 Tomcat6.0 Tomcat6.0连接池配置 1. 配置tomcat下的conf下的context.xml文件,在之间添加连接池配置: 一、问题引入 在java程序中，需要访问数据库，做增删改查等相关操作。如何访问数据库，做数据库的相关操作呢？ 二、Java连接数据库方法概述 java.sql提供了一些接口和类，用于支持数据库增删改查等相关的操作。该jar包定义了java访问各种不同数据库（mysql，oracle，sqlserver。。。。。）的统一接口和标准。同时，各个数据库厂商都提供了该jar包中定义的各个接口的实现类，用于具体实现本厂数据库的增删改查操作，即称之为“数据库驱动jdbc driver”。例如mysql的数据库驱动为：com.mysql.jdbc.driver；oracle的数据库驱动为：oracle.jdbc.driver.oracledriver。在java程序中访问数据库，做数据库连接时，可以采用两种方式： 1、使用java.sql API 利用该包提供的各种接口和类直接访问数据库。 例子： 2、使用数据库连接池 目前存在多个开源的java数据库连接池，这些连接池都是在java.sql基础上编写而成。 该连接池的解决的问题是： 当使用java.sql中提供的api创建数据库连接时候，需要耗费很大的资源，要进 行用户名密码数据库连接验证等，即耗费资源也耗费时间。如果在程序中，每次需 要访问数据库时候，都进行数据库连接，那么势必会造成性能低下；同时，如果用 户失误忘记释放数据库连接，会导致资源的浪费等。而数据库连接池就是解决该问 题，通过管理连接池中的多个连接对象（connection），实现connection重复利用。 从而，大大提高了数据库连接方面的性能。 该连接池的功能是： 负责创建，管理，释放，分配数据库连接即（connection）。首先，负责创建相应 数目的数据库连接对象（connection）对象，并存放到数据库连接池（connect pool）中。当用户请求数据库连接时，该连接池负责分配某个处于空闲状态的数据库连接 对象；当用户发出释放该数据库连接时，该连接池负责将该连接对象重新设置为空 import .*; import .*; import .*; public class NoteTextArea extends JFrame implements ActionListener { private JPanel jp=new JPanel(); private JButton[] jb = new JButton[4]; private JComboBox box; private JTextArea jt=new JTextArea(); private JScrollPane js=new JScrollPane(jt,,; private String[] obj; private JTextField text = new JTextField(); public NoteTextArea() { (null); String[] obj = new String[]{"微笑","生气","难过","得意"}; box = new JComboBox(obj); JLabel j1 = new JLabel("留言版"); JLabel j2 = new JLabel("你"); JLabel j3 = new JLabel("地说："); jb[0] = new JButton("清屏"); jb[1] = new JButton("至顶"); jb[2] = new JButton("至尾"); jb[3] = new JButton("提交"); for(int i = 0;i < 3;i++) { jb[i].setBounds(650,i*75+55,100,50); } for(int i = 0;i < 3;i++) { (jb[i]); } (280,10,50,30); (20,375,30,50); (55,385,80,30); (160,375,40,50); (210,385,300,30); jb[3].setBounds(520,365,75,50); (10,50,600,300); (j1); (j2); (j3); (box); (text); (jb[3]); (js); for(int i=0;i<=3;i++) { jb[i].addActionListener(this); } (false); (true); ("留言内容："); Java连接数据库全过程 第一次用java连接数据库，开始竟然不知道从哪里下手，后看了很多书，请教了很多高手，忙了一天才连接上，所以我把这个详细的过程整理出来贡献给大家，不当的地方，希望大家告诉我，一定更正。 要准备的软件： 1.操作系统：windows xp或其他系统； 2.java运行环境：JDK 官方下载网址：https://www.doczj.com/doc/7712654237.html,/javase/downloads/index.jsp 3.数据库：SQL server 2000； 下面是java连接数据库需要更新的东西，不然连不上的： 1安装SQL SP3补丁：“SQLSERVER2000SP3补丁.exe”，和普通的程序安装一样。 2.把3个jar包：“msbase.jar”，“mssqlserver.jar”，“msutil.jar”加到classpath中，具体的安装方法我已经详细整理：“Java连接数据库配置——加载jar包”。 Java连接数据库的核心程序文件："TestConnect.java"如下 //TestConnect.java import java.sql.*; public class TestConnect { private Connection con=null;//Connection:与特定数据库的连接（会话）。在连接上下文中执行 SQL 语句并返回结果。 String dbDriver="com.microsoft.jdbc.sqlserver.SQLServerDriver";//声明数据库驱动名(这个是微软的驱动名) //String dbDriver="sun.jdbc.odbc.JdbcOdbcDriver";//sun驱动程序名 //String dbUrl="jdbc:odbc:lhs"; String dbUrl="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=lhs";//数据库驱动程序URL,和相应的驱动配套。 String dbUser="sa";//定义数据库登陆用户名 String dbPasw="123";//定义相应用户的登陆密码 //创建数据库连接 public void connect() Java swing连接数据库的步骤 1．在工程中导入3个jar包，详见（导入Jar包的过程.doc） 2．在类中导入包 a)import java.sql.*; b)import com.microsoft.jdbc.sqlserver.*; 3．声明连接对象，执行语句对象，结果集对象 a)Connection conn=null; b)Statement stmt=null; c)ResultSet rs=null; 4．定义连接字符串 a)final String CLASSFORNAME="com.microsoft.jdbc.sqlserver.SQLServerDriver"; b)final String DBURL="jdbc:microsoft:sqlserver://127.0.0.1:1433;DataBaseName=pubs"; c)final String USER="sa"; d)final String PASS=""; 5．创建连接对象 try{ Class.forName(CLASSFORNAME); conn=DriverManager.getConnection(DBURL,USER,PASS); }catch(SQLException e){ System.out.println(e.getMessage()); }catch(ClassNotFoundException ex){ JOptionPane.showMessageDialog(this,"练苦失败"); return; } 6．创建执行语句对象stmt try{ String sql="insert into users values('name1','pass1')"; //上一行代码可以写成下一行的方式，试分析它的作用是什么？ //String sql="insert into users values('"+name+"','"+pass+"')"; stmt=conn.createStatement(); stmt.executeUpdate(sql); }catch(SQLException ex1){ } 7．完毕 此文中的代码主要列出连接数据库的关键代码，其他访问数据库代码省略 1、Oracle8/8i/9i数据库（thin模式） Class.forName("oracle.jdbc.driver.OracleDriver").newInstance(); String url="jdbc:oracle:thin:@localhost:1521:orcl"; //orcl为数据库的SID String user="test"; String password="test"; Connection conn= DriverManager.getConnection(url,user,password); 2、DB2数据库 Class.forName("com.ibm.db2.jdbc.app.DB2Driver ").newInstance(); String url="jdbc:db2://localhost:5000/sample"; //sample为你的数据库名 String user="admin"; String password=""; Connection conn= DriverManager.getConnection(url,user,password); 3、Sql Server7.0/2000数据库 Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance (); String url="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=mydb"; //mydb为数据库 String user="sa"; String password=""; Connection conn= DriverManager.getConnection(url,user,password); 4、Sybase数据库 Class.forName("com.sybase.jdbc.SybDriver").newInstance(); String url =" jdbc:sybase:Tds:localhost:5007/myDB"; //myDB为你的数据库名 Properties sysProps = System.getProperties(); SysProps.put("user","userid"); SysProps.put("password","user_password"); Connection conn= DriverManager.getConnection(url, SysProps); 5、Informix数据库 Class.forName("https://www.doczj.com/doc/7712654237.html,rmix.jdbc.IfxDriver").newInstance(); String url = "jdbc:informix-sqli://123.45.67.89:1533/myDB:INFORMIXSERVER=myserver; user=testuser;password=testpassword"; //myDB为数据库名 Connection conn= DriverManager.getConnection(url); Java连接MySQL 数据库的正确操作流程 时间:2010-05-25 15:41 来源:博客园字体:[大中小] 以下的文章主要介绍的是Java连接MySQL 数据库(以MySQL数据库为例)，我们主要是以MySQL数据库为例讲下Java正确连接MySQL数据库的实际操作流程，以下就是对其详细内容的描述。 当然，首先要安装有JDK(一般是JDK1.5.X)。然后安装MySQL，这些都比较简单，具体过程就不说了。配置好这两个环境后，下载JDBC驱动MySQL-connector-java-5.0.5.zip（这个是最新版的）。然后将其解压缩到任一目录。我是解压到D盘，然后将其目录下的 MySQL-connector-java-5.0.5-bin.jar加到classpath里，具体如下： “我的电脑”-> “属性” -> “高级” -> “环境变量”，在系统变量那里编辑classpath，将D:\MySQL-connector-java-5.0.5\MySQL-connector-java-5.0.5-bin.jar加到最后，在加这个字符串前要加“;”，以与前一个classpath区分开。然后确定。 环境配置好了，很简单。现在，先配置MySQL，设其用户名为“root”，密码为“root”。在命令行或用一个SQL的前端软件创建Database。 我是用SQLyog的前端软件来创建Database的。 先创接MySQL 数据库： 1.CREATE DATABASE SCUTCS; 接着，创建表： 1.CREATE TABLE STUDENT 2.( 3.SNO CHAR(7) NOT NULL, 4.SNAME VARCHAR(8) NOT NULL, 5.SEX CHAR(2) NOT NULL, 6.BDATE DATE NOT NULL, 7.HEIGHT DEC(5,2) DEFAULT 000.00, 8.PRIMARY KEY(SNO) 9.); 然后插入数据，可以用SQL语句insert into <表名> values (value1, value2, ...); 也可以用SQLyog来操作 一、选择题 1．Java中，JDBC是指（） A. Java程序与数据库连接的一种机制 B．Java程序与浏览器交互的一种机制 C．Java类库名称 D．Java类编译程序 2．在利用JDBC连接数据库时，为建立实际的网络连接，不必传递的参数是（） A. URL B．数据库用户名 C．密码 3．J2ME是为嵌入式和移动设备提供的Java平台，它的体系结构由( )组成。 A. Profiles B．Configuration C．OptionalPackages D. 以上都是 4．J2EE包括的服务功能有（） A. 命名服务JNDI(LDAP)和事务服务JTA B. 安全服务和部署服务 C．消息服务JMS和邮件服务JavaMail D．以上都是 5．JDBC的模型对开放数据库连接(ODBC)进行了改进,它包含（） A. 一套发出SQL语句的类和方法 B. 更新表的类和方法 C．调用存储过程的类和方法 D. 以上全部都是 6．JDBC中要显式地关闭连接的命令是（） A．Connection．close() B．RecordSet．close() C．Connection．stop() D．Connection．release() 7．TCP／IP系统中的端口号是一个( )位的数字，它的范围是0到65535。 A. 8 B．16 C．32 D．64 8．在Java编程语言中，TCP／IPsocket连接是用java．net包中的类实现的。其连接步骤和方法是 A. 服务器分配一个端口号。如果客户请求一个连接，服务器使用accept()方法打开 socket连接 B．客户在host的port端口建立连接 C．服务器和客户使用InputStream和OutputStream进行通信 D．以上全部 9．J2ME中的Profile定义应用系统的( )特性。 A. 生命周期模型 B. 用户界面 C. 访问设备 D. 以上全部都是 10．J2EE平台的优势不包括（） A. 一次编程，任意运行 B. 应用独立于供应商、服务器、工具，构件的选择自由 1 package com.kyo.connection; 2 3 import java.sql.Connection; 4 import java.sql.DatabaseMetaData; 5 import java.sql.Driver; 6 import java.sql.DriverManager; 7 import java.sql.SQLException; 8 import java.sql.Statement; 9 import java.util.Enumeration; 10 import java.util.Vector; 11 12 public class ConnectionPool { 13 14 private ConnectionParam param; 15 16 private String testTable = ""; // 测试连接是否可用的测试表名，默认没 有测试表 17 18 private Vector connections = null; // 存放连接池中数据库连接的向量 , 初始时为 19 // null,它中存放的对象为PooledConnection 型 20 21 public void setParam(ConnectionParam param { 22 this.param = param; 23 } 24 25 public ConnectionParam getParam( { 26 return param; 27 } 28 29 /** 30 * 构造函数 31 * 32 * @param param 33 */ 34 public ConnectionPool(ConnectionParam param { 35 this.param = param; 36 } 37 38 /** 39 * 40 * 获取测试数据库表的名字 41 * 42 * @return 测试数据库表的名字 43 */ 44 45 public String getTestTable( { 46 return this.testTable; 47 } 48 49 /** 50 * 51 * 设置测试表的名字 52 * 53 * @param testTable Java 数据库连接（数据库为bbs，数据源名为test） 1、直接连接mysql数据库（先把mysql的驱动加载到工程中：选中工程：右键property---javabuildpath---libraries：再选择AddExternalJARS找到驱动存放位置把它加载进来）package dbLink; package dbLink; import java.sql.*; public class DataBaseConnection { public static Connection getConnection(){ Connection conn = null; try { Class.forName("com.mysql.jdbc.Driver"); conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/bbs","root","123"); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } return conn; } public static void closeConnection(Connection conn){ if(conn!=null) try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } public static void closeResultSet(ResultSet rs){ if(rs!=null) try{ rs.close(); }catch(SQLException e){ e.printStackTrace(); } } public static void closePreparedStatment(PreparedStatement ps){ if(ps!=null) try{ java jdbc数据库连接池总结 1. 引言 近年来，随着internet/intranet建网技术的飞速发展和在世界范围内的迅速普及，计算机 应用程序已从传统的桌面应用转到web应用。基于b/s（browser/server）架构的3层开发模式逐渐取代c/s（client/server）架构的开发模式，成为开发企业级应用和电子商务普遍采用的技术。在web应用开发的早期，主要使用的技术是cgi﹑asp﹑php等。之后，sun公司推出了基于java语言的servlet+jsp+javabean 技术。相比传统的开发技术，它具有跨平台﹑安全﹑有效﹑可移植等特性，这使其更便于使用和开发。 java应用程序访问数据库的基本原理 在java语言中，jdbc（java database connection）是应用程序与数据库沟通的桥梁 即java语言通过jdbc技术访问数据库。jdbc是一种“开放”的方案，它为数据库应用开发人员﹑数据库前台工具开发人员提供了一种标准的应用程序设计接口，使开发人员可以用纯java语言编写完整的数据库应用程序。jdbc提供两种api，分别是面向开发人员的api和面向底层的jdbc驱动程序api，底层主要通过直接的jdbc驱动和jdbc-odbc桥驱动实现与数据库的连接。 一般来说，java应用程序访问数据库的过程（如图1所示）是： ①装载数据库驱动程序； ②通过jdbc建立数据库连接； ③访问数据库，执行sql语句； ④断开数据库连接。 图1 java数据库访问机制 jdbc作为一种数据库访问技术，具有简单易用的优点。但使用这种模式进行web应用 程序开发，存在很多问题：首先，每一次web请求都要建立一次数据库连接。建立连接是一个费时的活动，每次都得花费0.05s～1s的时间，而且系统还 1.前言 数据库应用，在许多软件系统中经常用到，是开发中大型系统不可缺少的辅助。但如果对数据库资源没有很好地管理(如：没有及时回收数据库的游标(ResultSet)、Statement、连接(Connection)等资源)，往往会直接导致系统的稳定。这类不稳定因素，不单单由数据库或者系统本身一方引起，只有系统正式使用后，随着流量、用户的增加，才会逐步显露。 在b基于Java开发的系统中，JDBC是程序员和数据库打交道的主要途径，提供了完备的数据库操作方法接口。但考虑到规范的适用性，JDBC只提供了最直接的数据库操作规范，对数据库资源管理，如：对物理连接的管理及缓冲，期望第三方应用服务器(Application Server)的提供。 本文，以JDBC规范为基础，介绍相关的数据库连接池机制，并就如果以简单的方式，实现有效地管理数据库资源介绍相关实现技术。 2.连接池技术背景 2.1JDBC JDBC是一个规范，遵循JDBC接口规范，各个数据库厂家各自实现自己的驱动程序(Driver)，如下图所示: 应用在获取数据库连接时，需要以URL的方式指定是那种类型的Driver，在获得特定的连接后，可按照固定的接口操作不同类型的数据库，如: 分别获取Statement、执行SQL获得ResultSet等，如下面的例子: import java.sql.*; … ..DriverManager.registerDriver( new oracle.jdbc. driver.OracleDriver()); Connection dbConn = DriverManager.getConnection (“jdbc:oracle:thin:@127.0.0.1:1521: oracle”,“username”, “password” ); Statement st = dbConn.createStatement();java数据库连接方法
java图形界面以及链接数据库
Java连接数据库全过程
JAVA SWING 连接数据库的步骤
java连接到各种数据库的方法
Java连接MySQL 数据库
java语言的数据库访问技术试题
Java实现数据库连接池的代码.
Java 数据库连接
java jdbc数据库连接池总结
一种简单JDBC连接池的实现
相关主题
文本预览