如何在Corda中通过Liquibase脚本实现表间数据复制？

错误原因分析 #

你之前的尝试存在几个核心问题：

1. 错误使用<update>标签：<update>用于修改已有行的数据，而非插入新行。当TableB为空时，该标签不会执行任何操作；且未关联行的子查询会引发语法/逻辑错误。
2. Schema路径不明确：PostgreSQL会自动将未加引号的标识符转为大写，若你的schema是小写corda_schema，未明确指定路径会导致Liquibase找错schema；同时Corda节点若未配置默认schema，必须在SQL中显式指定schema。
3. <createTable>的valueComputed无效：该属性仅用于定义列的默认计算规则，不会自动从其他表插入数据，建表和数据插入是两个独立操作。

可行实现方案 #

根据你的场景（TableA已存在，需复制数据到同结构的TableB），提供两种方案：

方案1：先创建TableB结构，再复制数据

如果TableB尚未创建，用这个脚本一次性完成建表+数据复制：

<changeSet author="liquibase.corda" id="create-tableb-and-copy-data">
    <!-- 创建与TableA结构一致的TableB -->
    <createTable schemaName="corda_schema" tableName="TableB">
        <column name="id" type="UUID"/> <!-- 请根据TableA的实际列类型调整，比如TEXT/INT等 -->
        <column name="name" type="TEXT"/>
        <column name="value" type="TEXT"/>
    </createTable>

    <!-- 从TableA复制数据到TableB -->
    <insertSelect schemaName="corda_schema" tableName="TableB">
        <column name="id" value="id"/>
        <column name="name" value="name"/>
        <column name="value" value="value"/>
        <select>
            SELECT id, name, value FROM corda_schema.TableA;
        </select>
    </insertSelect>
</changeSet>

方案2：TableB已创建，仅复制数据

如果TableB的结构已经存在，直接用<insertSelect>标签完成数据复制：

<changeSet author="liquibase.corda" id="copy-data-from-tablea-to-tableb">
    <insertSelect schemaName="corda_schema" tableName="TableB">
        <column name="id" value="id"/>
        <column name="name" value="name"/>
        <column name="value" value="value"/>
        <select>
            SELECT id, name, value FROM corda_schema.TableA;
        </select>
    </insertSelect>
</changeSet>

额外配置建议 #

为避免后续schema路径问题，可在Corda节点的node.conf中配置默认schema，这样脚本中无需重复写schemaName：

dataSourceProperties = {
    dataSourceClassName = "org.postgresql.ds.PGSimpleDataSource"
    dataSource.url = "jdbc:postgresql://localhost:5432/corda_node"
    dataSource.user = "corda"
    dataSource.password = "corda"
    dataSource.currentSchema = "corda_schema" # 指定默认schema
}

内容的提问来源于stack exchange，提问作者Manikanta Reddy A