摘要：元數(shù)據(jù)什么是元數(shù)據(jù)元數(shù)據(jù)其實(shí)就是數(shù)據(jù)庫(kù)，表，列的定義信息為什么我們要用元數(shù)據(jù)即使我們寫(xiě)了一個(gè)簡(jiǎn)單工具類，我們的代碼還是非常冗余。我們要使用元數(shù)據(jù)獲取結(jié)果集的信息，才能對(duì)結(jié)果集進(jìn)行操作。

一個(gè)SESSION所進(jìn)行的所有更新操作要么一起成功，要么一起失敗

舉個(gè)例子:A向B轉(zhuǎn)賬，轉(zhuǎn)賬這個(gè)流程中如果出現(xiàn)問(wèn)題，事務(wù)可以讓數(shù)據(jù)恢復(fù)成原來(lái)一樣【A賬戶的錢(qián)沒(méi)變，B賬戶的錢(qián)也沒(méi)變】。

事例說(shuō)明：

        /*
        * 我們來(lái)模擬A向B賬號(hào)轉(zhuǎn)賬的場(chǎng)景
        *   A和B賬戶都有1000塊，現(xiàn)在我讓A賬戶向B賬號(hào)轉(zhuǎn)500塊錢(qián)
        *
        * */
            //JDBC默認(rèn)的情況下是關(guān)閉事務(wù)的，下面我們看看關(guān)閉事務(wù)去操作轉(zhuǎn)賬操作有什么問(wèn)題

            //A賬戶減去500塊
            String sql = "UPDATE a SET money=money-500 ";
            preparedStatement = connection.prepareStatement(sql);
            preparedStatement.executeUpdate();

            //B賬戶多了500塊
            String sql2 = "UPDATE b SET money=money+500";
            preparedStatement = connection.prepareStatement(sql2);
            preparedStatement.executeUpdate();

從上面看，我們的確可以發(fā)現(xiàn)A向B轉(zhuǎn)賬，成功了。可是如果A向B轉(zhuǎn)賬的過(guò)程中出現(xiàn)了問(wèn)題呢？下面模擬一下

            //A賬戶減去500塊
            String sql = "UPDATE a SET money=money-500 ";
            preparedStatement = connection.prepareStatement(sql);
            preparedStatement.executeUpdate();
            
            //這里模擬出現(xiàn)問(wèn)題
            int a = 3 / 0;


            String sql2 = "UPDATE b SET money=money+500";
            preparedStatement = connection.prepareStatement(sql2);
            preparedStatement.executeUpdate();

顯然，上面代碼是會(huì)拋出異常的，我們?cè)賮?lái)查詢一下數(shù)據(jù)。A賬戶少了500塊錢(qián)，B賬戶的錢(qián)沒(méi)有增加。這明顯是不合理的。

我們可以通過(guò)事務(wù)來(lái)解決上面出現(xiàn)的問(wèn)題

            //開(kāi)啟事務(wù),對(duì)數(shù)據(jù)的操作就不會(huì)立即生效。
            connection.setAutoCommit(false);
            
            //A賬戶減去500塊
            String sql = "UPDATE a SET money=money-500 ";
            preparedStatement = connection.prepareStatement(sql);
            preparedStatement.executeUpdate();

            //在轉(zhuǎn)賬過(guò)程中出現(xiàn)問(wèn)題
            int a = 3 / 0;

            //B賬戶多500塊
            String sql2 = "UPDATE b SET money=money+500";
            preparedStatement = connection.prepareStatement(sql2);
            preparedStatement.executeUpdate();
            
            //如果程序能執(zhí)行到這里，沒(méi)有拋出異常，我們就提交數(shù)據(jù)
            connection.commit();

            //關(guān)閉事務(wù)【自動(dòng)提交】
            connection.setAutoCommit(true);
            

        } catch (SQLException e) {
            try {
                //如果出現(xiàn)了異常，就會(huì)進(jìn)到這里來(lái)，我們就把事務(wù)回滾【將數(shù)據(jù)變成原來(lái)那樣】
                connection.rollback();
                
                //關(guān)閉事務(wù)【自動(dòng)提交】
                connection.setAutoCommit(true);
            } catch (SQLException e1) {
                e1.printStackTrace();
            }

上面的程序也一樣拋出了異常，A賬戶錢(qián)沒(méi)有減少，B賬戶的錢(qián)也沒(méi)有增加。

注意：當(dāng)Connection遇到一個(gè)未處理的SQLException時(shí)，系統(tǒng)會(huì)非正常退出，事務(wù)也會(huì)自動(dòng)回滾，但如果程序捕獲到了異常，是需要在catch中顯式回滾事務(wù)的。

我們還可以使用savepoint設(shè)置中間點(diǎn)。如果在某地方出錯(cuò)了，我們?cè)O(shè)置中間點(diǎn)，回滾到出錯(cuò)之前即可。

