开篇

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

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

类依赖图

• 着重讲解DeleteExecutor实现类。

DeleteExecutor方法介绍

public class DeleteExecutor
    
      extends AbstractDMLBaseExecutor
     
       {    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
      
        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
       
      
     
    

说明：

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

public class DeleteExecutor
    
      extends AbstractDMLBaseExecutor
     
       {    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。