一、JDBC简介
JDBC(Java Data Base Connectivity,java数据库连接)是一种用于执行SQL语句的Java API,可以为多种关系数据库提供统一访问,它由一组用Java语言编写的类和接口组成。JDBC为数据库开发人员提供了一个标准的API,据此可以构建更高级的工具和接口,使数据库开发人员能够用纯 Java API 编写数据库应用程序,并且可跨平台运行,并且不受数据库供应商的限制。
二、实例
package org.hj.util.jdbc;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
/**
* JDBC工具类:关闭流和取得连接
* @author DingJie
* @date 2014-5-3
* @email [email protected]
*/
public final class JdbcUtil {
private static String driver;
private static String url;
private static String user;
private static String password;
private static Connection conn;
//静态块:加载文件
static{
Properties props = new Properties();
InputStream is = JdbcUtil.class.getClassLoader().getResourceAsStream("org/hj/config/jdbc/db.properties");
try {
props.load(is);
} catch (Exception e) {
e.printStackTrace();
}
driver = props.getProperty("driver");
url = props.getProperty("url");
user = props.getProperty("user");
password = props.getProperty("password");
}
//静态块:注册驱动
static{
try {
Class.forName(driver);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 每个线程获取一个唯一jdbc连接
* @return
*/
public static Connection getMySqlConnection() {
if(conn == null) {
synchronized (JdbcUtil.class) {
if(conn == null) {
try {
conn = DriverManager.getConnection(url,user,password);
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
return conn;
}
/**
* 关闭结果集
* @param rs
*/
public static void close(ResultSet rs){
if(rs!=null){
try {
rs.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
/**
* 关闭SQL语句声明
* @param stmt
*/
public static void close(Statement stmt){
if(stmt!=null){
try {
stmt.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
/**
* 关闭数据库连接
* @param conn
*/
public static void close(Connection conn){
if(conn!=null){
try {
conn.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
这里有两个连续的Dao操作:
public List<TreeType> listAllTreeType(){ List<TreeType> list = new ArrayList<TreeType>(); Connection conn = JdbcUtil.getMySqlConnection(); Statement stmt = null; ResultSet rs = null; try { stmt = conn.createStatement(); rs = stmt.executeQuery("SELECT id, tree_name FROM tree_type"); while(rs.next()) { TreeType tt = new TreeType(); tt.setId(rs.getInt("id")); tt.setTreeType(rs.getString("tree_name")); list.add(tt); } } catch (SQLException e) { e.printStackTrace(); } finally { if(rs != null) { JdbcUtil.close(rs); } if(stmt != null) { JdbcUtil.close(stmt); } /*if(conn != null) { JdbcUtil.close(conn); }*/ } return list; } /** * 通过名称查找所有的树种 * @param treeName * @return */ public List<TreeType> findTreeByName(String treeName) { List<TreeType> list = new ArrayList<TreeType>(); Connection conn = JdbcUtil.getMySqlConnection(); Statement stmt = null; ResultSet rs = null; try { stmt = conn.createStatement(); rs = stmt.executeQuery("SELECT id, tree_zone FROM tree_type where tree_name='"+treeName+"'"); while(rs.next()) { TreeType tt = new TreeType(); tt.setId(rs.getInt("id")); tt.setTreeType(rs.getString("tree_zone")); list.add(tt); } } catch (SQLException e) { e.printStackTrace(); } finally { if(rs != null) { JdbcUtil.close(rs); } if(stmt != null) { JdbcUtil.close(stmt); } if(conn != null) { JdbcUtil.close(conn); conn = null; } } return list; }
上述两段代码都有JdbcUtil.close()的操作,但是连续执行两段代码时会抛出
使用如下sql命令查看当前活动连接:
Threads_connected:表示当前打开连接的线程数;
Threads_created:表示当前创建的线程数;
Threads_running:表示当前尚未睡眠的线程;
出现上述异常是因为,conn是单例的,但是在进行第二次数据库操作 findTreeByName时数据库已经关闭了,所以将第一个方法JdbcUtil.close(conn)注释掉。在执行第最后一次数据库操作时在关闭。
这里需要好好设计一下究竟在什么时候关闭数据库,一般而言是可以在entity,dao,service层中写可以分别打开分别关闭。为了和数据库事物操作保持一致可以在服务层打开和关闭。
因此这里要么不关闭,要么显示的关闭,并同时设置conn为空,但这样单例也就失去了部分意义,因为每次JdbcUtil.getConnection()都是需要new对象,但是可以保证每次只有一个conn存在。所以需要综合考虑数据库操作的情况来进行。