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
  • GoF之工廠模式 @目錄GoF之工廠模式每博一文案1. 簡單說明“23種設計模式”1.2 介紹工廠模式的三種形態1.3 簡單工廠模式(靜態工廠模式)1.3.1 簡單工廠模式的優缺點:1.4 工廠方法模式1.4.1 工廠方法模式的優缺點:1.5 抽象工廠模式1.6 抽象工廠模式的優缺點:2. 總結:3 ...
  • 新改進提供的Taurus Rpc 功能,可以簡化微服務間的調用,同時可以不用再手動輸出模塊名稱,或調用路徑,包括負載均衡,這一切,由框架實現並提供了。新的Taurus Rpc 功能,將使得服務間的調用,更加輕鬆、簡約、高效。 ...
  • 本章將和大家分享ES的數據同步方案和ES集群相關知識。廢話不多說,下麵我們直接進入主題。 一、ES數據同步 1、數據同步問題 Elasticsearch中的酒店數據來自於mysql資料庫,因此mysql數據發生改變時,Elasticsearch也必須跟著改變,這個就是Elasticsearch與my ...
  • 引言 在我們之前的文章中介紹過使用Bogus生成模擬測試數據,今天來講解一下功能更加強大自動生成測試數據的工具的庫"AutoFixture"。 什麼是AutoFixture? AutoFixture 是一個針對 .NET 的開源庫,旨在最大程度地減少單元測試中的“安排(Arrange)”階段,以提高 ...
  • 經過前面幾個部分學習,相信學過的同學已經能夠掌握 .NET Emit 這種中間語言,並能使得它來編寫一些應用,以提高程式的性能。隨著 IL 指令篇的結束,本系列也已經接近尾聲,在這接近結束的最後,會提供幾個可供直接使用的示例,以供大伙分析或使用在項目中。 ...
  • 當從不同來源導入Excel數據時,可能存在重覆的記錄。為了確保數據的準確性,通常需要刪除這些重覆的行。手動查找並刪除可能會非常耗費時間,而通過編程腳本則可以實現在短時間內處理大量數據。本文將提供一個使用C# 快速查找並刪除Excel重覆項的免費解決方案。 以下是實現步驟: 1. 首先安裝免費.NET ...
  • C++ 異常處理 C++ 異常處理機制允許程式在運行時處理錯誤或意外情況。它提供了捕獲和處理錯誤的一種結構化方式,使程式更加健壯和可靠。 異常處理的基本概念: 異常: 程式在運行時發生的錯誤或意外情況。 拋出異常: 使用 throw 關鍵字將異常傳遞給調用堆棧。 捕獲異常: 使用 try-catch ...
  • 優秀且經驗豐富的Java開發人員的特征之一是對API的廣泛瞭解,包括JDK和第三方庫。 我花了很多時間來學習API,尤其是在閱讀了Effective Java 3rd Edition之後 ,Joshua Bloch建議在Java 3rd Edition中使用現有的API進行開發,而不是為常見的東西編 ...
  • 框架 · 使用laravel框架,原因:tp的框架路由和orm沒有laravel好用 · 使用強制路由,方便介面多時,分多版本,分文件夾等操作 介面 · 介面開發註意欄位類型,欄位是int,查詢成功失敗都要返回int(對接java等強類型語言方便) · 查詢介面用GET、其他用POST 代碼 · 所 ...
  • 正文 下午找企業的人去鎮上做貸後。 車上聽同事跟那個司機對罵,火星子都快出來了。司機跟那同事更熟一些,連我在內一共就三個人,同事那一手指桑罵槐給我都聽愣了。司機也是老社會人了,馬上聽出來了,為那個無辜的企業經辦人辯護,實際上是為自己辯護。 “這個事情你不能怪企業。”“但他們總不能讓銀行的人全權負責, ...