這兩天複習了一下JDBC操作MySQL,把crud操作的例子記一下,

類庫連結(mysql-connector-java-5.1.37-bin.jar):https://files.cnblogs.com/files/xujingyang/mysql-connector-java-5.1.37-bin.zip

1.1JDBC概述

JDBC（Java Data Base Connectivity,java資料庫連接配接）是一種用于執行SQL語句的Java API，可以為多種關系資料庫提供統一通路，它由一組用Java語言編寫的類和接口組成。是Java通路資料庫的标準規範

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

JDBC需要連接配接驅動，驅動是兩個裝置要進行通信，滿足一定通信資料格式，資料格式由裝置提供商規定，裝置提供商為裝置提供驅動軟體，通過軟體可以與該裝置進行通信。

今天我們使用的是mysql的驅動mysql-connector-java-5.1.39-bin.jar

1.2JDBC原理

Java提供通路資料庫規範稱為JDBC，而生産廠商提供規範的實作類稱為驅動。

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

1.3JDBC開發步驟

注冊驅動.獲得連接配接.獲得語句執行平台執行sql語句處理結果釋放資源.

1.3.1導入驅動jar包

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

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

1.4.1API詳解：注冊驅動

代碼：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類“主動”将自己進行注冊

public class Driver extends NonRegisteringDriver implements java.sql.Driver {

static {

try {

java.sql.DriverManager.registerDriver(new Driver());

} catch (SQLException E) {

throw new RuntimeException("Can't register driver!");

}

……

}

1.4.2API詳解：獲得連結

代碼：Connection con = DriverManager.getConnection

(“jdbc:mysql://localhost:3306/mydb”,”root”,”root”);

擷取連接配接需要方法 DriverManager.getConnection(url,username,password)，三個參數分别表示，url 需要連接配接資料庫的位置（網址） user使用者名 password 密碼

url比較複雜，下面是mysql的url：

jdbc:mysql://localhost:3306/mydb

JDBC規定url的格式由三部分組成，每個部分中間使用冒号分隔。

l 第一部分是jdbc，這是固定的；

l 第二部分是資料庫名稱，那麼連接配接mysql資料庫，第二部分當然是mysql了；

l 第三部分是由資料庫廠商規定的，我們需要了解每個資料庫廠商的要求，mysql的第三部分分别由資料庫伺服器的IP位址（localhost）、端口号（3306），以及DATABASE名稱(mydb)組成。

1.4.3API詳解：獲得語句執行平台

String sql = "某SQL語句";

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

常用方法：

n int executeUpdate(String sql); --執行insert update delete語句.

n ResultSet executeQuery(String sql); --執行select語句.

n boolean execute(String sql); --執行select傳回true 執行其他的語句傳回false.

1.4.4API詳解：處理結果集（執行insert、update、delete無需處理）

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

rs.next();//指向第一行

rs.getInt(1);//擷取第一行第一列的資料

常用方法：

n Object getObject(int index) / Object getObject(String name) 獲得任意對象

n String getString(int index) / Object getObject(String name) 獲得字元串

n int getInt(int index) / Object getObject(String name) 獲得整形

n double getDouble(int index) / Object getObject(String name) 獲得雙精度浮點型

1.4.5API詳解：釋放資源

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

rs.close();

stmt.close();

con.close();

1.5SQL注入問題

假設有登入案例SQL語句如下:

SELECT * FROM 使用者表 WHERE NAME = 使用者輸入的使用者名 AND PASSWORD = 使用者輸的密碼;

此時，當使用者輸入正确的賬号與密碼後，查詢到了資訊則讓使用者登入。但是當使用者輸入的賬号為XXX 密碼為：XXX’ OR ‘a’=’a時，則真正執行的代碼變為：

SELECT * FROM 使用者表 WHERE NAME = ‘XXX’ AND PASSWORD =’ XXX’ OR ’a’=’a’;

此時，上述查詢語句時永遠可以查詢出結果的。那麼使用者就直接登入成功了，顯然我們不希望看到這樣的結果，這便是SQL注入問題。

為此，我們使用PreparedStatement來解決對應的問題。

1.6API詳解：預處理對象

使用PreparedStatement預處理對象時，建議每條sql語句所有的實際參數，都使用逗号分隔。

String sql = "insert into sort(sid,sname) values(?,?)";;

PreparedStatement預處理對象代碼：

PreparedStatement psmt = conn.prepareStatement(sql)

常用方法：

執行SQL語句:

l int executeUpdate(); --執行insert update delete語句.

l ResultSet executeQuery(); --執行select語句.

l boolean execute(); --執行select傳回true 執行其他的語句傳回false.

設定實際參數

l void setXxx(int index, Xxx xx) 将指定參數設定為給定Java的xx值。在将此值發送到資料庫時，驅動程式将它轉換成一個 SQL Xxx類型值。

例如：

setString(2, "家用電器") 把SQL語句中第2個位置的占位符？替換成實際參數 "家用電器"

1.7預處理對象executeUpdate方法

通過預處理對象的executeUpdate方法，完成記錄的insert\update\delete語句的執行。操作格式統一如下：

1. 注冊驅動

2. 擷取連接配接

3. 擷取預處理對象

4. SQL語句占位符設定實際參數

5. 執行SQL語句

6. 釋放資源

2.1使用properties配置檔案

開發中獲得連接配接的4個參數（驅動、URL、使用者名、密碼）通常都存在配置檔案中，友善後期維護，程式如果需要更換資料庫，隻需要修改配置檔案即可。

通常情況下，我們習慣使用properties檔案，此檔案我們将做如下要求：

檔案位置：任意，建議src下檔案名稱：任意，擴充名為properties檔案内容：一行一組資料，格式是“key=value”.

a) key命名自定義，如果是多個單詞，習慣使用點分隔。例如：jdbc.driver

b) value值不支援中文，如果需要使用非英文字元，将進行unicode轉換。

