1 概述

在Java中，數(shù)據(jù)庫存取技術可分為如下幾類：

• JDBC直接訪問數(shù)據(jù)庫
• JDO技術（Java Data Object）
• 第三方O/R工具，如Hibernate, Mybatis 等
  JDBC是java訪問數(shù)據(jù)庫的基石，JDO, Hibernate等只是更好的封裝了JDBC。

1.1 什么是JDBC

JDBC(Java Database Connectivity)是一個獨立于特定數(shù)據(jù)庫管理系統(tǒng)（DBMS）、通用的SQL數(shù)據(jù)庫存取和操作的公共接口（一組API），定義了用來訪問數(shù)據(jù)庫的標準Java類庫，使用這個類庫可以以一種標準的方法、方便地訪問數(shù)據(jù)庫資源
JDBC為訪問不同的數(shù)據(jù)庫提供了一種統(tǒng)一的途徑 ，為開發(fā)者屏蔽了一些細節(jié)問題。
JDBC的目標是使Java程序員使用JDBC可以連接任何提供了JDBC驅(qū)動程序的數(shù)據(jù)庫系統(tǒng)，這樣就使得程序員無需對特定的數(shù)據(jù)庫系統(tǒng)的特點有過多的了解，從而大大簡化和加快了開發(fā)過程。

2 JDBC程序編寫步驟

• 注冊驅(qū)動
• 獲取連接
• 執(zhí)行增刪改查
• 釋放資源

2.1 演示完整步驟

準備工作：引入JDBC驅(qū)動程序

驅(qū)動程序由數(shù)據(jù)庫提供商提供下載。 MySQL的驅(qū)動下載地址：http://dev.mysql.com/downloads/
以此點擊Connector/J→選擇Platform Independent→下載.zip文件→下載好的zip里的jar就是要的jar

• （1）把mysql-connector-java-8.0.21.jar拷貝到項目中l(wèi)ib目錄中
  

• （2）添加到項目的類路徑下
  在驅(qū)動jar上右鍵–>Build Path–>Add to Build Path
  

注意：如果是Dynamic Web Project（動態(tài)的web項目）話，則是把驅(qū)動jar放到WebContent（有的開發(fā)工具叫WebRoot）目錄中的WEB-INF目錄中的lib目錄下即可

（一）加載并注冊驅(qū)動

加載并注冊驅(qū)動：
加載驅(qū)動，把驅(qū)動類加載到內(nèi)存
注冊驅(qū)動，把驅(qū)動類的對象交給DriverManager管理，用于后面創(chuàng)建連接等使用。

• 1、Class.forName( )

DriverManager.registerDriver(new Driver());//這是舊方法 Class.forName("com.mysql.cj.jdbc.Driver");//這是新方法

因為 Driver 接口的驅(qū)動程序類都包含了靜態(tài)代碼塊，在這個靜態(tài)代碼塊中，會調(diào)用 DriverManager.registerDriver() 方法來注冊自身的一個實例，所以可以換一種方式來加載驅(qū)動。（即只要想辦法讓驅(qū)動類的這段靜態(tài)代碼塊執(zhí)行即可注冊驅(qū)動類，而要讓這段靜態(tài)代碼塊執(zhí)行，只要讓該類被類加載器加載即可）

調(diào)用 Class 類的靜態(tài)方法 forName()，向其傳遞要加載的 JDBC 驅(qū)動的類名
//通過反射，加載與注冊驅(qū)動類，解耦合（不直接依賴）
Class.forName(“com.mysql.jdbc.Driver”);

• 2、服務提供者框架（例如：JDBC的驅(qū)動程序）自動注冊（有版本要求）
  符合JDBC 4.0規(guī)范的驅(qū)動程序包含了一個文件META-INF/services/java.sql.Driver，在這個文件中提供了JDBC驅(qū)動實現(xiàn)的類名。例如：mysql-connector-java-5.1.40-bin.jar文件中就可以找到java.sql.Driver文件，用文本編輯器打開文件就可以看到：com.mysql.jdbc.Driver類。
  
  JVM的服務提供者框架在啟動應用時就會注冊服務，例如：MySQL的JDBC驅(qū)動就會被注冊，而原代碼中的Class.forName(“com.mysql.jdbc.Driver”)仍然可以存在，但是不會起作用。
  但是注意mysql-connector-java-5.0.8-bin.jar版本的jar中沒有，如下
  

（二）獲取數(shù)據(jù)庫鏈接

可以通過 DriverManager 類建立到數(shù)據(jù)庫的連接Connection：
DriverManager 試圖從已注冊的 JDBC 驅(qū)動程序集中選擇一個適當?shù)尿?qū)動程序。

- public static Connection getConnection(String url) - public static Connection getConnection(String url,String user, String password) - public static Connection getConnection(String url,Properties info)其中Properties info通常至少應該包括 "user" 和 "password" 屬性

例如：

Connection connection=DriverManager.getConnection("jdbc:mysql://localhost:3306/girls?serverTimezone=UTC","root","root");

JDBC URL 用于標識一個被注冊的驅(qū)動程序，驅(qū)動程序管理器通過這個 URL 選擇正確的驅(qū)動程序，從而建立到數(shù)據(jù)庫的連接。JDBC URL的標準由三部分組成，各部分間用冒號分隔。
jdbc:<子協(xié)議>:<子名稱>

• 協(xié)議：JDBC URL中的協(xié)議總是jdbc
• 子協(xié)議：子協(xié)議用于標識一個數(shù)據(jù)庫驅(qū)動程序
• 子名稱：一種標識數(shù)據(jù)庫的方法。子名稱可以依不同的子協(xié)議而變化，用子名稱的目的是為了定位數(shù)據(jù)庫提供足夠的信息
  例如：
  
  MySQL的連接URL編寫方式：

