使用java进行数据库操作时, 读表前后的步骤繁杂, 在读表前要进行注册驱动, 获得Connection对象等步骤, 在读表之后要进行资源的释放, 而且通用性不强, 为了简化步骤可以定义工具类, 通过调用静态方法简化代码。这里定义了JDBCUtils工具类, 功能主要有在静态代码块中加载读取配置文件, 注册驱动; 使用JBDCUtils.getConnection()方法获得Connection对象; 使用两个重载的close()方法进行资源释放。
注意: 一定要注意数据库加载地址的格式
最开始写成了下面这样:
url = jdbc:mysql///db3
报错
java.sql.SQLException: No suitable driver found for url = jdbc:mysql///db3
mysql后面的冒号<:>丢了...
正确的写法:
url = jdbc:mysql:///db3
// 或者完整格式
jdbc:mysql://localhost:3306/db3
测试用例
package cn.itcast.jdbc.demo4JDBCUtils;
import cn.itcast.utils.JDBCUtils;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class UtilsDemo {
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
try {
conn = JDBCUtils.getConnection();
stmt = conn.createStatement();
// sql语句
String sql_query = "SELECT * FROM account";
rs = stmt.executeQuery(sql_query);
int id = 0;
String name = null;
double salary = 0.0;
while (rs.next()) { // 依次读取每一行
id = rs.getInt(1); // 使用列索引
name = rs.getString(2);
salary = rs.getDouble(3);
System.out.println(id + "--" + name + "--" + salary);
}
} catch (SQLException e) {
e.printStackTrace();
}finally {
JDBCUtils.close(rs, stmt, conn);
}
}
}
JBDCUtils工具类
package cn.itcast.utils;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.sql.*;
import java.util.Properties;
/*
作用:
1. 注册驱动
* 注册驱动整个程序运行阶段只需要执行一次, 不需要每次创建连接对象都执行
因此放在静态代码块中, 在JVM加载该工具类的时候执行一次
* 配置文件读取也是只需要一次, 因此也放在静态代码块中
2. 创建连接对象
3. 释放资源
*/
public class JDBCUtils {
// 静态变量域
// 之所以设置全局变量是因为在静态代码块中读取文件, 在getConnection()中使用, 这样就不需要参数传递了
// 设置成静态变量是因为getConnection是静态方法
private static String url;
private static String user;
private static String password;
private static String driver;
static{
try {
// 获取配置文件
// 创建Properties对象
Properties pro = new Properties();
// 加载配置文件
// 找到配置文件
ClassLoader classLoader = JDBCUtils.class.getClassLoader();
// 通过类加载器查找配置文件, 得到路径
String path = classLoader.getResource("pro.properties").getPath();
// 注意load的参数是字节流或字符流, 使用路径创建字符流
pro.load(new FileReader(path));
url = pro.getProperty("url"); // // url = jdbc:mysql///db3
user = pro.getProperty("user");
password = pro.getProperty("password");
driver = pro.getProperty("driver");
// 注册驱动
//Class.forName(driver);
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public static Connection getConnection() throws SQLException {
// 返回连接对象
return DriverManager.getConnection(url, user, password);
}
// 释放资源
public static void close(ResultSet rs, Statement stmt, Connection conn){
if (rs != null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (stmt != null){
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (conn != null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
// 释放资源 重载没有ResultSet的情况
public static void close(Statement stmt, Connection conn){
if (stmt != null){
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (conn != null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
配置文件pro.properties
url = jdbc:mysql://localhost:3306/db3
user = root
password = root
driver = com.mysql.jdbc.Driver
