java學習之jdbc

来源:https://www.cnblogs.com/0x3e-time/archive/2022/04/30/16201010.html
-Advertisement-
Play Games

在一些web開發或者是數據存儲的時候,肯定會使用到資料庫來進行數據存儲。而在Java裡面需要調用JDBC來對資料庫進行操作。每次用jdbc很麻煩,就可以採用一些連接池來解決這個問題 ...


0x00前言

在一些web開發或者是數據存儲的時候,肯定會使用到資料庫來進行數據存儲。而在Java裡面需要調用JDBC來對資料庫進行操作。每次用jdbc很麻煩,就可以採用一些連接池來解決這個問題

0x01常用類和方法

0x1Connection介面

1.createStatement() 
創建一個 Statement對象,用於將SQL語句發送到資料庫。
2.close() 
Connection發佈此 Connection對象的資料庫和JDBC資源,而不是等待它們自動釋放。
3.CallableStatement prepareCall(String sql)
創建一個調用資料庫存儲過程的 CallableStatement對象。  
4.prepareStatement(String sql) 
創建一個 PreparedStatement對象,用於將參數化的SQL語句發送到資料庫。 對sql語句進行預處理,解決sql註入問題
5.boolen execute(String sql)
執行的select語句就返回true,其他返回false
6.ResultSet executeQuery(String sql)  
執行給定的(select)SQL語句,該語句返回單個 ResultSet對象,
7.int executeUpdate(String sql) 
執行給定的SQL語句,這可能是 INSERT , UPDATE ,或 DELETE語句,或者不返回任何內容,如SQL DDL語句的SQL語句。返回的int是影響的函數
8.批處理的執行
(1)void addBatch(String sql) 
將給定的SQL命令添加到此 Statement對象的當前命令列表中。  
(2)int[] executeBatch() 
將一批命令提交到資料庫以執行,並且所有命令都執行成功,返回一個更新計數的數組。  
(3)void clearBatch() 
清空此 Statement對象的當前SQL命令列表。

0x2ResultSet

1.表示資料庫結果集的數據表,通常通過執行查詢資料庫的語句生成。
2.boolean next()是否還有下一行數據存在返回true
3.getString(String key);查找指定的列名的數據

public class JVAV_Test01 {
    public static void main(String[] args) throws Exception {
        Class.forName("com.mysql.cj.jdbc.Driver");
        Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306", "root", "zhonglin");
        //執行sql語句的對象
        Statement statement = connection.createStatement();
        String s=("select * from  web_1.student;");
        ResultSet resultSet = statement.executeQuery(s);
        while (resultSet.next()){
            System.out.println(resultSet.getString("name"));
            System.out.println(resultSet.getString("id"));
            
        }
        statement.close();
        resultSet.close();
    }
}

0x02抽取工具類和用配置文件使用

0x1Properties類

在使用jdbc的時候會存在很多重覆利用的代碼我們就可以把重覆的代碼給寫成一個類供我們使用,同時使用配置文件去靈活的配置資料庫文件。

0x2常用方法

1.String getProperty(String key)
使用此屬性列表中指定的鍵搜索屬性
2.void list(PrintStream out)
將此屬性列表列印到指定的輸出流。