jdbc:mysql://主機名稱:mysql服務端口號/數(shù)據(jù)庫名稱?參數(shù)=值&參數(shù)=值 jdbc:mysql://localhost:3306/testdb jdbc:mysql://localhost:3306/testdb?useUnicode=true&characterEncoding=utf8（如果JDBC程序與服務器端的字符集不一致，會導致亂碼，那么可以通過參數(shù)指定服務器端的字符集） jdbc:mysql://localhost:3306/testdb?user=root&password=123456 "jdbc:mysql://localhost:3306/girls?serverTimezone=UTC","root","root"

MySQL的連接URL之利用properties文件
在src下新建一個文件：jdbc.properties

（三）操作或訪問數(shù)據(jù)庫

數(shù)據(jù)庫連接被用于向數(shù)據(jù)庫服務器發(fā)送命令和 SQL 語句，并接受數(shù)據(jù)庫服務器返回的結(jié)果。
其實一個數(shù)據(jù)庫連接就是一個Socket連接。
在 java.sql 包中有 3 個接口分別定義了對數(shù)據(jù)庫的調(diào)用的不同方式：

• Statement：用于執(zhí)行靜態(tài) SQL 語句并返回它所生成結(jié)果的對象。
• PrepatedStatement：SQL 語句被預編譯并存儲在此對象中，然后可以使用此對象多次高效地執(zhí)行該語句。
• CallableStatement：用于執(zhí)行 SQL 存儲過程

3.1Statement

通過調(diào)用 Connection 對象的 createStatement() 方法創(chuàng)建該對象
該對象用于執(zhí)行靜態(tài)的 SQL 語句，并且返回執(zhí)行結(jié)果
Statement 接口中定義了下列方法用于執(zhí)行 SQL 語句：
- int excuteUpdate(String sql)：執(zhí)行更新操作INSERT、UPDATE、DELETE，返回值為被改變的行數(shù)
- ResultSet excuteQuery(String sql)：執(zhí)行查詢操作SELECT

executeUpdate

