JDBC【PreparedStatment、批處理、處理二進制、自動主鍵、調用存儲過程、函數】

YFan 發布于2019-08-15 14:14 / 3110人閱讀

摘要：可對進行預編譯，提高效率，預編譯的存儲在對象中防止注入。獲取到自動主鍵列的值調用數據庫的存儲過程調用存儲過程的語法調用函數的語法如果是類型的，那么在調用的時候是要注冊的。

1.PreparedStatement對象

PreparedStatement對象繼承Statement對象，它比Statement對象更強大，使用起來更簡單

Statement對象編譯SQL語句時，如果SQL語句有變量，就需要使用分隔符來隔開，如果變量非常多，就會使SQL變得非常復雜。PreparedStatement可以使用占位符，簡化sql的編寫

Statement會頻繁編譯SQL。PreparedStatement可對SQL進行預編譯，提高效率，預編譯的SQL存儲在PreparedStatement對象中

PreparedStatement防止SQL注入?！維tatement通過分隔符"++",編寫永等式，可以不需要密碼就進入數據庫】

        //模擬查詢id為2的信息
        String id = "2";

        Connection connection = UtilsDemo.getConnection();

        String sql = "SELECT * FROM users WHERE id = ?";
        PreparedStatement preparedStatement = connection.preparedStatement(sql);

        //第一個參數表示第幾個占位符【也就是?號】，第二個參數表示值是多少
        preparedStatement.setString(1,id);

        ResultSet resultSet = preparedStatement.executeQuery();

        if (resultSet.next()) {
            System.out.println(resultSet.getString("name"));
        }

        //釋放資源
        UtilsDemo.release(connection, preparedStatement, resultSet);

2.批處理

當需要向數據庫發送一批SQL語句執行時，應避免向數據庫一條條發送執行，采用批處理以提升執行效率

批處理有兩種方式：

Statement

PreparedStatement

通過executeBath()方法批量處理執行SQL語句，返回一個int[]數組，該數組代表各句SQL的返回值

以下代碼是以Statement方式實現批處理

        /*
        * Statement執行批處理
        *
        * 優點：
        *       可以向數據庫發送不同的SQL語句
        * 缺點：
        *       SQL沒有預編譯
        *       僅參數不同的SQL，需要重復寫多條SQL
        * */
        Connection connection = UtilsDemo.getConnection();

        Statement statement = connection.createStatement();
        String sql1 = "UPDATE users SET name="zhongfucheng" WHERE id="3"";
        String sql2 = "INSERT INTO users (id, name, password, email, birthday)" +
                " VALUES("5","nihao","123","ss@qq.com","1995-12-1")";

        //將sql添加到批處理
        statement.addBatch(sql1);
        statement.addBatch(sql2);

        //執行批處理
        statement.executeBatch();

        //清空批處理的sql
        statement.clearBatch();

        UtilsDemo.release(connection, statement, null);

以下方式以PreparedStatement方式實現批處理

        /*
        * PreparedStatement批處理
        *   優點：
        *       SQL語句預編譯了
        *       對于同一種類型的SQL語句，不用編寫很多條
        *   缺點：
        *       不能發送不同類型的SQL語句
        *
        * */
        Connection connection = UtilsDemo.getConnection();

        String sql = "INSERT INTO test(id,name) VALUES (?,?)";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);

        for (int i = 1; i <= 205; i++) {
            preparedStatement.setInt(1, i);
            preparedStatement.setString(2, (i + "zhongfucheng"));

            //添加到批處理中
            preparedStatement.addBatch();

            if (i %2 ==100) {

                //執行批處理
                preparedStatement.executeBatch();

                //清空批處理【如果數據量太大，所有數據存入批處理，內存肯定溢出】
                preparedStatement.clearBatch();
            }

        }
        //不是所有的%2==100，剩下的再執行一次批處理
        preparedStatement.executeBatch();

        //再清空
        preparedStatement.clearBatch();

        UtilsDemo.release(connection, preparedStatement, null);

3.處理大文本和二進制數據

clob和blob

clob用于存儲大文本