1.2建立配置檔案

在項目跟目錄下，建立檔案，輸入“db.properties”檔案名。

l 檔案中的内容

driver=com.mysql.jdbc.Driver

url=jdbc:mysql://localhost:3306/mydb

user=root

password=root

1.3加載配置檔案：Properties對象

對應properties檔案處理，開發中也使用Properties對象進行。我們将采用加載properties檔案獲得流，然後使用Properties對象進行處理。

l JDBCUtils.java中編寫代碼

JDBC操作MySQL(crud)

1 public class JDBCUtils {
 2 
 3     private static String driver;
 4     private static String url;
 5     private static String user;
 6     private static String password;
 7     // 靜态代碼塊
 8     static {
 9         try {
10             // 1 使用Properties處理流
11             // 使用load()方法加載指定的流
12             Properties props = new Properties();
13             Reader is = new FileReader("db.properties");
14             props.load(is);
15             // 2 使用getProperty(key)，通過key獲得需要的值，
16             driver = props.getProperty("driver");
17             url = props.getProperty("url");
18             user = props.getProperty("user");
19             password = props.getProperty("password");
20         } catch (Exception e) {
21             throw new RuntimeException(e);
22         }
23     }
24 
25     /**
26      * 獲得連接配接
27      */
28     public static Connection getConnection() {
29         try {
30             // 1 注冊驅動
31             Class.forName(driver);
32             // 2 獲得連接配接
33             Connection conn = DriverManager.getConnection(url, user, password);
34             return conn;
35         } catch (Exception e) {
36             throw new RuntimeException(e);
37         }
38     }
39 }

JDBC操作MySQL(crud)

3案例分析

JDBC操作MySQL(crud)

