12JDBC
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開發步驟
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();
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文件，此文件我們將做如下要求：
- key命名自定義，如果是多個單詞，習慣使用點分隔。例如：jdbc.driver
- value值不支持中文，如果需要使用非英文字符，將進行unicode轉換。
11.2創建配置文件
在src根目錄下新建一個mydatabase.properties文件，里面的內容如下：
driverClass=com.mysql.jdbc.Driver url=jdbc:mysql://localhost:3306/mydatabase username=root password=12345611.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位技術專家共同創作，文字、視頻、音頻交互閱讀總結
- 上一篇： SpringMvc之集成Swagger
- 下一篇： Springboot+JdbcTempl