JDBC - 快速指南

什么是JDBC？

JDBC代表J ava D ata b ase C onnectivity，它是Java编程语言和各种数据库之间独立于数据库的连接的标准Java API。

JDBC库包含通常与数据库使用相关的每个任务的API:

建立与数据库的连接
创建SQL或MySQL语句
在数据库中执行SQL或MySQL查询
查看和修改结果记录

Pre-Requisite:

您需要对以下两个主题有很好的理解才能学习JDBC:

JDBC - 环境设置:

确保您已完成以下设置:

核心JAVA安装
SQL或MySQL数据库安装

除此之外，您还需要设置一个用于项目的数据库。假设这是EMP，并且您已在同一数据库中的表Employees上创建。

创建JDBC应用程序:

构建JDBC应用程序涉及六个步骤，我将在本教程中简要介绍:

导入包:

这要求您包含包含数据库编程所需的JDBC类的包。通常，使用import java.sql。*就足够了，如下所示:

//STEP 1. Import required packages
import java.sql.*;

注册JDBC驱动程序:

这要求您初始化驱动程序，以便可以打开与数据库的通信通道。以下是实现此目的的代码段:

//STEP 2: Register JDBC driver
Class.forName("com.mysql.jdbc.Driver");

打开连接:

这需要使用DriverManager.getConnection（）方法创建一个Connection对象，该对象表示与数据库的物理连接，如下所示:

//STEP 3: Open a connection
//  Database credentials
static final String USER = "username";
static final String PASS = "password";
System.out.println("Connecting to database...");
conn = DriverManager.getConnection(DB_URL,USER,PASS);

执行查询:

这需要使用Statement或PreparedStatement类型的对象来构建和向数据库提交SQL语句，如下所示:

//STEP 4: Execute a query
System.out.println("Creating statement...");
stmt = conn.createStatement();
String sql;
sql = "SELECT id, first, last, age FROM Employees";
ResultSet rs = stmt.executeQuery(sql);

如果需要SQL UPDATE，INSERT或DELETE语句，则需要以下代码片段:

//STEP 4: Execute a query
System.out.println("Creating statement...");
stmt = conn.createStatement();
String sql;
sql = "DELETE FROM Employees";
ResultSet rs = stmt.executeUpdate(sql);

从结果集中提取数据:

如果从数据库中提取数据，则需要执行此步骤。您可以使用适当的ResultSet.getXXX（）方法从结果集中检索数据，如下所示:

//STEP 5: Extract data from result set
while(rs.next()){
    //Retrieve by column name
    int id  = rs.getInt("id");
    int age = rs.getInt("age");
    String first = rs.getString("first");
    String last = rs.getString("last");
    //Display values
    System.out.print("ID: " + id);
    System.out.print(", Age: " + age);
    System.out.print(", First: " + first);
    System.out.println(", Last: " + last);
}

清理环境:

您应该显式关闭所有数据库资源，而不是依赖于JVM的垃圾收集，如下所示:

//STEP 6: Clean-up environment
rs.close();
stmt.close();
conn.close();

第一个JDBC程序:

基于上述步骤，我们可以使用以下整合的示例代码，我们可以在编写JDBC代码时将其用作模板:

此示例代码是基于环境章节中完成的环境和数据库设置编写的。

//STEP 1. Import required packages
import java.sql.*;
public class FirstExample {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost/EMP";
   //  Database credentials
   static final String USER = "username";
   static final String PASS = "password";
   public static void main(String[] args) {
   Connection conn = null;
   Statement stmt = null;
   try{
      //STEP 2: Register JDBC driver
      Class.forName("com.mysql.jdbc.Driver");
      //STEP 3: Open a connection
      System.out.println("Connecting to database...");
      conn = DriverManager.getConnection(DB_URL,USER,PASS);
      //STEP 4: Execute a query
      System.out.println("Creating statement...");
      stmt = conn.createStatement();
      String sql;
      sql = "SELECT id, first, last, age FROM Employees";
      ResultSet rs = stmt.executeQuery(sql);
      //STEP 5: Extract data from result set
      while(rs.next()){
         //Retrieve by column name
         int id  = rs.getInt("id");
         int age = rs.getInt("age");
         String first = rs.getString("first");
         String last = rs.getString("last");
         //Display values
         System.out.print("ID: " + id);
         System.out.print(", Age: " + age);
         System.out.print(", First: " + first);
         System.out.println(", Last: " + last);
      }
      //STEP 6: Clean-up environment
      rs.close();
      stmt.close();
      conn.close();
   }catch(SQLException se){
      //Handle errors for JDBC
      se.printStackTrace();
   }catch(Exception e){
      //Handle errors for Class.forName
      e.printStackTrace();
   }finally{
      //finally block used to close resources
      try{
         if(stmt!=null)
            stmt.close();
      }catch(SQLException se2){
      }// nothing we can do
      try{
         if(conn!=null)
            conn.close();
      }catch(SQLException se){
         se.printStackTrace();
      }//end finally try
   }//end try
   System.out.println("Goodbye!");
}//end main
}//end FirstExample

