1.1 JDBC 入门
1.1.1 JDBC 简介
JDBC 是 Java 平台上的数据库访问标准，几乎所有数据库都支持通过 JDBC 进行访问。
和微软平台的 ODBC 、 ADO 、 ADO.NET 等类似， JDBC 的作用是屏蔽 Java 程序访问各种 不
同数据库操作的差异性。使用 JDBC ，开发人员可以通过同样的程序接口访问不同的数据 库 ，
大大增强了系统的可移植性，同时也简化了开发人员的工作。
需要注意的就是， JDBC 只是一个定义了访问接口的标准规范，针对不同的数据库有 不
同的实现，这些不同的时间被称为对应数据库平台的 “ JDBC 驱动 ” 。不过开发人员无需关
心这些 “ JDBC 驱动 ” 的实现细节，只需在程序初始化的时候指定采用哪个 “ JDBC 驱动 ”
即可，其后的数据库操作完全是标准的 JDBC 操作。
1.1.2 JDBC 驱动
不同的数据库有相对应的不同的 JDBC 驱动，这些 JDBC 驱动通常是以 Jar 包的形式 存
在的，在使用这些驱动的时候需要到相应网站上去下载，下面列出常用数据库的驱动下载 地
址：
MySQL:http://www.mysql.com
Oracle:http://www.oracle.com/
Microsoft SQLServer: http://www.microsoft.com
DB2:http://www.ibm.com
下载完成以后把下载包中的相应的 jar 包添加到 CLASSPATH 中即可。这些 JDBC 驱动
中有一个驱动类是暴露给开发人员的，在使用相应的 JDBC 驱动之前必须首先加载这个驱 动
类，在后边将讲解如何加载这个 JDBC 驱动类，这里只列出这些驱动类的名称：
MySQL: com.mysql.jdbc.Driver
Oracle:oracle.jdbc.driver.OracleDriver
Microsoft SQLServer:com.microsoft.jdbc.sqlserver.SQLServerDriver
DB2:Com.ibm.db2.jdbc.net.DB2Driver
1.1.3 连接字符串
在连接数据库的时候，我们必须告诉 JDBC 关于要连接数据库的具体信息，比如数据 库
服务器的 IP 地址是多少、要连接的数据库名字是什么等等。由于这些连接信息的复杂性以
及在各个不同数据库平台上信息的差异性，因此我们需要把这些信息以字符串的形式发送 给
JDBC 。不同的 JDBC 驱动对字符串的格式要求也是不同的，这是学习 JDBC 的一个难点，
因此下面我们列出这些产用的 JDBC 驱动的连接字符串的格式：
（ 1 ） MySQL:jdbc:mysql:// 数据库的主机名或者 IP 地址 :3306/ 数据库名。例如我要
连接 IP 地址为 192.168.88.88 的 MySQL 服务器上的名字为 afa 的数据库， 那
么正确的连接字符串即为： jdbc:mysql://192.168.88.88:3306/afa 。
（ 2 ） Oracle ： jdbc:oracle:thin:@ 数据库的主机名或者 IP 地址 :1521: 数据库名。例 如
我要连接 IP 地址为 192.168.88.88 的 Oracle 服务器上的名字为 afa 的数据库，
那么正确的连接字符串即为： jdbc:oracle:thin:@192.168.88.88:1521:afa 。
（ 3 ） Microsoft SQLServer ： jdbc:microsoft:sqlserver:// 数据库的主机名或者 IP 地
址 :1433;databaseName= 数据库名。例如我要连接 IP 地址为 192.168.88.88 的
Microsoft SQLServer 服务器上的名字为 afa 的数据库，那么正确的连接字符串即为： sqlserver://192.168.88.88:1433;databaseName=afa 。
（ 4 ） DB2 ： jdbc:db2:// 数据库的主机名或者 IP 地址 :6789/ 数据库名。例如我要连 接
IP 地址为 192.168.88.88 的 DB2 服务器上的名字为 afa 的数据库，那么正确 的
连接字符串即为： jdbc:db2://192.168.88.88:6789/afa 。
注意：如果要连接本机的数据库，则 “ 数据库的主机名或者 IP 地址 ” 一般填为 127.0. 0.1
或者 localhost 即可。
1.1.4 JDBC 的常见概念
连接（ Connection ） ： “ 连接 ” 是建立在 Java 程序和数据库服务器之间的一条通路，在 J ava
程序对数据库进行操作之前必须首先建立一个 “ 连接 ” ，在操作完成后需要关闭 “ 连接 ” 。
语句（ Statement ）： “ 语句 ” 是 Java 程序向数据库服务器发起的操作命令，也就是它代
表了 Java 程序要求数据库服务器执行的 SQL 语句。
结果集（ ResultSet ）： “ 结果集 ” 是数据库服务器执行 “ 语句 ” 的执行结果， Java 程序 可
以通过读取 “ 结果集 ” 来取得 SQL 语句的执行结果。
1.2 JDBC 实战
本节我们将以一个实例介绍如何通过 JDBC 访问 MySQL 数据库。
第一步、启动 MySQL 数据库，在 MySQL 数据库中创建一个数据库 afa ，并创建一张代表 人
员的表 :T_Person ，建表 SQL 语句为：
Create Create Create Create Table Table Table Table T_Person(FId Varchar Varchar Varchar Varchar ( 50 ) not not not not null null null null ,FName Varchar Varchar Varchar Varchar ( 50 ) not not not not
null null null null ,FAge int int int int not not not not null null null null , primary primary primary primary key key key key (FId));
在数据库中插入一条记录：
Insert Insert Insert Insert into into into into T_Person(FId,FName,FAge) values values values values ( '1' , 'tom' , 22 ) ;
第二步、将 MySQL 的 JDBC 驱动 Jar 包放到 CLASSPATH 中；
第三步、建立一个 Java 文件 JDBCTest ：
public public public public class class class class JDBCTest
{
public public public public static static static static void void void void main(String[] args)
{
}
}
第四步、加载 MySQL 的 JDBC 驱动：
Class.forName("com.mysql.jdbc.Driver");
可以看到加载数据库驱动的方法就是： Class.forName( 驱动类名 );
由于加载数据库驱动的时候有可能会发生驱动找不到的异常，因此需要捕捉这个异常并且
将这个异常情况报告给客户，这里我们使用最简单的输出字符串的方式报告：
try try try try
{
Class. forName ( "com.mysql.jdbc.Driver" );
} catch catch catch catch (ClassNotFoundException e)
{
System. out .println( " 数据库驱动找不到！ " );
return return return return ;}
第五步、建立和数据库的连接：
JDBC 中建立和数据库连接的方式非常简单，只要调用 java.sql.DriverManager 类的 静
态方法 getConnection 即可。 getConnection 接受三个字符串类型的参数：第一个参数为 连
接字符串；第二个参数为连接数据库的用户名；第二个参数为连接数据库的密码。
getConnection 的返回值为代表数据库连接的 java.sql.Connection 对象。
在这里，我们要建立 IP 地址为本地（即 localhost ），数据库名称为 afa 的 MySQL 数据库 ，
用户名为 root ，密码为空，因此如下建立连接：
Connection conn = null;
conn = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/afa","root","");
第六步、创建查询 SQL 语句：
建立连接以后就可以创建要执行的 SQL 语句，调用数据库连接的 prepareStatement 方法
即得到代表 SQL 语句的 java.sql.PreparedStatement 对象， prepareStatement 的参数 为
要执行的 SQL 语句。这里要查询 T_Person 表中的所有数据，因此如下创建 SQL 语句对象：
PreparedStatement ps = null;
ps = conn.prepareStatement("select * from T_Person");
第七步、执行 SQL 语句对象：
PreparedStatement 有两个主要的方法： executeQuery 用于执行 Select 等有返回结
果集的 SQL 语句，而 execute 则用于执行 Delete 、 Update 语句等没有返回结果集的 SQL 语句。
这里我们要执行的是 select 语句，因此使用 executeQuery 方法执行：
ResultSet rs = null;
rs = ps.executeQuery();
executeQuery 方法的返回值类型为 java.sql.ResultSet ，它代表执行以后的结果集 ，
读取 ResultSet 即可得到所有的执行结果。
第八步、读取执行结果集
因为执行结果集数量非常大，为了减少资源占用， ResultSet 采用了类似于游标的处理方
式，也就是每次只处理一行结果集，当要处理其他行的时候必须移动游标到相应行上。游标可 以
位于结果集的任何一行，也可以位于结果集的第一行之前的位置，也可以位于结果集的最后一 行
之后的位置。初始状态时游标位于结果集的第一行之前的位置。
ResultSet 中提供了很多移动游标的方法，主要包括：
next() ：向下一行游标。
beforeFirst () ；将游标移动到第一行之前的位置。
afterLast() ：将游标移动到最后一行之后的位置。
first() ：将游标移动到第一行。
last() ：将游标移动到最后一行。
absolute( int row ) ：将游标移动到第 row 行。
所有数据库都支持 next() 方法移动游标，而其他移动游标的方法在很多情况下不被支持，
因此我们通常只使用 next() 方法进行游标控制，而且实际业务中也通常是从上到下逐行进行 结
果集读取，因此 next() 方法一般也就够用了。 next() 方法的返回值表示是否已经到了结果 集
的最后一行之后的位置。
ResultSet 提供了读取当前行中各个列中数据值的方法：
� String getString(String columnName) ：取得列名为 columnName 的值，返回类
型为 String 。� boolean getBoolean(String columnName) ：取得列名为 columnName 的值，返回
类型为 boolean 。
� int getInt(String columnName) ：取得列名为 columnName 的值，返回类型为 int 。
� java.sql.Date getDate(String columnName) ：取得列名为 columnName 的值，
返回类型为 java.sql.Date 。
ResultSet 也提供了根据列索引号来取得值的方法，但是出于程序可读性和可维护性的考
虑，我们不推荐这种使用方式。
讲解了这些基础知识，下面就来显示第七步的执行结果：
while (rs.next())
{
StringBuffer sb = new StringBuffer();
sb.append(" 主键 :").append(rs.getString("FId"))
.append("; 姓名 :").append(rs.getString("FName"))
.append("; 年龄 :").append(rs.getInt("FAge"));
System.out.println(sb);
}
这里使用 ResultSet 的 next() 方法做为循环退出的判断条件。 next() 有两个作用，第 一
个作用是将游标下移一个位置，第二个作用就是判断是否已经处理到最后一行。执行结果如下：
主键 :1; 姓名 :tom; 年龄 :22
第九步、异常处理和资源回收
SQL 执行的过程中有可能发生各种异常，这些异常的类型通常是 SQLException ，我们需
要对这些异常进行处理，这里我们采用最简单的打印异常消息的处理方式：
catch (SQLException e)
{
System.out.println(" 数据库执行过程中发生异常情况 :" +
e.getMessage());
}
执行完数据库操作以后我们需要对数据库连接、 SQL 语句对象、结果集等进行资源关闭等 回
收操作，否则会造成数据库资源泄露。为了保证资源一定会被回收我们将资源回收的工作放到
finally 块中来执行：
finally
{
if (rs != null)
{
try
{
rs.close();
} catch (SQLException e)
{
}
}if (ps != null)
{
try
{
ps.close();
} catch (SQLException e)
{
}
}
if (conn != null)
{
try
{
conn.close();
} catch (SQLException e)
{
}
}
}
需要注意的是，在调用 close 的方法中也有可能抛出 SQLException 异常，为了不影响后
续的资源回收操作，这里通常要对 close 方法抛出的异常捕获。
下面是这个例子的全部代码：
package com.test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class JDBCTest
{
public static void main(String[] args)
{
try
{
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e)
{
System.out.println(" 数据库驱动找不到！ ");
return;}
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try
{
conn = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/afa", "root", "");
ps = conn.prepareStatement("select * from T_Person");
rs = ps.executeQuery();
while (rs.next())
{
StringBuffer sb = new StringBuffer();
sb.append(" 主键 :").append(rs.getString("FId")).append(" ;
姓名 :")
.append(rs.getString("FName")).append("; 年
龄 :").append(
rs.getInt("FAge"));
System.out.println(sb);
}
} catch (SQLException e)
{
System.out.println(" 数据库执行过程中发生异常情况 :" +
e.getMessage());
} finally
{
if (rs != null)
{
try
{
rs.close();
} catch (SQLException e)
{
}
}
if (ps != null)
{
try
{
ps.close();
} catch (SQLException e)
{}
}
if (conn != null)
{
try
{
conn.close();
} catch (SQLException e)
{
}
}
}
}
}
对应的 Java 工程为： JDBCDemo.rar
1.3 JDBC 其他问题
1.3.1 执行没有结果集的 SQL
ps = conn.prepareStatement( " Update T_Person set F a ge=20 " );
rs = ps.execute();
1.3.2 参数化 SQL
在执行 SQL 的时候经常需要拼一些查询条件，比如查询名称等于用户输入的 name 值的人员 ，
我们可以采用拼 SQL 语句的方法来进行：
ps = conn.prepareStatement( "select * from T_Person where
F n ame= ’ " +name+ ”’” );
rs = ps.executeQuery();
这样有可能会被人采用注入 SQL 的方式进行攻击，而且也会有执行效率的问题。更好的方 式
是使用参数化 SQL 来解决。参数化 SQL 将 SQL 语句中需要在运行期才能确定的参数用？表示，并
且在运行时再通过 JDBC 提供的方法为这些参数赋值。
比如我们要查询名称等于用户输入的 name 值的人员，只要如下编写即可：
package com.test;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;import java.sql.ResultSet;
import java.sql.SQLException;
public class JDBCParamTest
{
public static void main(String[] args)
{
// 从控制台中读取用户输入的参数
System.out.print(" 请输入要查询的用户的名称： ");
BufferedReader br = new BufferedReader(new
InputStreamReader(System.in));
String name = "";
try
{
name = br.readLine();
} catch (IOException e)
{
e.printStackTrace();
return;
}
try
{
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e)
{
System.out.println(" 数据库驱动找不到！ ");
return;
}
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try
{
conn = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/afa", "root", "");
pspspsps = = = = conn.prepareStatement("select conn.prepareStatement("select conn.prepareStatement("select conn.prepareStatement("select * * * * from from from from T_Person T_Person T_Person T_Person where where where where
FName=?"); FName=?"); FName=?"); FName=?");
ps.setString(1, ps.setString(1, ps.setString(1, ps.setString(1, name); name); name); name);
rs = ps.executeQuery();
while (rs.next())
{
StringBuffer sb = new StringBuffer();sb.append(" 主键 :").append(rs.getString("FId")).append(" ;
姓名 :")
.append(rs.getString("FName")).append("; 年
龄 :").append(
rs.getInt("FAge"));
System.out.println(sb);
}
} catch (SQLException e)
{
System.out.println(" 数据库执行过程中发生异常情况 :" +
e.getMessage());
} finally
{
if (rs != null)
{
try
{
rs.close();
} catch (SQLException e)
{
}
}
if (ps != null)
{
try
{
ps.close();
} catch (SQLException e)
{
}
}
if (conn != null)
{
try
{
conn.close();
} catch (SQLException e)
{
}}
}
}
}
代码一开始从控制台中读取用户输入的值，并将输入的值赋值给字符串 name 。从控制台中
读取用户输入的值的代码涉及到了流操作，如果你目前不熟悉也无所谓，只要知道这段代码的 作
用就可以了。
这段代码的核心就是红色粗体字部分：
pspspsps = = = = conn.prepareStatement("select conn.prepareStatement("select conn.prepareStatement("select conn.prepareStatement("select * * * * from from from from T_Person T_Person T_Person T_Person where where where where
FName=?"); FName=?"); FName=?"); FName=?");
ps.setString(1, ps.setString(1, ps.setString(1, ps.setString(1, name); name); name); name);
这里采用了参数化的 SQL ： "select "select "select "select * * * * from from from from T_Person T_Person T_Person T_Person where where where where FName=?" FName=?" FName=?" FName=?" ， 可以看到采
用？为 F n ame 的值预留了位置；接着调用 ps 的 setString 方法为这个参数赋值，注意在这里 参
数的索引号是从 1 开始的，而非通常的 0 ，这是初学者经常犯错误的地方。还可以为参数赋予其
他类型的参数值，比如赋整数类型的 setInt 、赋日期类型的 setDate 等。
还需要特别注意的就是参数只适用于 where 语句以及计算列等部分，而不能将表名、字段
名等部分也用参数代替。比如根据用户输入的表名来查询某个表，很多初学者会这么写 ( 示例 代
码 ) ：
pspspsps = = = = conn.prepareStatement("select conn.prepareStatement("select conn.prepareStatement("select conn.prepareStatement("select * * * * from from from from ? ? ? ? "); "); "); ");
ps.setString(1, ps.setString(1, ps.setString(1, ps.setString(1, “ “ “ “ T_Person T_Person T_Person T_Person ” ” ” ” ););););
这是不对的，在运行的时候会报语法错误。