1 package com.xujingyang.jdbc;
  2 
  3 import java.sql.Connection;
  4 import java.sql.DriverManager;
  5 import java.sql.PreparedStatement;
  6 import java.sql.ResultSet;
  7 import java.sql.SQLException;
  8 import java.util.ArrayList;
  9 import java.util.List;
 10 
 11 import com.xujingyang.bean.Floor;
 12 
 13 public class JdbcDemo {
 14     public static void main(String[] args) {
 15         delete();
 16     }
 17     public static void delete(){
 18         Connection con=null;
 19         PreparedStatement state=null;
 20         try {
 21             Class.forName("com.mysql.jdbc.Driver");
 22             con=DriverManager.getConnection("jdbc:mysql://localhost:3306/gz","root","920606");
 23             state=con.prepareStatement("delete from t_room where id=?");
 24             state.setInt(1, 123);
 25             int num = state.executeUpdate();
 26             System.out.println("删除成功!删除了"+num+"條");
 27         } catch (Exception e) {
 28             e.printStackTrace();
 29             // TODO: handle exception
 30         }finally{
 31             try {
 32                 if(con!=null){
 33                     con.close();
 34                 }
 35                 if(state!=null){
 36                     state.close();
 37                 }
 38             } catch (Exception e2) {
 39                 // TODO: handle exception
 40             }
 41         }
 42     }
 43     
 44     
 45     public static void update(){
 46         Connection connection=null;
 47         PreparedStatement statement=null;
 48         try {
 49             Class.forName("com.mysql.jdbc.Driver");
 50             connection=DriverManager.getConnection("jdbc:mysql://localhost:3306/gz","root","920606");
 51             statement=connection.prepareStatement("update t_room set roomtype=? where id=123");
 52             statement.setInt(1, 1);
 53             int num = statement.executeUpdate();
 54             System.out.println("更新成功!更新了+"+num+"條");
 55         } catch (Exception e) {
 56             e.printStackTrace();
 57             // TODO: handle exception
 58         }finally{
 59             try {
 60                 if(connection!=null){
 61                     connection.close();
 62                 }
 63                 if(statement!=null){
 64                     statement.close();
 65                 }
 66             } catch (Exception e2) {
 67                 // TODO: handle exception
 68             }
 69         }
 70     }
 71     
 72     public static void insert(){
 73         Connection con=null;
 74         PreparedStatement statement=null;
 75         try {
 76             Class.forName("com.mysql.jdbc.Driver");
 77             con = DriverManager.getConnection("jdbc:mysql://localhost:3306/gz","root","920606");
 78             statement = con.prepareStatement("insert into t_room values(?,?,?,?,?,?,?)");
 79             Floor floor=new Floor(123, 0, "room1", "30", 123, 0,50f);
 80             statement.setInt(1, floor.getId());
 81             statement.setInt(2, floor.getType());
 82             statement.setString(3, floor.getName());
 83             statement.setString(4, floor.getNum());
 84             statement.setInt(5, floor.getFloorId());
 85             statement.setInt(6, floor.getState());
 86             statement.setDouble(7, floor.getArea());
 87             int num = statement.executeUpdate();
 88             System.out.println("更新成功!更新了"+num+"條");
 89         } catch (Exception e) {
 90             e.printStackTrace();
 91         }finally{
 92             try {
 93                 if(con!=null){
 94                     con.close();
 95                 }
 96                 if (statement!=null) {
 97                     statement.close();
 98                 }
 99             } catch (SQLException e) {
100                 // TODO Auto-generated catch block
101                 e.printStackTrace();
102             }
103             
104         }
105     }
106     
107 
108     private static void query() {
109         Connection con = null;
110         PreparedStatement statement = null;
111         ResultSet resultSet = null;
112         try {
113             // 1.注冊驅動
114             Class.forName("com.mysql.jdbc.Driver");
115             // 2.獲得連結
116             con = DriverManager.getConnection(
117                     "jdbc:mysql://localhost:3306/gz", "root", "920606");                          
118             statement = con
119                     .prepareStatement("select * from t_room");
120             resultSet = statement.executeQuery();
121             List<Floor> lists = new ArrayList<Floor>();
122             while (resultSet.next()) {
123                 int id = resultSet.getInt(1);
124                 int type = resultSet.getInt(2);
125                 String name = resultSet.getString(3);
126                 String num = resultSet.getString(4);
127                 int floorId = resultSet.getInt(5);
128                 int state = resultSet.getInt(6);
129                 double area = resultSet.getDouble(7);
130                 Floor floor = new Floor(id, type, name, num, floorId, state,
131                         area);
132                 lists.add(floor);
133             }
134             
135             for (Floor floor : lists) {
136                 System.out.println(floor);
137             }
138 
139         } catch (Exception e) {
140             e.printStackTrace();
141         }finally{
142             try {
143                 resultSet.close();
144                 statement.close();
145                 con.close();
146             } catch (SQLException e) {
147                 // TODO Auto-generated catch block
148                 e.printStackTrace();
149             }
150         }
151     }
152 }