應(yīng)用場(chǎng)景：現(xiàn)在我們要算一道數(shù)學(xué)題，算到后面發(fā)現(xiàn)算錯(cuò)數(shù)了。前面的運(yùn)算都是正確的，我們不可能重頭再算【直接rollback】，最好的做法就是在保證前面算對(duì)的情況下，設(shè)置一個(gè)保存點(diǎn)。從保存點(diǎn)開(kāi)始重新算。

注意：savepoint不會(huì)結(jié)束當(dāng)前事務(wù)，普通提交和回滾都會(huì)結(jié)束當(dāng)前事務(wù)的

數(shù)據(jù)庫(kù)定義了4個(gè)隔離級(jí)別：

Serializable【可避免臟讀，不可重復(fù)讀，虛讀】

Repeatable read【可避免臟讀，不可重復(fù)讀】

Read committed【可避免臟讀】

Read uncommitted【級(jí)別最低，什么都避免不了】

分別對(duì)應(yīng)Connection類中的4個(gè)常量

TRANSACTION_READ_UNCOMMITTED

TRANSACTION_READ_COMMITTED

TRANSACTION_REPEATABLE_READ

TRANSACTION_SERIALIZABLE

臟讀：一個(gè)事務(wù)讀取到另外一個(gè)事務(wù)未提交的數(shù)據(jù)

例子：A向B轉(zhuǎn)賬，A執(zhí)行了轉(zhuǎn)賬語(yǔ)句，但A還沒(méi)有提交事務(wù)，B讀取數(shù)據(jù)，發(fā)現(xiàn)自己賬戶錢(qián)變多了！B跟A說(shuō)，我已經(jīng)收到錢(qián)了。A回滾事務(wù)【rollback】，等B再查看賬戶的錢(qián)時(shí)，發(fā)現(xiàn)錢(qián)并沒(méi)有多。

不可重復(fù)讀：一個(gè)事務(wù)讀取到另外一個(gè)事務(wù)已經(jīng)提交的數(shù)據(jù)，也就是說(shuō)一個(gè)事務(wù)可以看到其他事務(wù)所做的修改

注：A查詢數(shù)據(jù)庫(kù)得到數(shù)據(jù)，B去修改數(shù)據(jù)庫(kù)的數(shù)據(jù)，導(dǎo)致A多次查詢數(shù)據(jù)庫(kù)的結(jié)果都不一樣【危害：A每次查詢的結(jié)果都是受B的影響的，那么A查詢出來(lái)的信息就沒(méi)有意思了】

虛讀(幻讀)：是指在一個(gè)事務(wù)內(nèi)讀取到了別的事務(wù)插入的數(shù)據(jù)，導(dǎo)致前后讀取不一致。

注：和不可重復(fù)讀類似，但虛讀(幻讀)會(huì)讀到其他事務(wù)的插入的數(shù)據(jù)，導(dǎo)致前后讀取不一致

簡(jiǎn)單總結(jié)：臟讀是不可容忍的，不可重復(fù)讀和虛讀在一定的情況下是可以的【做統(tǒng)計(jì)的肯定就不行】。

元數(shù)據(jù)其實(shí)就是數(shù)據(jù)庫(kù)，表，列的定義信息

即使我們寫(xiě)了一個(gè)簡(jiǎn)單工具類，我們的代碼還是非常冗余。對(duì)于增刪改而言，只有SQL和參數(shù)是不同的，我們?yōu)楹尾话堰@些相同的代碼抽取成一個(gè)方法？對(duì)于查詢而言，不同的實(shí)體查詢出來(lái)的結(jié)果集是不一樣的。我們要使用元數(shù)據(jù)獲取結(jié)果集的信息，才能對(duì)結(jié)果集進(jìn)行操作。

ParameterMetaData --參數(shù)的元數(shù)據(jù)

ResultSetMetaData --結(jié)果集的元數(shù)據(jù)

DataBaseMetaData --數(shù)據(jù)庫(kù)的元數(shù)據(jù)