现在让我们编译上面的例子如下:

C:\>javac FirstExample.java
C:\>

运行FirstExample ，它会产生以下结果:

C:\>java FirstExample
Connecting to database...
Creating statement...
ID: 100, Age: 18, First: Zara, Last: Ali
ID: 101, Age: 25, First: Mahnaz, Last: Fatma
ID: 102, Age: 30, First: Zaid, Last: Khan
ID: 103, Age: 28, First: Sumit, Last: Mittal
C:\>

SQLException Methods:

SQLException可以在驱动程序和数据库中发生。发生此类异常时，SQLException类型的对象将传递给catch子句。

传递的SQLException对象具有以下可用于检索有关异常的其他信息的方法:

方法	描述
getErrorCode（）	获取与异常关联的错误号。
getMessage（）	获取驱动程序处理的错误的JDBC驱动程序错误消息，或获取Oracle错误编号和数据库错误消息。
getSQLState（）	获取XOPEN SQLstate字符串。对于JDBC驱动程序错误，此方法不返回任何有用信息。对于数据库错误，返回五位XOPEN SQLstate代码。此方法可以返回null。
getNextException（）	获取异常链中的下一个Exception对象。
printStackTrace（）	将当前异常或throwable及其回溯打印到标准错误流。
printStackTrace（PrintStream s）	将此throwable及其回溯打印到您指定的打印流。
printStackTrace（PrintWriter w）	将此throwable及其回溯打印到您指定的打印编写器。

通过利用Exception对象提供的信息，您可以捕获异常并适当地继续您的程序。以下是try块的一般形式:

try {
   // Your risky code goes between these curly braces!!!
}
catch(Exception ex) {
   // Your exception handling code goes between these 
   // curly braces, similar to the exception clause 
   // in a PL/SQL block.
}
finally {
   // Your must-always-be-executed code goes between these 
   // curly braces. Like closing database connection.
}

JDBC - 数据类型:

下表总结了在调用PreparedStatement或CallableStatement对象的setXXX（）方法或ResultSet.updateXXX（）方法时，Java数据类型转换为的默认JDBC数据类型。

SQL	JDBC/Java的	的setXXX	updateXXX
VARCHAR	java.lang.String	setString	updateString
CHAR	java.lang.String	setString	updateString
LONGVARCHAR	java.lang.String	setString	updateString
BIT	boolean	setBoolean	updateBoolean
NUMERIC	java.math.BigDecimal	setBigDecimal	updateBigDecimal
TINYINT	byte	setByte	updateByte
SMALLINT	short	setShort	updateShort
INTEGER	int	setInt	updateInt
BIGINT	long	setLong	updateLong
REAL	float	setFloat	updateFloat
FLOAT	float	setFloat	updateFloat
DOUBLE	double	setDouble	updateDouble
VARBINARY	byte []	setBytes	updateBytes
BINARY	byte []	setBytes	updateBytes
DATE	java.sql.Date	setDate	updateDate
TIME	java.sql.Time	setTime	updateTime
TIMESTAMP	java.sql.Timestamp	setTimestamp	updateTimestamp
CLOB	java.sql.Clob	setClob	updateClob
BLOB	java.sql.Blob	setBlob	updateBlob
ARRAY	java.sql.Array	setARRAY	updateARRAY
REF	java.sql.Ref	SetRef	updateRef
STRUCT	java.sql.Struct	SetStruct	updateStruct

JDBC 3.0增强了对BLOB，CLOB，ARRAY和REF数据类型的支持。 ResultSet对象现在具有updateBLOB（），updateCLOB（），updateArray（）和updateRef（）方法，使您可以直接操作服务器上的相应数据。

