1.JDBC概述

?

JDBC（Java Data Base Connectivity,java數據庫連接）是一種用于執行SQL語句的Java API，可以為多種關系數據庫提供統一訪問，它由一組用Java語言編寫的類和接口組成。是Java訪問數據庫的標準規范

JDBC提供了一種基準,據此可以構建更高級的工具和接口，使數據庫開發人員能夠編寫數據庫應用程序。

JDBC需要連接驅動，驅動是兩個設備要進行通信，滿足一定通信數據格式，數據格式由設備提供商規定，設備提供商為設備提供驅動軟件，通過軟件可以與該設備進行通信。

2.JDBC原理

Java提供訪問數據庫規范稱為JDBC，而生產廠商提供規范的實現類稱為驅動。

????????

JDBC是接口，驅動是接口的實現，沒有驅動將無法完成數據庫連接，從而不能操作數據庫！每個數據庫廠商都需要提供自己的驅動，用來連接自己公司的數據庫，也就是說驅動一般都由數據庫生成廠商提供。

3.案例數據準備

CREATE TABLE sort(sid INT PRIMARY KEY AUTO_INCREMENT,sname VARCHAR(100),sprice DOUBLE,sdesc VARCHAR(5000) ); #初始化數據 INSERT INTO sort(sname,sprice,sdesc) VALUES('家電',2000,'優惠的促銷'), ('家具',8900,'家具價格上調,原材料漲價'), ('兒童玩具',300,'賺家長錢'), ('生鮮',500.99,'生鮮商品'), ('服裝',24000,'換季銷售'), ('洗滌',50,'洗發水促銷');

4.JDBC開發步驟

注冊驅動.

獲得連接.

獲得語句執行平臺

執行sql語句

處理結果

釋放資源.

4.1導入驅動jar包

創建lib目錄，用于存放當前項目需要的所有jar包

選擇jar包，右鍵執行build path / Add to Build Path

4.2注冊驅動

?

代碼：Class.forName("com.mysql.jdbc.Driver");

JDBC規范定義驅動接口：java.sql.Driver，MySql驅動包提供了實現類：com.mysql.jdbc.Driver

DriverManager工具類，提供注冊驅動的方法 registerDriver()，方法的參數是java.sql.Driver，所以我們可以通過如下語句進行注冊:

DriverManager.registerDriver(new com.mysql.jdbc.Driver());

以上代碼不推薦使用，存在兩方面不足

硬編碼，后期不易于程序擴展和維護

驅動被注冊兩次。

通常開發我們使用Class.forName() 加載一個使用字符串描述的驅動類。

如果使用Class.forName()將類加載到內存，該類的靜態代碼將自動執行。

通過查詢com.mysql.jdbc.Driver源碼，我們發現Driver類“主動”將自己進行注冊

4.3獲得鏈接