blob用于存儲二進制數據

MYSQL

MySQL存儲大文本是用Test【代替clob】，Test又分為4類

TINYTEXT

TEXT

MEDIUMTEXT

LONGTEXT

同理blob也有這4類

下面用JDBC連接MySQL數據庫去操作大文本數據和二進制數據



/*
*用JDBC操作MySQL數據庫去操作大文本數據
*
*setCharacterStream(int parameterIndex,java.io.Reader reader,long length)
*第二個參數接收的是一個流對象，因為大文本不應該用String來接收，String太大會導致內存溢出
*第三個參數接收的是文件的大小
*
* */
public class Demo5 {

    @Test
    public void add() {

        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;

        try {
            connection = JdbcUtils.getConnection();
            String sql = "INSERT INTO test2 (bigTest) VALUES(?) ";
            preparedStatement = connection.prepareStatement(sql);

            //獲取到文件的路徑
            String path = Demo5.class.getClassLoader().getResource("BigTest").getPath();
            File file = new File(path);
            FileReader fileReader = new FileReader(file);

            //第三個參數，由于測試的Mysql版本過低，所以只能用int類型的。高版本的不需要進行強轉
            preparedStatement.setCharacterStream(1, fileReader, (int) file.length());

            if (preparedStatement.executeUpdate() > 0) {
                System.out.println("插入成功");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        } finally {
            JdbcUtils.release(connection, preparedStatement, null);
        }


    }

    /*
    * 讀取大文本數據，通過ResultSet中的getCharacterStream()獲取流對象數據
    * 
    * */
    @Test
    public void read() {

        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        try {
            connection = JdbcUtils.getConnection();
            String sql = "SELECT * FROM test2";
            preparedStatement = connection.prepareStatement(sql);
            resultSet = preparedStatement.executeQuery();

            if (resultSet.next()) {

                Reader reader = resultSet.getCharacterStream("bigTest");

                FileWriter fileWriter = new FileWriter("d:abc.txt");
                char[] chars = new char[1024];
                int len = 0;
                while ((len = reader.read(chars)) != -1) {
                    fileWriter.write(chars, 0, len);
                    fileWriter.flush();
                }
                fileWriter.close();
                reader.close();

            }
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            JdbcUtils.release(connection, preparedStatement, resultSet);
        }
        
    }

/*
* 使用JDBC連接MYsql數據庫操作二進制數據
* 如果我們要用數據庫存儲一個大視頻的時候，數據庫是存儲不到的。
* 需要設置max_allowed_packet，一般我們不使用數據庫去存儲一個視頻
* */
public class Demo6 {

    @Test
    public void add() {


        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;


        try {
            connection = JdbcUtils.getConnection();
            String sql = "INSERT INTO test3 (blobtest) VALUES(?)";
            preparedStatement = connection.prepareStatement(sql);

            //獲取文件的路徑和文件對象
            String path = Demo6.class.getClassLoader().getResource("1.wmv").getPath();
            File file = new File(path);

            //調用方法
            preparedStatement.setBinaryStream(1, new FileInputStream(path), (int)file.length());

            if (preparedStatement.executeUpdate() > 0) {

                System.out.println("添加成功");
            }

        } catch (SQLException e) {
            e.printStackTrace();
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        } finally {
            JdbcUtils.release(connection, preparedStatement, null);
        }

    }

    @Test
    public void read() {


        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;


        try {
            connection = JdbcUtils.getConnection();
            String sql = "SELECT * FROM test3";
            preparedStatement = connection.prepareStatement(sql);

            resultSet = preparedStatement.executeQuery();


            //如果讀取到數據，就把數據寫到磁盤下
            if (resultSet.next()) {
                InputStream inputStream = resultSet.getBinaryStream("blobtest");
                FileOutputStream fileOutputStream = new FileOutputStream("d:aa.jpg");

                int len = 0;
                byte[] bytes = new byte[1024];
                while ((len = inputStream.read(bytes)) > 0) {

                    fileOutputStream.write(bytes, 0, len);

                }
                fileOutputStream.close();
                inputStream.close();

            }

        } catch (SQLException e) {
            e.printStackTrace();
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            JdbcUtils.release(connection, preparedStatement, null);
        }

    }

Oracle

下面用JDBC連接Oracle數據庫去操作大文本數據和二進制數據



//使用JDBC連接Oracle數據庫操作二進制數據
    
/*
* 對于Oracle數據庫和Mysql數據庫是有所不同的。
* 1.Oracle定義了BLOB字段，但是這個字段不是真正地存儲二進制數據
* 2.向這個字段存一個BLOB指針，獲取到Oracle的BLOB對象,把二進制數據放到這個指針里面,指針指向BLOB字段
* 3.需要事務支持
*
* */
public class Demo7 {
    @Test
    public void add() {


        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;

        try {
            connection = UtilsDemo.getConnection();

            //開啟事務
            connection.setAutoCommit(false);

            //插入一個BLOB指針
            String sql = "insert into test4(id,image) values(?,empty_blob())";
            preparedStatement = connection.prepareStatement(sql);
            preparedStatement.setInt(1, 1);
            preparedStatement.executeUpdate();

            //把BLOB指針查詢出來,得到BLOB對象
            String sql2 = "select image from test4 where id= ? for update";
            preparedStatement = connection.prepareStatement(sql2);
            preparedStatement.setInt(1, 1);
            resultSet = preparedStatement.executeQuery();

            if (resultSet.next()) {
                //得到Blob對象--當成是Oracle的Blob,不是JDBC的,所以要強轉[導的是oracle.sql.BLOB包]
                BLOB  blob = (BLOB) resultSet.getBlob("image");

                //寫入二進制數據
                OutputStream outputStream = blob.getBinaryOutputStream();

                //獲取到讀取文件讀入流
                InputStream inputStream = Demo7.class.getClassLoader().getResourceAsStream("01.jpg");

                int len=0;
                byte[] bytes = new byte[1024];
                while ((len = inputStream.read(bytes)) > 0) {

                    outputStream.write(bytes, 0, len);
                }
                outputStream.close();
                inputStream.close();
                connection.setAutoCommit(true);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            UtilsDemo.release(connection, preparedStatement, null);
        }

    }

    @Test
    public void find() {
        
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;

        try {
            connection = UtilsDemo.getConnection();
            String sql = "SELECT * FROM test4 WHERE id=1";

            preparedStatement = connection.prepareStatement(sql);
            resultSet = preparedStatement.executeQuery();

            if (resultSet.next()) {

                //獲取到BLOB對象
                BLOB blob = (BLOB) resultSet.getBlob("image");

                //將數據讀取到磁盤上
                InputStream inputStream = blob.getBinaryStream();
                FileOutputStream fileOutputStream = new FileOutputStream("d:zhongfucheng.jpg");
                int len=0;
                byte[] bytes = new byte[1024];

                while ((len = inputStream.read(bytes)) > 0) {

                    fileOutputStream.write(bytes, 0, len);
                }

                inputStream.close();
                fileOutputStream.close();

            }

        } catch (SQLException e) {
            e.printStackTrace();
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            UtilsDemo.release(connection, preparedStatement, null);
        }
    }
}

對于JDBC連接Oracle數據庫操作CLOB數據,我就不再重復了,操作跟BLOB幾乎相同

4.獲取數據庫的自動主鍵列 為什么要獲取數據庫的自動主鍵列數據?

應用場景:

有一張老師表，一張學生表。現在來了一個新的老師，學生要跟著新老師上課。

我首先要知道老師的id編號是多少，學生才能知道跟著哪個老師學習【學生外鍵參照老師主鍵】。


    @Test
    public void test() {

        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;

        try {
            connection = JdbcUtils.getConnection();

            String sql = "INSERT INTO test(name) VALUES(?)";
            preparedStatement = connection.prepareStatement(sql);

            preparedStatement.setString(1, "ouzicheng");

            if (preparedStatement.executeUpdate() > 0) {

                //獲取到自動主鍵列的值
                resultSet = preparedStatement.getGeneratedKeys();

                if (resultSet.next()) {
                    int id = resultSet.getInt(1);
                    System.out.println(id);
                }
            }
            
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JdbcUtils.release(connection, preparedStatement, null);
        }

5.調用數據庫的存儲過程

調用存儲過程的語法：

    {call [(,, ...)]}

調用函數的語法：

    {?= call [(,, ...)]}

如果是Output類型的，那么在JDBC調用的時候是要注冊的。如下代碼所示：


/*
    jdbc調用存儲過程

    delimiter $$
        CREATE PROCEDURE demoSp(IN inputParam VARCHAR(255), INOUT inOutParam varchar(255))
        BEGIN
            SELECT CONCAT("zyxw---", inputParam) into inOutParam;
        END $$
    delimiter ;
*/
//我們在JDBC調用存儲過程,就像在調用方法一樣
public class Demo9 {

    public static void main(String[] args) {
        Connection connection = null;
        CallableStatement callableStatement = null;

        try {
            connection = JdbcUtils.getConnection();
            
            callableStatement = connection.prepareCall("{call demoSp(?,?)}");

            callableStatement.setString(1, "nihaoa");
            
            //注冊第2個參數,類型是VARCHAR
            callableStatement.registerOutParameter(2, Types.VARCHAR);
            callableStatement.execute();
            
            //獲取傳出參數[獲取存儲過程里的值]
            String result = callableStatement.getString(2);
            System.out.println(result);

        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            try {
                connection.close();
                callableStatement.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

    }

參考資料：


----------------------------------------------------------------------------------過程

#修改mysql語句的結果符為//
mysql > delimiter //

#定義一個過程，獲取users表總記錄數，將10設置到變量count中
create procedure simpleproc(out count int)
begin
    select count(id) into count from users;
end
//

#修改mysql語句的結果符為;
mysql > delimiter ;

#調用過程，將結果覆給變量a，@是定義變量的符號
call simpleproc(@a);

#顯示變量a的值
select @a;

//以下是Java調用Mysql的過程
    String sql = "{call simpleproc(?)}";
    Connection conn = JdbcUtil.getConnection();
    CallableStatement cstmt = conn.prepareCall(sql);
    cstmt.registerOutParameter(1,Types.INTEGER);
    cstmt.execute();
    Integer count = cstmt.getInt(1);
    System.out.println("共有" + count + "人");

----------------------------------------------------------------------------------函數

#修改mysql語句的結果符為//
mysql > delimiter //

#定義一個函數，完成字符串拼接
create function hello( s char(20) ) returns char(50) 
return concat("hello，",s,"!");
//

#修改mysql語句的結果符為;
mysql > delimiter ;

#調用函數
select hello("world");

//以下是Java調用Mysql的函數
    String sql = "{? = call hello(?)}";
    Connection conn = JdbcUtil.getConnection();
    CallableStatement cstmt = conn.prepareCall(sql);
    cstmt.registerOutParameter(1,Types.VARCHAR);
    cstmt.setString(2,"zhaojun");
    cstmt.execute();
    String value = cstmt.getString(1);
    System.out.println(value);
    JdbcUtil.close(cstmt);
    JdbcUtil.close(conn);

如果文章有錯的地方歡迎指正，大家互相交流。習慣在微信看技術文章的同學，可以關注微信公眾號:Java3y

云服務器 GPU云服務器 js處理二進制數據數據處理過程 webrtc聲音處理過程 webrtc音頻處理過程

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/68488.html

Java3y文章目錄導航

摘要：前言由于寫的文章已經是有點多了，為了自己和大家的檢索方便，于是我就做了這么一個博客導航。前言由于寫的文章已經是有點多了，為了自己和大家的檢索方便，于是我就做了這么一個博客導航。由于更新比較頻繁，因此隔一段時間才會更新目錄導航哦～想要獲取最新原創的技術文章歡迎關注我的公眾號：Java3y Java3y文章目錄導航 Java基礎泛型就這么簡單注解就這么簡單 Druid數據庫連接池...

KevinYan 2019-08-15 15:13 評論0 收藏0
Java JDBC編程

摘要：和很像，嚴格來說，應該是模仿了是設計。程序中使用該類的主要功能是獲取對象，該類包含如下方法該方法獲得對應數據庫的連接代表數據庫連接對象，每個代表一個物理連接會話。當執行查詢時，返回查詢到的結果集。程序可以通過操作該對象來取出查詢結果。 JDBC基礎 JDBC的全稱是Java Database Connectivity，即Java數據庫連接，它是一種可以執行SQL語句的Java API。...

鄒強 2019-08-14 17:10 評論0 收藏0
通過項目逐步深入了解Mybatis<一>

摘要：解決方法使用數據庫連接池管理數據庫連接。向中設置參數，對占位符號位置和設置參數值，硬編碼在代碼中，同樣也不利于系統的維護。從中遍歷結果集數據時，存在硬編碼，將獲取表的字段進行硬編碼，不利于系統維護。 Mybatis Mybatis 和 SpringMVC 通過訂單商品案例驅動官方中文地址：http://www.mybatis.org/mybati... 官方托管地址：https://...

2bdenny 2019-08-14 16:50 評論0 收藏0
hibernate和jdbc的淵源

摘要：同時，我們將語句預編譯在中，這個類可以使用占位符，避免注入，當然，后面說到的的占位符的原理也是這樣，同時，的占位符原理也是如此。的底層封裝了，比如說為了防止注入，一般會有占位符，也會有響應的占位符。介紹jdbc 我們學習Java數據庫操作時，一般會設計到jdbc的操作，這是一位程序員最基本的素養。jdbc以其優美的代碼和高性能，將瞬時態的javabean對象轉化為持久態的SQL數據。...

includecmath 2019-08-16 14:43 評論0 收藏0

發表評論

登陸后可評論

0條評論

YFan

男|高級講師

我要關注我要私信

TA的文章

【騰訊云輕量云】1核2G5M輕量應用服務器50元首年,高性價比,助您輕松上云

閱讀 2305·2021-09-28 09:45
【程序員必會十大算法】之二分查找算法

閱讀 3596·2021-09-24 09:48
怎么進入虛擬主機-虛擬主機怎么登陸圖解？

閱讀 2256·2021-09-22 15:49
UCan技術開放日｜實踐過，才知道云原生技術“真香”！

閱讀 3093·2021-09-08 16:10
前端BFC布局學習

閱讀 1586·2019-08-30 15:54
[譯]10個驚人的CSS和JavaScript動畫logos例子

閱讀 2317·2019-08-30 15:53
程序員如何在996之外獲得收入

閱讀 3012·2019-08-29 18:42
link和@import的區別淺析

閱讀 2865·2019-08-29 16:19

国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務器低至59元/年，更有多臺、長期優惠，快來選購！

JDBC【PreparedStatment、批處理、處理二進制、自動主鍵、調用存儲過程、函數】

相關文章

Java3y文章目錄導航

**Java JDBC編程**

通過項目逐步深入了解Mybatis<一>

**hibernate和jdbc的淵源**

發表評論

0條評論

YFan

男|高級講師

TA的文章

【騰訊云輕量云】1核2G5M輕量應用服務器50元首年,高性價比,助您輕松上云

【程序員必會十大算法】之二分查找算法

怎么進入虛擬主機-虛擬主機怎么登陸圖解？

UCan技術開放日｜實踐過，才知道云原生技術“真香”！

前端BFC布局學習

[譯]10個驚人的CSS和JavaScript動畫logos例子

程序員如何在996之外獲得收入

link和@import的區別淺析

最新活動

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務器低至59元/年，更有多臺、長期優惠，快來選購！

JDBC【PreparedStatment、批處理、處理二進制、自動主鍵、調用存儲過程、函數】

相關文章

發表評論

0條評論

男|高級講師

TA的文章

最新活動

上云采購季！| 2核2G4M爆款云服務器低至59元/年，更有多臺、長期優惠，快來選購！

JDBC【PreparedStatment、批處理、處理二進制、自動主鍵、調用存儲過程、函數】