JDBC操作MySQL(crud)

執行個體中用到的Javabean

JDBC操作MySQL(crud)

1 package com.xujingyang.bean;
 2 
 3 
 4 public class Floor {
 5     private int id;
 6     private int type;
 7     private String name;
 8     private String num;
 9 
10     private int floorId;
11     private int state;
12     private double area;
13 
14     public Floor() {
15     }
16 
17     public Floor(int id, int type, String name, String num, int floorId,
18             int state, double area) {
19         super();
20         this.id = id;
21         this.type = type;
22         this.name = name;
23         this.num = num;
24         this.floorId = floorId;
25         this.state = state;
26         this.area = area;
27     }
28 
29     public int getId() {
30         return id;
31     }
32 
33     public void setId(int id) {
34         this.id = id;
35     }
36 
37     public int getType() {
38         return type;
39     }
40 
41     public void setType(int type) {
42         this.type = type;
43     }
44 
45     public String getName() {
46         return name;
47     }
48 
49     public void setName(String name) {
50         this.name = name;
51     }
52 
53     public String getNum() {
54         return num;
55     }
56 
57     public void setNum(String num) {
58         this.num = num;
59     }
60 
61     public int getFloorId() {
62         return floorId;
63     }
64 
65     public void setFloorId(int floorId) {
66         this.floorId = floorId;
67     }
68 
69     public int getState() {
70         return state;
71     }
72 
73     public void setState(int state) {
74         this.state = state;
75     }
76 
77     public double getArea() {
78         return area;
79     }
80 
81     public void setArea(double area) {
82         this.area = area;
83     }
84 
85     @Override
86     public String toString() {
87         return "Floor [id=" + id + ", type=" + type + ", name=" + name
88                 + ", num=" + num + ", floorId=" + floorId + ", state=" + state
89                 + ", area=" + area + "]";
90     }
91     
92 }

JDBC操作MySQL(crud)

1.1JDBC概述

1.2JDBC原理

1.3JDBC開發步驟

1.3.1導入驅動jar包

1.4.1API詳解：注冊驅動

1.4.2API詳解：獲得連結

1.4.3API詳解：獲得語句執行平台

1.4.4API詳解：處理結果集（執行insert、update、delete無需處理）

1.4.5API詳解：釋放資源

1.5SQL注入問題

1.6API詳解：預處理對象

1.7預處理對象executeUpdate方法

2.1使用properties配置檔案

1.2建立配置檔案

1.3加載配置檔案：Properties對象

3案例分析

繼續閱讀

2022秋招面試總結（cpp+java+測開）百度測開一面位元組後端一面蝦皮後端一面蝦皮後端二面

資料庫之DDL操作資料庫DDL操作資料庫DDL操作資料表

資料庫之DQL操作資料庫

mysql優化（sql優化）

資料遷移方法資料遷移原則資料遷移之雙寫方案資料遷移之級聯同步方案

redis叢集資料一緻性_RedisRaft為Redis叢集帶來強大的資料一緻性

寶塔面闆mysql恢複2018.1.8更新

Centos7 MySQL 5.7 安裝MySQL 5.7 安裝

查找入職員工時間排名倒數第三的員工所有資訊

Hibernate使用Hibernate的“3個準備，7個步驟”Hibernate API簡介操作實體對象對象識别

雲計算面試題——mysql/存儲引擎/備份

SQL語言基礎：常用的資料查詢語句

Ubuntu16.04安裝Apache+MySQL+PHP1. 安裝Apache2. 安裝MySQL3. 安裝PHP4. 安裝phpMyAdmin

MySQL的4種隔離級别？出現問題

neo4j之cypher使用文檔

mysql使用source指令導入.sql檔案