代碼：Connection con = DriverManager.getConnection
(“jdbc:mysql://localhost:3306/mydb”,”root”,”123456”);

獲取連接需要方法 DriverManager.getConnection(url,username,password)，三個參數分別表示，url 需要連接數據庫的位置（網址） user用戶名? password 密碼

4.4獲得語句執行平臺

?

?

String sql = "某SQL語句";

獲取Statement語句執行平臺：Statement stmt = con.createStatement();

???????? 常用方法：

• int executeUpdate(String sql); --執行insert update delete語句.
• ResultSet executeQuery(String sql); --執行select語句.
• boolean execute(String sql); --執行select返回true 執行其他的語句返回false.

4.5處理結果集（執行insert、update、delete無需處理）

ResultSet實際上就是一張二維的表格，我們可以調用其boolean next()方法指向某行記錄，當第一次調用next()方法時，便指向第一行記錄的位置，這時就可以使用ResultSet提供的getXXX(int col)方法(與索引從0開始不同個，列從1開始)來獲取指定列的數據：

• rs.next();//指向第一行
• rs.getInt(1);//獲取第一行第一列的數據

常用方法：

• Object getObject(int index) / Object getObject(String name) 獲得任意對象
• String getString(int index) / Object getObject(String name) 獲得字符串
• nt getInt(int index) / Object getObject(String name) 獲得整形
• double getDouble(int index) / Object getObject(String name) 獲得雙精度浮點型

4.6釋放資源

與IO流一樣，使用后的東西都需要關閉！關閉的順序是先得到的后關閉，后得到的先關閉。

• rs.close();
• stmt.close();
• con.close();

package cn.jxufe.java.chapter11.demo01;import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement;/*JDBC操作數據庫的步驟* 1. 注冊驅動.* 告知JVM是哪一個的數據庫的驅動2. 獲得連接.使用JDBC中的類完成對MYSQL的連接3. 獲得語句執行平臺通過連接對象獲取對SQL語句的執行者對象4. 執行sql語句使用執行這對象，向數據庫執行SQL語句獲取到數據庫的執行后的結果5. 處理結果6. 釋放資源.close（） */ public class Test01JDBC {public static void main(String[] args) throws ClassNotFoundException, SQLException {// TODO Auto-generated method stub// 1.注冊驅動 反射技術,將驅動類加入到內容// 使用java.sql.DriverManager類靜態方法 registerDriver(Driver driver)// Diver是一個接口,參數傳遞,MySQL驅動程序中的實現類// DriverManager.registerDriver(new Driver());// 驅動類源代碼,注冊2次驅動程序Class.forName("com.mysql.jdbc.Driver");// 2.獲得數據庫連接 DriverManager類中靜態方法// static Connection getConnection(String url, String user, String password)// 返回值是Connection接口的實現類,在mysql驅動程序// url: 數據庫地址 jdbc:mysql://連接主機IP:端口號/數據庫名字String url = "jdbc:mysql://localhost:3306/mydatabase";String username = "root";String password = "123456";Connection con = DriverManager.getConnection(url, username, password);// 3.獲得語句執行平臺, 通過數據庫連接對象,獲取到SQL語句的執行者對象// con對象調用方法 Statement createStatement() 獲取Statement對象,將SQL語句發送到數據庫// 返回值是 Statement接口的實現類對象,,在mysql驅動程序 Statement stat = con.createStatement();// 4.執行sql語句// 通過執行者對象調用方法執行SQL語句,獲取結果// int executeUpdate(String sql) 執行數據庫中的SQL語句, insert delete update// 返回值int,操作成功數據表多少行int row = stat.executeUpdate("INSERT INTO sort(sname,sprice,sdesc) VALUES('汽車用品',50000,'瘋狂漲價')");System.out.println(row);// 6.釋放資源 一堆close() stat.close();con.close();}}

package cn.jxufe.java.chapter11.demo01;import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement;/** JDBC技術,查詢數據表,獲取結果集*/ public class Test02JDBC {public static void main(String[] args) throws ClassNotFoundException, SQLException {// TODO Auto-generated method stub// 1. 注冊驅動Class.forName("com.mysql.jdbc.Driver");// 2. 獲取連接對象String url = "jdbc:mysql://localhost:3306/mydatabase";String username = "root";String password = "123456";Connection con = DriverManager.getConnection(url, username, password);// 3 .獲取執行SQL 語句對象Statement stat = con.createStatement();// 拼寫查詢的SQLString sql = "SELECT * FROM sort";// 4. 調用執行者對象方法,執行SQL語句獲取結果集// ResultSet executeQuery(String sql) 執行SQL語句中的select查詢// 返回值ResultSet接口的實現類對象,實現類在mysql驅動中ResultSet rs = stat.executeQuery(sql);// 5 .處理結果集// ResultSet接口方法 boolean next() 返回true,有結果集,返回false沒有結果集while (rs.next()) {// 獲取每列數據,使用是ResultSet接口的方法 getXX方法參數中,建議寫String列名System.out.println(rs.getInt("sid") + " " + rs.getString("sname") + " " + rs.getDouble("sprice") + " "+ rs.getString("sdesc"));}// 6.釋放資源 rs.close();stat.close();con.close();}}

5.注入攻擊

CREATE TABLE users(id INT PRIMARY KEY AUTO_INCREMENT,username VARCHAR(100),PASSWORD VARCHAR(100) );INSERT INTO users (username,PASSWORD) VALUES ('a','1'),('b','2');SELECT * FROM users;

package cn.jxufe.java.chapter11.demo01;import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.Scanner;/** Java程序實現用戶登錄,用戶名和密碼,數據庫檢查* 演示被別人注入攻擊*/ public class Test03JDBC {public static void main(String[] args) throws ClassNotFoundException, SQLException {// TODO Auto-generated method stub// 1. 注冊驅動Class.forName("com.mysql.jdbc.Driver");// 2. 獲取連接對象String url = "jdbc:mysql://localhost:3306/mydatabase";String username = "root";String password = "123456";Connection con = DriverManager.getConnection(url, username, password);// 3 .獲取執行SQL 語句對象Statement stat = con.createStatement();Scanner sc = new Scanner(System.in);String user = sc.nextLine();String pass = sc.nextLine();// 執行SQL語句,數據表,查詢用戶名和密碼,如果存在,登錄成功,不存在登錄失敗String sql = "SELECT * FROM users WHERE username='" + user + "' AND PASSWORD='" + pass + "'";System.out.println(sql);ResultSet rs = stat.executeQuery(sql);while (rs.next()) {System.out.println(rs.getString("username") + " " + rs.getString("password"));}rs.close();stat.close();con.close();}}

這就是注入攻擊，別人密碼不對，照樣可以登錄。

6.使用使用PrepareSatement防止注入攻擊

package cn.jxufe.java.chapter11.demo01;import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.Scanner;/** Java程序實現用戶登錄,用戶名和密碼,數據庫檢查* 防止注入攻擊* Statement接口實現類,作用執行SQL語句,返回結果集* 有一個子接口PreparedStatement (SQL預編譯存儲,多次高效的執行SQL) * PreparedStatement的實現類數據庫的驅動中,如何獲取接口的實現類* * 是Connection數據庫連接對象的方法* PreparedStatement prepareStatement(String sql) */ public class Test04JDBC {public static void main(String[] args) throws ClassNotFoundException, SQLException {// TODO Auto-generated method stub// 1. 注冊驅動Class.forName("com.mysql.jdbc.Driver");// 2. 獲取連接對象String url = "jdbc:mysql://localhost:3306/mydatabase";String username = "root";String password = "123456";Connection con = DriverManager.getConnection(url, username, password);Scanner sc = new Scanner(System.in);String user = sc.nextLine();String pass = sc.nextLine();// 執行SQL語句,數據表,查詢用戶名和密碼,如果存在,登錄成功,不存在登錄失敗String sql = "SELECT * FROM users WHERE username=? AND PASSWORD=?";// 調用Connection接口的方法prepareStatement,獲取PrepareStatement接口的實現類// 方法中參數,SQL語句中的參數全部采用問號占位符PreparedStatement pst = con.prepareStatement(sql); // System.out.println(pst);// 調用pst對象set方法,設置問號占位符上的參數pst.setObject(1, user);pst.setObject(2, pass);// 調用方法,執行SQL,獲取結果集ResultSet rs = pst.executeQuery();while (rs.next()) {System.out.println(rs.getString("username") + " " + rs.getString("password"));}rs.close();pst.close();con.close();}}

?這種方式可以防止注入攻擊

?

7.使用PrepareStatement接口,實現數據表的更新操作

package cn.jxufe.java.chapter11.demo02;import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException;/** 使用PrepareStatement接口,實現數據表的更新操作*/ public class Test01PreparedStatement {public static void main(String[] args) throws ClassNotFoundException, SQLException {// TODO Auto-generated method stub// 1. 注冊驅動Class.forName("com.mysql.jdbc.Driver");// 2. 獲取連接對象String url = "jdbc:mysql://localhost:3306/mydatabase";String username = "root";String password = "123456";Connection con = DriverManager.getConnection(url, username, password);// 拼寫修改的SQL語句,參數采用?占位String sql = "UPDATE sort SET sname= ?,sprice=? WHERE sid=?";// 調用數據庫連接對象con的方法prepareStatement獲取SQL語句的預編譯對象PreparedStatement pst = con.prepareStatement(sql);// 調用pst的方法setXXX設置?占位pst.setObject(1, "汽車美容");pst.setObject(2, 49988);pst.setObject(3, 7);// 調用pst方法執行SQL語句 pst.executeUpdate();pst.close();con.close();}}

8.使用PrepareStatement接口實現數據表的查詢操作

package cn.jxufe.java.chapter11.demo02;import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;public class Test02PrepareStatement {public static void main(String[] args) throws ClassNotFoundException, SQLException {// TODO Auto-generated method stub// 1. 注冊驅動Class.forName("com.mysql.jdbc.Driver");// 2. 獲取連接對象String url = "jdbc:mysql://localhost:3306/mydatabase";String username = "root";String password = "123456";Connection con = DriverManager.getConnection(url, username, password);String sql = "SELECT * FROM sort";PreparedStatement pst = con.prepareStatement(sql);// 調用pst對象的方法,執行查詢語句,SelectResultSet rs = pst.executeQuery();while (rs.next()) {System.out.println(rs.getString("sid") + " " + rs.getString("sname") + " " + rs.getString("sprice") + " "+ rs.getString("sdesc"));}rs.close();pst.close();con.close();}}

9.?實現JDBC的工具類

package cn.jxufe.java.chapter11.jdbc_util;import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement;/** 實現JDBC的工具類* 定義方法,直接返回數據庫的連接對象* * 寫關閉方法*/ public class JDBCUtils {private static Connection con;private JDBCUtils() {}static {try {Class.forName("com.mysql.jdbc.Driver");String url = "jdbc:mysql://localhost:3306/mydatabase";String username = "root";String password = "123456";con = DriverManager.getConnection(url, username, password);} catch (Exception ex) {throw new RuntimeException(ex + "數據庫連接失敗");}}/** 定義靜態方法,返回數據庫的連接對象*/public static Connection getConnection() {return con;}public static void close(Connection con, Statement stat) {if (stat != null) {try {stat.close();} catch (SQLException ex) {}}if (con != null) {try {con.close();} catch (SQLException ex) {}}}public static void close(Connection con, Statement stat, ResultSet rs) {if (rs != null) {try {rs.close();} catch (SQLException ex) {}}if (stat != null) {try {stat.close();} catch (SQLException ex) {}}if (con != null) {try {con.close();} catch (SQLException ex) {}}} } package cn.jxufe.java.chapter11.demo02;import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;import cn.jxufe.java.chapter11.jdbc_util.JDBCUtils;public class Test03JDBCUtil {public static void main(String[] args) throws SQLException {// TODO Auto-generated method stubConnection con= JDBCUtils.getConnection();PreparedStatement pst = con.prepareStatement("SELECT * FROM sort");ResultSet rs = pst.executeQuery();while(rs.next()){System.out.println(rs.getString("sname"));}JDBCUtils.close(con, pst, rs);}}

10.將數據庫中的表數據存儲到java對象

package cn.jxufe.java.chapter11.demo02;import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List;import cn.jxufe.java.chapter11.jdbc_util.JDBCUtils;public class Test03JDBCUtil {public static void main(String[] args) throws SQLException {// TODO Auto-generated method stubConnection con = JDBCUtils.getConnection();PreparedStatement pst = con.prepareStatement("SELECT * FROM sort");ResultSet rs = pst.executeQuery();// 創建集合對象List<Sort> list = new ArrayList<>();while (rs.next()) {// 獲取每列元素，封裝到Sort對象中Sort s = new Sort(rs.getInt("sid"), rs.getString("sname"), rs.getDouble("sprice"), rs.getString("sdesc"));list.add(s);}JDBCUtils.close(con, pst, rs);// 遍歷list集合for (Sort sort : list) {System.out.println(sort);}}}class Sort {private int sid;private String sname;private double sprice;private String sdesc;public Sort(int sid, String sname, double sprice, String sdesc) {this.sid = sid;this.sname = sname;this.sprice = sprice;this.sdesc = sdesc;}public int getSid() {return sid;}public void setSid(int sid) {this.sid = sid;}public String getSname() {return sname;}public void setSname(String sname) {this.sname = sname;}public double getSprice() {return sprice;}public void setSprice(double sprice) {this.sprice = sprice;}public String getSdesc() {return sdesc;}public void setSdesc(String sdesc) {this.sdesc = sdesc;}@Overridepublic String toString() {return "Sort [sid=" + sid + ", sname=" + sname + ", sprice=" + sprice + ", sdesc=" + sdesc + "]";}}

11.properties配置文件

11.1使用properties配置文件

開發中獲得連接的4個參數（驅動、URL、用戶名、密碼）通常都存在配置文件中，方便后期維護，程序如果需要更換數據庫，只需要修改配置文件即可。

通常情況下，我們習慣使用properties文件，此文件我們將做如下要求：

文件位置：任意，建議src下

文件名稱：任意，擴展名為properties

文件內容：一行一組數據，格式是“key=value”.

• key命名自定義，如果是多個單詞，習慣使用點分隔。例如：jdbc.driver
• value值不支持中文，如果需要使用非英文字符，將進行unicode轉換。

11.2創建配置文件

在src根目錄下新建一個mydatabase.properties文件，里面的內容如下：

driverClass=com.mysql.jdbc.Driver url=jdbc:mysql://localhost:3306/mydatabase username=root password=123456

11.3加載配置文件：Properties對象

對應properties文件處理，開發中也使用Properties對象進行。我們將采用加載properties文件獲得流，然后使用Properties對象進行處理。

package cn.jxufe.java.chapter11.demo03;import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; import java.io.InputStream; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.util.Properties;/** 加載properties配置文件* IO讀取文件,鍵值對存儲到集合* 從集合中以鍵值對方式獲取數據庫的連接信息,完成數據庫的連接*/ public class Test01Properties {public static void main(String[] args) throws IOException, ClassNotFoundException, SQLException {// TODO Auto-generated method stub/*FileInputStream fis = new FileInputStream("src\\mydatabase.properties");System.out.println(fis);*/ // 發布給用戶的時候沒有src文件夾，所以如何不使用src這個路徑還可以找到這個文件呢？// 使用類的加載器,是從bin目錄下加載InputStream in = Test01Properties.class.getClassLoader().getResourceAsStream("mydatabase.properties");System.out.println(in);Properties pro = new Properties();pro.load(in);// 獲取集合中的鍵值對String driverClass = pro.getProperty("driverClass");String url = pro.getProperty("url");String username = pro.getProperty("username");String password = pro.getProperty("password");Class.forName(driverClass);Connection con = DriverManager.getConnection(url, username, password);System.out.println(con);}}

12.采用配置文件方式編寫數據庫連接的工具類,JDBC工具類

package cn.jxufe.java.chapter11.demo03;import java.io.InputStream; import java.sql.Connection; import java.sql.DriverManager; import java.util.Properties;public class Test02JDBCUtilsConfig {public static void main(String[] args) {Connection con = JDBCUtilsConfig.getConnection();System.out.println(con);} }/** 編寫數據庫連接的工具類,JDBC工具類* 獲取連接對象采用讀取配置文件方式* 讀取文件獲取連接,執行一次,static{}*/ class JDBCUtilsConfig {private static Connection con;private static String driverClass;private static String url;private static String username;private static String password;static {try {readConfig();Class.forName(driverClass);con = DriverManager.getConnection(url, username, password);} catch (Exception ex) {throw new RuntimeException("數據庫連接失敗");}}private static void readConfig() throws Exception {InputStream in = JDBCUtilsConfig.class.getClassLoader().getResourceAsStream("mydatabase.properties");Properties pro = new Properties();pro.load(in);driverClass = pro.getProperty("driverClass");url = pro.getProperty("url");username = pro.getProperty("username");password = pro.getProperty("password");}public static Connection getConnection() {return con;} }

?

轉載于:https://www.cnblogs.com/xinmomoyan/p/11028930.html

《新程序員》：云原生和全面數字化實踐50位技術專家共同創作，文字、視頻、音頻交互閱讀

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。