青青在线A片,午夜精品人妻,夜夜

今日內(nèi)容

JDBC基本概念
快速入門(mén)
對(duì)JDBC中各個(gè)接口和類詳解

一、JDBC概述

概念：Java DataBase Connectivity Java 數(shù)據(jù)庫(kù)連接， Java語(yǔ)言操作數(shù)據(jù)庫(kù)
JDBC本質(zhì)：官方（sun公司）定義的一套操作所有關(guān)系型數(shù)據(jù)庫(kù)的規(guī)則，即接口。各個(gè)數(shù)據(jù)庫(kù)廠商去實(shí)現(xiàn)這套接口，提供數(shù)據(jù)庫(kù)驅(qū)動(dòng)jar包。我們可以使用這套接口（JDBC）編程，真正執(zhí)行的代碼是驅(qū)動(dòng)jar包中的實(shí)現(xiàn)類。

快速入門(mén)：

步驟：
①導(dǎo)入驅(qū)動(dòng)jar包 mysql-connector-java-5.1.37-bin.jar
（1）復(fù)制mysql-connector-java-5.1.37-bin.jar到項(xiàng)目的libs目錄下
（2）右鍵-->Add As Library
②注冊(cè)驅(qū)動(dòng)
③獲取數(shù)據(jù)庫(kù)連接對(duì)象 Connection
④定義sql
⑤獲取執(zhí)行sql語(yǔ)句的對(duì)象 Statement
⑥執(zhí)行sql，接受返回結(jié)果
⑦處理結(jié)果
⑧釋放資源
代碼實(shí)現(xiàn)：

//1. 導(dǎo)入驅(qū)動(dòng)jar包
//2.注冊(cè)驅(qū)動(dòng)
Class.forName("com.mysql.jdbc.Driver");
//3.獲取數(shù)據(jù)庫(kù)連接對(duì)象
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db3", "root", "123");
//4.定義sql語(yǔ)句
String sql = "update anfly set score = 80 where id = 2";
//5.獲取執(zhí)行sql的對(duì)象 Statement
Statement stmt = conn.createStatement();
//6.執(zhí)行sql
int count = stmt.executeUpdate(sql);
//7.處理結(jié)果
System.out.println(count);
//8.釋放資源
stmt.close();
conn.close();

二、詳解各個(gè)對(duì)象：

DriverManager：驅(qū)動(dòng)管理對(duì)象
①注冊(cè)驅(qū)動(dòng)：告訴程序該使用哪一個(gè)數(shù)據(jù)庫(kù)驅(qū)動(dòng)jar
static void registerDriver(Driver driver) :注冊(cè)與給定的驅(qū)動(dòng)程序 DriverManager 。
寫(xiě)代碼使用： Class.forName("com.mysql.jdbc.Driver");
通過(guò)查看源碼發(fā)現(xiàn)：在com.mysql.jdbc.Driver類中存在靜態(tài)代碼塊
```
static {
    try {
        java.sql.DriverManager.registerDriver(new Driver());
    } catch (SQLException E) {
    throw new RuntimeException("Can't register driver!");
    }
}                    
```
- 注意：mysql5之后的驅(qū)動(dòng)jar包可以省略注冊(cè)驅(qū)動(dòng)的步驟。
②獲取數(shù)據(jù)庫(kù)連接：
方法：static Connection getConnection(String url, String user, String password)
參數(shù)：
url：指定連接的路徑
語(yǔ)法：jdbc:mysql://ip地址(域名):端口號(hào)/數(shù)據(jù)庫(kù)名稱
例子：jdbc:mysql://localhost:3306/db3
細(xì)節(jié)：如果連接的是本機(jī)mysql服務(wù)器，并且mysql服務(wù)默認(rèn)端口是3306，則url可以簡(jiǎn)寫(xiě)為：jdbc:mysql:///數(shù)據(jù)庫(kù)名稱
user：用戶名
password：密碼

Connection：數(shù)據(jù)庫(kù)連接對(duì)象
①獲取執(zhí)行sql 的對(duì)象

Statement createStatement()
PreparedStatement prepareStatement(String sql)

②管理事務(wù)：

//開(kāi)啟事務(wù)：
setAutoCommit(boolean autoCommit) ：調(diào)用該方法設(shè)置參數(shù)為false，即開(kāi)啟事務(wù)
// 提交事務(wù)
commit() 
// 回滾事務(wù)
  rollback()

