[引言]
我们在学习Java编程时，连接数据库技术（JDBC）是一项必备技能，我们经常需要读取或操作持久性存储的结构化数据。那么现在开始，小博老师就开始为大家讲解JDBC中的常用操作技术，今天我们来了解JDBC中对数据库常用操作类的封装。
[步骤阅读一]项目添加jdbc驱动
我们想要在Java项目中使用JDBC的功能，就必须要为项目添加JDBC驱动文件（jar），我们一般可以在各种数据库产品的官网上找到它们，例如mysql数据库则可以在：http://www.mysql.com/products/connector/中找到驱动文件。
为项目添加了JDBC驱动文件（jar文件）后，我们可以看到项目的Referenced Library中结构如下：
[步骤阅读二]数据库操作类的封装
接下来，我们就进入了本文的重点了，对数据中数据表记录进行增、删、改、查的操作是很频繁的，因此我们在开发过程中，经常会对此类操作进行封装。今天小博老师就为大家演示一段常见的数据库操作封装方式，核心代码如下：
/**
* JDBC连接MySQL数据库的操作类
* */
publicclassMySQLDBHelper {
// 静态变量 存放所需连接MySQL数据库的参数
// 当前案例演示直接赋值 通常需要编写配置文件
// MySQL数据库所在的Ip地址
privatestaticStringIPAddress="127.0.0.1";
// MySQL数据库的端口号
privatestaticintPort= 3306;
// MySQL数据库的身份登录名称
privatestaticStringUsername="root";
// MySQL数据库的身份登录密码
privatestaticStringPassword="";
// 要操作的MySQL数据库的数据表名称
privatestaticStringDatabase="bwf";
/**
* 非参数化执行查询语句的方法
*@paramsql 要执行的查询SQL语句
*@return查询到的结果集
* */
publicstaticResultSet query(Stringsql){
ResultSetrs=null;
try{
// 加载mysql驱动
Driverdriver=newDriver();
// 实例化 数据库连接对象
Connectionconn= DriverManager.getConnection(
"jdbc:mysql://"+IPAddress+":"+Port+"/"+Database+"?useUnicode=true&characterEncoding=utf8",
Username,Password);
// 获取 命令申明对象
Statementstmt=conn.createStatement();
// 发送 查询SQL语句去数据库查询，返回结果集
rs=stmt.executeQuery(sql);
}catch(Exceptione){
e.printStackTrace();
}
// 返回查询到的结果集
returnrs;
}
/**
* 参数化执行查询语句的方法
*@paramsql 要执行的查询SQL语句
*@paramparams 查询SQL语句中的参数列表
*@return查询到的结果集
* */
publicstaticResultSet query(Stringsql,Object[]params){
ResultSetrs=null;
try{
// 加载mysql驱动
Driverdriver=newDriver();
// 实例化 数据库连接对象
Connectionconn= DriverManager.getConnection(
"jdbc:mysql://"+IPAddress+":"+Port+"/"+Database+"?useUnicode=true&characterEncoding=utf8",
Username,Password);
// 获取 命令申明对象
PreparedStatementstmt=conn.prepareStatement(sql);
// 为命令申明对象添加参数
for(inti= 0 ;i<=params.length- 1 ;i++ ){
stmt.setObject(i+1,params[i]);
}
// 发送 查询SQL语句去数据库查询，返回结果集
rs=stmt.executeQuery();
}catch(Exceptione){
e.printStackTrace();
}
// 返回查询到的结果集
returnrs;
}
/**
* 非参数化执行增加、删除、修改语句的方法
*@paramsql 要执行的增加、删除、修改SQL语句
*@return数据库受影响的行数
* */
publicstaticintexecute(Stringsql){
introwNum= 0;
try{
// 加载mysql驱动
Driverdriver=newDriver();
// 实例化 数据库连接对象
Connectionconn= DriverManager.getConnection(
"jdbc:mysql://"+IPAddress+":"+Port+"/"+Database+"?useUnicode=true&characterEncoding=utf8",
Username,Password);
// 获取 命令申明对象
Statementstmt=conn.createStatement();
// 发送 查询SQL语句去数据库查询，返回结果集
rowNum=stmt.executeUpdate(sql);
}catch(Exceptione){
e.printStackTrace();
}
// 返回查询到的结果集
returnrowNum;
}
/**
* 参数化执行增加、删除、修改语句的方法
*@paramsql 要执行的增加、删除、修改SQL语句
*@paramparams参数列表
*@return数据库受影响的行数
* */
publicstaticintexecute(Stringsql,Object[]params){
introwNum= 0;
try{
// 加载mysql驱动
Driverdriver=newDriver();
// 实例化 数据库连接对象
Connectionconn= DriverManager.getConnection(
"jdbc:mysql://"+IPAddress+":"+Port+"/"+Database+"?useUnicode=true&characterEncoding=utf8",
Username,Password);
// 获取 命令申明对象
PreparedStatementstmt=conn.prepareStatement(sql);
// 为命令申明对象 添加参数
for(inti= 0 ;i<=params.length- 1;i++ ){
stmt.setObject(i+1,params[i]);
}
// 发送 查询SQL语句去数据库查询，返回结果集
rowNum=stmt.executeUpdate();
}catch(Exceptione){
e.printStackTrace();
}
// 返回查询到的结果集
returnrowNum;
}
}
