JDBC-文档

Love The Way You Lie 2021-12-20 12:59 197阅读 0赞

# **第1章概述** #

在Java中，数据库存取技术可分为如下几类：

l JDBC直接访问数据库

l JDO技术（Java Data Object）

l 第三方O/R工具，如Hibernate, Mybatis 等

JDBC是java访问数据库的基石，JDO, Hibernate等只是更好的封装了JDBC。

## **1****、什么是****JDBC** ##

JDBC(是一个**独立于特定数据库管理系统（DBMS）、通用的SQL数据库存取和操作的公共接口**（一组API），定义了用来访问数据库的标准Java类库，使用这个类库可以以一种标准的方法、方便地访问数据库资源

JDBC为访问不同的数据库提供了一种**统一的途径**，为开发者屏蔽了一些细节问题。

JDBC的目标是使Java程序员使用JDBC可以连接任何**提供了JDBC驱动程序**的数据库系统，这样就使得程序员无需对特定的数据库系统的特点有过多的了解，从而大大简化和加快了开发过程。

如果没有JDBC，那么Java程序访问数据库时是这样的：

改装：

实际上：

**结论：**

JDBC是SUN公司提供一套用于数据库操作的接口API，Java程序员只需要面向这套接口编程即可。

不同的数据库厂商，需要针对这套接口，提供不同实现。不同的实现的集合，即为不同数据库的驱动。

## **2、****JDBC API** ##

JDBC API是一系列的接口，它统一和规范了应用程序与数据库的连接、执行SQL语句，并到得到返回结果等各类操作。声明在java.sql与javax.sql包中。

## **3、****JDBC****程序编写步骤** ##

# **第2章 使用****JDBC API** #

## **1****、引入****JDBC****驱动程序** ##

### **1.1如何获取****JDBC****驱动程序** ###

驱动程序由数据库提供商提供下载。

MySQL的驱动下载地址：http://dev.mysql.com/downloads/

### **1.2如何在****Java Project****项目应用中添加数据库驱动****jar** ###

**注意：**如果是Dynamic Web Project（动态的web项目）话，则是把驱动jar放到WebContent（有的开发工具叫WebRoot）目录中的WEB-INF目录中的lib目录下即可

## **2、加载并注册驱动** ##

加载并注册驱动：

加载驱动，把驱动类加载到内存

注册驱动，把驱动类的对象交给DriverManager管理，用于后面创建连接等使用。

### **2.1 Driver接口** ###

Java.sql.Driver 接口是所有 JDBC 驱动程序需要实现的接口。这个接口是提供给数据库厂商使用的，不同数据库厂商提供不同的实现。

l MySQL：com.mysql.jdbc.Driver

l SQLServer：com.microsoft.sqlserver.jdbc.SQLServerDriver

l Oracle：oracle.jdbc.driver.OracleDriver

### **2.2编写加载与注册驱动的代码** ###

#### **1）直接创建****Driver****接口的实现类对象** ####

例如：

<table> 
 <tbody> 
 <tr> 
 <td> Driver driver = new com.mysql.jdbc.Driver(); //因为与mysql驱动包中的类发生直接依赖，所以这样可移植性不够好 </td> 
 </tr> 
 </tbody> 
</table>

#### **2）****DriverManager****类的****registerDriver()** ####

在实际开发中，程序中不直接去访问实现了 Driver 接口的类，而是由驱动程序管理器类(去调用这些Driver实现。

DriverManager 类是驱动程序管理器类，负责管理驱动程序。

通常不用显式调用 DriverManager 类的 registerDriver() 方法来注册驱动程序类的实例。

<table> 
 <tbody> 
 <tr> 
 <td> //DriverManager.registerDriver()方式注册驱动，还是依赖 DriverManager.registerDriver(new com.mysql.jdbc.Driver()); </td> 
 </tr> 
 </tbody> 
</table>

#### **3）****Class.forName()****或****ClassLoader****对象****.loadClass()** ####

因为 Driver 接口的驱动程序类都包含了静态代码块，在这个静态代码块中，会调用 DriverManager.registerDriver() 方法来注册自身的一个实例，所以可以换一种方式来加载驱动。（即只要想办法让驱动类的这段静态代码块执行即可注册驱动类，而要让这段静态代码块执行，只要让该类被类加载器加载即可）

调用 Class 类的静态方法 forName()，向其传递要加载的 JDBC 驱动的类名

<table> 
 <tbody> 
 <tr> 
 <td> //1、通过反射，加载与注册驱动类，解耦合（不直接依赖） Class.forName("com.mysql.jdbc.Driver"); </td> 
 </tr> 
 <tr> 
 <td> //2、通过类加载器加载驱动类，解耦合（不直接依赖） ClassLoader.getSystemClassLoader().loadClass("com.mysql.jdbc.Driver"); </td> 
 </tr> 
 </tbody> 
</table>

#### **4）服务提供者框架（例如：****JDBC****的驱动程序）自动注册（有版本要求）** ####

符合JDBC 4.0规范的驱动程序包含了一个文件META-INF/services/java.sql.Driver，在这个文件中提供了JDBC驱动实现的类名。例如：mysql-connector-java-5.1.40-bin.jar文件中就可以找到java.sql.Driver文件，用文本编辑器打开文件就可以看到：com.mysql.jdbc.Driver类。

JVM的服务提供者框架在启动应用时就会注册服务，例如：MySQL的JDBC驱动就会被注册，而原代码中的Class.forName("com.mysql.jdbc.Driver")仍然可以存在，但是不会起作用。

**但是注意mysql-connector-java-5.0.8-bin.jar版本的****jar****中没有，如下**

## **3****、获取数据库链接** ##

可以通过 DriverManager 类建立到数据库的连接Connection：

DriverManager 试图从**已注册**的 JDBC 驱动程序集中选择一个**适当的**驱动程序。

l public static Connection getConnection(String url)

l public static Connection getConnection(String url,String user, String password)

l public static Connection getConnection(String url,Properties info)

### **3.1 JDBC URL** ###

JDBC URL 用于标识一个被注册的驱动程序，驱动程序管理器通过这个 URL 选择正确的驱动程序，从而建立到数据库的连接。

JDBC URL的标准由三部分组成，各部分间用冒号分隔。

jdbc:<子协议>:<子名称>

l 协议：JDBC URL中的协议总是jdbc

l 子协议：子协议用于标识一个数据库驱动程序

l 子名称：一种标识数据库的方法。子名称可以依不同的子协议而变化，用子名称的目的是为了**定位数据库**提供足够的信息

例如：

l MySQL的连接URL编写方式：

n jdbc:mysql://主机名称:mysql服务端口号/数据库名称?参数=值&参数=值

n jdbc:mysql://localhost:3306/testdb

n jdbc:mysql://localhost:3306/testdb**?useUnicode=true&characterEncoding=utf8**

n jdbc:mysql://localhost:3306/testdb?user=root&password=123456

l Oracle9i:

n jdbc:oracle:thin:@主机名称:oracle服务端口号:数据库名称

n jdbc:oracle:thin:@localhost:1521:testdb

l SQLServer

n jdbc:sqlserver://主机名称:sqlserver服务端口号:DatabaseName=数据库名称

n jdbc:sqlserver://localhost:1433:DatabaseName=testdb

<table> 
 <tbody> 
 <tr> 
 <td> //1、加载与注册驱动 Class.forName("com.mysql.jdbc.Driver"); //2、获取数据库连接 String url = "jdbc:mysql://localhost:3306/test"; Connection conn = DriverManager.getConnection(url, "root", "root"); &nbsp; //硬编码 </td> 
 </tr> 
 </tbody> 
</table>

### **3.2 jdbc.properties** ###

在**src下**建立文件jdbc.properties，当然也可以是其他名字，只不过这里为了见名知意取这个名

通常至少应该包括 "user" 和 "password" 属性

<table> 
 <tbody> 
 <tr> 
 <td> #key=value driver=com.mysql.jdbc.Driver url=jdbc:mysql://localhost:3306/test user=root password=root </td> 
 </tr> 
 <tr> 
 <td> public static void main(String[] args) throws Exception { //预先加载配置文件jdbc.properties，把配置信息封装到Properties对象中 Properties pro = new Properties(); &nbsp; //ClassLoader只能加载类路径下的资源文件 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//如果不是类路径下，只能使用FileInputStream pro.load(ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties")); //1、加载与注册驱动 Class.forName(pro.getProperty("driver")); //2、获取数据库连接 //&nbsp;Connection conn = DriverManager.getConnection(pro.getProperty("url"), pro); Connection conn = DriverManager.getConnection(pro.getProperty("url"), pro.getProperty("user"),pro.getProperty("password")); System.out.println(conn); } &nbsp; //解决了硬编码的问题 </td> 
 </tr> 
 </tbody> 
</table>

## **4****、操作或访问数据库** ##

数据库连接被用于向数据库服务器发送命令和 SQL 语句，并接受数据库服务器返回的结果。

其实一个数据库连接就是一个Socket连接。

在 java.sql 包中有 3 个接口分别定义了对数据库的调用的不同方式：

l Statement：用于执行静态 SQL 语句并返回它所生成结果的对象。

n PrepatedStatement：SQL 语句被预编译并存储在此对象中，然后可以使用此对象多次高效地执行该语句。

u CallableStatement：用于执行 SQL 存储过程

### **4.1****Statement** ###

通过调用 Connection 对象的 createStatement() 方法创建该对象

该对象用于执行静态的 SQL 语句，并且返回执行结果

Statement 接口中定义了下列方法用于执行 SQL 语句：

int excuteUpdate(String sql)：执行更新操作INSERT、UPDATE、DELETE

ResultSet excuteQuery(String sql)：执行查询操作SELECT

### **4.2 ResultSet** ###

通过调用 Statement 对象的 excuteQuery() 方法创建该对象

ResultSet 对象以逻辑表格的形式封装了执行数据库操作的结果集，ResultSet 接口由数据库厂商实现

ResultSet 对象维护了一个指向当前数据行的**游标**，初始的时候，游标在第一行之前，可以通过 ResultSet 对象的 next() 方法移动到下一行

ResultSet 接口的常用方法：

l boolean next()

l getXxx(String columnLabel)：columnLabel使用 SQL AS 子句指定的列标签。如果未指定 SQL AS 子句，则标签是列名称

l getXxx(int index) :索引从1开始

l …

#### **java类型与****SQL****类型的对应关系** ####

## **5****、释放资源** ##

Connection、Statement、ResultSet都是应用程序和数据库服务器的连接资源，使用后一定要关闭，可以在finally中关闭

**未关闭后果：**

<table> 
 <tbody> 
 <tr> 
 <td> @Test public void testConnection4()throws Exception{ Properties pro = new Properties(); pro.load(ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties")); String url = pro.getProperty("url"); //my.ini中max_connections=10 for (int i = 0; i &lt; 15; i++) { Connection conn = DriverManager.getConnection(url,pro); System.out.println(conn); //没有关闭，资源一直没有释放 } } </td> 
 </tr> 
 </tbody> 
</table>

## **6、增、删、改、查示例代码** ##

<table> 
 <tbody> 
 <tr> 
 <td> package com.atguigu.statement; &nbsp; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; &nbsp; import org.junit.Test; &nbsp; &nbsp; public class TestStatement { &nbsp; @Test public void testAdd()throws Exception{ String sql = "INSERT INTO dept(dname,description) VALUES('财务部','负责发钱工作')"; String url = "jdbc:mysql://localhost:3306/1221db"; String user = "root"; String password = "123456"; Connection conn = DriverManager.getConnection(url, user, password); Statement st = conn.createStatement(); int len = st.executeUpdate(sql);//把insert,update,delete都用这个方法 if(len&gt;0){ System.out.println("添加成功"); }else{ System.out.println("添加失败"); } st.close(); conn.close(); } &nbsp; @Test public void testUpdate()throws Exception{ String sql = "UPDATE dept SET description = '负责发工资、社保、公积金工作' WHERE dname ='财务部'"; String url = "jdbc:mysql://localhost:3306/1221db"; String user = "root"; String password = "123456"; Connection conn = DriverManager.getConnection(url, user, password); Statement st = conn.createStatement(); int len = st.executeUpdate(sql);//把insert,update,delete都用这个方法 if(len&gt;0){ System.out.println("修改成功"); }else{ System.out.println("修改失败"); } st.close(); conn.close(); } &nbsp; @Test public void testDelete()throws Exception{ String sql = "DELETE FROM dept WHERE did =2"; String url = "jdbc:mysql://localhost:3306/1221db"; String user = "root"; String password = "123456"; Connection conn = DriverManager.getConnection(url, user, password); Statement st = conn.createStatement(); int len = st.executeUpdate(sql);//把insert,update,delete都用这个方法 if(len&gt;0){ System.out.println("删除成功"); }else{ System.out.println("删除失败"); } st.close(); conn.close(); } &nbsp; @Test public void testSelect()throws Exception{ String sql = "SELECT * FROM dept"; String url = "jdbc:mysql://localhost:3306/1221db"; String user = "root"; String password = "123456"; Connection conn = DriverManager.getConnection(url, user, password); Statement st = conn.createStatement(); ResultSet rs = st.executeQuery(sql);//select语句用query方法 while(rs.next()){//是否有下一行 //取这一行的单元格 int id = rs.getInt(1); String name = rs.getString(2); String desc = rs.getString(3); System.out.println(id+"\t" + name + "\t" + desc); } rs.close(); st.close(); conn.close(); } &nbsp; @Test public void testSelect2()throws Exception{ String sql = "SELECT did,dname FROM dept"; String url = "jdbc:mysql://localhost:3306/1221db"; String user = "root"; String password = "123456"; Connection conn = DriverManager.getConnection(url, user, password); Statement st = conn.createStatement(); ResultSet rs = st.executeQuery(sql);//select语句用query方法 while(rs.next()){//是否有下一行 //取这一行的单元格 int id = rs.getInt("did"); String name = rs.getString("dname"); System.out.println(id+"\t" + name); } rs.close(); st.close(); conn.close(); } } </td> 
 </tr> 
 </tbody> 
</table>

# **第3章** **JDBC****工具类** #

## **3.1****使用****JDBC API****操作数据库的基本步骤** ##

分析使用JDBC API操作数据库，进行CRUD基本步骤都相似。

1、加载和注册驱动

2、获取数据库连接

3、准备操作执行SQL的Statement对象

4、执行SQL

（1）调用Statement对象的executeUpdate(String sql)执行SQL语句进行插入、修改、删除操作

（2）调用Statement对象的executeQuery(String sql)执行SQL语句进行查询操作

5、处理执行结果

（1）CUD操作，根据返回的int值判断结果

（2）查询操作，根据返回ResultSet结果集，获取查询数据

6、释放资源

总结：

（1）加载和注册驱动，整个项目做一次即可

（2）获取数据库连接可以封装到一个方法中

（3）释放资源可以封装到一个方法中

## **3.2编写工具类****JDBCUtils** ##

<table> 
 <tbody> 
 <tr> 
 <td> package com.atguigu.utils; import java.io.IOException; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.Properties; &nbsp; public class JDBCUtils { private static String drivername; private static String url; private static String user; private static String password; private static Properties pro = new Properties(); static{ try { //加载，读取jdbc.properties配置的信息 //pro.load的作用是把jdbc.properties文件中配置的信息，一一put到pro这个map中 pro.load(ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties")); //&nbsp;drivername = pro.getProperty("key") drivername = pro.getProperty("drivername"); url = pro.getProperty("url"); user = pro.getProperty("user"); password = pro.getProperty("password"); //注册驱动，加载驱动 Class.forName(drivername); } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } &nbsp; public static Connection getConnection()throws SQLException{ Connection conn = DriverManager.getConnection(url, user, password); return conn; } &nbsp; public static void closeQuietly(Connection conn){ try { if(conn!=null){ conn.close(); } } catch (SQLException e) { e.printStackTrace(); } } &nbsp; public static void closeQuietly(Statement st){ try { if(st!=null){ st.close(); } } catch (SQLException e) { e.printStackTrace(); } } &nbsp; public static void closeQuietly(ResultSet rs){ try { if(rs!=null){ rs.close(); } } catch (SQLException e) { e.printStackTrace(); } } &nbsp; public static void closeQuietly(Statement st,Connection conn){ closeQuietly(st); closeQuietly(conn); } &nbsp; public static void closeQuietly(ResultSet rs,Statement st,Connection conn){ closeQuietly(rs); closeQuietly(st); closeQuietly(conn); } } </td> 
 </tr> 
 </tbody> 
</table>

# **第4章****PreparedStatement** #

## **1****、****PreparedStatement****概述** ##

可以通过调用 Connection 对象的 preparedStatement(**String sql**) 方法获取 PreparedStatement 对象

PreparedStatement 接口是 Statement 的子接口，它表示一条预编译过的 SQL 语句

l PreparedStatement 对象所代表的 SQL 语句中的参数用问号(?)来表示，调用 PreparedStatement 对象的 setXxx()方法来设置这些参数. setXxx() 方法有两个参数，第一个参数是要设置的 SQL 语句中的参数的索引(从 1 开始)，第二个是设置的 SQL 语句中的参数的值

l ResultSet executeQuery()执行查询，并返回该查询生成的 ResultSet 对象。

l int executeUpdate()：执行更新，包括增、删、该

## **2、****Statement****的不足** ##

#### **（1）****SQL****拼接** ####

#### **（2）****SQL****注入** ####

SQL 注入是利用某些系统没有对用户输入的数据进行充分的检查，而在用户输入数据中注入非法的 SQL 语句段或命令，从而利用系统的 SQL 引擎完成恶意行为的做法。对于 Java 而言，要防范 SQL 注入，只要用PreparedStatement 取代 Statement 就可以了。

#### **（3）处理****Blob****类型的数据** ####

BLOB (binary large object)，二进制大对象，BLOB常常是数据库中用来存储二进制文件的字段类型。

插入BLOB类型的数据必须使用PreparedStatement，因为BLOB类型的数据无法使用字符串拼接写的。

MySQL的四种BLOB类型(除了在存储的最大信息量上不同外，他们是等同的)

<table> 
 <tbody> 
 <tr> 
 <td> &nbsp; &nbsp; </td> 
 <td> &nbsp;&nbsp;如果还是报错：xxx too large，那么在mysql的安装目录下，找my.ini文件加上如下的配置参数： &nbsp;&nbsp;max_allowed_packet=16M &nbsp; 注意：修改了my.ini文件，一定要重新启动服务 </td> 
 </tr> 
 </tbody> 
</table>

实际使用中根据需要存入的数据大小定义不同的BLOB类型。  
需要注意的是：如果存储的文件过大，数据库的性能会下降。

<table> 
 <tbody> 
 <tr> 
 <td> CREATE TABLE `user` ( &nbsp;&nbsp;`id` int(11) NOT NULL AUTO_INCREMENT, &nbsp;&nbsp;`username` varchar(20) COLLATE utf8_unicode_ci DEFAULT NULL, &nbsp;&nbsp;`head_picture`&nbsp;mediumblob, &nbsp;&nbsp;PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci; </td> 
 </tr> 
 <tr> 
 <td> package com.jdbc; &nbsp; import java.io.FileInputStream; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.util.Properties; &nbsp; public class TestBlob { &nbsp; public static void main(String[] args) throws Exception{ //加载jdbc.properties资源配置文件 Properties pro = new Properties(); pro.load(ClassLoader.getSystemResourceAsStream("jdbc.properties")); //1、加载与注册驱动 Class.forName(pro.getProperty("driver")); //2、获取数据库连接 Connection conn = DriverManager.getConnection(pro.getProperty("url"), pro); //3、访问数据库 //(1)准备带参数(?)的SQL //PreparedStatement&nbsp;接口是&nbsp;Statement&nbsp;的子接口，它表示一条预编译过的&nbsp;SQL&nbsp;语句 //PreparedStatement&nbsp;对象所代表的&nbsp;SQL&nbsp;语句中的参数用问号(?)来表示 String sql ="insert into user(username,head_picture) value(?,?)"; //(2)通过调用&nbsp;Connection&nbsp;对象的&nbsp;preparedStatement(String sql)&nbsp;方法获取&nbsp;PreparedStatement&nbsp;对象 PreparedStatement pst = conn.prepareStatement(sql); //(3)调用&nbsp;PreparedStatement&nbsp;对象的&nbsp;setXxx(int parameterIndex,XX value)&nbsp;方法来设置这些参数 pst.setString(1, "lily"); pst.setBlob(2, new FileInputStream("head/girl.jpg")); //(4)调用PreparedStatement的executeUpdate()执行SQL语句进行插入 //注意此处不能在传sql，否则?就白设置了 int len = pst.executeUpdate(); //(5)处理结果 if (len &gt; 0) { System.out.println("添加成功"); } else { System.out.println("添加失败"); } //4、释放资源 pst.close(); conn.close(); } } </td> 
 </tr> 
 </tbody> 
</table>

## **3、****PreparedStatement vs****Statement** ##

l 代码的可读性和可维护性. Statement的sql拼接是个难题。

l PreparedStatement 可以防止 SQL 注入

l PreparedStatement 可以处理Blob类型的数据

l PreparedStatement 能最大可能提高性能：**（Oracle和****PostgreSQL8****是这样，但是对于****MySQL****不一定比****Statement****高）**

n DBServer会对预编译语句提供性能优化。因为预编译语句有可能被重复调用，所以语句在被DBServer的编译器编译后的执行代码被缓存下来，那么下次调用时只要是相同的预编译语句就不需要编译，只要将参数直接传入编译过的语句执行代码中就会得到执行。

n 在statement语句中,即使是相同操作但因为数据内容不一样,所以整个语句本身不能匹配,没有缓存语句的意义.事实是没有数据库会对普通语句编译后的执行代码缓存.这样每执行一次都要对传入的语句编译一次.

n (语法检查，语义检查，翻译成二进制命令，缓存)

## **4****、示例代码** ##

### **（1）使用****Statement** ###

<table> 
 <tbody> 
 <tr> 
 <td> package com.atguigu.statement; import java.sql.Connection; import java.sql.ResultSet; import java.sql.Statement; import java.util.Scanner; import org.junit.Test; import com.atguigu.utils.JDBCUtils; &nbsp; public class TestStatementProblem { &nbsp; @Test public void add() throws Exception{ Scanner input = new Scanner(System.in); System.out.println("请输入姓名："); String name = input.nextLine(); System.out.println("请输入领导编号："); int mid = input.nextInt(); System.out.println("请输入部门编号："); int did = input.nextInt(); //1、获取连接 Connection conn = JDBCUtils.getConnection(); //2、创建Statement对象 Statement st = conn.createStatement(); //3、编写sql String sql = "INSERT INTO emp (ename,`mid`,did) VALUES('" + name+"'," + mid + "," + did + ")"; //4、执行sql int update = st.executeUpdate(sql); System.out.println(update&gt;0?"添加成功":"添加失败"); //5、释放资源 JDBCUtils.closeQuietly(st, conn); } &nbsp; @Test public void select()throws Exception{ Scanner input = new Scanner(System.in); System.out.println("请输入姓名："); String name = input.nextLine(); //1、获取连接 Connection conn = JDBCUtils.getConnection(); //2、写sql //孙红雷 &nbsp;' or '1' = '1 String sql = "SELECT eid,ename,tel,gender,salary FROM t_employee WHERE ename = '" + name + "'"; System.out.println(sql); //&nbsp;SELECT eid,ename,tel,gender,salary FROM t_employee WHERE ename = '孙红雷 &nbsp;' or '1' = '1' //3、用Statement执行 Statement st = conn.createStatement(); //4、执行查询sql ResultSet rs = st.executeQuery(sql); while(rs.next()){ int id = rs.getInt(1); String ename = rs.getString(2); String tel = rs.getString(3); String gender =rs.getString(4); double salary = rs.getDouble(5); System.out.println(id+"\t" + ename + "\t" + tel + "\t" + gender + "\t" +salary); } //5、释放资源 JDBCUtils.closeQuietly(rs, st, conn); } &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;@Test public void testAddBlob(){ String sql = "INSERT INTO `user` (username,`password`,photo)VALUES('chai','123',没法在String中处理Blob类型的数据);"; } } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

### **（2）使用****PreparedStatement** ###

<table> 
 <tbody> 
 <tr> 
 <td> package com.atguigu.preparedstatement; &nbsp; import java.io.FileInputStream; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.util.Scanner; import org.junit.Test; import com.atguigu.utils.JDBCUtils; &nbsp; public class TestPreparedStatement { @Test public void add() throws Exception { Scanner input = new Scanner(System.in); System.out.println("请输入姓名："); String name = input.nextLine();&nbsp; System.out.println("请输入性别："); String gender = input.nextLine();&nbsp; System.out.println("请输入领导编号："); int mid = input.nextInt();&nbsp; System.out.println("请输入部门编号："); int did = input.nextInt();&nbsp; String sql = "INSERT INTO emp VALUES(NULL,?,?,?,?)";//&nbsp;参数，占位符，通配符，表示这个地方需要设置值&nbsp; // 2、获取连接 Connection conn = JDBCUtils.getConnection();&nbsp; // 3、准备一个PreparedStatement：预编译sql PreparedStatement pst = conn.prepareStatement(sql);//&nbsp;对带？的sql进行预编译&nbsp; // 4、把?用具体的值进行代替 pst.setString(1, name); pst.setString(2, gender); pst.setInt(3, mid); pst.setInt(4, did);&nbsp; // 5、执行sql int len = pst.executeUpdate();&nbsp; // 6、释放资源 JDBCUtils.closeQuietly(pst, conn); }&nbsp; @Test public void select() throws Exception { // 3、写sql Scanner input = new Scanner(System.in); System.out.println("请输入姓名："); String name = input.nextLine(); //&nbsp;孙红雷&nbsp;' or '1' = '1 String sql = "SELECT eid,ename,tel,gender,salary FROM t_employee WHERE ename = ?";&nbsp; // 1、注册驱动，注册过了 // 2、获取连接 Connection conn = JDBCUtils.getConnection();&nbsp; // 3、把带？的sql语句进行预编译 PreparedStatement pst = conn.prepareStatement(sql);&nbsp; // 4、把？用具体的变量的赋值 pst.setString(1, name);&nbsp; // 5、执行sql ResultSet rs = pst.executeQuery(); while (rs.next()) { int id = rs.getInt("eid"); String ename = rs.getString("ename"); String tel = rs.getString("tel"); String gender = rs.getString("gender"); double salary = rs.getDouble("salary"); System.out.println(id + "\t" + ename + "\t" + tel + "\t" + gender + "\t" + salary); }&nbsp; // 6、释放资源 JDBCUtils.closeQuietly(rs, pst, conn); } @Test public void addBlob() throws Exception { Scanner input = new Scanner(System.in); System.out.println("请输入用户名："); String username = input.nextLine();&nbsp; System.out.println("请输入密码："); String password = input.nextLine(); System.out.println("请指定照片的路径："); String photoPath = input.nextLine(); // INSERT INTO `user` VALUES(NULL,用户名,密码,照片) String sql = "INSERT INTO `user` VALUES(NULL,?,?,?)";&nbsp; // 1、注册驱动，注册过了 // 2、获取连接 Connection conn = JDBCUtils.getConnection(); // 3、准备一个PreparedStatement：预编译sql PreparedStatement pst = conn.prepareStatement(sql);//&nbsp;对带？的sql进行预编译 // 4、对？进行设置 pst.setString(1, username); pst.setString(2, password); pst.setBlob(3, new FileInputStream(photoPath)); // 5、执行sql int len = pst.executeUpdate(); System.out.println(len &gt; 0 ? "添加成功" : "添加失败");&nbsp; // 6、释放资源 JDBCUtils.closeQuietly(pst, conn); } } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

# **第5章** **JDBC****的其他操作** #

## **1****、****JDBC****取得数据库自动生成的主键** ##

获取自增长的键值：

（1）在创建PreparedStatement对象时

原来：

PreparedStatement pst = conn.preparedStatement(sql);

现在：

PreparedStatement pst = conn.prepareStatement(orderInsert,Statement.RETURN\_GENERATED\_KEYS);

（2）原来执行更新

原来：

int len = pst.executeUpdate();

现在：

int len = pst.executeUpdate();

ResultSet rs = pst.getGeneratedKeys();

if(rs.next())\{

Object key = rs.getObject(第几列);//获取自增长的键值

<table> 
 <tbody> 
 <tr> 
 <td> package com.atguigu.other; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.Statement; import java.util.Scanner; import org.junit.Test; import com.atguigu.utils.JDBCUtils; public class TestGetGenericKey { @Test public void add() throws Exception { Scanner input = new Scanner(System.in); System.out.println("请输入姓名："); String name = input.nextLine();&nbsp; System.out.println("请输入性别："); String gender = input.nextLine();&nbsp; System.out.println("请输入领导编号："); int mid = input.nextInt(); System.out.println("请输入部门编号："); int did = input.nextInt(); String sql = "INSERT INTO emp VALUES(NULL,?,?,?,?)";//&nbsp;参数，占位符，通配符，表示这个地方需要设置值&nbsp; // 2、获取连接 Connection conn = JDBCUtils.getConnection();&nbsp; // 3、准备一个PreparedStatement：预编译sql //&nbsp;执行添加语句，如果需要获取自增长的键值，那么在此处要告知mysql服务器，在创建PreparedStatement对象时，增加一个参数 //autoGeneratedKeys -&nbsp;指示是否应该返回自动生成的键的标志，它是&nbsp;Statement.RETURN_GENERATED_KEYS&nbsp;或Statement.NO_GENERATED_KEYS&nbsp;之一 PreparedStatement pst = conn.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS); // 4、把?用具体的值进行代替 pst.setString(1, name); pst.setString(2, gender); pst.setInt(3, mid); pst.setInt(4, did);&nbsp; // 5、执行sql int len = pst.executeUpdate(); ResultSet rs = pst.getGeneratedKeys(); if(rs.next()){ System.out.println("新员工编号是：" + rs.getObject(1)); }&nbsp; // 6、释放资源 JDBCUtils.closeQuietly(pst, conn); } }&nbsp; </td> 
 </tr> 
 </tbody> 
</table>

## **2****、批处理** ##

当需要成批插入或者更新记录时。可以采用Java的批量更新机制，这一机制允许多条语句一次性提交给数据库批量处理。通常情况下比单独提交处理更有效率。

JDBC的批量处理语句包括下面两个方法：

l addBatch()：添加需要批量处理的SQL语句或参数

l executeBatch()：执行批量处理语句；

通常我们会遇到两种批量执行SQL语句的情况：

l 多条SQL语句的批量处理；

l 一个SQL语句的批量传参；

注意：

**JDBC连接****MySQL****时，如果要使用批处理功能，请再****url****中加参数****?rewriteBatchedStatements=true**

**PreparedStatement作批处理插入时使用****values****（使用****value****没有效果）**

### **2.1 Statement** ###

void addBatch(String sql)：添加需要批量处理的SQL语句

int\[\] executeBatch()；执行批量处理语句；

### **2.2 PreparedStatement** ###

void addBatch()将一组参数添加到此 PreparedStatement 对象的批处理命令中

int\[\] executeBatch()；执行批量处理语句；

### **2.3 关于效率测试** ###

测试：插入100000条记录

l （1）Statement不使用批处理

l （2）PreparedStatement不使用批处理

l （3）Statement使用批处理

l （4）PreparedStatement使用批处理（效率最高）

（4）>（3）>（1）>（2）

### **2.4 示例代码** ###

<table> 
 <tbody> 
 <tr> 
 <td> package com.atguigu.other; &nbsp; import java.sql.Connection; import java.sql.PreparedStatement; &nbsp; import org.junit.Test; &nbsp; import com.atguigu.utils.JDBCUtils; &nbsp; public class TestBatch { &nbsp; @Test public void testNoBatch() throws Exception { long start = System.currentTimeMillis(); //批处理 //添加500件商品 String sql = "INSERT INTO t_goods (pname,price) VALUES(?,?)"; Connection conn = JDBCUtils.getConnection(); PreparedStatement pst = conn.prepareStatement(sql); for (int i = 1; i &lt;= 100; i++) { String pname = "商品" + i; double price = i; pst.setString(1, pname); pst.setDouble(2, price); int len = pst.executeUpdate(); System.out.println("第" +i +"条添加：" + (len&gt;0?"成功":"失败")); } long end = System.currentTimeMillis(); System.out.println("耗时：" + (end-start)); } &nbsp; @Test public void testBatch()throws Exception { long start = System.currentTimeMillis(); String sql = "INSERT INTO t_goods (pname,price) VALUES(?,?)"; Connection conn = JDBCUtils.getConnection(); PreparedStatement pst = conn.prepareStatement(sql); for (int i = 1; i &lt;= 100; i++) { String pname = "商品" + i; double price = i; pst.setObject(1, pname); pst.setObject(2, price); pst.addBatch();//添加到批处理中 } int[] executeBatch = pst.executeBatch();//一批命名同时执行 for (int i = 0; i &lt; executeBatch.length; i++) { System.out.println("第" +i +"条添加：" + (executeBatch[i]&gt;0?"成功":"失败")); } JDBCUtils.closeQuietly(pst, conn); long end = System.currentTimeMillis(); System.out.println("耗时：" + (end-start)); } } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

## **3****、事务** ##

JDBC程序中当**一个连接对象**被创建时，默认情况下是自动提交事务：每次执行一个 SQL 语句时，如果执行成功，就会向数据库自动提交，而不能回滚。

JDBC程序中为了让多个 SQL 语句作为一个事务执行：（重点）

l 调用 Connection 对象的 setAutoCommit(false); 以取消自动提交事务

l 在所有的 SQL 语句都成功执行后，调用 commit(); 方法提交事务

l 在其中某个操作失败或出现异常时，调用 rollback(); 方法回滚事务

l 若此时 Connection 没有被关闭, 则需要恢复其自动提交状态 setAutoCommit(true);

**注意：**

**如果多个操作，每个操作使用的是自己单独的连接，则无法保证事务。即同一个事务的多个操作必须在同一个连接下**

JDBC还可以通过Connection对象的：

l int getTransactionIsolation()：获取此 Connection 对象的当前事务隔离级别

l void setTransactionIsolation(int level)：试图将此 Connection 对象的事务隔离级别更改为给定的级别。可能的事务隔离级别是 Connection 接口中定义的常量。

level - 以下 Connection 常量之一：

l Connection.TRANSACTION\_READ\_UNCOMMITTED**（=1）**

l Connection.TRANSACTION\_READ\_COMMITTED**（=2）**、

l Connection.TRANSACTION\_REPEATABLE\_READ**（=4）**

l Connection.TRANSACTION\_SERIALIZABLE**（=8）**。

（注意，不能使用 Connection.TRANSACTION\_NONE**（=0）**，因为它指定了不受支持的事务。）

<table> 
 <tbody> 
 <tr> 
 <td> package com.atguigu.other; &nbsp; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; &nbsp; import org.junit.Test; &nbsp; import com.atguigu.utils.DBUtils; &nbsp; public class TestTransaction { &nbsp; @Test public void test() &nbsp;{ int uid = 2;//谁买的 int[] pids = {1,2,3};//购买的商品的编号 int[] amount = {1,1,1};//分别每一个商品的数量 double[] price = {45,34,2.5};//购买时，每一件商品的价格 //如何把这些订单的数据保存到数据库中 //分别在订单表t_order添加一条记录：订单编号，订单时间，订单总价，用户编号 //在订单明细表t_detail添加几条记录：订单编号，商品编号，数量（多行），这里3行 //这些数据要么同时保存成功，要么同时失败（撤销），那么表示他们要组成一个事务 Connection conn = null; try { //手动提交事务 //1、获取连接对象(注册驱动省略，因为在DBUtils注册过了) conn = JDBCUtils.getConnection(); //2、设置手动提交 conn.setAutoCommit(false); String orderInsert = "INSERT INTO t_order (sumprice,uid) VALUES(?,?)"; double sumprice = 0; for (int i = 0; i &lt; price.length; i++) { sumprice += price[i]*amount[i]; } //3、执行添加语句，如果需要获取自增长的键值，那么在此处要告知mysql服务器，在创建PreparedStatement对象时，增加一个参数 //autoGeneratedKeys -&nbsp;指示是否应该返回自动生成的键的标志，它是&nbsp;Statement.RETURN_GENERATED_KEYS&nbsp;或Statement.NO_GENERATED_KEYS&nbsp;之一 PreparedStatement pst = conn.prepareStatement(orderInsert,Statement.RETURN_GENERATED_KEYS); pst.setObject(1, sumprice); pst.setObject(2, uid); pst.executeUpdate(); ResultSet rs = pst.getGeneratedKeys(); if(rs.next()){ Object oid = rs.getObject(1); String detailInsert = "INSERT INTO t_details (oid,pid,amount) VALUES(?,?,?)"; PreparedStatement pst2 = conn.prepareStatement(detailInsert); for (int i = 0; i &lt; pids.length; i++) { pst2.setObject(1, oid); pst2.setObject(2, pids[i]); pst2.setObject(3, amount[i]); pst2.addBatch(); } pst2.executeBatch(); } //4、提交事务 conn.commit(); System.out.println("添加成功"); }catch (Exception e) { e.printStackTrace(); try { //如果发生异常，应该回滚 if(conn!=null){ System.out.println("添加失败"); conn.rollback(); } } catch (SQLException e1) { e1.printStackTrace(); } }finally{ try { //释放资源 if(conn!=null){ conn.setAutoCommit(true); conn.close(); } } catch (SQLException e) { e.printStackTrace(); } } } } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

# **第6章****DAO****和增删改查通用方法** #

DAO：Data Access Object访问数据信息的类和接口，包括了对数据的CRUD（Create、Retrival、Update、Delete），而不包含任何业务相关的信息

作用：为了实现功能的模块化，更有利于代码的维护和升级。

## **1****、练习** ##

### **1.1表和****JavaBean** ###

<table> 
 <tbody> 
 <tr> 
 <td> &nbsp; &nbsp; </td> 
 <td> public class Department { private Integer id; private String name; private String description; .... } </td> 
 </tr> 
 <tr> 
 <td> &nbsp; int,double等在Java中都用包装类，因为mysql中的所有类型都可能是NULL，而Java只有引用数据类型才有NULL值 </td> 
 <td> public class Employee { private Integer eid; private String ename; private String tel; private String gender;//mysql中用char,在Java中也要用String private Double salary; private Double commissionPct; private Date birthday;//此处用String或Date private Date hiredate; private Integer jobId; private String email; private Integer mid; private String address; private String nativePlace; private Integer did; ... } </td> 
 </tr> 
 </tbody> 
</table>

### **1.2 DAO接口** ###

<table> 
 <tbody> 
 <tr> 
 <td> package&nbsp;com.atguigu.dao; &nbsp; import&nbsp;java.util.List; &nbsp; import&nbsp;com.atguigu.bean.Department; &nbsp; public&nbsp;interface&nbsp;DepartmentDAO { void&nbsp;addDepartment(Department&nbsp;department)throws&nbsp;Exception; void&nbsp;updateDepartment(Department&nbsp;department)throws&nbsp;Exception; void&nbsp;deleteById(String&nbsp;did)throws&nbsp;Exception; Department getById(String&nbsp;did)throws&nbsp;Exception; List getAll()throws&nbsp;Exception; } &nbsp; </td> 
 </tr> 
 <tr> 
 <td> package&nbsp;com.atguigu.dao; &nbsp; import&nbsp;java.util.List; import&nbsp;java.util.Map; &nbsp; import&nbsp;com.atguigu.bean.Employee; &nbsp; public&nbsp;interface&nbsp;EmployeeDAO { void&nbsp;addEmployee(Employee&nbsp;emp)throws&nbsp;Exception; void&nbsp;updateEmployee(Employee&nbsp;emp)throws&nbsp;Exception; void&nbsp;deleteById(String&nbsp;eid)throws&nbsp;Exception; Employee getById(String&nbsp;eid)throws&nbsp;Exception; List getAll()throws&nbsp;Exception; Long getCount()throws&nbsp;Exception; List getAll(int&nbsp;page,&nbsp;int&nbsp;pageSize)throws&nbsp;Exception; Double getMaxSalary()throws&nbsp;Exception; Map getAvgSalaryByDid()throws&nbsp;Exception; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

### **1.3 DAO实现类** ###

#### **（****1）原生版** ####

<table> 
 <tbody> 
 <tr> 
 <td> package&nbsp;com.atguigu.dao.impl.original; &nbsp; import&nbsp;java.sql.Connection; import&nbsp;java.sql.PreparedStatement; import&nbsp;java.sql.ResultSet; import&nbsp;java.util.ArrayList; import&nbsp;java.util.List; &nbsp; import&nbsp;com.atguigu.bean.Department; import&nbsp;com.atguigu.dao.DepartmentDAO; import&nbsp;com.atguigu.utils.JDBCUtils; &nbsp; public&nbsp;class&nbsp;DepartmentDAOImpl&nbsp;implements&nbsp;DepartmentDAO{ &nbsp; @Override public&nbsp;void&nbsp;addDepartment(Department&nbsp;department)&nbsp;throws&nbsp;Exception { Connection&nbsp;conn&nbsp;= JDBCUtils.getConnection(); String&nbsp;sql&nbsp;=&nbsp;"INSERT INTO t_department(did,dname,description) VALUES(NULL,?,?)"; PreparedStatement&nbsp;pst&nbsp;=&nbsp;conn.prepareStatement(sql); pst.setString(1,&nbsp;department.getName()); pst.setString(2,&nbsp;department.getDescription()); pst.executeUpdate(); JDBCUtils.closeQuietly(pst,&nbsp;conn); } &nbsp; @Override public&nbsp;void&nbsp;updateDepartment(Department&nbsp;department)&nbsp;throws&nbsp;Exception { Connection&nbsp;conn&nbsp;= JDBCUtils.getConnection(); String&nbsp;sql&nbsp;=&nbsp;"UPDATE t_department SET dname = ?,description = ? WHERE did = ?"; PreparedStatement&nbsp;pst&nbsp;=&nbsp;conn.prepareStatement(sql); pst.setString(1,&nbsp;department.getName()); pst.setString(2,&nbsp;department.getDescription()); pst.setInt(3,&nbsp;department.getId()); pst.executeUpdate(); JDBCUtils.closeQuietly(pst,&nbsp;conn); } &nbsp; @Override public&nbsp;void&nbsp;deleteById(String&nbsp;did)&nbsp;throws&nbsp;Exception { Connection&nbsp;conn&nbsp;= JDBCUtils.getConnection(); String&nbsp;sql&nbsp;=&nbsp;"DELETE FROM t_department WHERE did = ?"; PreparedStatement&nbsp;pst&nbsp;=&nbsp;conn.prepareStatement(sql); pst.setString(1,&nbsp;did); pst.executeUpdate(); JDBCUtils.closeQuietly(pst,&nbsp;conn); } &nbsp; @Override public&nbsp;Department getById(String&nbsp;did)&nbsp;throws&nbsp;Exception { Connection&nbsp;conn&nbsp;= JDBCUtils.getConnection(); String&nbsp;sql&nbsp;=&nbsp;"SELECT did,dname,description FROM t_department WHERE did = ?"; PreparedStatement&nbsp;pst&nbsp;=&nbsp;conn.prepareStatement(sql); pst.setString(1,&nbsp;did); ResultSet&nbsp;rs&nbsp;=&nbsp;pst.executeQuery(); Department&nbsp;dept&nbsp;=&nbsp;null; if(rs.next()){ dept&nbsp;=&nbsp;new&nbsp;Department(); dept.setId(rs.getInt("did")); dept.setName(rs.getString("dname")); dept.setDescription(rs.getString("description")); } JDBCUtils.closeQuietly(rs,&nbsp;pst,&nbsp;conn); return&nbsp;dept; } &nbsp; @Override public&nbsp;List getAll()&nbsp;throws&nbsp;Exception { Connection&nbsp;conn&nbsp;= JDBCUtils.getConnection(); String&nbsp;sql&nbsp;=&nbsp;"SELECT did,dname,description FROM t_department"; PreparedStatement&nbsp;pst&nbsp;=&nbsp;conn.prepareStatement(sql); ResultSet&nbsp;rs&nbsp;=&nbsp;pst.executeQuery(); ArrayList&nbsp;list&nbsp;=&nbsp;new&nbsp;ArrayList(); while(rs.next()){ Department&nbsp;dept&nbsp;=&nbsp;new&nbsp;Department(); dept.setId(rs.getInt("did")); dept.setName(rs.getString("dname")); dept.setDescription(rs.getString("description")); list.add(dept); } JDBCUtils.closeQuietly(rs,&nbsp;pst,&nbsp;conn); return&nbsp;list; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

### **1.4 抽取****BasicDAO** ###

package com.atguigu.dao.impl;

import java.lang.reflect.Field;

import java.lang.reflect.ParameterizedType;

import java.lang.reflect.Type;

import java.sql.Connection;

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;

import com.atguigu.utils.JDBCUtils;

//泛型类

public abstract class BasicDAOImpl \{

private Class type;

@SuppressWarnings("all")

protected BasicDAOImpl() \{

// 为什么要在构造器中写，因为子类继承BasicDAOImpl类一定会调用父类的构造器

Class clazz = this.getClass();// this代表的是正在创建的那个对象，即子类的对象

// 获取clazz的带泛型父类信息

Type superType = clazz.getGenericSuperclass();

// Father：参数化的类型

ParameterizedType p = (ParameterizedType) superType;

// 获取泛型实参

Type\[\] ts = p.getActualTypeArguments();

// 因为当前类只有一个泛型形参，即子类中只有一个泛型实参

type = (Class) ts\[0\];

protected int update(String sql, Object... params) throws SQLException \{

//1、获取连接

Connection conn = JDBCUtils.getConnection();

//2、执行更新数据库语句

int len = executeUpdate(conn, sql, params);

//3、关闭连接

JDBCUtils.closeQuietly(conn);

return len;

// 如果有需要在一个事务中完成更新，可以调用这个带conn的方法

protected int update(Connection conn, String sql, Object... params) throws SQLException \{

//执行更新数据库语句

int len = executeUpdate(conn, sql, params);

return len;

private int executeUpdate(Connection conn, String sql, Object... params) throws SQLException \{

//1、sql预编译

PreparedStatement pst = conn.prepareStatement(sql);

//2、设置sql中的?

if (params != null && params.length > 0) \{

// 数组的下标是从0开始，？的编号是1开始

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

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

//3、执行sql

int len = pst.executeUpdate();

//4、释放资源

JDBCUtils.closeQuietly(pst);

return len;

//通用的查询方法之一：查询一行，即一个对象

protected T get(String sql, Object... params) throws Exception \{

//1、获取连接

Connection conn = JDBCUtils.getConnection();

//2、执行查询语句

ResultSet rs = executeQuery( conn,sql, params);

//3、处理查询结果

//（1）获取查询的结果集的元数据信息

ResultSetMetaData rsmd = rs.getMetaData();

//（2）这是查询的结果集中，一共有几列

int count = rsmd.getColumnCount();

//（3）创建实例对象

T t = type.newInstance();// 要求这个Javabean类型必须有无参构造

//（4）遍历结果集

while (rs.next()) \{

// （5）循环每一行有几列

for (int i = 0; i < count; i++) \{

// （6）获取第几列的名称

// String columnName = rsmd.getColumnName(i+1);

// 如果sql中没有取别名，那么就是列名，如果有别名，返回的是别名

String fieldName = rsmd.getColumnLabel(i + 1);

// （7）获取该列的值

// Object value = rs.getObject(columnName);

Object value = rs.getObject(fieldName);

// （8）设置obj对象的某个属性中

Field field = type.getDeclaredField(fieldName);// JavaBean的属性名

field.setAccessible(true);

field.set(t, value);

//4、释放资源

JDBCUtils.closeQuietly(rs);

JDBCUtils.closeQuietly(conn);

return t;

private static ResultSet executeQuery(Connection conn, String sql, Object... params) throws SQLException \{

//1、sql预编译

PreparedStatement pst = conn.prepareStatement(sql);

//2、设置？

if (params != null && params.length > 0) \{

// 数组的下标是从0开始，？的编号是1开始

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

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

//3、查询

ResultSet rs = pst.executeQuery();

return rs;

// 通用的查询方法之二：查询多行，即多个对象

// Class clazz：用来创建实例对象，获取对象的属性，并设置属性值

public ArrayList getList(String sql, Object... args) throws Exception \{

// 1、获取连接

Connection conn = JDBCUtils.getConnection();

//2、执行查询sql

ResultSet rs = executeQuery(conn,sql, args);

//3、获取结果集的元数据

ResultSetMetaData metaData = rs.getMetaData();

// 获取结果中总列数

int count = metaData.getColumnCount();

// 创建集合对象

ArrayList list = new ArrayList();

while (rs.next()) \{// 遍历的行

// 1、每一行是一个对象

T obj = type.newInstance();

// 2、每一行有很多列

// for的作用是为obj对象的每一个属性设置值

for (int i = 0; i < count; i++) \{

// (1)每一列的名称

String fieldName = metaData.getColumnLabel(i + 1);// 获取第几列的名称，如果有别名获取别名，如果没有别名获取列名

// (2)每一列的值

Object value = rs.getObject(i + 1);// 获取第几列的值

// (3)获取属性对象

Field field = type.getDeclaredField(fieldName);

// (4)设置可见性

field.setAccessible(true);

// (5)设置属性值

field.set(obj, value);

// 3、把obj对象放到集合中

list.add(obj);

// 6、释放资源

JDBCUtils.closeQuietly(rs);

JDBCUtils.closeQuietly(conn);

// 7、返回结果

return list;

//通用的查询方法之三：查询单个值

//单值：select max(salary) from employee; 一行一列

//select count(\*) from t\_goods; 一共几件商品

public Object getValue(String sql,Object... args)throws Exception\{

//1、获取连接

Connection conn = JDBCUtils.getConnection();

//2、执行查询sql

ResultSet rs = executeQuery(conn, sql, args);

Object value = null;

if(rs.next())\{//一行

value = rs.getObject(1);//一列

//3、释放资源

JDBCUtils.closeQuietly(rs);

JDBCUtils.closeQuietly(conn);

return value;

//通用的查询方法之四：查询多行多列，但每一行又不是一个JavaBean

public List> getListMap(String sql,Object... args)throws Exception\{

//1、获取连接

Connection conn = JDBCUtils.getConnection();

//2、执行sql

ResultSet rs = executeQuery(conn, sql, args);

//获取结果集的元数据对象

ResultSetMetaData metaData = rs.getMetaData();

//一共有几列

int count = metaData.getColumnCount();

//创建List

ArrayList> list = new ArrayList>();

while(rs.next())\{

//每一行是一个Map的对象

HashMap map = new HashMap();

//map的key是列名

for (int i = 0; i < count; i++) \{

//（1）获取列名或别名

String columnName = metaData.getColumnLabel(i+1);

//（2）获取对应的值

Object value = rs.getObject(i+1);

//（3）把这对值放到map中

map.put(columnName, value);

//把map放到List中

list.add(map);

//6、释放资源

JDBCUtils.closeQuietly(rs);

JDBCUtils.closeQuietly(conn);

return list;

//通用的查询方法之四：查询一行多列，但一行又不是一个JavaBean

public Map getMap(String sql,Object... args)throws Exception\{

List> listMap = getListMap(sql,args);

if(listMap.size()>0)\{

return listMap.get(0);

return null;

### **1.5 继承****BasicDAO****的后的****DAO****实现类** ###

#### **DepartmentDAO****实现类** ####

#### **EmployeeDAO实现类** ####

<table> 
 <tbody> 
 <tr> 
 <td> package&nbsp;com.atguigu.dao.impl.basic; import&nbsp;java.util.ArrayList; import&nbsp;java.util.HashMap; import&nbsp;java.util.List; import&nbsp;java.util.Map; import&nbsp;java.util.Map.Entry; import&nbsp;java.util.Set; import&nbsp;com.atguigu.bean.Employee; import&nbsp;com.atguigu.dao.EmployeeDAO; import&nbsp;com.atguigu.dao.impl.BasicDAOImpl; public&nbsp;class&nbsp;EmployeeDAOImpl&nbsp;extends&nbsp;BasicDAOImpl&nbsp;implements&nbsp;EmployeeDAO{ @Override public&nbsp;void&nbsp;addEmployee(Employee&nbsp;emp)&nbsp;throws&nbsp;Exception { String&nbsp;sql&nbsp;=&nbsp;"INSERT INTO t_employee " &nbsp;+&nbsp;"(eid,ename,tel,gender,salary,commission_pct,birthday,hiredate,job_id,email,mid,address,native_place,did)" &nbsp;+&nbsp;"VALUES(NULL,?,?,?,?,?,?,?,?,?,?,?,?,?)"; Object[]&nbsp;args&nbsp;=&nbsp;new&nbsp;Object[13]; args[0] =&nbsp;emp.getEname(); args[1] =&nbsp;emp.getTel(); args[2] =&nbsp;emp.getGender(); args[3] =&nbsp;emp.getSalary(); args[4] =&nbsp;emp.getCommissionPct(); args[5] =&nbsp;emp.getBirthday(); args[6] =&nbsp;emp.getHiredate(); args[7] =&nbsp;emp.getJobId(); args[8] =&nbsp;emp.getEmail(); args[9] =&nbsp;emp.getMid(); args[10] =&nbsp;emp.getAddress(); args[11] =&nbsp;emp.getNativePlace(); args[12] =&nbsp;emp.getDid(); update(sql,&nbsp;args); } @Override public&nbsp;void&nbsp;updateEmployee(Employee&nbsp;emp)&nbsp;throws&nbsp;Exception { String&nbsp;sql&nbsp;=&nbsp;"UPDATE t_employee SET " &nbsp;+"ename=?,tel=?,gender=?,salary=?,commission_pct=?,birthday=?,hiredate=?,job_id=?,email=?,MID=?,address=?,native_place=?,did=?" &nbsp;+" WHERE eid = ?"; Object[]&nbsp;args&nbsp;=&nbsp;new&nbsp;Object[14]; args[0] =&nbsp;emp.getEname(); args[1] =&nbsp;emp.getTel(); args[2] =&nbsp;emp.getGender(); args[3] =&nbsp;emp.getSalary(); args[4] =&nbsp;emp.getCommissionPct(); args[5] =&nbsp;emp.getBirthday(); args[6] =&nbsp;emp.getHiredate(); args[7] =&nbsp;emp.getJobId(); args[8] =&nbsp;emp.getEmail(); args[9] =&nbsp;emp.getMid(); args[10] =&nbsp;emp.getAddress(); args[11] =&nbsp;emp.getNativePlace(); args[12] =&nbsp;emp.getDid(); args[13] =&nbsp;emp.getEid(); update(sql,&nbsp;args); } @Override public&nbsp;void&nbsp;deleteById(String&nbsp;eid)&nbsp;throws&nbsp;Exception { String&nbsp;sql&nbsp;=&nbsp;"DELETE FROM t_employee WHERE eid = ?"; update(sql,&nbsp;eid); }&nbsp; @Override public&nbsp;Employee getById(String&nbsp;eid)&nbsp;throws&nbsp;Exception { String&nbsp;sql&nbsp;=&nbsp;"SELECT eid,ename,tel,gender,salary,commission_pct as 'commissionPct',birthday,hiredate," +&nbsp;"job_id as 'jobId',email,mid,address,native_place as 'nativePlace' ,did FROM t_employee WHERE eid = ?"; Employee&nbsp;employee&nbsp;= get(sql,&nbsp;eid); return&nbsp;employee; } @Override public&nbsp;List getAll()&nbsp;throws&nbsp;Exception { String&nbsp;sql&nbsp;=&nbsp;"SELECT eid,ename,tel,gender,salary,commission_pct as 'commissionPct',birthday,hiredate," +&nbsp;"job_id as 'jobId',email,mid,address,native_place as 'nativePlace' ,did FROM t_employee"; ArrayList&nbsp;list&nbsp;= getList(sql); return&nbsp;list; }&nbsp; @Override public&nbsp;Long getCount()&nbsp;throws&nbsp;Exception { String&nbsp;sql&nbsp;=&nbsp;"SELECT COUNT(*) FROM t_employee"; Long&nbsp;value&nbsp;= (Long) getValue(sql); return&nbsp;value; }&nbsp; @Override public&nbsp;List getAll(int&nbsp;page,&nbsp;int&nbsp;pageSize)&nbsp;throws&nbsp;Exception { String&nbsp;sql&nbsp;=&nbsp;"SELECT eid,ename,tel,gender,salary,commission_pct as 'commissionPct',birthday,hiredate," +&nbsp;"job_id as 'jobId',email,mid,address,native_place as 'nativePlace' ,did FROM t_employee LIMIT ?,?"; ArrayList&nbsp;list&nbsp;= getList(&nbsp;sql, (page-1)*pageSize,&nbsp;pageSize); return&nbsp;list; } @Override public&nbsp;Double getMaxSalary()&nbsp;throws&nbsp;Exception { String&nbsp;sql&nbsp;=&nbsp;"SELECT MAX(salary) FROM t_employee"; Double&nbsp;value&nbsp;= (Double) getValue(sql); return&nbsp;value; }&nbsp; @Override public&nbsp;Map getAvgSalaryByDid()&nbsp;throws&nbsp;Exception { String&nbsp;sql&nbsp;=&nbsp;"SELECT did,MAX(salary) FROM t_employee GROUP BY did"; List&gt;&nbsp;list&nbsp;= getListMap(sql); HashMap&nbsp;result&nbsp;=&nbsp;new&nbsp;HashMap&lt;&gt;(); for&nbsp;(Map&nbsp;map&nbsp;:&nbsp;list) { Set&gt;&nbsp;entrySet&nbsp;=&nbsp;map.entrySet(); Integer&nbsp;did&nbsp;=&nbsp;null; Double&nbsp;salary&nbsp;=&nbsp;null; for&nbsp;(Entry&nbsp;entry&nbsp;:&nbsp;entrySet) { String&nbsp;key&nbsp;=&nbsp;entry.getKey(); if("did".equals(key)){ did&nbsp;= (Integer)&nbsp;entry.getValue(); }else{ salary&nbsp;= (Double)&nbsp;entry.getValue(); } } result.put(did,&nbsp;salary); } return&nbsp;result; }&nbsp; }&nbsp; </td> 
 </tr> 
 </tbody> 
</table>

### **1.6 测试类** ###

<table> 
 <tbody> 
 <tr> 
 <td> package&nbsp;com.atguigu.dao.test; import&nbsp;java.util.List; import&nbsp;java.util.Scanner;&nbsp; import&nbsp;org.junit.Test;&nbsp; import&nbsp;com.atguigu.bean.Department; import&nbsp;com.atguigu.dao.DepartmentDAO; import&nbsp;com.atguigu.dao.impl.basic.DepartmentDAOImplBasic; import&nbsp;com.atguigu.dao.impl.original.DepartmentDAOImpl; import&nbsp;com.atguigu.utils.CMUtility;&nbsp; public&nbsp;class&nbsp;TestDepartmentDAO { //&nbsp;DepartmentDAO&nbsp;dao&nbsp;= new DepartmentDAOImpl(); DepartmentDAO&nbsp;dao&nbsp;=&nbsp;new&nbsp;DepartmentDAOImplBasic();&nbsp; @Test public&nbsp;void&nbsp;addDepartment() { Scanner&nbsp;input&nbsp;=&nbsp;new&nbsp;Scanner(System.in); System.out.println("请输入部门名称："); String&nbsp;name&nbsp;=&nbsp;input.nextLine();&nbsp; System.out.println("请输入部门简介："); String&nbsp;description&nbsp;=&nbsp;input.nextLine();&nbsp; Department&nbsp;department&nbsp;=&nbsp;new&nbsp;Department(name,&nbsp;description);&nbsp; try&nbsp;{ dao.addDepartment(department); System.out.println("添加成功"); }&nbsp;catch&nbsp;(Exception&nbsp;e) { e.printStackTrace(); System.out.println("添加失败"); } }&nbsp; @Test public&nbsp;void&nbsp;getAllDepartment()&nbsp;throws&nbsp;Exception { List&nbsp;all&nbsp;=&nbsp;dao.getAll(); for&nbsp;(Department&nbsp;department&nbsp;:&nbsp;all) { System.out.println(department); } }&nbsp; @Test public&nbsp;void&nbsp;updateDepartment() {&nbsp; try&nbsp;{ getAllDepartment();&nbsp; Scanner&nbsp;input&nbsp;=&nbsp;new&nbsp;Scanner(System.in); System.out.println("请选择要修改的部门编号："); String&nbsp;did&nbsp;=&nbsp;input.nextLine(); Department&nbsp;dept&nbsp;=&nbsp;dao.getById(did); System.out.println("请输入部门名称("+dept.getName()+")："); String&nbsp;name&nbsp;= CMUtility.readString(dept.getName());&nbsp; System.out.println("请输入部门简介("+dept.getDescription()+")："); String&nbsp;description&nbsp;= CMUtility.readString(dept.getDescription());&nbsp; Department&nbsp;department&nbsp;=&nbsp;new&nbsp;Department(dept.getId(),name,&nbsp;description); dao.updateDepartment(department); System.out.println("修改成功"); }&nbsp;catch&nbsp;(Exception&nbsp;e) { e.printStackTrace(); System.out.println("修改失败"); } } &nbsp; @Test public&nbsp;void&nbsp;deleteDepartment() {&nbsp; try&nbsp;{ getAllDepartment();&nbsp; Scanner&nbsp;input&nbsp;=&nbsp;new&nbsp;Scanner(System.in); System.out.println("请选择要删除的部门编号："); String&nbsp;did&nbsp;=&nbsp;input.nextLine();&nbsp; dao.deleteById(did); System.out.println("删除成功"); }&nbsp;catch&nbsp;(Exception&nbsp;e) { e.printStackTrace(); System.out.println("删除失败"); } } &nbsp; }&nbsp; </td> 
 </tr> 
 <tr> 
 <td> package&nbsp;com.atguigu.dao.test;&nbsp; import&nbsp;java.util.Date; import&nbsp;java.util.List; import&nbsp;java.util.Map; import&nbsp;java.util.Map.Entry; import&nbsp;java.util.Set;&nbsp; import&nbsp;org.junit.Test;&nbsp; import&nbsp;com.atguigu.bean.Employee; import&nbsp;com.atguigu.dao.EmployeeDAO; import&nbsp;com.atguigu.dao.impl.basic.EmployeeDAOImpl;&nbsp; public&nbsp;class&nbsp;TestEmployeeDAO { EmployeeDAO&nbsp;ed&nbsp;=&nbsp;new&nbsp;EmployeeDAOImpl(); &nbsp; @Test public&nbsp;void&nbsp;addEmployee()throws&nbsp;Exception{ //省略键盘输入 String&nbsp;ename&nbsp;=&nbsp;"张三"; String&nbsp;tel&nbsp;=&nbsp;"10080"; String&nbsp;gender&nbsp;=&nbsp;"男"; double&nbsp;salary&nbsp;= 10000; double&nbsp;commissionPct&nbsp;= 0.3; Date&nbsp;birthday&nbsp;=&nbsp;new&nbsp;Date(); Date&nbsp;hiredate&nbsp;=&nbsp;new&nbsp;Date();; int&nbsp;jobId&nbsp;= 2; String&nbsp;email="zhangsan@lina.com"; int&nbsp;mid&nbsp;= 1; String&nbsp;address&nbsp;=&nbsp;"xx"; String&nbsp;nativePlace&nbsp;=&nbsp;"xxx"; int&nbsp;did&nbsp;= 2; Employee&nbsp;emp&nbsp;=&nbsp;new&nbsp;Employee(ename,&nbsp;tel,&nbsp;gender,&nbsp;salary,&nbsp;commissionPct,&nbsp;birthday,&nbsp;hiredate,&nbsp;jobId,&nbsp;email,&nbsp;mid,address,&nbsp;nativePlace,&nbsp;did); try&nbsp;{ ed.addEmployee(emp); System.out.println("添加成功"); }&nbsp;catch&nbsp;(Exception&nbsp;e) { e.printStackTrace(); System.out.println("添加失败"); } } &nbsp; @Test public&nbsp;void&nbsp;updateEmployee()throws&nbsp;Exception{ //省略键盘输入 String&nbsp;eid&nbsp;=&nbsp;"1"; Employee&nbsp;emp&nbsp;=&nbsp;ed.getById(eid); //这里只演示修改一下，可以修改除了eid以外的所有项目 emp.setSalary(emp.getSalary() + 1000); try&nbsp;{ ed.updateEmployee(emp); System.out.println("修改成功"); }&nbsp;catch&nbsp;(Exception&nbsp;e) { e.printStackTrace(); System.out.println("修改失败"); } } &nbsp; @Test public&nbsp;void&nbsp;deleteById()throws&nbsp;Exception{ //省略键盘输入 String&nbsp;eid&nbsp;=&nbsp;"26"; try&nbsp;{ ed.deleteById(eid); System.out.println("删除成功"); }&nbsp;catch&nbsp;(Exception&nbsp;e) { e.printStackTrace(); System.out.println("删除失败"); } } &nbsp; @Test public&nbsp;void&nbsp;getAll()throws&nbsp;Exception{ List&nbsp;all&nbsp;=&nbsp;ed.getAll(); for&nbsp;(Employee&nbsp;employee&nbsp;:&nbsp;all) { System.out.println(employee); } } &nbsp; @Test public&nbsp;void&nbsp;getAllPage()throws&nbsp;Exception{ Long&nbsp;count&nbsp;=&nbsp;ed.getCount(); System.out.println("总记录数："&nbsp;+&nbsp;count); int&nbsp;pageSize&nbsp;= 5; System.out.println("每页显示5条"); int&nbsp;page&nbsp;= 2; System.out.println("用户选择第"&nbsp;+&nbsp;page&nbsp;+&nbsp;"页"); List&nbsp;all&nbsp;=&nbsp;ed.getAll(page,&nbsp;pageSize); for&nbsp;(Employee&nbsp;employee&nbsp;:&nbsp;all) { System.out.println(employee); } } &nbsp; @Test public&nbsp;void&nbsp;getMaxSalary()throws&nbsp;Exception{ Double&nbsp;maxSalary&nbsp;=&nbsp;ed.getMaxSalary(); System.out.println("公司最高工资是： "&nbsp;+&nbsp;maxSalary); } &nbsp; @Test public&nbsp;void&nbsp;getAvgSalaryByDid()throws&nbsp;Exception{ Map&nbsp;map&nbsp;=&nbsp;ed.getAvgSalaryByDid(); Set&gt;&nbsp;entrySet&nbsp;=&nbsp;map.entrySet(); for&nbsp;(Entry&nbsp;entry&nbsp;:&nbsp;entrySet) { System.out.println(entry.getKey()+&nbsp;":"&nbsp;+&nbsp;entry.getValue()); } } }&nbsp; </td> 
 </tr> 
 </tbody> 
</table>

## **2****、编写通用的增删改查方法** ##

### **2.1通用的增删改** ###

<table> 
 <tbody> 
 <tr> 
 <td> //通用的更新数据库的方法：insert,update,delete语句时 public static int update(String sql)throws SQLException{ //1、获取连接 Connection conn = JDBCUtils.getConnection(); //2、获取Statement对象，这个对象是用来给服务器传sql并执行sql Statement st = conn.createStatement(); //3、执行sql int len = st.executeUpdate(sql); //4、释放资源 JDBCUtils.closeQuietly(st, conn); return len; } &nbsp; //&nbsp;通用的更新数据库的方法：insert,update,delete语句，允许sql带? public static int update(String sql, Object... args)throws SQLException{ Connection conn = JDBCUtils.getConnection(); int len = update(conn,sql,args); JDBCUtils.closeQuietly(conn); return len; } &nbsp; //&nbsp;通用的更新数据库的方法：insert,update,delete语句，允许sql带? public static int update(Connection conn, String sql, Object... args)throws SQLException{ //2、获取PreparedStatement对象，这个对象是用来sql进行预编译 PreparedStatement pst = conn.prepareStatement(sql); //3、设置sql中的? if(args!=null &amp;&amp; args.length&gt;0){ //数组的下标是从0开始，？的编号是1开始 for (int i = 0; i &lt; args.length; i++) { pst.setObject(i+1, args[i]); } } //4、执行sql int len = pst.executeUpdate(); //5、释放资源 JDBCUtils.closeQuietly(pst); return len; } </td> 
 </tr> 
 </tbody> 
</table>

### **2.2尝试编写通用的查询方法** ###

<table> 
 <tbody> 
 <tr> 
 <td> &nbsp; public static T get(Class clazz,String sql,Object... args)throws Exception{ Connection conn = null; PreparedStatement pst = null; ResultSet rs = null; T entity = null; //1、获取连接 conn = JDBCUtils.getConnection(); //2、获取PreparedStatement对象，并预编译带参数?的SQL pst = conn.prepareStatement(sql); //3、设置参数?的值 if(args!=null &amp;&amp; args.length&gt;0){ for(int i=0;i pst.setObject(i+1, args[i]); } } //4、执行SQL rs = pst.executeQuery(); //5、获取结果，封装到对象中 if(rs.next()){ entity = clazz.newInstance(); } JDBCUtils.free(rs, pst, conn); return entity; } </td> 
 </tr> 
 </tbody> 
</table>

### **2.3****ResultSetMetaData** **类** ###

可用于获取关于 ResultSet 对象中列的类型和属性信息的对象：

**l** **int getColumnCount()**返回当前 ResultSet 对象中的列数。

**l** **String getColumnName(int column)**获取指定列的名称。 数据库中的字段名

**l** **String getColumnLabel(int column)**建议标题通常由 SQL AS 子句来指定。如果未指定 SQL AS，则返回列名

l String getColumnTypeName(int column)：检索指定列的数据库特定的类型名称。

l int getColumnDisplaySize(int column)：指示指定列的最大标准宽度，以字符为单位。

l boolean isNullable(int column)：指示指定列中的值是否可以为 null。

boolean isAutoIncrement(int column)：指示是否自动为指定列进行编号，这样这些列仍然是只读的。

### **2.4 特殊的****SQL** ###

通过给列取别名的方式，来告知数据库的列名与其对应实体的属性名

### **2.5工具类通用的查询一个实体的方法** ###

<table> 
 <tbody> 
 <tr> 
 <td> //通用的查询方法之一：查询一行，即一个对象 &nbsp; public static T get(Class clazz,String sql,Object... args)throws Exception{ //1、注册驱动 //2、获取连接 Connection conn = JDBCUtils.getConnection(); //3、对sql进行预编译 PreparedStatement pst = conn.prepareStatement(sql); //4、设置？ if(args!=null &amp;&amp; args.length&gt;0){ //数组的下标是从0开始，？的编号是1开始 for (int i = 0; i &lt; args.length; i++) { pst.setObject(i+1, args[i]); } } //5、查询 ResultSet rs = pst.executeQuery(); //获取查询的结果集的元数据信息 ResultSetMetaData rsmd = rs.getMetaData(); //这是查询的结果集中，一共有几列 int count = rsmd.getColumnCount(); T t = clazz.newInstance();//要求这个Javabean类型必须有无参构造 while(rs.next()){ //循环每一行有几列 for (int i = 0; i &lt; count; i++) { //第几列的名称 //&nbsp;String columnName = rsmd.getColumnName(i+1); //如果sql中没有取别名，那么就是列名，如果有别名，返回的是别名 String fieldName = rsmd.getColumnLabel(i+1); //该列的值 //&nbsp;Object value = rs.getObject(columnName); Object value = rs.getObject(fieldName); //设置obj对象的某个属性中 Field field = clazz.getDeclaredField(fieldName);//JavaBean的属性名 field.setAccessible(true); field.set(t, value); } } //5、释放资源 //5、释放资源 JDBCUtils.closeQuietly(rs,pst,conn); return t; } </td> 
 </tr> 
 </tbody> 
</table>

### **2.6工具类通用的查询多个实体的方法** ###

<table> 
 <tbody> 
 <tr> 
 <td> //通用的查询方法之二：查询多行，即多个对象 //Class clazz：用来创建实例对象，获取对象的属性，并设置属性值 &nbsp; public static ArrayList getList(Class clazz,String sql,Object... args)throws Exception{ //1、注册驱动，不用了 //2、获取连接 Connection conn = JDBCUtils.getConnection(); //3、对sql进行预编译 PreparedStatement pst = conn.prepareStatement(sql); //4、对？进行设置值 if(args!=null &amp;&amp; args.length&gt;0){ for (int i = 0; i &lt; args.length; i++) { pst.setObject(i+1, args[i]); } } //5、执行sql ResultSet rs = pst.executeQuery(); //获取结果集的元数据 ResultSetMetaData metaData = rs.getMetaData(); //获取结果中总列数 int count = metaData.getColumnCount(); //创建集合对象 ArrayList list = new ArrayList(); while(rs.next()){//遍历的行 //1、每一行是一个对象 T obj = clazz.newInstance(); //2、每一行有很多列 //for的作用是为obj对象的每一个属性设置值 for (int i = 0; i &lt; count; i++) { //(1)每一列的名称 String fieldName = metaData.getColumnLabel(i+1);//获取第几列的名称，如果有别名获取别名，如果没有别名获取列名 //(2)每一列的值 Object value = rs.getObject(i+1);//获取第几列的值 //(3)获取属性对象 Field field = clazz.getDeclaredField(fieldName); //(4)设置可见性 field.setAccessible(true); //(5)设置属性值 field.set(obj, value); } //3、把obj对象放到集合中 list.add(obj); } //6、释放资源 JDBCUtils.closeQuietly(rs,pst,conn); //7、返回结果 return list; } </td> 
 </tr> 
 </tbody> 
</table>

### **2.7工具类通用的查询单值** ###

<table> 
 <tbody> 
 <tr> 
 <td> //通用的查询方法之三：查询单个值 //单值：select max(salary) from employee; &nbsp;&nbsp;一行一列 //select count(*) from t_goods;&nbsp;一共几件商品 public static Object getValue(String sql,Object... args)throws Exception{ //2、获取连接 Connection conn = JDBCUtils.getConnection(); //3、对sql进行预编译 PreparedStatement pst = conn.prepareStatement(sql); //4、对？进行设置值 if(args!=null &amp;&amp; args.length&gt;0){ for (int i = 0; i &lt; args.length; i++) { pst.setObject(i+1, args[i]); } } //5、执行sql ResultSet rs = pst.executeQuery(); Object value = null; if(rs.next()){//一行 value = rs.getObject(1);//一列 } //6、释放资源 JDBCUtils.closeQuietly(rs,pst,conn); return value; } </td> 
 </tr> 
 </tbody> 
</table>

### **2.8工具类通用的查询一行多列，非实体** ###

<table> 
 <tbody> 
 <tr> 
 <td> //通用的查询方法之四：查询多行多列，但每一行又不是一个JavaBean &nbsp; public static List&gt; getListMap(String sql,Object... args)throws Exception{ //2、获取连接 Connection conn = JDBCUtils.getConnection(); //3、对sql进行预编译 PreparedStatement pst = conn.prepareStatement(sql); //4、对？进行设置值 if(args!=null &amp;&amp; args.length&gt;0){ for (int i = 0; i &lt; args.length; i++) { pst.setObject(i+1, args[i]); } } //5、执行sql ResultSet rs = pst.executeQuery(); //获取结果集的元数据对象 ResultSetMetaData metaData = rs.getMetaData(); //一共有几列 int count = metaData.getColumnCount(); //创建List ArrayList&gt; list = new ArrayList&gt;(); while(rs.next()){ //每一行是一个Map的对象 HashMap map = new HashMap(); //map的key是列名 for (int i = 0; i &lt; count; i++) { //（1）获取列名或别名 String columnName = metaData.getColumnLabel(i+1); //（2）获取对应的值 Object value = rs.getObject(i+1); //（3）把这对值放到map中 map.put(columnName, value); } //把map放到List中 list.add(map); } //6、释放资源 JDBCUtils.closeQuietly(rs,pst,conn); return list; } </td> 
 </tr> 
 </tbody> 
</table>

### **2.9工具类通用的查询多行多列，非实体** ###

<table> 
 <tbody> 
 <tr> 
 <td> //通用的查询方法之四：查询一行多列，但一行又不是一个JavaBean public static Map getMap(String sql,Object... args)throws Exception{ List&gt; listMap = getListMap(sql,args); if(listMap.size()&gt;0){ return listMap.get(0); } return null; } </td> 
 </tr> 
 </tbody> 
</table>

# **第7章 数据库连接池** #

## **1****、数据库连接池的必要性** ##

**不使用数据库连接池：**

在使用开发基于数据库的web程序时，**传统的模式**基本是按以下步骤：

l 在主程序（如servlet、beans、DAO）中建立数据库连接。

l 进行sql操作

l 断开数据库连接。

这种模式开发，存在的问题:

l 普通的JDBC数据库连接使用 DriverManager 来获取，每次向数据库建立连接的时候都要将 Connection加载到内存中，再验证IP地址，用户名和密码(得花费0.05s～1s的时间)。需要数据库连接的时候，就向数据库要求一个，执行完成后再断开连接。这样的方式将会消耗大量的资源和时间。**数据库的连接资源并没有得到很好的重复利用**.若同时有几百人甚至几千人在线，频繁的进行数据库连接操作将占用很多的系统资源，严重的甚至会造成服务器的崩溃。

l 对于每一次数据库连接，使用完后都得断开。否则，如果程序出现异常而**未能关闭**，将会导致**数据库系统中的内存泄漏**，最终将导致重启数据库。

l 这种开发不能控制被创建的**连接对象数**，系统资源会被毫无顾及的分配出去，如连接**过多**，也可能导致**内存泄漏，服务器崩溃**。

**数据库连接池的基本思想：**

为解决传统开发中的数据库连接问题，可以采用**数据库连接池技术（connection pool）**。

**数据库连接池的基本思想**就是为数据库连接建立一个“缓冲池”。预先在缓冲池中放入一定数量的连接，当需要建立数据库连接时，只需从“缓冲池”中取出一个，使用完毕之后再放回去。数据库连接池负责分配、管理和释放数据库连接，它**允许应用程序重复使用一个现有的数据库连接，而不是重新建立一个**。

数据库连接池在初始化时将创建一定数量的数据库连接放到连接池中，这些数据库连接的数量是由最小数据库连接数来设定的。无论这些数据库连接是否被使用，连接池都将一直保证至少拥有这么多的连接数量。连接池的最大数据库连接数量限定了这个连接池能占有的最大连接数，当应用程序向连接池请求的连接数超过最大连接数量时，这些请求将被加入到等待队列中。

**数据库连接池技术的优点：**

**l** **资源重用：**

n 由于数据库连接得以重用，避免了频繁创建，释放连接引起的大量性能开销。在减少系统消耗的基础上，另一方面也增加了系统运行环境的平稳性。

**l** **更快的系统反应速度**

n 数据库连接池在初始化过程中，往往已经创建了若干数据库连接置于连接池中备用。此时连接的初始化工作均已完成。对于业务请求处理而言，直接利用现有可用连接，避免了数据库连接初始化和释放过程的时间开销，从而减少了系统的响应时间

**l** **新的资源分配手段**

n 对于多应用共享同一数据库的系统而言，可在应用层通过数据库连接池的配置，实现某一应用最大可用数据库连接数的限制，避免某一应用独占所有的数据库资源

**l** **统一的连接管理，避免数据库连接泄露**

n 在较为完善的数据库连接池实现中，可根据预先的占用超时设定，强制回收被占用连接，从而避免了常规数据库连接操作中可能出现的资源泄露

## **2****、两种开源的数据库连接池** ##

JDBC 的数据库连接池使用 javax.sql.DataSource 来表示，DataSource 只是一个接口，该接口通常由服务器(Weblogic, WebSphere, Tomcat)提供实现，也有一些开源组织提供实现：

l DBCP 数据库连接池

l C3P0 数据库连接池

DataSource 通常被称为数据源，它包含连接池和连接池管理两个部分，习惯上也经常把 DataSource 称为连接池

### **2.1 DBCP数据源** ###

DBCP 是 Apache 软件基金组织下的开源连接池实现，该连接池依赖该组织下的另一个开源系统：Common-pool. 如需使用该连接池实现，应在系统中增加如下两个 jar 文件：

l Commons-dbcp.jar：连接池的实现

l Commons-pool.jar：连接池实现的依赖库

Tomcat 的连接池正是采用该连接池来实现的。该数据库连接池既可以与应用服务器整合使用，也可由应用程序独立使用。

注意：

l 数据源和数据库连接不同，数据源无需创建多个，它是产生数据库连接的工厂，因此整个应用只需要一个数据源即可。

l 当数据库访问结束后，程序还是像以前一样关闭数据库连接：conn.close(); 但conn.close()并没有关闭数据库的物理连接，它仅仅把数据库连接释放，归还给了数据库连接池。

#### **方式一：** ####

#### **示例代码：** ####

**步骤：**

1、加入两个jar

DBCP数据库连接池的的jar：Commons-dbcp.jar

连接池实现的依赖库：Commons-pool.jar，如果不加这个，运行报如下异常

<table> 
 <tbody> 
 <tr> 
 <td> Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/commons/pool/KeyedObjectPoolFactory at com.jdbc.datasource.TestDBCP.main(TestDBCP. Caused by: java.lang.ClassNotFoundException: org.apache.commons.pool.KeyedObjectPoolFactory at at at sun.misc.Launcher$AppClassLoader.loadClass(Unknown Source) at ... 1 more </td> 
 </tr> 
 </tbody> 
</table>

2、编写代码

<table> 
 <tbody> 
 <tr> 
 <td> package com.jdbc.datasource; import java.sql.Connection; import java.sql.SQLException; import org.apache.commons.dbcp.BasicDataSource; public class TestDBCP { public static void main(String[] args) throws SQLException { //1.创建DBCP数据源（即连接池） BasicDataSource ds = new BasicDataSource(); //2.设置数据源的必须属性 ds.setDriverClassName("com.mysql.jdbc.Driver"); ds.setUrl("jdbc:mysql://localhost:3306/test"); ds.setUsername("root"); ds.setPassword("root"); //3.设置数据源的可选属性 //(1)指定数据库连接池中初始化连接数的个数 ds.setInitialSize(10); //(2)指定最大的连接数:&nbsp;同一时刻可以同时向数据库申请的连接数 ds.setMaxActive(50); //(3)在数据库连接池中保存的最少的空闲连接的数量 ds.setMinIdle(2); //(4)等待数据库连接池分配连接的最长时间.&nbsp;单位为毫秒.&nbsp;超出该时间将抛出异常. ds.setMaxWait(1000*5); //4.从数据源中获取数据库连接 Connection conn = ds.getConnection(); System.out.println(conn); } } </td> 
 </tr> 
 </tbody> 
</table>

#### **测试超过连接数** ####

<table> 
 <tbody> 
 <tr> 
 <td> package com.jdbc.datasource; import java.sql.Connection; import java.sql.SQLException; import org.apache.commons.dbcp.BasicDataSource; public class TestDBCP2 { public static void main(String[] args) throws SQLException { //1.创建DBCP数据源（即连接池） BasicDataSource ds = new BasicDataSource(); //2.设置数据源的必须属性 ds.setDriverClassName("com.mysql.jdbc.Driver"); ds.setUrl("jdbc:mysql://localhost:3306/test"); ds.setUsername("root"); ds.setPassword("root"); //3.设置数据源的可选属性 //(1)指定数据库连接池中初始化连接数的个数 ds.setInitialSize(3); //(2)指定最大的连接数:&nbsp;同一时刻可以同时向数据库申请的连接数 ds.setMaxActive(5); //(3)指定最小活跃的连接数:&nbsp;在数据库连接池中保存的最少的空闲连接的数量 ds.setMinIdle(2); //(4)等待数据库连接池分配连接的最长时间.&nbsp;单位为毫秒.&nbsp;超出该时间将抛出异常. ds.setMaxWait(1000*5); //4.从数据源中获取数据库连接 for(int i=0;i&lt;6;i++){ Connection conn = ds.getConnection(); System.out.println("获取第"+(i+1)+"个"+conn); //这里没有关闭，即没有放回连接池 } } } </td> 
 </tr> 
 </tbody> 
</table>

#### **测试如果连接重复使用** ####

<table> 
 <tbody> 
 <tr> 
 <td> package com.jdbc.datasource; import java.sql.Connection; import java.sql.SQLException; import org.apache.commons.dbcp.BasicDataSource; public class TestDBCP3 { public static void main(String[] args) throws SQLException { //1.创建DBCP数据源（即连接池） BasicDataSource ds = new BasicDataSource(); //2.设置数据源的必须属性 ds.setDriverClassName("com.mysql.jdbc.Driver"); ds.setUrl("jdbc:mysql://localhost:3306/test"); ds.setUsername("root"); ds.setPassword("root"); //3.设置数据源的可选属性 //(1)指定数据库连接池中初始化连接数的个数 ds.setInitialSize(3); //(2)指定最大的连接数:&nbsp;同一时刻可以同时向数据库申请的连接数 ds.setMaxActive(5); //(3)指定最小活跃的连接数:&nbsp;在数据库连接池中保存的最少的空闲连接的数量 ds.setMinIdle(2); //(4)等待数据库连接池分配连接的最长时间.&nbsp;单位为毫秒.&nbsp;超出该时间将抛出异常. ds.setMaxWait(1000*5); //4.从数据源中获取数据库连接 for(int i=0;i&lt;10;i++){ new Thread(){ public void run(){ try { Connection conn = ds.getConnection(); System.out.println("获取1个"+conn); Thread.sleep(3000); //隔3秒换回去 conn.close(); } catch (Exception e) { e.printStackTrace(); } } }.start(); } } } </td> 
 </tr> 
 </tbody> 
</table>

#### **方式一：** ####

#### **示例代码：** ####

**步骤：**

1、加入两个jar

DBCP数据库连接池的的jar：Commons-dbcp.jar

连接池实现的依赖库：Commons-pool.jar，如果不加这个，运行报如下异常

2、编写代码

#### **测试超过连接数** ####

<table> 
 <tbody> 
 <tr> 
 <td> package com.jdbc.datasource; import java.sql.Connection; import java.sql.SQLException; import org.apache.commons.dbcp.BasicDataSource; public class TestDBCP2 { public static void main(String[] args) throws SQLException { //1.创建DBCP数据源（即连接池） BasicDataSource ds = new BasicDataSource(); //2.设置数据源的必须属性 ds.setDriverClassName("com.mysql.jdbc.Driver"); ds.setUrl("jdbc:mysql://localhost:3306/test"); ds.setUsername("root"); ds.setPassword("root"); //3.设置数据源的可选属性 //(1)指定数据库连接池中初始化连接数的个数 ds.setInitialSize(3); //(2)指定最大的连接数:&nbsp;同一时刻可以同时向数据库申请的连接数 ds.setMaxActive(5); //(3)指定最小活跃的连接数:&nbsp;在数据库连接池中保存的最少的空闲连接的数量 ds.setMinIdle(2); //(4)等待数据库连接池分配连接的最长时间.&nbsp;单位为毫秒.&nbsp;超出该时间将抛出异常. ds.setMaxWait(1000*5); //4.从数据源中获取数据库连接 for(int i=0;i&lt;6;i++){ Connection conn = ds.getConnection(); System.out.println("获取第"+(i+1)+"个"+conn); //这里没有关闭，即没有放回连接池 } } } </td> 
 </tr> 
 </tbody> 
</table>

#### **测试如果连接重复使用** ####

<table> 
 <tbody> 
 <tr> 
 <td> package com.jdbc.datasource; import java.sql.Connection; import java.sql.SQLException; import org.apache.commons.dbcp.BasicDataSource; public class TestDBCP3 { public static void main(String[] args) throws SQLException { //1.创建DBCP数据源（即连接池） BasicDataSource ds = new BasicDataSource(); //2.设置数据源的必须属性 ds.setDriverClassName("com.mysql.jdbc.Driver"); ds.setUrl("jdbc:mysql://localhost:3306/test"); ds.setUsername("root"); ds.setPassword("root"); //3.设置数据源的可选属性 //(1)指定数据库连接池中初始化连接数的个数 ds.setInitialSize(3); //(2)指定最大的连接数:&nbsp;同一时刻可以同时向数据库申请的连接数 ds.setMaxActive(5); //(3)指定最小活跃的连接数:&nbsp;在数据库连接池中保存的最少的空闲连接的数量 ds.setMinIdle(2); //(4)等待数据库连接池分配连接的最长时间.&nbsp;单位为毫秒.&nbsp;超出该时间将抛出异常. ds.setMaxWait(1000*5); //4.从数据源中获取数据库连接 for(int i=0;i&lt;10;i++){ new Thread(){ public void run(){ try { Connection conn = ds.getConnection(); System.out.println("获取1个"+conn); Thread.sleep(3000); //隔3秒换回去 conn.close(); } catch (Exception e) { e.printStackTrace(); } } }.start(); } } } </td> 
 </tr> 
 </tbody> 
</table>

### **2.2 C3P0数据源** ###

C3P0是一个开源的JDBC连接池，它实现了数据源和JNDI绑定，支持JDBC3规范和JDBC2的标准扩展。目前使用它的开源项目有Hibernate，Spring等。

c3p0与dbcp区别

dbcp没有自动回收空闲连接的功能

c3p0有自动回收空闲连接功能

### **方式一：** ###

步骤：

1、加入jar

如果是c3p0-0.9.1.2版本，加入一个jar即可c3p0-0.9.1.2.jar

如果是c3p0-0.9.2之后的版本，需要加入两个jar：c3p0-0.9.X.jar和mchange-commons-java-XX.jar

2、编写代码

<table> 
 <tbody> 
 <tr> 
 <td> package com.jdbc.datasource; &nbsp; import com.mchange.v2.c3p0.ComboPooledDataSource; &nbsp; public class TestC3P0 { public static void main(String[] args)throws Exception { //1、创建c3p0数据源对象 ComboPooledDataSource ds = new ComboPooledDataSource(); //2、设置必须属性 ds.setDriverClass( "com.mysql.jdbc.Driver" ); ds.setJdbcUrl( "jdbc:mysql://localhost:3306/test" ); ds.setUser("root"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ds.setPassword("root"); //3、获取连接 System.out.println(ds.getConnection()); } } </td> 
 </tr> 
 </tbody> 
</table>

### **方式二：** ###

步骤：

1. 在src目录创建 c3p0-config.xml 文件, 参考帮助文档中 Appendix B: Configuation Files 的内容

2. 创建 ComboPooledDataSource 实例；

DataSource dataSource = new ComboPooledDataSource("helloc3p0");

3. 从 DataSource 实例中获取数据库连接.

<table> 
 <tbody> 
 <tr> 
 <td> package com.jdbc.datasource; &nbsp; import javax.sql.DataSource; &nbsp; import com.mchange.v2.c3p0.ComboPooledDataSource; &nbsp; public class TestC3P02 { public static void main(String[] args)throws Exception { DataSource dataSource = new ComboPooledDataSource("helloc3p0"); &nbsp; System.out.println(dataSource.getConnection()); } } </td> 
 </tr> 
 </tbody> 
</table>

**JDBCUtils修改成c3p0版**

<table> 
 <tbody> 
 <tr> 
 <td> package&nbsp;com.atguigu.utils; &nbsp; import&nbsp;java.sql.Connection; import&nbsp;java.sql.SQLException; &nbsp; import&nbsp;com.mchange.v2.c3p0.ComboPooledDataSource; &nbsp; public&nbsp;class&nbsp;C3p0Utils { //创建数据源，用的是c3p0-config.xml文件中config&gt; private&nbsp;static&nbsp;ComboPooledDataSource&nbsp;dataSource&nbsp;=&nbsp;new&nbsp;ComboPooledDataSource(); &nbsp; //获取数据源对象 public&nbsp;static&nbsp;ComboPooledDataSource getDataSource() { return&nbsp;dataSource; } &nbsp; //获取连接 public&nbsp;static&nbsp;Connection getConnection()&nbsp;throws&nbsp;SQLException{ return&nbsp;dataSource.getConnection(); } } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

# **第8章** **Apache****—****DBUtils****简介** #

commons-dbutils 是 Apache 组织提供的一个开源 JDBC工具类库，它是对JDBC的简单封装，学习成本极低，并且使用dbutils能极大简化jdbc编码的工作量，同时也不会影响程序的性能。

## **1****、****DbUtils****类** ##

DbUtils ：提供如关闭连接、装载JDBC驱动程序等常规工作的工具类，里面的所有方法都是静态的。主要方法如下：

l public static void close(…) throws java.sql.SQLException：　DbUtils类提供了三个重载的关闭方法。这些方法检查所提供的参数是不是NULL，如果不是的话，它们就关闭Connection、Statement和ResultSet。

l public static void closeQuietly(…): 这一类方法不仅能在Connection、Statement和ResultSet为NULL情况下避免关闭，还能隐藏一些在程序中抛出的SQLEeception。

l public static void commitAndClose(Connection conn)throws SQLException 用来提交连接的事务，然后关闭连接

l public static void commitAndCloseQuietly(Connection conn)： 用来提交连接的事务，然后关闭连接，并且在关闭连接时不抛出SQL异常。

l public static void rollback(Connection conn)throws SQLException允许conn为null，因为方法内部做了判断

l public static void rollbackAndClose(Connection conn)throws SQLException

l rollbackAndCloseQuietly(Connection)

l public static boolean loadDriver(java.lang.String driverClassName)：这一方装载并注册JDBC驱动程序，如果成功就返回true。使用该方法，你不需要捕捉这个异常ClassNotFoundException。/2QueryRunner类

该类封装了SQL的执行，是线程安全的。

（1）可以实现增、删、改、查、批处理、

（2）考虑了事务处理需要共用Connection。

（3）该类最主要的就是简单化了SQL查询，它与ResultSetHandler组合在一起使用可以完成大部分的数据库操作，能够大大减少编码量。

QueryRunner类提供了两个构造方法：

l QueryRunner()：默认的构造方法

l QueryRunner(DataSource ds)：需要一个 javax.sql.DataSource 来作参数的构造方法。

### **使用QueryRunner类实现更新（增、删、改、批处理）** ###

#### **（1）更新** ####

public int update(Connection conn, String sql, Object... params) throws SQLException:用来执行一个更新（插入、更新或删除）操作。

public int update(Connection conn, String sql) throws SQLException：用来执行一个不需要置换参数的更新操作。

#### **（2）插入** ####

public T insert(Connection conn,String sql,ResultSetHandler rsh)throws SQLException：其中rsh - The handler used to create the result object from the ResultSet of auto-generated keys. 返回值: An object generated by the handler.即自动生成的键值

public T insert(Connection conn,String sql,ResultSetHandler rsh, Object... params) throws SQLException：只支持INSERT

public T insert(String sql,ResultSetHandler rsh)throws SQLException：只支持INSERT

public T insert(String sql,ResultSetHandler rsh,Object... params)throws SQLException：只支持INSERT

#### **（3）批处理** ####

public int\[\] batch(Connection conn,String sql,Object\[\]\[\] params)throws SQLException：INSERT, UPDATE, or DELETE语句

public int\[\] batch(String sql,Object\[\]\[\] params)throws SQLException： INSERT, UPDATE, or DELETE语句

public T insertBatch(Connection conn,String sql,ResultSetHandler rsh,Object\[\]\[\] params)throws SQLException：只支持INSERT

public T insertBatch(String sql,ResultSetHandler rsh,Object\[\]\[\] params)throws SQLException：只支持INSERT

#### **（****4）是否需要传递****Connection****？** ####

A：不需要传递Connection对象：

前提是不考虑事务而且QueryRunner对象创建时指定数据源，这样在QueryRunner的所有增删改查方法中都会从数据源中自己获取连接

B：必须传递Connection对象

如果有事务，必须传递Connection对象，因为同一个事务的多条语句必须在一个Connection连接中完成

<table> 
 <tbody> 
 <tr> 
 <td> public static void main(String[] args) throws Exception{ //1、通过数据库连接池来获取连接 DataSource ds = new ComboPooledDataSource("mypool"); //2、传sql，并执行，并接收结果 String sql = "insert into t_goods(pname,price,description)values(?,?,?)"; QueryRunner qr = new QueryRunner(ds); int len = qr.update(sql, "电源",78,"充电必备");//自己到数据库连接池中拿连接 System.out.println(len&gt;0?"添加成功":"添加失败"); } </td> 
 </tr> 
 <tr> 
 <td> public&nbsp;static&nbsp;void&nbsp;main(String[]&nbsp;args)throws&nbsp;Exception{ //1、通过数据库连接池来获取连接 DataSource&nbsp;ds&nbsp;=&nbsp;new&nbsp;ComboPooledDataSource("mypool"); QueryRunner&nbsp;qr&nbsp;=&nbsp;new&nbsp;QueryRunner(); //从web页面传过来，有这样的数据 int&nbsp;uid&nbsp;= 1; int[]&nbsp;pids&nbsp;= {5,6,7}; int[]&nbsp;amount&nbsp;= {1,1,1}; double[]&nbsp;price&nbsp;= {560,58,68}; String&nbsp;sql1&nbsp;=&nbsp;"insert into t_order(ordertime,sumprice,uid)values(now(),?,?)"; String&nbsp;sql2&nbsp;=&nbsp;"insert into t_detail(oid,pid,amount)values(?,?,?）"; //2、获取连接 Connection&nbsp;conn&nbsp;= &nbsp;null; try&nbsp;{ conn&nbsp;=&nbsp;ds.getConnection(); conn.setAutoCommit(false);//手动提交事务 double&nbsp;sumprice&nbsp;= 0; for(int&nbsp;i=0;&nbsp;i&lt;&lt;/span&gt;amount.length;&nbsp;i++){ sumprice&nbsp;+=&nbsp;amount[i] *&nbsp;price[i]; } //返回的是自增的键值 Object&nbsp;object&nbsp;=&nbsp;qr.insert(conn,&nbsp;sql1,&nbsp;new&nbsp;ScalarHandler(),&nbsp;sumprice,uid); Object[][]&nbsp;params&nbsp;&nbsp;=&nbsp;new&nbsp;Object[pids.length][3]; for(int&nbsp;i=0;i&lt;&lt;/span&gt;params.length;i++){ for(int&nbsp;j=0;&nbsp;j&lt;&lt;/span&gt;params[i].length;&nbsp;j++){ params[i][0] =&nbsp;object;//订单编号 params[i][1] =&nbsp;pids[i];//产品编号 params[i][2] =&nbsp;amount[i];//每一件产品的数量 } } qr.insertBatch(conn,&nbsp;sql2,&nbsp;new&nbsp;ScalarHandler(),&nbsp;params);//如果没有自增的键值，那么返回值是null //提交事务 conn.commit(); }&nbsp;catch&nbsp;(Exception&nbsp;e) { //回滚事务 if(conn!=null){ conn.rollback(); } }&nbsp;finally{ if(conn!=null){ //在关闭之前，要设置conn的事务方式为自动提交 conn.setAutoCommit(true); //关闭连接 DbUtils.closeQuietly(conn); } } } </td> 
 </tr> 
 <tr> 
 <td> &nbsp; 使用QueryRunner类实现查询 </td> 
 </tr> 
 </tbody> 
</table>

l public Object query(Connection conn, String sql, ResultSetHandler rsh,Object... params) throws SQLException：执行一个查询操作，在这个查询中，对象数组中的每个元素值被用来作为查询语句的置换参数。该方法会自行处理 PreparedStatement 和 ResultSet 的创建和关闭。

l public Object query(String sql, ResultSetHandler rsh, Object... params) throws SQLException:　几乎与第一种方法一样；唯一的不同在于它不将数据库连接提供给方法，并且它是从提供给构造方法的数据源(DataSource) 或使用的setDataSource 方法中重新获得 Connection。

l public Object query(Connection conn, String sql, ResultSetHandler rsh) throws SQLException : 执行一个不需要置换参数的查询操作。

l public Object query( String sql, ResultSetHandler rsh) throws SQLException : 执行一个不需要置换参数的查询操作。

#### **ResultSetHandler接口** ####

该接口用于处理 java.sql.ResultSet，将数据按要求转换为另一种形式。

ResultSetHandler 接口提供了一个单独的方法：Object handle (java.sql.ResultSet rs)

该方法的返回值将作为QueryRunner类的query()方法的返回值。

<table> 
 <tbody> 
 <tr> 
 <td> @Test public void testResultSetHandler() { // 1.创建QueryRunner的实例 QueryRunner qr = new QueryRunner(); &nbsp; Connection conn = null; &nbsp; try { // 2.获取连接 conn = JDBCTools.getConnection(); class MyResultSetHandler implements ResultSetHandler{ @Override public Object handle(ResultSet rs) throws SQLException { Student stu = new Student(); if (rs.next()) { stu.setId(rs.getInt(1)); stu.setSname(rs.getString(2)); stu.setSex(rs.getString(3)); stu.setMajor(rs.getString(4)); stu.setClasses(rs.getString(5)); } return stu; } } &nbsp; String sql = "select sno,sname,sex,major,classes from t_stu where sno =?"; // 3、使用query方法 // QueryRunner&nbsp;的&nbsp;query&nbsp;方法的返回值取决于其&nbsp;ResultSetHandler&nbsp;参数的handle&nbsp;方法的返回值 Object obj = qr.query(conn, sql, new MyResultSetHandler(),1); &nbsp; System.out.println(obj); } catch (SQLException e) { e.printStackTrace(); } finally { JDBCTools.free(null, null, conn); } } </td> 
 </tr> 
 </tbody> 
</table>

l ArrayHandler：把结果集中的第一行数据转成对象数组。

l ArrayListHandler：把结果集中的每一行数据都转成一个数组，再存放到List中。

l BeanHandler：将结果集中的第一行数据封装到一个对应的JavaBean实例中。

l BeanListHandler：将结果集中的每一行数据都封装到一个对应的JavaBean实例中，存放到List里。

l ColumnListHandler：将结果集中某一列的数据存放到List中。

l KeyedHandler(name)：将结果集中的每一行数据都封装到一个Map里，再把这些map再存到一个map里，其key为指定的key。

l MapHandler：将结果集中的第一行数据封装到一个Map里，key是列名，value就是对应的值。

l MapListHandler：将结果集中的每一行数据都封装到一个Map里，然后再存放到List

#### **BeanHandler实现类** ####

<table> 
 <tbody> 
 <tr> 
 <td> &nbsp; public static void main(String[] args) throws SQLException { //1、连接池 DataSource ds = new ComboPooledDataSource("mypool"); //2、直接使用QueryRunner QueryRunner qr = new QueryRunner(ds); String sql = "select pid as id,pname,price,description from t_goods where pid =?"; Goods goods = qr.query(sql, new BeanHandler(Goods.class), 1); System.out.println(goods); } </td> 
 </tr> 
 </tbody> 
</table>

#### **BeanListHandler实现类** ####

<table> 
 <tbody> 
 <tr> 
 <td> &nbsp; public static void main(String[] args) throws SQLException { //1、连接池 DataSource ds = new ComboPooledDataSource("mypool"); //2、直接使用QueryRunner QueryRunner qr = new QueryRunner(ds); String sql = "select pid as id,pname,price,description from t_goods"; List query = qr.query(sql, new BeanListHandler(Goods.class)); for (Goods goods : query) { System.out.println(goods); } } </td> 
 </tr> 
 </tbody> 
</table>

#### **MapHandler实现类** ####

<table> 
 <tbody> 
 <tr> 
 <td> public static void main(String[] args) throws SQLException { // 1、连接池 DataSource ds = new ComboPooledDataSource("mypool"); // 2、直接使用QueryRunner QueryRunner qr = new QueryRunner(ds); String sql = "select did,count(*) from employee where did = 1"; Map map = qr.query(sql, new MapHandler()); Set&gt; entrySet = map.entrySet(); for (Entry entry : entrySet) { // System.out.println(entry.getKey() +"--&gt;" + entry.getValue()); if ("did".equals(entry.getKey())) { System.out.println("部门编号：" + entry.getValue()); } else { System.out.println("人数：" + entry.getValue()); } } } </td> 
 </tr> 
 </tbody> 
</table>

#### **MapListHandler实现类** ####

<table> 
 <tbody> 
 <tr> 
 <td> public static void main(String[] args) throws SQLException { //1、连接池 DataSource ds = new ComboPooledDataSource("mypool"); //2、直接使用QueryRunner QueryRunner qr = new QueryRunner(ds); String sql = "select did,count(*) from employee group by did"; List&gt; query = qr.query(sql, new MapListHandler()); for (Map map : query) { Set&gt; entrySet = map.entrySet(); for (Entry entry : entrySet) { //System.out.println(entry.getKey() +"--&gt;" + entry.getValue()); if("did".equals(entry.getKey())){ System.out.println("部门编号：" + entry.getValue()); }else{ System.out.println("人数：" + entry.getValue()); } } } } </td> 
 </tr> 
 </tbody> 
</table>

#### **ScalarHandler实现类** ####

<table> 
 <tbody> 
 <tr> 
 <td> &nbsp; @Test public static void main(String[] args) throws SQLException { //1、连接池 DataSource ds = new ComboPooledDataSource("mypool"); //2、直接使用QueryRunner QueryRunner qr = new QueryRunner(ds); //&nbsp;String sql = "select count(*) from t_goods"; String sql = "select max(price) from t_goods"; Object query = qr.query(sql, new ScalarHandler()); System.out.println(query); } </td> 
 </tr> 
 </tbody> 
</table>

## **2****、****JDBC****修改成****DbUtils****版** ##

<table> 
 <tbody> 
 <tr> 
 <td> package&nbsp;com.atguigu.utils; &nbsp; import&nbsp;java.sql.Connection; import&nbsp;java.sql.ResultSet; import&nbsp;java.sql.SQLException; import&nbsp;java.sql.Statement; &nbsp; import&nbsp;org.apache.commons.dbutils.DbUtils; &nbsp; import&nbsp;com.mchange.v2.c3p0.ComboPooledDataSource; &nbsp; public&nbsp;class&nbsp;DBUtilsTool { //创建数据源，用的是c3p0-config.xml文件中config&gt; private&nbsp;static&nbsp;ComboPooledDataSource&nbsp;dataSource&nbsp;=&nbsp;new&nbsp;ComboPooledDataSource(); &nbsp; //获取数据源对象 public&nbsp;static&nbsp;ComboPooledDataSource getDataSource() { return&nbsp;dataSource; } &nbsp; //获取连接 public&nbsp;static&nbsp;Connection getConnection()&nbsp;throws&nbsp;SQLException{ return&nbsp;dataSource.getConnection(); } &nbsp; public&nbsp;static&nbsp;void&nbsp;closeQuietly(Connection&nbsp;conn){ DbUtils.closeQuietly(conn); } &nbsp; public&nbsp;static&nbsp;void&nbsp;closeQuietly(Statement&nbsp;st){ DbUtils.closeQuietly(st); } &nbsp; public&nbsp;static&nbsp;void&nbsp;closeQuietly(ResultSet&nbsp;rs){ DbUtils.closeQuietly(rs); } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

## **应用案例演示：书城项目** ##

package com.lxl.test;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.Statement;
    
    import org.junit.Test;
    
    /*
     * 
     * 通过Java连接MySQL数据库的步骤：
     *     1.1 将MySQL的驱动包导入到项目中
     *     1.2 对jar包右键，build path，将其添加到编译环境中
     *     1.3 加载MySQL的驱动类：已经创建了Driver驱动对象
     *     1.4 通过DriverManager获取数据库连接
     * 
     */
    
    public class JDBCTest01 {
        
        @Test
        public void testConn() throws Exception {
            //1.加载驱动类  com.mysql.cj.jdbc.Driver: 将Driver类的对象 注册到DriverManager类中，以便使用
            Class.forName("com.mysql.cj.jdbc.Driver");
            
            //2.获取数据库连接：类似于sqlyog连接mysql：必须通过主机地址端口号，账户，密码连接
            Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306?useSSL=false&serverTimezone=UTC", "root", "123456");
            
            //3.使用数据库连接
            System.out.println(conn);
            
            //4.关闭数据库连接：MySQL数据库默认只有101个连接
            conn.close();
            
        }
        
        //向数据库插入数据
        @Test
        public void testInsert() throws Exception {
            //1.加载驱动类  com.mysql.cj.jdbc.Driver: 将Driver类的对象 注册到DriverManager类中，以便使用
            Class.forName("com.mysql.cj.jdbc.Driver");
            
            //2.获取数据库连接：类似于sqlyog连接mysql：必须通过主机地址端口号，账户，密码连接
            Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/ziliaoku?useSSL=false&serverTimezone=UTC", "root", "123456");
            
            //3.插入数据
            //获取发送sql命令的对象 Statement
            Statement sm = conn.createStatement();
            String sql = "INSERT INTO output_table VALUES(11, 'xiaobai', 24)";
            long i = sm.executeLargeUpdate(sql);
            System.out.println(i>0?"插入成功":"插入失败");
            
            //执行增删改：int sm.executeUpdate(String sql);
            //执行查询：sm.executeQuery(String sql);
            //4.关闭数据库连接
            sm.close();
            conn.close();
            
        }
        
        //更新数据
        @Test
        public void testUpdate() throws Exception {
            //1.加载驱动类  com.mysql.cj.jdbc.Driver: 将Driver类的对象 注册到DriverManager类中，以便使用
            Class.forName("com.mysql.cj.jdbc.Driver");
            
            //2.获取数据库连接：类似于sqlyog连接mysql：必须通过主机地址端口号，账户，密码连接
            Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/ziliaoku?useSSL=false&serverTimezone=UTC", "root", "123456");
            
            //3.更新数据
            String sql = "UPDATE output_table SET name='xiaohong' WHERE ID=2";
            Statement sm = conn.createStatement();
            long i = sm.executeLargeUpdate(sql);
            System.out.println(i);
            
            //4.关闭资源
            sm.close();
            conn.close();
            
            
            
            
                    
        }
        
        //删除数据库中的数据
        
        
        //查询一条记录
        @Test
        public void testQuerOne() throws Exception {
            //1.加载驱动类  com.mysql.cj.jdbc.Driver: 将Driver类的对象 注册到DriverManager类中，以便使用
            Class.forName("com.mysql.cj.jdbc.Driver");
            
            //2.获取数据库连接：类似于sqlyog连接mysql：必须通过主机地址端口号，账户，密码连接
            Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/myemployees?useSSL=false&serverTimezone=UTC", "root", "123456");
            
            //3.通过SQL命令发送器，执行查询SQL，得到查询的结果集
            Statement sm = conn.createStatement();
            String sql = "SELECT * FROM employees WHERE employee_id=100";
            ResultSet rs = sm.executeQuery(sql);
            
            //4.解析结果集
            //rs.next();//游标默认停留在第一行数据上，将游标移动到下一行，如果下一行有数据则返回true，如果没有返回false；
            if(rs.next()){ //rs.getXxx(); 可以通过列的索引位置获取该列的数据，也可以通过列名称获取该列的数据
                int e_id = rs.getInt(1);
                String ename = rs.getString("first_name");
                Object tel = rs.getObject("phone_number");
                System.out.println("员工id：" + e_id + "，员工姓名：" + ename + "，电话号码：" + tel);
            }
            
            //4.关闭资源
            sm.close();
            conn.close();
            
            
        }
        
        //查询多条记录
        
        
        
    }

转载于:https://www.cnblogs.com/LXL616/p/10953076.html