問(wèn)題：我們對(duì)數(shù)據(jù)庫(kù)的增刪改查都要連接數(shù)據(jù)庫(kù)，關(guān)閉資源，獲取PreparedSteatment對(duì)象，獲取Connection對(duì)象此類的操作，這樣的代碼重復(fù)率是極高的，所以我們要對(duì)工具類進(jìn)行增強(qiáng)

    //我們發(fā)現(xiàn)，增刪改只有SQL語(yǔ)句和傳入的參數(shù)是不知道的而已，所以讓調(diào)用該方法的人傳遞進(jìn)來(lái)
    
    //由于傳遞進(jìn)來(lái)的參數(shù)是各種類型的，而且數(shù)目是不確定的，所以使用Object[]
    
    public static void update(String sql, Object[] objects) {

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

        try {
            connection = getConnection();
            preparedStatement = connection.prepareStatement(sql);

            //根據(jù)傳遞進(jìn)來(lái)的參數(shù)，設(shè)置SQL占位符的值
            for (int i = 0; i < objects.length; i++) {
                preparedStatement.setObject(i + 1, objects[i]);
            }

            //執(zhí)行SQL語(yǔ)句
            preparedStatement.executeUpdate();


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

    /*
        1:對(duì)于查詢語(yǔ)句來(lái)說(shuō)，我們不知道對(duì)結(jié)果集進(jìn)行什么操作【常用的就是把數(shù)據(jù)封裝成一個(gè)Bean對(duì)象，封裝成一個(gè)List集合】
        2:我們可以定義一個(gè)接口，讓調(diào)用者把接口的實(shí)現(xiàn)類傳遞進(jìn)來(lái)
        3:這樣接口調(diào)用的方法就是調(diào)用者傳遞進(jìn)來(lái)實(shí)現(xiàn)類的方法。【策略模式】

    */
    //這個(gè)方法的返回值是任意類型的，所以定義為Object。
    public static Object query(String sql, Object[] objects, ResultSetHandler rsh) {

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

        try {
            connection = getConnection();
            preparedStatement = connection.prepareStatement(sql);

            //根據(jù)傳遞進(jìn)來(lái)的參數(shù)，設(shè)置SQL占位符的值
            if (objects != null) {
                for (int i = 0; i < objects.length; i++) {
                    preparedStatement.setObject(i + 1, objects[i]);
                }
            }


            resultSet = preparedStatement.executeQuery();

            //調(diào)用調(diào)用者傳遞進(jìn)來(lái)實(shí)現(xiàn)類的方法，對(duì)結(jié)果集進(jìn)行操作
            return rsh.hanlder(resultSet);
    }

接口：

    /*
    * 定義對(duì)結(jié)果集操作的接口，調(diào)用者想要對(duì)結(jié)果集進(jìn)行什么操作，只要實(shí)現(xiàn)這個(gè)接口即可
    * */
    public interface ResultSetHandler {
         Object hanlder(ResultSet resultSet);
    
    }

實(shí)現(xiàn)類：

//接口實(shí)現(xiàn)類，對(duì)結(jié)果集封裝成一個(gè)Bean對(duì)象
public class BeanHandler implements ResultSetHandler {


    //要封裝成一個(gè)Bean對(duì)象，首先要知道Bean是什么，這個(gè)也是調(diào)用者傳遞進(jìn)來(lái)的。
    private Class clazz;

    public BeanHandler(Class clazz) {
        this.clazz = clazz;
    }

    @Override
    public Object hanlder(ResultSet resultSet) {

        try {

            //創(chuàng)建傳進(jìn)對(duì)象的實(shí)例化
            Object bean = clazz.newInstance();

            if (resultSet.next()) {

                //拿到結(jié)果集元數(shù)據(jù)
                ResultSetMetaData resultSetMetaData = resultSet.getMetaData();

                for (int i = 0; i < resultSetMetaData.getColumnCount(); i++) {

                    //獲取到每列的列名
                    String columnName = resultSetMetaData.getColumnName(i+1);

                    //獲取到每列的數(shù)據(jù)
                    String columnData = resultSet.getString(i+1);

                    //設(shè)置Bean屬性
                    Field field = clazz.getDeclaredField(columnName);
                    field.setAccessible(true);
                    field.set(bean,columnData);
                }

                //返回Bean對(duì)象
                return bean;
            }

樂(lè)于分享和輸出干貨的Java技術(shù)公眾號(hào)：Java3y。

文章的目錄導(dǎo)航：

https://github.com/ZhongFuCheng3y/3y