public class Jdbc_toll_class {
    private static final  String drvierClassname;
    private static final  String user;
    private static final  String password;
    private static final  String url;
    static {
        Properties properties=new Properties();//專門處理配置文件的一個類
        try {
            properties.load(new FileInputStream("C:\\Users\\**\\IdeaProjects\\sec_Reptile\\src\\main\\resources\\db.properties"));//讀取配置文件路徑
        } catch (IOException e) {
            e.printStackTrace();
        }
        drvierClassname=properties.getProperty("drvierClassname");
        user=properties.getProperty("user");
        password=properties.getProperty("password");;
        url=properties.getProperty("url");;
    }
    public static void loadDriver(){
        try {
            Class.forName(drvierClassname);

        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }

    public static Connection getConnecton() {
        Connection connection = null;
        try {
            loadDriver();
            connection = DriverManager.getConnection(url, user, password);



        } catch (SQLException e) {
            e.printStackTrace();
        }return connection;
    }
    public static void release(Statement statement,Connection connection){

        try {
            connection.close();
            statement.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    public static void release(ResultSet resultSet, Statement statement, Connection connection){
        try {
            resultSet.close();
            statement.close();
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }


    }

    }

0x03public interface PreparedStatement

0x1方法基礎使用

1.int executeUpdate()
執行在該SQL語句PreparedStatement對象,它必須是一個SQL數據操縱語言(DML)語句,如INSERT , UPDATE或DELETE ; 或不返回任何內容的SQL語句,例如DDL語句。
2.boolean execute()
執行此 PreparedStatement對象中的SQL語句,這可能是任何類型的SQL語句。
3.ResultSet executeQuery()
執行此 PreparedStatement對象中的SQL查詢,並返回查詢 PreparedStatement的 ResultSet對象。
4.void setInt(String,byte)(int parameterIndex, int x)
將指定的參數設置為給定的Java int(String,byte)值。

public class JAVA_test03 {
    public static void main(String[] args) {
        Connection connection;
        PreparedStatement preparedStatement;
        connection=Jdbc_toll_class.getConnection();
        String sql="insert into student values (null ,?)";
        try {
            preparedStatement=connection.prepareStatement(sql);
            preparedStatement.setString(1,"hellow");

            preparedStatement.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

0x04批處理

1.首先要在的資料庫後面加上:?rewriteBatchedStatements=true
2.PreparedStatement的批處理是利用設置參數和循壞去處理
3.如果批處理命令過多要執行後清除再添加

public class JAVA_tese06 {
    //批處理後面要加需要在連接的資料庫後面加上:?rewriteBatchedStatements=true
    public static void main(String[] args) {
        Connection connection = Jdbc_toll_class.getConnection();
        PreparedStatement preparedStatement=null;
        Jdbc_toll_class.executesql("use tese");
        String sql="insert into user values(null,?)";
        try {
            preparedStatement = connection.prepareStatement(sql);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        try {
            for (int i = 0; i < 10; i++) {
                preparedStatement.setString(1,"試試");
                preparedStatement.addBatch();
                if (i %10==0){
                    preparedStatement.execute();
                    preparedStatement.clearBatch();
                }

            }

        }catch (Exception e){
            e.printStackTrace();
        }finally {
            Jdbc_toll_class.release(connection,preparedStatement);
        }
    }
}

4.Statement批處理
5.是用addbatch,方法去把批處理命令都添加進去,用executeBatch執行

public class JAVA_test05 {
    public static void main(String[] args) {
        Connection connection = Jdbc_toll_class.getConnection();
        try {
            Statement statement = connection.createStatement();
            String sql2="use tese";
            String sql4="insert into user values(null,'aaa')";
            String sql5="insert into user values(null,'bbb')";
            String sql6="insert into user values(null,'ccc')";
            String sql7="update user set name='mmm' where id=2";
            String sql8="delete from user where id=1";
            statement.addBatch(sql2);
            statement.addBatch(sql4);
            statement.addBatch(sql5);
            statement.addBatch(sql6);
            statement.addBatch(sql7);
            statement.addBatch(sql8);
            statement.executeBatch();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

0x05連接池

0x1c3p0連接池

public class c3p0_test {
1.獲取對象2.還是通過連接對象connection去獲取prepareStatement等對象去執行3.它的配置文件需要放在src下麵。

    public static void main(String[] args) throws SQLException {
        DataSource dataSource=new ComboPooledDataSource();//這裡可以選擇你的配置文件裡面預先設定好的配置
        Connection connection = dataSource.getConnection();
        System.out.println(connection);
    }

0x2druid連接池

1.獲取對象是通過Properties類獲取文件
2.InputStream resourceAsStream = Druid_test.class.getClassLoader().getResourceAsStream("druid.properties");
3.properties.load(resourceAsStream);//構建配置文件

public class Druid_test {
    public static void main(String[] args) {
        Properties properties=new Properties();
        InputStream resourceAsStream = Druid_test.class.getClassLoader().getResourceAsStream("druid.properties");
        try {
            properties.load(resourceAsStream);
            DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);
            Connection connection = dataSource.getConnection();
            System.out.println(connection);
        } catch (IOException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        }

    }
}

4.工具類的定義
1.封裝一些方法方便我們使用方法

public class JDBCUtils {
    //1定義成員變數
    private static DataSource dataSource;
    static {

        try {
            Properties properties=new Properties();
            properties.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));
            dataSource= DruidDataSourceFactory.createDataSource(properties);
        } catch (IOException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }public static Connection getconnection() throws SQLException {
        return dataSource.getConnection();
    }
    public static  void close(Statement statement,Connection connection){
        if (statement!=null){
        try {
            statement.close();
        }catch (Exception E){
            E.printStackTrace();
        }

    }
        if (connection!=null){
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        }
    public static  void close(ResultSet resultSet, Statement statement, Connection connection){
        if (statement!=null){
            try {
                statement.close();
            }catch (Exception E){
                E.printStackTrace();
            }

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

    }
    public static DataSource getDataSource(){
        return dataSource;

    }
    }

0x3JDBCtemplate

1.用Spring框架集成的這個JDBCtemplate,只需要獲取一個Source對象就可以直接執行sql語句
2。它會自己獲取連接對象和釋放連接對象,

public class JDBCtemplate {
    public static void main(String[] args) {
        JdbcTemplate jdbcTemplate = new JdbcTemplate(JDBCUtils.getDataSource());
        String sql="insert into user values (null,?)";
        int i = jdbcTemplate.update(sql, "小天");
        System.out.println(1);
    }

0x06總結

總結下來其實Spring框架的JDBCtemplate使用起來最簡單,以後在有框架開發的時候會用到這些,開發的時候多使用 preparedStatement,預防,sql註入。


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

-Advertisement-
Play Games
更多相關文章
  • SAS (Statistical Analysis System) 是一個統計軟體系統,由 SAS Institute 開發, 用於數據管理、高級分析、多元分析、商業智能、刑事調查和預測分析. SAS 由北卡羅來納州立大學在1966至1976年之間開發, 並於1976年成立了SAS軟體研究所. 19... ...
  • HDFS HDFS由大量伺服器組成存儲集群,將數據進行分片與副本,實現高容錯。 而分片最小的單位就是塊。預設塊的大小是64M。 HDFS Cli操作 官網https://hadoop.apache.org/docs/stable/hadoop-project-dist/hadoop-common/F ...
  • 一、Spark on Hive 和 Hive on Spark的區別 1)Spark on Hive Spark on Hive 是Hive只作為存儲角色,Spark負責sql解析優化,執行。這裡可以理解為Spark 通過Spark SQL 使用Hive 語句操作Hive表 ,底層運行的還是 Spa ...
  • 常用的資料庫代碼 -- 通過 * 把 users 表中所有的數據查詢出來 -- select * from users -- 從 users 表中把 username 和 password 對應的數據查詢出來 -- select username, password from users -- 向 ...
  • ##Bootstrap導航欄樣式不生效的原因 今天在看bootstrap教程,想要將代碼複製粘貼到編譯器中運行,可是無法將效果正常顯示 ####情況如下: ####代碼如下: <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> ...
  • 菜單中有的項目有夏季菜單,需要添加一個三角形,這個三角形是利用兩個邊框不同顏色產生的楔形製作的 設置盒子的高度和寬度均為0,邊框合適的大小,透明顏色,對應邊設置高度、顏色 幾個變形如下 最終的效果如下: ...
  • 前言 所謂軟體過程模型就是一種開發策略,這種策略針對軟體工程的各個階段提供了一套範形,使工程的進展達到預期的目的。對一個軟體的開發無論其大小,我們都需要選擇一個合適的軟體過程模型,這種選擇基於項目和應用的性質、採用的方法、需要的控制,以及要交付的產品的特點。一個錯誤模型的選擇,將迷失我們的開發方向。 ...
  • 很多 C++ 方面的書籍都說明瞭虛析構的作用: 保證派生類的析構函數被調用,並且使析構順序與構造函數相反 保證資源能夠被正確釋放 很久一段時間以來,我一直認為第 2 點僅僅指的是:當派生類使用 RAII 手法時,如果派生類的析構沒有被調用,就會產生資源泄露。就像下麵的代碼: #include <io ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...