MySQL之JDBC編程增刪改查

来源:https://www.cnblogs.com/bfy0221/archive/2022/08/10/16574145.html
-Advertisement-
Play Games

MySQL之JDBC 一、JDBC是什麼 Java DatabaseConnectivity (java語言連接資料庫) 二、JDBC的本質 JDBC是SUN公司制定的一套介面(interface)。 介面都有調用者和實現者。 面向介面調用、面向介面寫實現類,這都屬於面向介面編程。 三、為什麼要面向 ...


MySQL之JDBC

一、JDBC是什麼

Java DatabaseConnectivity (java語言連接資料庫)

二、JDBC的本質

JDBC是SUN公司制定的一套介面(interface)。

介面都有調用者和實現者。

面向介面調用、面向介面寫實現類,這都屬於面向介面編程。

三、為什麼要面向介面編程

解耦合:降低程式的耦合度,提高程式的擴展力。解耦合可以理解為淘寶的兩個頁面,你在將商品加入訂單的時候出現錯誤,但是不會影響你在主頁瀏覽商品,就是兩個模塊之間的聯繫不那麼緊密,說明兩個模塊內聚就高。

image-20220808192237630

四、為什麼SUN制定一套JDBC介面

因為每一個資料庫產品都有自己獨特的實現原理

五、JDBC編程六步

1、註冊驅動(告訴Java程式要連接哪個品牌的資料庫)

2、獲取連接(表示JVM的進程和資料庫進程之間的通道打開了,這屬於進程之間的通信,使用完後記得關閉通道)。

3、獲取資料庫操作對象(專門執行sql語句的對象)

4、執行SQL語句(DQL,DML...)

5、處理查詢結果集 (只有當第四步執行的是select語句的時候,才有本步)

6、釋放資源(使用完資源後一定要關閉資源,Java和資料庫之間屬於進程間的通信,開啟之後一定要記得關閉)

六、IDEA編寫JDBC連接MySQL

第一種方法:

1.進入mysql官網

2.點擊下載downloads

image-20220808195519535

3.點擊下載社區版[MySQL Community (GPL) Downloads »]

image-20220808195710565

4.選擇jdbc連接器Connector/J

image-20220808195835709

5.選擇Archives下載5.1版本的(支持的資料庫版本更多)

image-20220808200019726

兩個都可以下載,自己選一個

image-20220808200545011

6.解壓後拿到一個mysql-connector-java-5.1.49.jar的包

7.在idea創建一個工程,點擊file

image-20220808201322097

image-20220808201414118

8.點擊Java,選擇你解壓後的jar包,不要選擇帶bin的,是二進位的意思。點擊ok就行。

第二種方法

先檢查jar包位置:在目錄里新建一個文件夾 libs,把jar包複製進去

image-20220506224119232

然後右鍵選擇新建文件夾libs轉成library

image-20220506224131247

然後就可以寫代碼啦!

image-20220808202020897

七、jdbc連接mysql程式編寫

7.1 第一種註冊驅動方式

