Fescar - RM DeleteExecutor介绍

开篇

 这篇文章的目的是讲解RM Executor模块当中一些通用的方法，这些方法在各个Executor的父类当中实现的，各个子类Executor模块都会复用，因此抽取出来统一的进行讲解。

 个人是认为抽取通用的内容放在一篇文章讲解完后可以针对每类Executor讲解特有的功能，这样能够有更好的理解。这篇文章讲解Executor的实现类DeleteExecutor。

类依赖图

说明：

• 着重讲解DeleteExecutor实现类。

DeleteExecutor方法介绍

public class DeleteExecutor<T, S extends Statement> extends AbstractDMLBaseExecutor<T, S> {

    public DeleteExecutor(StatementProxy statementProxy, StatementCallback statementCallback, SQLRecognizer sqlRecognizer) {
        super(statementProxy, statementCallback, sqlRecognizer);
    }

    @Override
    protected TableRecords beforeImage() throws SQLException {
        SQLDeleteRecognizer visitor = (SQLDeleteRecognizer) sqlRecognizer;
        // 获取表的所有的列
        TableMeta tmeta = getTableMeta(visitor.getTableName());
        List<String> columns = new ArrayList<>();
        for (String column : tmeta.getAllColumns().keySet()) {
            columns.add(column);
        }
        
        // 拼接SELECT的SQL语句
        StringBuffer selectSQLAppender = new StringBuffer("SELECT ");

        for (int i = 0; i < columns.size(); i++) {
            selectSQLAppender.append(getColumnNameInSQL(columns.get(i)));
            if (i < (columns.size() - 1)) {
                selectSQLAppender.append(", ");
            }
        }
        String whereCondition = null;
        // 解析并获取where条件
        ArrayList<Object> paramAppender = new ArrayList<>();
        if (statementProxy instanceof ParametersHolder) {
            whereCondition = visitor.getWhereCondition((ParametersHolder) statementProxy, paramAppender);
        } else {
            whereCondition = visitor.getWhereCondition();
        }

        // 拼接SQL的where条件
        selectSQLAppender.append(" FROM " + getFromTableInSQL() + " WHERE " + whereCondition + " FOR UPDATE");
        String selectSQL = selectSQLAppender.toString();

        // 根据拼接的SQL查询数据表获取删除前的数据
        TableRecords beforeImage = null;
        PreparedStatement ps = null;
        Statement st = null;
        ResultSet rs = null;
        try {
            if (paramAppender.isEmpty()) {
                st = statementProxy.getConnection().createStatement();
                rs = st.executeQuery(selectSQL);
            } else {
                ps = statementProxy.getConnection().prepareStatement(selectSQL);
                for (int i = 0; i< paramAppender.size(); i++) {
                    ps.setObject(i + 1, paramAppender.get(i));
                }
                rs = ps.executeQuery();
            }
            beforeImage = TableRecords.buildRecords(tmeta, rs);

        } finally {
            if (rs != null) {
                rs.close();
            }
            if (st != null) {
                st.close();
            }
            if (ps != null) {
                ps.close();
            }
        }
        return beforeImage;
    }
}

说明：

• DeleteExecutor需要保存SQL执行前的镜像。
• 执行前镜像的准备整体思路是按照按照删除条件逆向拼接正向查询SQL。
• 查询的SQL的select的字段直接从查询表的元数据的列值。
• 查询的SQL的条件通过解析delete的条件生成。
• 执行根据delete操作生成的正向select语句查询删除前的数据。
• 根据TableRecords.buildRecords生成执行前镜像。

public class DeleteExecutor<T, S extends Statement> extends AbstractDMLBaseExecutor<T, S> {

    public DeleteExecutor(StatementProxy statementProxy, StatementCallback statementCallback, SQLRecognizer sqlRecognizer) {
        super(statementProxy, statementCallback, sqlRecognizer);
    }

    @Override
    protected TableRecords afterImage(TableRecords beforeImage) throws SQLException {
        return TableRecords.empty(getTableMeta());
    }
}

说明：

• DeleteExecutor保存的执行后的镜像就是生产空白进行而已。
• TableRecords.empty()方法返回空白镜像。

期待

 DeleteExecutor生成执行前后镜像的过程分析完后，会接着分析UpdateExecutor。