Statement：執(zhí)行sql的對(duì)象
①boolean execute(String sql) ：可以執(zhí)行任意的sql 了解
②int executeUpdate(String sql) ：執(zhí)行DML（insert、update、delete）語(yǔ)句、DDL(create，alter、drop)語(yǔ)句
返回值：影響的行數(shù)，可以通過(guò)這個(gè)影響的行數(shù)判斷DML語(yǔ)句是否執(zhí)行成功返回值>0的則執(zhí)行成功，反之，則失敗。
③ResultSet executeQuery(String sql) ：執(zhí)行DQL（select)語(yǔ)句
練習(xí)：
①account表添加一條記錄
②account表修改記錄
③account表刪除一條記錄

Statement stmt = null;
Connection conn = null;
try {
    //1. 注冊(cè)驅(qū)動(dòng)
    Class.forName("com.mysql.jdbc.Driver");
    //2. 定義sql
    String sql = "insert into account values(null,'王五',3000)";
    //3.獲取Connection對(duì)象
    conn = DriverManager.getConnection("jdbc:mysql:///db3", "root", "root");
    //4.獲取執(zhí)行sql的對(duì)象 Statement
    stmt = conn.createStatement();
    //5.執(zhí)行sql
    int count = stmt.executeUpdate(sql);//影響的行數(shù)
    //6.處理結(jié)果
    System.out.println(count);
    if(count > 0){
    System.out.println("添加成功！");
    }else{
    System.out.println("添加失??！");
    }

} catch (ClassNotFoundException e) {
    e.printStackTrace();
} catch (SQLException e) {
    e.printStackTrace();
}finally {
    //stmt.close();
    //7. 釋放資源
    //避免空指針異常
    if(stmt != null){
        try {
        stmt.close();
        } catch (SQLException e) {
        e.printStackTrace();
        }
    }

    if(conn != null){
    try {
    conn.close();
    } catch (SQLException e) {
    e.printStackTrace();
         }
    }
}

ResultSet：結(jié)果集對(duì)象,封裝查詢結(jié)果

boolean next(): 游標(biāo)向下移動(dòng)一行，判斷當(dāng)前行是否是最后一行末尾(是否有數(shù)據(jù))，如果是，則返回false，如果不是則返回true
getXxx(參數(shù)):獲取數(shù)據(jù)
Xxx：代表數(shù)據(jù)類型如： int getInt() , String getString()
參數(shù)：
1. int：代表列的編號(hào),從1開(kāi)始如： getString(1)
2. String：代表列名稱。如： getDouble("balance")
注意：

使用步驟：
1. 游標(biāo)向下移動(dòng)一行
2. 判斷是否有數(shù)據(jù)
3. 獲取數(shù)據(jù)

//循環(huán)判斷游標(biāo)是否是最后一行末尾。
while(rs.next()){
  //獲取數(shù)據(jù)
  //6.2 獲取數(shù)據(jù)
  int id = rs.getInt(1);
  String name = rs.getString("name");
  double balance = rs.getDouble(3);
  System.out.println(id + "---" + name + "---" + balance);
}

練習(xí)

//定義一個(gè)方法，查詢emp表的數(shù)據(jù)將其封裝為對(duì)象，然后裝載集合，返回。
//1. 定義Emp類
package cn.itcast.domain;

public class Emp {
    private int id;
    private String name;
    private String sex;
    private int age;

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getSex() {
        return sex;
    }