setXXX（）和updateXXX（）方法使您可以将特定Java类型转换为特定的JDBC数据类型。方法setObject（）和updateObject（）使您可以将几乎任何Java类型映射到JDBC数据类型。

ResultSet对象为每种数据类型提供相应的getXXX（）方法以检索列值。每种方法都可以使用列名或其序号位置。

SQL	JDBC/Java的	的setXXX	的getXXX
VARCHAR	java.lang.String	setString	getString
CHAR	java.lang.String	setString	getString
LONGVARCHAR	java.lang.String	setString	getString
BIT	boolean	setBoolean	getBoolean
NUMERIC	java.math.BigDecimal	setBigDecimal	getBigDecimal
TINYINT	byte	setByte	getByte
SMALLINT	short	setShort	getShort
INTEGER	int	setInt	getInt
BIGINT	long	setLong	getLong
REAL	float	setFloat	getFloat
FLOAT	float	setFloat	getFloat
DOUBLE	double	setDouble	getDouble
VARBINARY	byte []	setBytes	getBytes
BINARY	byte []	setBytes	getBytes
DATE	java.sql.Date	setDate	getDate
TIME	java.sql.Time	setTime	getTime
TIMESTAMP	java.sql.Timestamp	setTimestamp	getTimestamp
CLOB	java.sql.Clob	setClob	getClob
BLOB	java.sql.Blob	setBlob	getBlob
ARRAY	java.sql.Array	setARRAY	getARRAY
REF	java.sql.Ref	SetRef	getRef
STRUCT	java.sql.Struct	SetStruct	getStruct

JDBC - 批处理:

批处理允许您将相关的SQL语句分组到批处理中，并通过一次调用数据库来提交它们。

当您一次向数据库发送多个SQL语句时，可以减少通信开销，从而提高性能。

JDBC驱动程序不需要支持此功能。您应该使用DatabaseMetaData.supportsBatchUpdates()方法来确定目标数据库是否支持批量更新处理。如果JDBC驱动程序支持此功能，则该方法返回true。
Statement, PreparedStatement,和CallableStatement的addBatch()方法用于向批处理添加单个语句。 executeBatch()用于开始执行组合在一起的所有语句。
executeBatch()返回一个整数数组，数组的每个元素表示相应更新语句的更新计数。
就像您可以向批处理中添加语句进行处理一样，您可以使用clearBatch()方法删除它们。此方法删除使用addBatch（）方法添加的所有语句。但是，您无法有选择地选择要删除的语句。

JDBC - 流数据:

PreparedStatement对象能够使用输入和输出流来提供参数数据。这使您可以将整个文件放入可以容纳大值的数据库列，例如CLOB和BLOB数据类型。

有以下方法可用于流式传输数据:

setAsciiStream():此方法用于提供大的ASCII值。
setCharacterStream():此方法用于提供大型UNICODE值。
setBinaryStream():此方法用于提供大型二进制值。

除了参数占位符之外，setXXXStream（）方法还需要一个额外的参数，即文件大小。此参数通知驱动程序应使用流将数据发送到数据库的数量。

有关所有这些概念的详细信息，您需要完成完整的教程。

<上一篇.JDBC - 问题与解答( Questions and Answers)

JDBC - 有用的资源.下一篇>

JDBC - 教程

JDBC - 介绍

JDBC - SQL 语法

JDBC - 环境

JDBC - 示例代码( Sample Code)

JDBC - 驱动程序类型( Driver Types)

JDBC - 连接( Connections)

JDBC - 声明

JDBC - 结果集( Result Sets)

JDBC - 数据类型

JDBC - 事务( Transactions)

JDBC - 事务( Transactions)

JDBC - 批处理( Batch Processing)

JDBC - 存储过程( Stored Procedure)

JDBC - 流数据( Streaming Data)

JDBC - 创建数据库( Create Database)

JDBC - 选择数据库( Select Database)

JDBC - 删除数据库( Drop Database)

JDBC - 创建表( Create Tables)

JDBC - 删除表( Drop Tables)

JDBC - 插入记录( Insert Records)

JDBC - 选择记录( Select Records)

JDBC - 更新记录( Update Records)

JDBC - 删除记录( Delete Records)

JDBC - WHERE 子句

JDBC - Like 子句

JDBC - 排序数据( Sorting Data)

JDBC - 问题与解答( Questions and Answers)