测试代码如下：

     @SneakyThrows
    public JsonResult createTable(String tableName,String dsId) {
        if (StringUtils.isEmpty(dsId)) {
            dsId = "1664472893795082241";
        }
        var ds = DruidUtils.getDataSource(dsId);
        var template = new JdbcTemplate(ds);
        //手动事务
        var txManager=new DataSourceTransactionManager(ds);
        DefaultTransactionDefinition transDef = new DefaultTransactionDefinition(); // 定义事务属性
        transDef.setPropagationBehavior(DefaultTransactionDefinition.PROPAGATION_REQUIRED); // 设置传播行为属性
        TransactionStatus status = txManager.getTransaction(transDef); // 获得事务状态
        try {
            TableModel t = new TableModel(tableName);
            t.comment("测试创建的表");
            t.column("id").VARCHAR(64).pkey().comment("主键");
            t.column("name").VARCHAR(50).comment("姓名");
            t.column("age").INTEGER().comment("年龄");
            t.column("create_time").TIMESTAMP().comment("创建时间");
            t.column("create_by").VARCHAR(64).comment("创建人");
            Dialect dialect = Dialect.guessDialect(ds);
            String[] ddlArray = dialect.toDropAndCreateDDL(t);
            for (String ddl : ddlArray) {
                template.execute(ddl);
            }
            String now = DateUtils.getTime();
            String sql = "insert into " + tableName + " (id,name,age,create_time) values('101','李明',18,'" + now + "')";
            template.execute(sql);
            int j=1/0;
            sql = "insert into " + tableName + " (id,name,age,create_time) values('102','李明2',38,'" + now + "')";
            template.execute(sql);
            sql = "select * from " + tableName;
            JsonResult result = JsonResult.getSuccessResult("common.handleSuccess");
            var data = template.queryForList(sql);
            result.setData(data);
            txManager.commit(status);// 提交
            return result;
        } catch (Exception e) {
            txManager.rollback(status);// 回滚
            return JsonResult.Fail(e.getMessage());
        }
    }

主要就是通过创建DataSourceTransactionManager实例来管理事务，因为不确定是哪个数据源实例，所以不方便用@Transactional注解。测试了MySQL和PostgreSQL两种数据库，如果只是两条insert语句中间加一个异常，两种数据库都是可以正常回滚的。如果前面增加了删除表和创建表的SQL语句，PostgreSQL表现正常，MySQL的原来表中的数据却丢失了。看来MySQL的DDL语句在事务中有时无法正常回滚，之前用Seata的时候也遇到过，后来基本放弃Seata了。