首页 > 代码库 > JavaSE基础之JDBC
JavaSE基础之JDBC
JavaSE基础之JDBC
1、JDBC 的步骤:
①加载数据库驱动;
a.MySQL:com.mysql.jdbc.Driver;
b.SQLServer:com.microsoft.jdbc.sqlserver.SQLServerDriver;
c.Oracle:oracle.jdbc.driver.OracleDriver;
②获取数据库链接;
a.MySQL:jdbc:mysql://localhost:3306/DataBaseName;
b.SQLServer:jdbc:sqlserver://localhost:1433; DatabaseName=DataBaseName;
c.Oracle:jdbc:oracle:thin:@localhost:1521:orcl;
③创建SQL语句对象;
④执行SQL语句对象;
a.如果是insert、delete、update,则返回 int;
b.如果是query,则返回ResultSet,需要封装结果集。
⑤关闭数据库资源。
2、JDBC 的工具类(以链接MySQL为例):DBUtil.java
package cn.com.zfc.util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
*
* @title DbUtil
* @describe 连接数据库的帮助类:链接 MySQL 数据库
* @author 张富昌
* @date 2016年8月23日上午9:52:44
*/
public class DbUtil {
/* 数据库链接的 URL,数据库名称可随意更改 */
private final static String URL = "jdbc:mysql://localhost:3306/library";
/* 数据库用户名 */
private final static String USERNAME = "root";
/* 数据库密码 */
private final static String PASSWORD = "root";
/* 数据库链接对象 */
private Connection connection = null;
/* 预处理语句对象,相同的 sql 语句只编译一次 */
private PreparedStatement preparedStatement = null;
/* 结果集对象,用于存储查询的数据 */
private ResultSet resultSet = null;
/* 结果集结构化对象,用于对结果集的处理,方便获取数据 */
private ResultSetMetaData resultSetMetaData = http://www.mamicode.com/null;
/**
*
* 功能:1、加载数据库驱动包
*
*/
static {
try {
// 需要加载数据库的驱动
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
System.out.println("加载数据库驱动包出现了异常...");
e.printStackTrace();
}
}
/**
*
* 功能:2、获取数据库链接
*
* 参数:
*
* 返回类型:Connection
*/
private Connection getConnection() {
try {
connection = DriverManager.getConnection(URL, USERNAME, PASSWORD);
return connection;
} catch (SQLException e) {
System.out.println("获取链接出现了异常");
e.printStackTrace();
}
return null;
}
/**
*
* 功能:3、提供更新的方法,包括(添加、修改、删除)
*
* 参数: String sql, Object... objects
*
* 返回类型:int
*/
public int update(String sql, Object... objects) {
// 1、创建数据库链接对象
connection = getConnection();
// 2、创建预处理语句对象
try {
preparedStatement = connection.prepareStatement(sql);
// 3、遍历参数 Object,代替 SQL 语句中的占位符(如果有)
for (int i = 0; i < objects.length; i++) {
preparedStatement.setObject(i + 1, objects[i]);
}
// 4、执行 sql 语句
return preparedStatement.executeUpdate();
} catch (SQLException e) {
System.out.println("创建预处理语句对象出现了异常...");
e.printStackTrace();
} finally {
// 5、关闭数据库资源
release();
}
return -1;
}
/**
*
* 功能:4、查询数据库中的信息
*
* 参数:String sql, Object... objects
*
* 返回类型:List<Map<String,Object>>
*/
public List<Map<String, Object>> query(String sql, Object... objects) {
List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
// 1、创建数据库链接对象
connection = getConnection();
// 2、创建预处理语句对象
try {
preparedStatement = connection.prepareStatement(sql);
// 3、遍历参数 Object
for (int i = 0; i < objects.length; i++) {
preparedStatement.setObject(i + 1, objects[i]);
}
// 4、执行 SQL 语句,创建结果集对象
resultSet = preparedStatement.executeQuery();
// 5、创建结果集结构化对象
resultSetMetaData = http://www.mamicode.com/resultSet.getMetaData();
// 6、遍历结果集,把存储数据类型转化为 List<Map<String, Object>>
while (resultSet.next()) {
Map<String, Object> map = new HashMap<String, Object>();
for (int i = 1; i <= resultSetMetaData.getColumnCount(); i++) {
String key = resultSetMetaData.getColumnName(i);
Object value = http://www.mamicode.com/resultSet.getObject(key);
// 封装结果集
map.put(key, value);
}
list.add(map);
}
return list;
} catch (SQLException e) {
System.out.println("创建预处理语句对象出现了异常...");
e.printStackTrace();
} finally {
// 7、关闭数据库资源
release();
}
return null;
}
/**
*
* 功能:5、关闭数据库资源,很重要
*
* 参数:
*
* 返回类型:void
*/
private void release() {
// 1、关闭数据库链接对象
if (connection != null) {
try {
connection.close();
} catch (SQLException e) {
System.out.println("关闭数据库链接对象出现了异常...");
e.printStackTrace();
}
}
// 2、关闭预处理语句对象
if (preparedStatement != null) {
try {
preparedStatement.close();
} catch (SQLException e) {
System.out.println("关闭预处理语句对象出现了异常...");
e.printStackTrace();
}
}
// 3、关闭结果集对象
if (resultSet != null) {
try {
resultSet.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
JavaSE基础之JDBC