public class JDBCTest1 {
    private static Statement stat;
    private static Connection conn;
    public static void main(String[] args) {
        //1.註冊驅動
        try {
            DriverManager.registerDriver(new Driver());
            //2.獲取連接
//            DriverManager.getConnection("jdbc:mysql://192.168.137.150:3306?" +
//                    "useUnicode=true&characterEncoding=utf8&useSSL=false","root","123456");
            /*
            url: 統一資源定位系統
             *          http/https: 通過網路請求去訪問網路上的資源
             *          jdbc:mysql: 是驅動提供的請求頭
             *          請求的地址: 指定mysql的伺服器地址:192.168.254.150
             *          埠號: 3306
             *          useUnicode=true&characterCharset=utf8
             */
            String url ="jdbc:mysql://192.168.137.150:3306/bigdata19?useUnicode=true&characterEncoding=utf8&useSSL=false";
            String user = "root";
            String password = "123456";
            conn = DriverManager.getConnection(url, user, password);
            System.out.println("與mysql連接成功"+conn);
            //獲取資料庫操作對象
            stat = conn.createStatement();
            //DQL
            //ResultSet executeQuery(String sql)
            //執行給定的SQL語句,該語句返回單個 ResultSet對象。

            //DML(資料庫操作語言,增刪改)
            //int executeUpdate(String sql)
            //執行給定的SQL語句,這可能是 INSERT , UPDATE ,或 DELETE語句,或者不返回任何內容,如SQL DDL語句的SQL語句。
            // 方法的返回值指的是受影響的行數: Affected rows: 1
            int count = stat.executeUpdate("insert into dept(deptno,dname,loc) values(50,'教學部','合肥')");
            System.out.println(count==1?"數據保存成功":"數據保存失敗");

        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            //釋放資源
            if (stat!=null){
                try {
                    stat.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (conn!=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

image-20220808210824057

7.2第二種註冊驅動方式

public class JDBCTest2 {
    public static void main(String[] args) {
        //註冊驅動的第二種方式
        //註冊驅動底層實際上就是用驅動包中對應的類,而驅動包中的類都是class尾碼的編譯好的文件
        //       要想直接使用編譯好的類,使用反射來實現。
        //       想一想,反射是如何獲取一個類的class文件對象呢?3種方式
        //       1、getClass
        //       2、.class
        //       3、Class.forName()

        Connection conn = null;
        Statement stat = null;

        try {
            //載入驅動
            Class.forName("com.mysql.jdbc.Driver");

            //創建與資料庫連接的對象
            String url = "jdbc:mysql://192.168.137.150:3306/bigdata19?useUnicode=true&characterEncoding=utf8&useSSL=false";
            String user="root";
            String password="123456";
            conn = DriverManager.getConnection(url, user, password);

            //獲取與操作資料庫的對象
            stat = conn.createStatement();

            //編寫sql語句並執行
            //增
            String sql="insert into dept(deptno,dname,loc) values(60,'行政部','合肥')";
            int count2 = stat.executeUpdate(sql);
            System.out.println(count2==1?"數據增加成功":"數據增加失敗");

            //改
            String sql1 ="update dept set dname='研發部'where deptno=60";
            int count3 = stat.executeUpdate(sql1);
            System.out.println(count3==1?"數據修改成功":"數據修改失敗");

            //刪
            String sql2 = "delete from dept where deptno=50";
            int count4 = stat.executeUpdate(sql2);
            System.out.println(count4==1?"數據刪除成功":"數據刪除失敗");


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

    }
}

image-20220808214519531

image-20220808214433659

7.3將連接資料庫的所有信息配置到配置文件中

public class JDBCTest3 {
    /*
    使用配置文件將連接資料庫的相關參數進行保存,然後在代碼中使用
        使用jdk自身提供的Properties類來載入配置文件
     */
    public static void main(String[] args) throws IOException, ClassNotFoundException, SQLException {
        //使用無參構造方法創建Properties類的對象
        Properties prop = new Properties();

        //使用字元流讀取配置文件
        BufferedReader br = new BufferedReader(new FileReader("F:\\software\\IdeaProjects\\bigdata19_mysql\\resource\\jdbc.properties"));

        prop.load(br);
        String driver = prop.getProperty("driver");
        String url = prop.getProperty("url");
        String user = prop.getProperty("user");
        String password = prop.getProperty("password");

        //載入驅動
        Class.forName(driver);

        //獲取連接對象
        Connection conn = DriverManager.getConnection(url, user, password);

        //獲取資料庫操作對象
        Statement stat = conn.createStatement();

        //執行sql語句
        int count = stat.executeUpdate("insert into dept(deptno,dname,loc) values(70,'教學部','合肥')");
        System.out.println(count==1?"數據插入成功":"數據插入失敗");

        //釋放資源
        if (stat!=null){
            stat.close();
        }
        if (conn!=null){
            conn.close();
        }

    }
}

image-20220808221443846

image-20220808221506640

7.4處理查詢

工具類封裝

public class MySqlTool {
    /*
    工具類
    1.不能讓外界實例化(構造方法私有化)
    2.方法必須是靜態

     */
    private static Connection conn;
    private MySqlTool(){}

    public static Connection init(){
        try {
            Properties prop = new Properties();

            //使用字元流讀取配置文件
            BufferedReader br = new BufferedReader(new FileReader("F:\\software\\IdeaProjects\\bigdata19_mysql\\resource\\jdbc.properties"));

            prop.load(br);
            String driver = prop.getProperty("driver");
            String url = prop.getProperty("url");
            String user = prop.getProperty("user");
            String password = prop.getProperty("password");

            //載入驅動
            Class.forName(driver);

            //獲取連接對象
            conn = DriverManager.getConnection(url, user, password);


        }catch (Exception e){
            e.printStackTrace();
        }
        return conn;
    }

}

public class JDBCTest4 {
    public static void main(String[] args) throws SQLException {
        //通過工具類獲取資料庫連接對象
        Connection conn = MySqlTool.init();
        //獲取資料庫操作對象
        Statement stat = conn.createStatement();

        //執行sql語句
        ResultSet result = stat.executeQuery("select deptno,dname,loc from dept");
        //處理查詢結果集
        boolean b = result.next();
        //將游標從當前位置向前移動一行。
        //如果游標移動的位置有值,這裡的返回值是true
//        if (b){
//            //獲取一行中每一列的數值,第一種方式
//            String deptno = result.getString(1);
//            String dname = result.getString(2);
//            String loc = result.getString(3);
//            System.out.println("部門編號:"+deptno+",部門名稱:"+dname+",部門地址:"+loc);
//
//        }
        //正常情況下,一張結果表的行數我們不確定,但是我們知道,當next的結果是false的時候,表示讀取到末尾
        while(result.next()){
            //獲取一行中每一列的數值,第一種方式
//            String deptno = result.getString(1);
//            String dname = result.getString(2);
//            String loc = result.getString(3);
//            System.out.println("部門編號:"+deptno+",部門名稱:"+dname+",部門地址:"+loc);
            //第二種方式,根據列名獲取對應的列值
            //註意事項:當查詢sql語句中存在起別名的情況時,通過列名獲取列值的時候,使用名字是別名
            String deptno = result.getString("deptno");
            String dname = result.getString("dname");
            String loc = result.getString("loc");
            System.out.println("部門編號:"+deptno+",部門名稱:"+dname+",部門地址:"+loc);
        }
        //註意事項2:同一個結果resultSet對象,只能遍歷一次
        System.out.println("=========================");
        //再次遍歷,結果不顯示
        while(result.next()){
            //獲取一行中每一列的數值,第一種方式
//            String deptno = result.getString(1);
//            String dname = result.getString(2);
//            String loc = result.getString(3);
//            System.out.println("部門編號:"+deptno+",部門名稱:"+dname+",部門地址:"+loc);
            //第二種方式,根據列名獲取對應的列值
            //註意事項:當查詢sql語句中存在起別名的情況時,通過列名獲取列值的時候,使用名字是別名
            String deptno = result.getString("deptno");
            String dname = result.getString("dname");
            String loc = result.getString("loc");
            System.out.println("部門編號:"+deptno+",部門名稱:"+dname+",部門地址:"+loc);
        }



        //釋放資源
        if (stat!=null){
            stat.close();
        }
        if (conn!=null){
            conn.close();
        }

    }
}

image-20220809101259185

7.5登錄註冊案例

public class JDBCTest5 {
    public static void main(String[] args) throws SQLException {
        /*
        使用jdbc模擬登錄註冊案例
        1、註冊賬號:往資料庫插入一條數據
        2、登錄賬號:查詢資料庫

         */
        //1.建表user
        //創建鍵盤錄入對象
        System.out.println("歡迎來到提瓦特大陸,準備好開始冒險了嗎?");
        Scanner scanner = new Scanner(System.in);
        System.out.println("請輸入旅行者的名字:");
        String username = scanner.next();
        System.out.println("請輸入密碼:");
        String password = scanner.next();

        //創建資料庫驅動
//        try {
//            DriverManager.registerDriver(new Driver());
//        } catch (SQLException e) {
//            e.printStackTrace();
//        }
//
//        Connection conn = DriverManager.getConnection();
        //直接採用工具類獲取與資料庫的連接對象
        Connection conn = MySqlTool.init();
        //獲取資料庫操作對象
        Statement stat = conn.createStatement();

        //編寫sql語句
        String sql= "select username,password from user where username='"+username+"'and password='"+password+"'";
        //執行sql語句
        ResultSet rs = stat.executeQuery(sql);
        //處理查詢結果集
        boolean b = rs.next();
        if (b){
            System.out.println("旅行者"+username+",歡迎來到提瓦特大陸!");
        }else{
            System.out.println("您還未註冊成為旅行者,是否註冊(Y/N)");
            String choice = scanner.next();
            if ("Y".equals(choice)){
                while (true){
                    System.out.println("請輸入旅行者的名字:");
                    String new_username = scanner.next();
                    System.out.println("請輸入密碼:");
                    String new_password = scanner.next();
                    System.out.println("請確認密碼:");
                    String again_password = scanner.next();
                    if (again_password.equals(new_password)) {
                        UUID uuid = UUID.randomUUID();//隨機生成uuid
                        String new_uuid = uuid + "-" + System.currentTimeMillis();

                        String sql2 = "insert into user(uid,username,password) values('" + new_uuid + "','" + new_username +"','"+ new_password +"')";
                        int count = stat.executeUpdate(sql2);
                        if (count == 1) {
                            System.out.println("註冊成功");
                        } else {
                            System.out.println("註冊失敗");
                        }
                        break;
                    }else {
                        System.out.println("兩次密碼輸入不一致,請重新輸入:");

                    }
                }
            }
        }
        stat.close();
        conn.close();

    }
}

image-20220810212326528

7.6解決sql註入問題

public class JDBCTest6 {
    public static void main(String[] args) throws SQLException {
        /*
        我們寫完程式後發現,當我們將密碼輸入成1234' or '1'='1這個樣子的時候,發現登錄成功
        原因:sql在編譯的時候,會將我們輸入的內容存在關鍵字or,會把or當作sql語法關鍵字進行執行
        如何解決呢?
            這樣的問題,稱之為sql註入的問題
            解決的思路就是在sql編譯完後再傳入數據

       獲取資料庫操作對象另外一種方式,預編譯的方式
         */
        /*
        使用jdbc模擬登錄註冊案例
        1、註冊賬號:往資料庫插入一條數據
        2、登錄賬號:查詢資料庫

         */
        //1.建表user
        //創建鍵盤錄入對象
        System.out.println("歡迎來到提瓦特大陸,準備好開始冒險了嗎?");
        Scanner scanner = new Scanner(System.in);
        System.out.println("請輸入旅行者的名字:");
        String username = scanner.nextLine();
        System.out.println("請輸入密碼:");
        String password = scanner.nextLine();

        //創建資料庫驅動
//        try {
//            DriverManager.registerDriver(new Driver());
//        } catch (SQLException e) {
//            e.printStackTrace();
//        }
//
//        Connection conn = DriverManager.getConnection();
        //直接採用工具類獲取與資料庫的連接對象
        Connection conn = MySqlTool.init();
//        //獲取資料庫操作對象
//        Statement stat = conn.createStatement();
//
//        //編寫sql語句
//        String sql= "select username,password from user where username='"+username+"'and password='"+password+"'";
//        //執行sql語句
//        ResultSet rs = stat.executeQuery(sql);

        //這裡的問號相當於一個占位符,為了後面傳值
        String sql = "select username,password from user where username=? and password=?";
        //創建預編譯資料庫操作對象
        PreparedStatement pps = conn.prepareStatement(sql);
        //將sql中的占位符附上值
        //第一個參數表示給第幾個問號傳值,第二個參數表示具體的值,序號從1開始
        pps.setString(1,username);
        pps.setString(2,password);

        //執行sql語句
        ResultSet rs = pps.executeQuery();

        //處理查詢結果集
        boolean b = rs.next();
        if (b){
            System.out.println("旅行者"+username+",歡迎來到提瓦特大陸!");
        }else{
            System.out.println("您還未註冊成為旅行者,是否註冊(Y/N)");
            String choice = scanner.next();
            if ("Y".equals(choice)){
                while (true){
                    System.out.println("請輸入旅行者的名字:");
                    String new_username = scanner.next();
                    System.out.println("請輸入密碼:");
                    String new_password = scanner.next();
                    System.out.println("請確認密碼:");
                    String again_password = scanner.next();
                    if (again_password.equals(new_password)) {
                        UUID uuid = UUID.randomUUID();//隨機生成uuid
                        String new_uuid = uuid + "-" + System.currentTimeMillis();

                        String sql2 = "insert into user(uid,username,password) values('" + new_uuid + "','" + new_username +"','"+ new_password +"')";
                        int count = pps.executeUpdate(sql2);
                        if (count == 1) {
                            System.out.println("註冊成功");
                        } else {
                            System.out.println("註冊失敗");
                        }
                        break;
                    }else {
                        System.out.println("兩次密碼輸入不一致,請重新輸入:");

                    }
                }
            }
        }
        pps.close();
        conn.close();

    }
}

image-20220810215933845

7.7JDBC實現模糊查詢

public class JDBCTest7 {
    public static void main(String[] args) throws SQLException {
        //獲取資料庫連接對象
        Connection conn = MySqlTool.init();
        //獲取預編譯資料庫操作對象
        String sql="select uid,username,password from user where username like ?";
        PreparedStatement pps = conn.prepareStatement(sql);
        pps.setString(1,"%bfy%");
        //執行sql語句
        ResultSet rs = pps.executeQuery();
        //處理查詢結果集
        while (rs.next()){
            String uid=rs.getString(1);
            String username=rs.getString(2);
            String password=rs.getString(3);
            System.out.println(uid+','+username+','+password);
        }

        pps.close();
        conn.close();
    }
}

image-20220810221532497


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 本文結合自身後臺開發經驗,從高可用、高性能、易維護和低風險(安全)角度出發,嘗試總結業界常見微服務介面設計原則,幫助大家設計出優秀的微服務。 ...
  • 本文由老王將建好的書房計劃請小王來幫忙,小王卻想謀權篡位,老王通過教育他引出裝飾器設計模式,第二部分針對老王提出的建設性意見實現裝飾器模式,第三部分針對裝飾器模式在Jdk中的IO、Spring中的緩存管理器、Mybatis的運用來加強我們的理解,第四部分說明裝飾器模式和代理模式的區別及他們各自的應用... ...
  • 冪等性在我們的工作中無處不在,無論是支付場景還是下訂單等核心場景都會涉及,也是分散式系統最常遇到的問題,除此之外,也是大廠面試的重災區。 知道了冪等性的重要性,下麵我就詳細介紹冪等性以及具體的解決方案,希望對大家有所幫助@mikechen 什麼是冪等性 冪等是一個數學與電腦學概念,在數學中某一元運 ...
  • 異常 筆記目錄:(https://www.cnblogs.com/wenjie2000/p/16378441.html) 運行下麵的代碼,看看有什麼問題->引出異常和異常處理機制 public static void main(String[] args) { int num1 =10; int n ...
  • 枚舉和註釋 筆記目錄:(https://www.cnblogs.com/wenjie2000/p/16378441.html) 自定義類實現枚舉 先看一個需求 要求創建季節(Season)對象,請設計並完成。 創建Season對象有如下特點 1.季節的值是有限的幾個值(spring, summer, ...
  • 一、分庫分表解決的現狀問題 解決資料庫本身瓶頸 連接數: 連接數過多時,就會出現‘too many connections’的錯誤,訪問量太大或者資料庫設置的最大連接數太小的原因 Mysql預設的最大連接數為100.可以修改,而mysql服務允許的最大連接數為16384 資料庫分表可以解決單表海量數 ...
  • #反射機制 AVA反射機制是在運行狀態中,對於任意一個類,都能夠知道這個類的所有屬性和方法;對於任意一個對象,都能夠調用它的任意一個方法和屬性;這種動態獲取的信息以及動態調用對象的方法的功能稱為java語言的反射機制。 Java反射機制在框架設計中極為廣泛,需要深入理解。 ##反射基礎 RTTI(R ...
  • 目錄 一.簡介 二.效果演示 三.源碼下載 四.猜你喜歡 零基礎 OpenGL (ES) 學習路線推薦 : OpenGL (ES) 學習目錄 >> OpenGL ES 基礎 零基礎 OpenGL (ES) 學習路線推薦 : OpenGL (ES) 學習目錄 >> OpenGL ES 轉場 零基礎 O ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...