小博老师解析Java核心技术 ——JDBC数据库操作类封装

[引言]

我们在学习Java编程时，连接数据库技术（JDBC）是一项必备技能，我们经常需要读取或操作持久性存储的结构化数据。那么现在开始，小博老师就开始为大家讲解JDBC中的常用操作技术，今天我们来了解JDBC中对数据库常用操作类的封装。

 

[步骤阅读一]项目添加jdbc驱动

我们想要在Java项目中使用JDBC的功能，就必须要为项目添加JDBC驱动文件（jar），我们一般可以在各种数据库产品的官网上找到它们，例如mysql数据库则可以在：http://www.mysql.com/products/connector/ 中找到驱动文件。

为项目添加了JDBC驱动文件（jar文件）后，我们可以看到项目的Referenced Library中结构如下：



[步骤阅读二]数据库操作类的封装

接下来，我们就进入了本文的重点了，对数据中数据表记录进行增、删、改、查的操作是很频繁的，因此我们在开发过程中，经常会对此类操作进行封装。今天小博老师就为大家演示一段常见的数据库操作封装方式，核心代码如下：

/**

 * JDBC连接MySQL数据库的操作类

 * */

public class MySQLDBHelper {

// 静态变量  存放所需连接MySQL数据库的参数

// 当前案例演示直接赋值 通常需要编写配置文件

// MySQL数据库所在的Ip地址

private static String IPAddress = "127.0.0.1";

// MySQL数据库的端口号

private static int Port = 3306;

// MySQL数据库的身份登录名称

private static String Username = "root";

// MySQL数据库的身份登录密码

private static String Password = "";

// 要操作的MySQL数据库的数据表名称

private static String Database = "bwf";

/**

 * 非参数化执行查询语句的方法

 * @param sql 要执行的查询SQL语句

 * @return 查询到的结果集

 * */

public static ResultSet query(String sql){

ResultSet rs = null;

try{

// 加载mysql驱动

Driver driver = new Driver();

// 实例化 数据库连接对象

Connection conn = DriverManager.getConnection(

"jdbc:mysql://"+IPAddress+":"+Port+"/"+Database+"?useUnicode=true&characterEncoding=utf8",

Username,Password);

// 获取 命令申明对象

Statement stmt = conn.createStatement();

// 发送 查询SQL语句去数据库查询，返回结果集

rs = stmt.executeQuery(sql);

}catch(Exception e){

e.printStackTrace();

}

// 返回查询到的结果集

return rs;

}

/**

 * 参数化执行查询语句的方法

 * @param sql 要执行的查询SQL语句

 * @param params 查询SQL语句中的参数列表

 * @return 查询到的结果集

 * */

public static ResultSet query(String sql,Object[] params){

ResultSet rs = null;

try{

// 加载mysql驱动

Driver driver = new Driver();

// 实例化 数据库连接对象

Connection conn = DriverManager.getConnection(

"jdbc:mysql://"+IPAddress+":"+Port+"/"+Database+"?useUnicode=true&characterEncoding=utf8",

Username,Password);

// 获取 命令申明对象

PreparedStatement stmt = conn.prepareStatement(sql);

// 为命令申明对象添加参数

for( int i = 0 ; i <= params.length -
1 ; i++ ){

stmt.setObject(i+1, params[i]);

}

// 发送 查询SQL语句去数据库查询，返回结果集

rs = stmt.executeQuery();

}catch(Exception e){

e.printStackTrace();

}

// 返回查询到的结果集

return rs;

}

 

/**

 * 非参数化执行增加、删除、修改语句的方法

 * @param sql 要执行的增加、删除、修改SQL语句

 * @return 数据库受影响的行数

 * */

public static int execute(String sql){

int rowNum = 0;

try{

// 加载mysql驱动

Driver driver = new Driver();

// 实例化 数据库连接对象

Connection conn = DriverManager.getConnection(

"jdbc:mysql://"+IPAddress+":"+Port+"/"+Database+"?useUnicode=true&characterEncoding=utf8",

Username,Password);

// 获取 命令申明对象

Statement stmt = conn.createStatement();

// 发送 查询SQL语句去数据库查询，返回结果集

rowNum = stmt.executeUpdate(sql);

}catch(Exception e){

e.printStackTrace();

}

// 返回查询到的结果集

return rowNum;

}

 

/**

 * 参数化执行增加、删除、修改语句的方法

 * @param sql 要执行的增加、删除、修改SQL语句

 * @param params参数列表

 * @return 数据库受影响的行数

 * */

public static int execute(String sql,Object[] params){

int rowNum = 0;

try{

// 加载mysql驱动

Driver driver = new Driver();

// 实例化 数据库连接对象

Connection conn = DriverManager.getConnection(

"jdbc:mysql://"+IPAddress+":"+Port+"/"+Database+"?useUnicode=true&characterEncoding=utf8",

Username,Password);

// 获取 命令申明对象

PreparedStatement stmt = conn.prepareStatement(sql);

// 为命令申明对象 添加参数

for( int i = 0 ; i <= params.length -
1; i++ ){

stmt.setObject(i+1, params[i]);

}

// 发送 查询SQL语句去数据库查询，返回结果集

rowNum = stmt.executeUpdate();

}catch(Exception e){

e.printStackTrace();

}

// 返回查询到的结果集

return rowNum;

}

}