package mysql;import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement;import com.mysql.jdbc.Driver;public class sqltest {public static void main(String[] args) throws SQLException, ClassNotFoundException {//1 加載驅(qū)動//DriverManager.registerDriver(new Driver());Class.forName("com.mysql.cj.jdbc.Driver");//2.獲取連接Connection connection=DriverManager.getConnection("jdbc:mysql://localhost:3306/girls?serverTimezone=UTC","root","root");//3.執(zhí)行增刪改查//3-1 編寫sql語句String sql="UPDATE boys SET boyName='盧本偉' where id=1";//3-2 獲取執(zhí)行sql語句的執(zhí)行對象Statement statement= connection.createStatement();//3-3 使用命令對象指向sql語句int update=statement.executeUpdate(sql);//這一句只能增刪改，返回受影響行數(shù)//3-4處理執(zhí)行結(jié)果System.out.println(update>0?"yes":"no");//4 關閉連接,后開先關閉，對稱statement.close();connection.close();}}

ResultSet

通過調(diào)用 Statement 對象的 excuteQuery() 方法創(chuàng)建該對象
ResultSet 對象以邏輯表格的形式封裝了執(zhí)行數(shù)據(jù)庫操作的結(jié)果集，ResultSet 接口由數(shù)據(jù)庫廠商實現(xiàn)
ResultSet 對象維護了一個指向當前數(shù)據(jù)行的游標，初始的時候，游標在第一行之前一行，可以通過 ResultSet 對象的 next() 方法移動到下一行
ResultSet 接口的常用方法：

• boolean next()
• getXxx(String columnLabel)：columnLabel使用 SQL AS 子句指定的列標簽。如果未指定 SQL AS 子句，則標簽是列名稱
• getXxx(int index) :索引從1開始
  

package mysql;import java.sql.Connection; import java.sql.Date; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement;import com.mysql.jdbc.Driver;public class sqltest {public static void main(String[] args) throws SQLException, ClassNotFoundException {//1 加載驅(qū)動//DriverManager.registerDriver(new Driver());Class.forName("com.mysql.cj.jdbc.Driver");//2.獲取連接Connection connection=DriverManager.getConnection("jdbc:mysql://localhost:3306/girls?serverTimezone=UTC","root","root");//3.執(zhí)行增刪改查//3-1 編寫sql語句String sql="select id,name,sex,borndate from beauty";//3-2 獲取執(zhí)行sql語句的執(zhí)行對象Statement statement= connection.createStatement();//3-3 使用命令對象指向sql語句ResultSet set=statement.executeQuery(sql);boolean flag= set.next();int id = set.getInt("id");String name = set.getString("name");String sex = set.getString("sex");Date date = set.getDate("borndate");System.out.println(id+"\t"+name+"\t"+sex+"\t"+date);//4 關閉連接,后開先關閉，對稱set.close();statement.close();connection.close();}}

3.2 PrepatedStatement

可以通過調(diào)用 Connection 對象的 preparedStatement(String sql) 方法獲取 PreparedStatement 對象
PreparedStatement 接口是 Statement 的子接口，它表示一條預編譯過的 SQL 語句

• PreparedStatement 對象所代表的 SQL 語句中的參數(shù)用問號(?)來表示，調(diào)用 PreparedStatement 對象的 setXxx() 方法來設置這些參數(shù). setXxx() 方法有兩個參數(shù)，第一個參數(shù)是要設置的 SQL 語句中的參數(shù)的索引(從 1 開始)，第二個是設置的 SQL 語句中的參數(shù)的值
• ResultSet executeQuery()執(zhí)行查詢，并返回該查詢生成的 ResultSet 對象。
• int executeUpdate()：執(zhí)行更新，包括增、刪、改

↑來驗證賬戶密碼會導致sql注入問題，因為如果兩個參數(shù)中含有’ "等符號，會出現(xiàn)語法錯誤


↑就可以避免sql注入問題

2.2 封裝JDBCUtils.java

因為很多步驟都是重復的，所以可以將重復的操作封裝起來

import java.io.FileInputStream; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.Properties;/*** 此類是封裝JDBC連接的工具類* * 功能：* 1、獲取連接* 2、釋放資源**/ public class JDBCUtils {static String user;static String password;static String url;static String driver;static{try {Properties info = new Properties();info.load(new FileInputStream("src\\jdbc.properties"));user = info.getProperty("user");password = info.getProperty("password");url = info.getProperty("url");driver = info.getProperty("driver");//1.注冊驅(qū)動Class.forName(driver);} catch (Exception e) {throw new RuntimeException(e);}}/*** 功能：獲取可用的連接對象* @return 連接* @throws Exception*/public static Connection getConnection(){try {return DriverManager.getConnection(url, user, password);} catch (Exception e) {throw new RuntimeException(e);}}/*** 功能：釋放資源* @param set* @param statement* @param connection* @throws Exception*/public static void close(ResultSet set,Statement statement,Connection connection){try {if (set!=null) {set.close();//如果是查詢操作，需要關閉set，否則這里傳個null}if (statement!=null) {statement.close();}if (connection!=null) {connection.close();}} catch (SQLException e) {throw new RuntimeException(e);}}}

至此以下為完整步驟

3 JDBC事務

package com.atguigu.jdbc2;import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException;import org.junit.Test;import com.atguigu.jdbc1.JDBCUtils;/*** 此類用于演示JDBC中的事務* @author liyuting* * 使用步驟：* 1、開啟新事務* 取消隱式事務自動提交的功能* setAutoCommit(false);* 2、編寫組成事務的一組sql語句* * 3、結(jié)束事務* commit();提交* rollback();回滾* * 細節(jié)：* 要求開啟事務的連接對象和獲取命令的連接對象必須是同一個！否則事務無效* * * * * * 案例：轉(zhuǎn)賬案例* 張三豐給滅絕轉(zhuǎn)5000* **/ public class TestTransaction {//不用事務@Testpublic void testNoTransaction() throws Exception{//1.獲取連接Connection connection = JDBCUtils.getConnection();//2.執(zhí)行sql語句PreparedStatement statement = connection.prepareStatement("update account set balance = ? where stuname=?");//操作1：張三豐的錢-5000statement.setDouble(1, 5000);statement.setString(2, "張三豐");statement.executeUpdate();int i = 1/0;//模擬異常//操作2：張三豐的錢-5000statement.setDouble(1, 15000);statement.setString(2, "滅絕師太");statement.executeUpdate();//3.釋放資源JDBCUtils.close(null, statement, connection);}//使用事務@Testpublic void testTransaction(){Connection connection = null;PreparedStatement statement = null;try {//1.獲取連接connection = JDBCUtils.getConnection();//①事務的使用步驟1：開啟事務，意思是取消每條語句自動commitconnection.setAutoCommit(false);//②事務的使用步驟2：編寫sql語句，并且執(zhí)行statement = connection.prepareStatement("update account set balance = ? where stuname=?");//操作1：張三豐的錢-5000statement.setDouble(1, 5000);statement.setString(2, "張三豐");statement.executeUpdate();// int i = 1/0;//模擬異常//操作2：張三豐的錢-5000statement.setDouble(1, 15000);statement.setString(2, "滅絕師太");statement.executeUpdate();//③事務的使用步驟3：結(jié)束事務connection.commit();} catch (SQLException e) {try {//回滾事務connection.rollback();} catch (SQLException e1) {e1.printStackTrace();}}finally{JDBCUtils.close(null, statement, connection);}}}

4 批處理

當需要成批插入或者更新記錄時?？梢圆捎肑ava的批量更新機制，這一機制允許多條語句一次性提交給數(shù)據(jù)庫批量處理。通常情況下比單獨提交處理更有效率。
JDBC的批量處理語句包括下面兩個方法：

• addBatch()：添加需要批量處理的SQL語句或參數(shù)
• executeBatch()：執(zhí)行批量處理語句；
• clearBatch():清空批處理包的語句
  分為兩種情況：

多條SQL語句的批量處理；

一個SQL語句的批量傳參；

5 Blob類型數(shù)據(jù)

MySQL中，BLOB是一個二進制大型對象，是一個可以存儲大量數(shù)據(jù)的容器，它能容納不同大小的數(shù)據(jù)。能夠存
MySQL的四種BLOB類型(除了在存儲的最大信息量上不同外，他們是等同的)
實際使用中根據(jù)需要存入的數(shù)據(jù)大小定義不同的BLOB類型。
需要注意的是：如果存儲的文件過大，數(shù)據(jù)庫的性能會下降

package com.atguigu.jdbc2;import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.InputStream; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;import org.junit.Test;import com.atguigu.jdbc1.JDBCUtils;/*** 此類用于演示Blob類型數(shù)據(jù)的存取* @author liyuting* 相關API：* * setBlob(占位符索引，InputStream對象)* getBlob(列索引或列名)* getBinaryStream(列索引或列名)* */ public class TestBlob {//存圖片@Testpublic void testSave() throws SQLException, Exception{//1.獲取連接Connection connection = JDBCUtils.getConnection();//2.執(zhí)行修改語句PreparedStatement statement = connection.prepareStatement("update beauty set photo=? where id = 1");statement.setBlob(1, new FileInputStream("src\\6.jpg"));int update = statement.executeUpdate();//3.關閉連接JDBCUtils.close(null, statement, connection);}//讀圖片@Testpublic void testRead() throws SQLException, Exception{//1.獲取連接Connection connection = JDBCUtils.getConnection();//2.執(zhí)行修改語句PreparedStatement statement = connection.prepareStatement("select photo from beauty where id = 1");ResultSet set = statement.executeQuery();if(set.next()){//方式1： // Blob blob = set.getBlob("photo"); // InputStream binaryStream = blob.getBinaryStream();//方式2：InputStream inputStream = set.getBinaryStream("photo");FileOutputStream fos = new FileOutputStream("src\\beauty.jpg");int len;byte[] b = new byte[1024];while((len=inputStream.read(b))!=-1){fos.write(b,0,len);}fos.close();inputStream.close();}//3.關閉連接JDBCUtils.close(null, statement, connection);} }

6 數(shù)據(jù)庫連接池

（1）數(shù)據(jù)庫連接池的必要性
不使用數(shù)據(jù)庫連接池存在的問題:

• 普通的JDBC數(shù)據(jù)庫連接使用 DriverManager 來獲取，每次向數(shù)據(jù)庫建立連接的時候都要將 Connection 加載到內(nèi)存中，再驗證IP地址，用戶名和密碼(得花費0.05s～1s的時間)。需要數(shù)據(jù)庫連接的時候，就向數(shù)據(jù)庫要求一個，執(zhí)行完成后再斷開連接。這樣的方式將會消耗大量的資源和時間。數(shù)據(jù)庫的連接資源并沒有得到很好的重復利用.若同時有幾百人甚至幾千人在線，頻繁的進行數(shù)據(jù)庫連接操作將占用很多的系統(tǒng)資源，嚴重的甚至會造成服務器的崩潰。
• 對于每一次數(shù)據(jù)庫連接，使用完后都得斷開。否則，如果程序出現(xiàn)異常而未能關閉，將會導致數(shù)據(jù)庫系統(tǒng)中的內(nèi)存泄漏，最終將導致重啟數(shù)據(jù)庫。
• 這種開發(fā)不能控制被創(chuàng)建的連接對象數(shù)，系統(tǒng)資源會被毫無顧及的分配出去，如連接過多，也可能導致內(nèi)存泄漏，服務器崩潰。
  為解決傳統(tǒng)開發(fā)中的數(shù)據(jù)庫連接問題，可以采用數(shù)據(jù)庫連接池技術（connection pool）。

數(shù)據(jù)庫連接池的基本思想就是為數(shù)據(jù)庫連接建立一個“緩沖池”。預先在緩沖池中放入一定數(shù)量的連接，當需要建立數(shù)據(jù)庫連接時，只需從“緩沖池”中取出一個，使用完畢之后再放回去。數(shù)據(jù)庫連接池負責分配、管理和釋放數(shù)據(jù)庫連接，它允許應用程序重復使用一個現(xiàn)有的數(shù)據(jù)庫連接，而不是重新建立一個。連接池的最大數(shù)據(jù)庫連接數(shù)量限定了這個連接池能占有的最大連接數(shù)，當應用程序向連接池請求的連接數(shù)超過最大連接數(shù)量時，這些請求將被加入到等待隊列中。

數(shù)據(jù)庫連接池技術的優(yōu)點：

• 資源重用：
  • 由于數(shù)據(jù)庫連接得以重用，避免了頻繁創(chuàng)建，釋放連接引起的大量性能開銷。在減少系統(tǒng)消耗的基礎上，另一方面也增加了系統(tǒng)運行環(huán)境的平穩(wěn)性。
• 更快的系統(tǒng)反應速度
  • 數(shù)據(jù)庫連接池在初始化過程中，往往已經(jīng)創(chuàng)建了若干數(shù)據(jù)庫連接置于連接池中備用。此時連接的初始化工作均已完成。對于業(yè)務請求處理而言，直接利用現(xiàn)有可用連接，避免了數(shù)據(jù)庫連接初始化和釋放過程的時間開銷，從而減少了系統(tǒng)的響應時間
• 新的資源分配手段
  • 對于多應用共享同一數(shù)據(jù)庫的系統(tǒng)而言，可在應用層通過數(shù)據(jù)庫連接池的配置，實現(xiàn)某一應用最大可用數(shù)據(jù)庫連接數(shù)的限制，避免某一應用獨占所有的數(shù)據(jù)庫資源
• 統(tǒng)一的連接管理，避免數(shù)據(jù)庫連接泄露
  • 在較為完善的數(shù)據(jù)庫連接池實現(xiàn)中，可根據(jù)預先的占用超時設定，強制回收被占用連接，從而避免了常規(guī)數(shù)據(jù)庫連接操作中可能出現(xiàn)的資源泄露

（2）多種開源的數(shù)據(jù)庫連接池
JDBC 的數(shù)據(jù)庫連接池使用 javax.sql.DataSource 來表示，DataSource 只是一個接口，該接口通常由服務器(Weblogic, WebSphere, Tomcat)提供實現(xiàn)，也有一些開源組織提供實現(xiàn)：

• DBCP 是Apache提供的數(shù)據(jù)庫連接池，速度相對c3p0較快，但因自身存在BUG，Hibernate3已不再提供支持
• C3P0 是一個開源組織提供的一個數(shù)據(jù)庫連接池，速度相對較慢，穩(wěn)定性還可以
• Proxool 是sourceforge下的一個開源項目數(shù)據(jù)庫連接池，有監(jiān)控連接池狀態(tài)的功能，穩(wěn)定性較c3p0差一點
• BoneCP 是一個開源組織提供的數(shù)據(jù)庫連接池，速度快
• Druid是阿里提供的數(shù)據(jù)庫連接池，據(jù)說是集DBCP 、C3P0 、Proxool 優(yōu)點于一身的數(shù)據(jù)庫連接池，但是速度不知道是否有BoneCP快
  DataSource 通常被稱為數(shù)據(jù)源，它包含連接池和連接池管理兩個部分，習慣上也經(jīng)常把 DataSource 稱為連接池
  注意：
• 數(shù)據(jù)源和數(shù)據(jù)庫連接不同，數(shù)據(jù)源無需創(chuàng)建多個，它是產(chǎn)生數(shù)據(jù)庫連接的工廠，因此整個應用只需要一個數(shù)據(jù)源即可。
• 當數(shù)據(jù)庫訪問結(jié)束后，程序還是像以前一樣關閉數(shù)據(jù)庫連接：conn.close(); 但conn.close()并沒有關閉數(shù)據(jù)庫的物理連接，它僅僅把數(shù)據(jù)庫連接釋放，歸還給了數(shù)據(jù)庫連接池。
  （3）Druid（德魯伊）數(shù)據(jù)源
  Druid是阿里巴巴開源平臺上一個數(shù)據(jù)庫連接池實現(xiàn)，它結(jié)合了C3P0、DBCP、Proxool等DB池的優(yōu)點，同時加入了日志監(jiān)控，可以很好的監(jiān)控DB池連接和SQL的執(zhí)行情況，可以說是針對監(jiān)控而生的DB連接池，據(jù)說是目前最好的連接池。

方式一

package com.atguigu.druid;import java.sql.Connection;import com.alibaba.druid.pool.DruidDataSource;public class TestDruid {public static void main(String[] args) throws Exception {DruidDataSource ds = new DruidDataSource();ds.setUrl("jdbc:mysql://localhost:3306/0319db");ds.setUsername("root");ds.setPassword("123456");ds.setDriverClassName("com.mysql.jdbc.Driver");ds.setInitialSize(10);//默認值0，應該在maxActive和minIdle之間ds.setMaxActive(20);//默認值8ds.setMinIdle(1);//默認值0//maxIdle是Druid為了方便DBCP用戶遷移而增加的，maxIdle是一個混亂的概念。連接池只應該有maxPoolSize和minPoolSize，druid只保留了maxActive和minIdle，分別相當于maxPoolSize和minPoolSize。ds.setMaxIdle(5);// 獲取連接時最大等待時間，單位毫秒。配置了maxWait之后，缺省啟用公平鎖，并發(fā)效率會有所下降，如果需要可以通過配置useUnfairLock屬性為true使用非公平鎖。ds.setMaxWait(1000);//配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接，單位是毫秒ds.setTimeBetweenEvictionRunsMillis(60000);//配置一個連接在池中最小生存的時間，單位是毫秒ds.setMinEvictableIdleTimeMillis(300000);//是否緩存preparedStatement，也就是PSCache。PSCache對支持游標的數(shù)據(jù)庫性能提升巨大，比如說oracle。在mysql下建議關閉。ds.setPoolPreparedStatements(true);// 要啟用PSCache，必須配置大于0，當大于0時，poolPreparedStatements自動觸發(fā)修改為true。在Druid中，不會存在Oracle下PSCache占用內(nèi)存過多的問題，可以把這個數(shù)值配置大一些，比如說100ds.setMaxPoolPreparedStatementPerConnectionSize(10);//配置多個英文逗號分隔//通過別名的方式配置擴展插件，常用的插件有： 監(jiān)控統(tǒng)計用的filter:stat日志用的filter:log4j防御sql注入的filter:wallds.setFilters("stat,wall");Connection conn = ds.getConnection();System.out.println(conn);} }

方式二，使用properties文件

package com.atguigu.utils;import java.io.FileInputStream; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.Properties;import javax.sql.DataSource;import com.alibaba.druid.pool.DruidDataSourceFactory;/*** 此類是通過德魯伊數(shù)據(jù)庫連接池獲取連接對象* @author liyuting**/ public class JDBCUtilsByDruid {static DataSource ds;static{try {Properties properties = new Properties();properties.load(new FileInputStream("src\\druid.properties"));//1.創(chuàng)建了一個指定參數(shù)的數(shù)據(jù)庫連接池ds = DruidDataSourceFactory.createDataSource(properties);} catch (Exception e) {e.printStackTrace();}}public static Connection getConnection() throws Exception{//2.從數(shù)據(jù)庫連接池中獲取可用的連接對象return ds.getConnection();}/*** 功能：釋放資源* @param set* @param statement* @param connection* @throws Exception*/public static void close(ResultSet set,Statement statement,Connection connection){try {if (set!=null) {set.close();}if (statement!=null) {statement.close();}if (connection!=null) {connection.close();}} catch (SQLException e) {throw new RuntimeException(e);}} }

properties文件👇

url=jdbc:mysql://localhost:3306/0319db username=root password=123456 driverClassName=com.mysql.jdbc.Driver initialSize=10 maxActive=20 maxWait=1000 filters=wall 配置缺省說明

name		配置這個屬性的意義在于，如果存在多個數(shù)據(jù)源，監(jiān)控的時候可以通過名字來區(qū)分開來。 如果沒有配置，將會生成一個名字，格式是：”DataSource-” + System.identityHashCode(this)
jdbcUrl		連接數(shù)據(jù)庫的url，不同數(shù)據(jù)庫不一樣。例如：mysql : jdbc:mysql://10.20.153.104:3306/druid2 oracle : jdbc:oracle:thin:@10.20.149.85:1521:ocnauto
username		連接數(shù)據(jù)庫的用戶名
password		連接數(shù)據(jù)庫的密碼。如果你不希望密碼直接寫在配置文件中，可以使用ConfigFilter。詳細看這里：https://github.com/alibaba/druid/wiki/%E4%BD%BF%E7%94%A8ConfigFilter
driverClassName		根據(jù)url自動識別 這一項可配可不配，如果不配置druid會根據(jù)url自動識別dbType，然后選擇相應的driverClassName(建議配置下)
initialSize	0	初始化時建立物理連接的個數(shù)。初始化發(fā)生在顯示調(diào)用init方法，或者第一次getConnection時
maxActive	8	最大連接池數(shù)量
maxIdle	8	已經(jīng)不再使用，配置了也沒效果
minIdle		最小連接池數(shù)量
maxWait		獲取連接時最大等待時間，單位毫秒。配置了maxWait之后，缺省啟用公平鎖，并發(fā)效率會有所下降，如果需要可以通過配置useUnfairLock屬性為true使用非公平鎖。
poolPreparedStatements	false	是否緩存preparedStatement，也就是PSCache。PSCache對支持游標的數(shù)據(jù)庫性能提升巨大，比如說oracle。在mysql下建議關閉。
maxOpenPreparedStatements		-1
validationQuery		用來檢測連接是否有效的sql，要求是一個查詢語句。如果validationQuery為null，testOnBorrow、testOnReturn、testWhileIdle都不會其作用。
testOnBorrow	true	申請連接時執(zhí)行validationQuery檢測連接是否有效，做了這個配置會降低性能。
testOnReturn	false	歸還連接時執(zhí)行validationQuery檢測連接是否有效，做了這個配置會降低性能
testWhileIdle	false	建議配置為true，不影響性能，并且保證安全性。申請連接的時候檢測，如果空閑時間大于timeBetweenEvictionRunsMillis，執(zhí)行validationQuery檢測連接是否有效。
timeBetweenEvictionRunsMillis		有兩個含義： 1)Destroy線程會檢測連接的間隔時間2)testWhileIdle的判斷依據(jù)，詳細看testWhileIdle屬性的說明
numTestsPerEvictionRun		不再使用，一個DruidDataSource只支持一個EvictionRun
minEvictableIdleTimeMillis
connectionInitSqls		物理連接初始化的時候執(zhí)行的sql
exceptionSorter		根據(jù)dbType自動識別 當數(shù)據(jù)庫拋出一些不可恢復的異常時，拋棄連接
filters		屬性類型是字符串，通過別名的方式配置擴展插件，常用的插件有： 監(jiān)控統(tǒng)計用的filter:stat日志用的filter:log4j防御sql注入的filter:wall
proxyFilters		類型是List，如果同時配置了filters和proxyFilters，是組合關系，并非替換關系

7 利用Druid的CRUD封裝

import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.util.ArrayList; import java.util.List;import com.atguigu.bean.Boys;/*** 此類用于封裝通用的增刪改查方法* @author liyuting* 功能：* 1、執(zhí)行增刪改* 2、執(zhí)行查詢* * */ public class CRUDUtils {/*** 功能：增刪改* 針對于任何表的任何增刪改語句* @return* @throws Exception */public static int update(String sql,Object...params){try {//1.獲取連接Connection connection = JDBCUtilsByDruid.getConnection();//2.執(zhí)行sql語句PreparedStatement statement = connection.prepareStatement(sql);for (int i = 0; i < params.length; i++) {statement.setObject(i+1, params[i]);}int update = statement.executeUpdate();return update;} catch (Exception e) {throw new RuntimeException(e);}}/*** orm：object relation mapping* @param sql* @param params* @return* * 只針對Boys表，查詢單條* @throws Exception */public static Boys querySingle(String sql,Object...params) throws Exception{Connection connection=null;PreparedStatement statement=null;ResultSet set = null;try {//1.獲取連接connection = JDBCUtilsByDruid.getConnection();//2.執(zhí)行查詢statement = connection.prepareStatement(sql);for (int i = 0; i < params.length; i++) {statement.setObject(i+1, params[i]);}set = statement.executeQuery();if(set.next()){int id = set.getInt("id");String boyName = set.getString("boyname");int userCP = set.getInt("userCP");Boys bo = new Boys(id,boyName,userCP);return bo;}return null;} catch (Exception e) {throw new RuntimeException(e);}finally{JDBCUtilsByDruid.close(set, statement, connection);}}/*** orm：object relation mapping* @param sql* @param params* @return* * 只針對Boys表，查詢多條* @throws Exception */public static List<Boys> queryMulti(String sql,Object...params) throws Exception{Connection connection=null;PreparedStatement statement=null;ResultSet set = null;try {//1.獲取連接connection = JDBCUtilsByDruid.getConnection();//2.執(zhí)行查詢statement = connection.prepareStatement(sql);for (int i = 0; i < params.length; i++) {statement.setObject(i+1, params[i]);}set = statement.executeQuery();List<Boys> list = new ArrayList<>();while(set.next()){int id = set.getInt("id");String boyName = set.getString("boyname");int userCP = set.getInt("userCP");Boys bo = new Boys(id,boyName,userCP);list.add(bo);}return list;} catch (Exception e) {throw new RuntimeException(e);}finally{JDBCUtilsByDruid.close(set, statement, connection);}}}

boys類👇

package com.atguigu.bean;public class Boys {private int id;private String boyName;private int userCP;public Boys() {super();}@Overridepublic String toString() {return "Boys [id=" + id + ", boyName=" + boyName + ", userCP=" + userCP + "]";}public int getId() {return id;}public void setId(int id) {this.id = id;}public String getBoyName() {return boyName;}public void setBoyName(String boyName) {this.boyName = boyName;}public int getUserCP() {return userCP;}public void setUserCP(int userCP) {this.userCP = userCP;}public Boys(int id, String boyName, int userCP) {super();this.id = id;this.boyName = boyName;this.userCP = userCP;}}

👇調(diào)用實例

package com.atguigu.utils;import java.util.List;import org.junit.Test;import com.atguigu.bean.Boys;public class TestCRUDUtils {@Testpublic void testUpdate(){// int update = CRUDUtils.update("update beauty set sex = ? where name='柳巖'", "男"); // // System.out.println(update>0?"success":"failure");int update = CRUDUtils.update("delete from admin where id>5");System.out.println(update>0?"success":"failure");}@Testpublic void testQuery() throws Exception{ // Boys boy = CRUDUtils.querySingle("select * from boys where id = ?", 2); // System.out.println(boy);List<Boys> list = CRUDUtils.queryMulti("select * from boys");for (Boys boys : list) {System.out.println(boys);}}}

8 DBUtils

commons-dbutils是 Apache 組織提供的一個開源 JDBC工具類庫，它是對JDBC的簡單封裝，學習成本極低，并且使用dbutils能極大簡化jdbc編碼的工作量，同時也不會影響程序的性能。
1、DbUtils類
DbUtils ：提供如關閉連接、裝載JDBC驅(qū)動程序等常規(guī)工作的工具類，里面的所有方法都是靜態(tài)的。主要方法如下：

• public static void close(…) throws java.sql.SQLException：　DbUtils類提供了三個重載的關閉方法。這些方法檢查所提供的參數(shù)是不是NULL，如果不是的話，它們就關閉Connection、Statement和ResultSet。
• public static void closeQuietly(…): 這一類方法不僅能在Connection、Statement和ResultSet為NULL情況下避免關閉，還能隱藏一些在程序中拋出的SQLEeception。
• public static void commitAndClose(Connection conn)throws SQLException 用來提交連接的事務，然后關閉連接
• public static void commitAndCloseQuietly(Connection conn)： 用來提交連接的事務，然后關閉連接，并且在關閉連接時不拋出SQL異常。
• public static void rollback(Connection conn)throws SQLException允許conn為null，因為方法內(nèi)部做了判斷
• public static void rollbackAndClose(Connection conn)throws SQLException
• rollbackAndCloseQuietly(Connection)
• public static boolean loadDriver(java.lang.String driverClassName)：這一方裝載并注冊JDBC驅(qū)動程序，如果成功就返回true。使用該方法，你不需要捕捉這個異常ClassNotFoundException。

2、QueryRunner類
該類封裝了SQL的執(zhí)行，是線程安全的。
（1）可以實現(xiàn)增、刪、改、查、批處理、
（2）考慮了事務處理需要共用Connection。
（3）該類最主要的就是簡單化了SQL查詢，它與ResultSetHandler組合在一起使用可以完成大部分的數(shù)據(jù)庫操作，能夠大大減少編碼量。
QueryRunner類提供了兩個構造方法：

• QueryRunner()：默認的構造方法
• QueryRunner(DataSource ds)：需要一個 javax.sql.DataSource 來作參數(shù)的構造方法。
  （1）更新
• public int update(Connection conn, String sql, Object… params) throws SQLException:用來執(zhí)行一個更新（插入、更新或刪除）操作。
  （2）插入
• public T insert(Connection conn,String sql,ResultSetHandler rsh, Object… params) throws SQLException：只支持INSERT語句，其中 rsh - The handler used to create the result object from the ResultSet of auto-generated keys. 返回值: An object generated by the handler.即自動生成的鍵值
  （3）批處理
• public int[] batch(Connection conn,String sql,Object[][] params)throws SQLException： INSERT, UPDATE, or DELETE語句
• public T insertBatch(Connection conn,String sql,ResultSetHandler rsh,Object[][] params)throws SQLException：只支持INSERT語句
  （4）使用QueryRunner類實現(xiàn)查詢
• public Object query(Connection conn, String sql, ResultSetHandler rsh,Object… params) throws SQLException：執(zhí)行一個查詢操作，在這個查詢中，對象數(shù)組中的每個元素值被用來作為查詢語句的置換參數(shù)。該方法會自行處理 PreparedStatement 和 ResultSet 的創(chuàng)建和關閉。
  3、ResultSetHandler接口
  該接口用于處理 java.sql.ResultSet，將數(shù)據(jù)按要求轉(zhuǎn)換為另一種形式。ResultSetHandler 接口提供了一個單獨的方法：Object handle (java.sql.ResultSet rs)該方法的返回值將作為QueryRunner類的query()方法的返回值。
  該接口有如下實現(xiàn)類可以使用：
• ArrayHandler：把結(jié)果集中的第一行數(shù)據(jù)轉(zhuǎn)成對象數(shù)組。
• ArrayListHandler：把結(jié)果集中的每一行數(shù)據(jù)都轉(zhuǎn)成一個數(shù)組，再存放到List中。
• BeanHandler：將結(jié)果集中的第一行數(shù)據(jù)封裝到一個對應的JavaBean實例中。
• BeanListHandler：將結(jié)果集中的每一行數(shù)據(jù)都封裝到一個對應的JavaBean實例中，存放到List里。
• ColumnListHandler：將結(jié)果集中某一列的數(shù)據(jù)存放到List中。
• KeyedHandler(name)：將結(jié)果集中的每一行數(shù)據(jù)都封裝到一個Map里，再把這些map再存到一個map里，其key為指定的key。
• MapHandler：將結(jié)果集中的第一行數(shù)據(jù)封裝到一個Map里，key是列名，value就是對應的值。
• MapListHandler：將結(jié)果集中的每一行數(shù)據(jù)都封裝到一個Map里，然后再存放到List
  4、表與JavaBean
  
  👇舉例代碼

package com.atguigu.jdbc4;import java.sql.Connection; import java.util.List;import org.apache.commons.dbutils.QueryRunner; import org.apache.commons.dbutils.handlers.BeanHandler; import org.apache.commons.dbutils.handlers.BeanListHandler; import org.apache.commons.dbutils.handlers.ScalarHandler; import org.junit.Test;import com.atguigu.utils.Admin; import com.atguigu.utils.Boys; import com.atguigu.utils.JDBCUtilsByDruid;/*** 此類用于演示DBUtils的使用* @author liyuting* 功能：封裝了和數(shù)據(jù)庫存取相關的一些方法* 通用的增刪改查等等* * QueryRunner類：* update(connection，sql，params):執(zhí)行任何增刪改語句* query(connection,sql,ResultSetHandler,params)：執(zhí)行任何查詢語句* ResultSetHandler接口* BeanHandler:將結(jié)果集的第一行，封裝成對象，并返回 new BeanHandler<>(XX.class)* BeanListHandler:將結(jié)果集中的所有行，封裝成對象的集合，并返回 new BeanListHandler<>(XX.class)* ScalarHandler:將結(jié)果集中的第一行第一列，以Object形式返回 new ScalarHandler()* * * 使用步驟：* * 1、導入jar包commons-dbutils-1.3.jar* 2、看幫助* 3、使用**/ public class TestDBUtils {@Testpublic void testUpadte() throws Exception{//1.獲取連接Connection connection = JDBCUtilsByDruid.getConnection();//2.執(zhí)行增刪改QueryRunner qr = new QueryRunner();int update = qr.update(connection, "update boys set boyname=? where id=4", "慕容復");System.out.println(update>0?"success":"failure");//3.關閉連接JDBCUtilsByDruid.close(null, null, connection);}@Testpublic void testQuerySingle() throws Exception{//1.獲取連接Connection connection = JDBCUtilsByDruid.getConnection();//2.執(zhí)行增刪改QueryRunner qr = new QueryRunner();// Admin admin = qr.query(connection, "select * from admin where id=?", new BeanHandler<>(Admin.class),3); // System.out.println(admin);Boys boys = qr.query(connection, "select * from boys where usercp=?", new BeanHandler<>(Boys.class),300);System.out.println(boys);//3.關閉連接JDBCUtilsByDruid.close(null, null, connection);}@Testpublic void testQueryMulti() throws Exception{//1.獲取連接Connection connection = JDBCUtilsByDruid.getConnection();//2.執(zhí)行增刪改QueryRunner qr = new QueryRunner();// Admin admin = qr.query(connection, "select * from admin where id=?", new BeanHandler<>(Admin.class),3); // System.out.println(admin);List<Admin> list2 = qr.query(connection, "select * from admin", new BeanListHandler<>(Admin.class));for (Admin admin : list2) {System.out.println(admin);} // // List<Boys> list = qr.query(connection, "select * from boys where usercp>?", new BeanListHandler<>(Boys.class),10); // // for (Boys boys : list) { // System.out.println(boys); // }//3.關閉連接JDBCUtilsByDruid.close(null, null, connection);}@Testpublic void testScalar() throws Exception{//1.獲取連接Connection connection = JDBCUtilsByDruid.getConnection();//2.執(zhí)行查詢單個值QueryRunner qr = new QueryRunner();Object query = qr.query(connection, "select * from admin", new ScalarHandler());System.out.println(query);//3.關閉JDBCUtilsByDruid.close(null, null, connection);}}

9 DAO和增刪改查通用方法

DAO：Data Access Object訪問數(shù)據(jù)信息的類和接口，包括了對數(shù)據(jù)的CRUD（Create、Retrival、Update、Delete），而不包含任何業(yè)務相關的信息
作用：為了實現(xiàn)功能的模塊化，更有利于代碼的維護和升級。

import java.sql.Connection; import java.sql.SQLException; import java.util.List;import org.apache.commons.dbutils.QueryRunner; import org.apache.commons.dbutils.handlers.BeanHandler; import org.apache.commons.dbutils.handlers.BeanListHandler; import org.apache.commons.dbutils.handlers.ScalarHandler;import com.atguigu.utils.JDBCUtilsByDruid;public class BasicDao<T> {QueryRunner qr = new QueryRunner();/** 功能： 通用的增刪改方法，針對于任何表*/public int update(String sql,Object...param){Connection connection = null;try {connection = JDBCUtilsByDruid.getConnection();int update = qr.update(connection, sql, param);return update;} catch (Exception e) {throw new RuntimeException(e);}finally{JDBCUtilsByDruid.close(null, null, connection);}}/*** 功能：返回單個對象，針對于任何表* @param sql* @param clazz* @param params* @return*/public T querySingle(String sql,Class<T> clazz,Object...params){Connection connection = null;try {connection = JDBCUtilsByDruid.getConnection();//執(zhí)行查詢return qr.query(connection, sql, new BeanHandler<T>(clazz), params);} catch (Exception e) {throw new RuntimeException(e);}finally{JDBCUtilsByDruid.close(null, null, connection);}}/*** 功能：返回多個對象，針對于任何表* @param sql* @param clazz* @param params* @return*/public List<T> queryMulti(String sql,Class<T> clazz,Object...params){Connection connection = null;try {connection = JDBCUtilsByDruid.getConnection();//執(zhí)行查詢return qr.query(connection, sql, new BeanListHandler<T>(clazz), params);} catch (Exception e) {throw new RuntimeException(e);}finally{JDBCUtilsByDruid.close(null, null, connection);}}/*** 功能：返回單個值* @param sql* @param params* @return*/public Object scalar(String sql,Object...params){Connection connection = null;try {connection = JDBCUtilsByDruid.getConnection();//執(zhí)行查詢return qr.query(connection, sql, new ScalarHandler(),params);} catch (Exception e) {throw new RuntimeException(e);}finally{JDBCUtilsByDruid.close(null, null, connection);}}}

👆只是基礎的增刪查改，適合于任何的類，還需要對每一張表定義一個實體類，然后用不同的類DAO繼承basicdao

比如說adminDAO，Admin指定了泛型

package com.atguigu.dao;import com.atguigu.bean.Admin;public class AdminDao extends BasicDao<Admin> { }

然后再AdminService里面

package com.atguigu.service;import com.atguigu.dao.AdminDao;public class AdminService {AdminDao dao = new AdminDao();public boolean login(String username,String password){Long count = (Long)dao.scalar("select count(*) from admin where username=? and password=?", username,password);return count>0;}}

👇最后再在view層調(diào)用

package com.atguigu.view;import java.util.Scanner;import com.atguigu.service.AdminService;public class StudentView {AdminService as = new AdminService();public static void main(String[] args) {new StudentView().login();}public void login(){Scanner input = new Scanner(System.in);System.out.println("請輸入用戶名：");String username = input.next();System.out.println("請輸入密碼：");String password = input.next();if( as.login(username, password)){System.out.println("登錄成功！");showMainMenu();}else{System.out.println("登錄失敗！");}}/*** 功能：顯示主菜單*/private void showMainMenu() {System.out.println("顯示主菜單");} }

總結(jié)

以上是生活随笔為你收集整理的JDBC入门的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。