设计模式综合实例分析之数据库同步系统(三)

    1. 策略模式

    由于表数据的同步方式有三种,分别是增量同步、先Delete后Insert方式、临时表方式,因此可以定义一个同步策略接口DataSynStrategy,并提供三个具体实现类:IncSynStrategy、DelAndInsSynStrategy和TempTableSynStrategy。类图如图8所示:

    图8 策略模式实例类图

    在图8中,Oracle表同步对象类OracleTableDBSynchronizer充当环境类,DataSynStrategy充当抽象策略类,其子类IncSynStrategy、DelAndInsSynStrategy和TempTableSynStrategy充当具体策略类。

    1. 组合模式、命令模式和职责链模式

    在使用临时表方式实现表同步时可以定义一系列命令对象,这些命令封装对数据库的操作,由于有些操作修改了数据库结构,因此传统的JDBC事务控制起不到作用,需要自己实现操作失败后的回滚逻辑。此时可以使用命令模式进行设计,在设计时还可以提供宏命令MacroCommand,用于将一些具体执行数据库操作的命令组合起来,形成复合命令。类图如图9所示(由于原始类图比较复杂,考虑到可读性,图9进行了适当简化,不过简化了之后还是挺复杂的):

    设计模式综合实例分析之数据库同步系统(三) - 图1

    图9 组合模式、命令模式和职责链模式实例类图

    (由于涉及到多个模式的联用,此图有点点复杂)

    在TempTableSynCommand中还定义了两个子类型的变量previousCommand、nextCommnad用于保存前一个命令和后一个命令,其中nextCommnad用于在执行完当前命令的业务逻辑后,再执行下一个命令的业务逻辑;而previousCommand用于在出现异常时,调用上一个命令的undo()方法实现恢复操作。此时使用了职责链模式,nextCommnad.execute()实现正向职责链,而previousCommand.undo()加上Java的异常处理机制实现反向职责链。

    MacroCommand是宏命令,其代码片段如下所示:

    在请求调用者类TempTableSynStrategy中通过如下代码片段来调用宏命令对象的execute()方法:

    1. public String processSyn() {
    2. //其他代码省略
    3. String tempTableName = generateTempTableName();
    4. String backupTableName = "BAK_" + tempTableName;
    5. DataSynHelper dataSynHelper = new DataSynHelperImpl();
    6. marcoCommand.add(new RenameTableConstraintCommand(dataSynHelper, tableName, destDB));
    7. marcoCommand.add(new RenameTableCommand(dataSynHelper, tableName, backupTableName, destDB));
    8. marcoCommand.add(new RenameTableCommand(dataSynHelper, tempTableName, tableName, destDB));
    9. try{
    10. marcoCommand.execute();
    11. try {
    12. //其他代码省略
    13. }
    14. } catch (Exception e){
    15. e.printStackTrace();
    16. }
    17. //其他代码省略
    18. }
    19. }

    【本实例分析到此全部结束,希望能给各位带来帮助!】