    public void setSex(String sex) {
        this.sex = sex;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

    @Override
    public String toString() {
        return "Emp{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", sex='" + sex + '\'' +
                ", age=" + age +
                '}';
    }
}

// 2. 定義方法 public List<Emp> findAll(){}
private List<Emp> findAll() {
    try {
        Class.forName("com.mysql.jdbc.Driver");
        conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/2103a", "root", "123");
        String sql = "select * from employee";
        stat = conn.createStatement();
        rs = stat.executeQuery(sql);
        list = new ArrayList<>();
        Emp emp = null;
        while (rs.next()) {
            int id = rs.getInt("id");
            String name = rs.getString("name");
            int age = rs.getInt("age");
            String sex = rs.getString("sex");

            emp = new Emp();
            emp.setAge(age);
            emp.setId(id);
            emp.setName(name);
            emp.setSex(sex);

            list.add(emp);
        }

    } catch (ClassNotFoundException | SQLException e) {
        e.printStackTrace();
    } finally {
        if(conn!=null) {
            try {
                conn.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if(stat!=null) {
            try {
                conn.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if (rs != null) {
            try {
                conn.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }

    }
    return list;
}

// 3. 實(shí)現(xiàn)方法 select * from emp;
public static void main(String[] args) {
        List<Emp> list = new JdbcDemo1().findAll();
        System.out.println(list);
}

PreparedStatement：執(zhí)行sql的對(duì)象
①SQL注入問(wèn)題：在拼接sql時(shí)，有一些sql的特殊關(guān)鍵字參與字符串的拼接。會(huì)造成安全性問(wèn)題
1）輸入用戶隨便，輸入密碼：a' or 'a' = 'a
2）sql：select * from user where username = 'fhdsjkf' and password = 'a' or 'a' = 'a'
②解決sql注入問(wèn)題：使用PreparedStatement對(duì)象來(lái)解決
③預(yù)編譯的SQL：參數(shù)使用?作為占位符
④步驟：

1. 導(dǎo)入驅(qū)動(dòng)jar包 mysql-connector-java-5.1.37-bin.jar
2. 注冊(cè)驅(qū)動(dòng)
3. 獲取數(shù)據(jù)庫(kù)連接對(duì)象 Connection
4. 定義sql
   注意：sql的參數(shù)使用？作為占位符。 如：select * from user where username = ? and password = ?;
5. 獲取執(zhí)行sql語(yǔ)句的對(duì)象 PreparedStatement  Connection.prepareStatement(String sql) 
6. 給？賦值：
    方法： setXxx(參數(shù)1,參數(shù)2)
    參數(shù)1：？的位置編號(hào) 從1 開(kāi)始
    參數(shù)2：？的值
7. 執(zhí)行sql，接受返回結(jié)果，不需要傳遞sql語(yǔ)句
8. 處理結(jié)果
9. 釋放資源

⑤注意：后期都會(huì)使用PreparedStatement來(lái)完成增刪改查的所有操作
1）可以防止SQL注入
2）效率更高

三、抽取JDBC工具類： JDBCUtils

目的：簡(jiǎn)化書(shū)寫(xiě)
分析：
①注冊(cè)驅(qū)動(dòng)也抽取
②抽取一個(gè)方法獲取連接對(duì)象
③需求：不想傳遞參數(shù)（麻煩），還得保證工具類的通用性。
④解決：配置文件
```
jdbc.properties
url=
user=
password=
```

抽取一個(gè)方法釋放資源

  package cn.itcast.utils;

import java.io.FileReader;
import java.io.IOException;
import java.net.URL;
import java.sql.*;
import java.util.Properties;

/**
 * JDBC工具類
 */
public class JDBCUtil {

    private static String url;
    private static String user;
    private static String password;
    private static String driver;

    /**
     * 文件的讀取，只需要讀取一次即可拿到這些值。使用靜態(tài)代碼塊
     */
    static {

        try {

            //1. 創(chuàng)建properties集合類
            Properties pro = new Properties();

            // 獲取src路徑下文件的方式 -- ClassLoader 類加載器
            ClassLoader loader = JDBCUtil.class.getClassLoader();
            URL res = loader.getResource("jdbc.properties");
            String path = res.getPath();

            // 2. 加載文件
            pro.load(new FileReader(path));

            // 3. 獲取數(shù)據(jù)，賦值
            url = pro.getProperty("url");
            user = pro.getProperty("user");
            password = pro.getProperty("password");
            driver = pro.getProperty("driver");

            // 4. 注冊(cè)驅(qū)動(dòng)
            try {
                Class.forName(driver);
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    /**
     * 獲取連接
     *
     * @return
     */
    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(url, user, password);
    }

    /**
     * 釋放資源
     */
    public static void close(Statement stat, Connection conn) {
        if (stat != null) {
            try {
                stat.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }

        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }

    }

    /**
     * 釋放資源
     */
    public static void close(ResultSet rs, Statement stat, Connection conn) {
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if (stat != null) {
            try {
                stat.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }

        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
    }
}

練習(xí)：
①需求：

1. 通過(guò)鍵盤(pán)錄入用戶名和密碼
2. 判斷用戶是否登錄成功
    select * from user where username = "" and password = "";
    如果這個(gè)sql有查詢結(jié)果，則成功，反之，則失敗

②步驟：
(1)創(chuàng)建數(shù)據(jù)庫(kù)表 user

CREATE TABLE USER(
    id INT PRIMARY KEY AUTO_INCREMENT,
    username VARCHAR(32),
    PASSWORD VARCHAR(32)
);

INSERT INTO USER VALUES(NULL,'zhangsan','123');
INSERT INTO USER VALUES(NULL,'lisi','234');

(2)代碼實(shí)現(xiàn)：

package cn.itcast.jdbc;

import cn.itcast.utils.JDBCUtil;

import java.sql.*;
import java.util.Scanner;

public class JDBCDemo3 {
    public static void main(String[] args) {
        //1.鍵盤(pán)錄入，接受用戶名和密碼
        Scanner scanner = new Scanner(System.in);
        System.out.println("請(qǐng)輸入 用戶名：");
        String name = scanner.nextLine();
        System.out.println("請(qǐng)輸入密碼：");
        String pwd = scanner.nextLine();
        //2.調(diào)用方法
        boolean isLogin = new JDBCDemo3().login(name, pwd);
        if(isLogin){
            System.out.println("登錄成功");
        } else {
            System.out.println("登錄失敗");
        }
    }

    /**
     * 登錄方法
     */
    public boolean login(String name, String pwd) {
        if (name == null || pwd == null) {
            return false;
        }
        // 連接數(shù)據(jù)庫(kù)判斷是否登錄成功
        Connection conn = null;
        Statement stat = null;
        ResultSet rs = null;
        try {
            conn = JDBCUtil.getConnection();
            String sql = "select * from user where username = '" + name + "' and password = '" + pwd + "' ";
            stat = conn.createStatement();
            rs = stat.executeQuery(sql);
            //查詢到有結(jié)果則成功，反之失敗。
            return rs.next();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            JDBCUtil.close(rs, stat, conn);
        }
        return false;
    }
}

四、JDBC控制事務(wù)：

事務(wù)：一個(gè)包含多個(gè)步驟的業(yè)務(wù)操作。如果這個(gè)業(yè)務(wù)操作被事務(wù)管理，則這多個(gè)步驟要么同時(shí)成功，要么同時(shí)失敗。
操作：
①開(kāi)啟事務(wù)
②提交事務(wù)
③回滾事務(wù)
使用Connection對(duì)象來(lái)管理事務(wù)
- 開(kāi)啟事務(wù)：setAutoCommit(boolean autoCommit) ：調(diào)用該方法設(shè)置參數(shù)為false，即開(kāi)啟事務(wù)
- 在執(zhí)行sql之前開(kāi)啟事務(wù)
- 提交事務(wù)：commit()
- 當(dāng)所有sql都執(zhí)行完提交事務(wù)
- 回滾事務(wù)：rollback()
- 在catch中回滾事務(wù)
代碼：

package cn.itcast.jdbc;
import cn.itcast.utils.JDBCUtil;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class JdbcDemo4 {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement pstmt1 = null;
        PreparedStatement pstmt2 = null;

        try {
            //1.獲取連接
            conn = JDBCUtil.getConnection();
            //開(kāi)啟事務(wù)
            conn.setAutoCommit(false);

            //2.定義sql
            //2.1 張三 - 500
            String sql1 = "update account set balance = balance - ? where id = ?";
            //2.2 李四 + 500
            String sql2 = "update account set balance = balance + ? where id = ?";
            //3.獲取執(zhí)行sql對(duì)象
            pstmt1 = conn.prepareStatement(sql1);
            pstmt2 = conn.prepareStatement(sql2);
            //4. 設(shè)置參數(shù)
            pstmt1.setDouble(1, 500);
            pstmt1.setInt(2, 1);

            pstmt2.setDouble(1, 500);
            pstmt2.setInt(2, 2);
            //5.執(zhí)行sql
            pstmt1.executeUpdate();
            // 手動(dòng)制造異常
            int i = 3 / 0;

            pstmt2.executeUpdate();
            //提交事務(wù)
            conn.commit();
        } catch (Exception e) {
            //事務(wù)回滾
            try {
                if (conn != null) {
                    conn.rollback();
                }
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
            e.printStackTrace();
        } finally {
            JDBCUtil.close(pstmt1, conn);
            JDBCUtil.close(pstmt2, null);
        }
    }
}

色偷偷精品伊人,欧洲久久精品,欧美综合婷婷骚逼,国产AV主播,国产最新探花在线,九色在线视频一区,伊人大交九欧美,1769亚洲,黄色成人av

一、JDBC

一、JDBC

今日內(nèi)容

一、JDBC概述

二、詳解各個(gè)對(duì)象：

三、抽取JDBC工具類： JDBCUtils

四、JDBC控制事務(wù)：

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容

色偷偷精品伊人,欧洲久久精品,欧美综合婷婷骚逼,国产AV主播,国产最新探花在线,九色在线视频一区,伊人大交九 欧美,1769亚洲,黄色成人av

一、JDBC

今日內(nèi)容

一、JDBC概述

二、詳解各個(gè)對(duì)象：

三、抽取JDBC工具類 ： JDBCUtils

四、JDBC控制事務(wù)：

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容

色偷偷精品伊人,欧洲久久精品,欧美综合婷婷骚逼,国产AV主播,国产最新探花在线,九色在线视频一区,伊人大交九欧美,1769亚洲,黄色成人av

一、JDBC概述

三、抽取JDBC工具類： JDBCUtils

四、JDBC控制事務(wù)：