如何自动复制Teradata数据库中带Identity Column的100+张表至另一库？

方法1：通过系统表生成精确DDL+批量数据插入 #

Teradata的系统字典表可以获取表的完整结构信息，包括Identity列的所有属性，你可以编写SQL脚本批量生成每张表的创建语句和数据插入语句，步骤如下：

1. 查询系统表获取表结构
   从DBC.ColumnsV获取列定义，DBC.IdentityColumnsV获取Identity列的详细属性（起始值、增量、缓存大小等），DBC.TablesV获取表的类型、存储参数等。

2. 生成CREATE TABLE语句
   动态拼接包含Identity列的完整建表语句，示例模板：

   SELECT 
      'CREATE TABLE ' || TargetDB || '.' || TableName || ' (' || 
      LISTAGG(
         CASE 
            WHEN c.ColumnName IN (SELECT ColumnName FROM DBC.IdentityColumnsV WHERE DatabaseName = SourceDB AND TableName = t.TableName)
            THEN c.ColumnName || ' ' || c.ColumnType || ' GENERATED ALWAYS AS IDENTITY (' || 
                 'START WITH ' || ic.StartValue || ', INCREMENT BY ' || ic.IncrementValue || 
                 CASE WHEN ic.CacheSize IS NOT NULL THEN ', CACHE ' || ic.CacheSize ELSE '' END || ')'
            ELSE c.ColumnName || ' ' || c.ColumnType || 
                 CASE WHEN c.Nullable = 'N' THEN ' NOT NULL' ELSE '' END
         END, ', '
      ) WITHIN GROUP (ORDER BY c.ColumnId) || 
      ') ' || 
      'PRIMARY INDEX (' || (SELECT LISTAGG(ColumnName, ', ') FROM DBC.IndexColumnsV WHERE DatabaseName = SourceDB AND TableName = t.TableName AND IndexType = 'P') || ');'
   FROM DBC.TablesV t
   JOIN DBC.ColumnsV c ON t.DatabaseName = c.DatabaseName AND t.TableName = c.TableName
   LEFT JOIN DBC.IdentityColumnsV ic ON t.DatabaseName = ic.DatabaseName AND t.TableName = ic.TableName AND c.ColumnName = ic.ColumnName
   WHERE t.DatabaseName = 'SourceDB' AND t.TableKind = 'T' -- 过滤普通表
   GROUP BY TargetDB, t.DatabaseName, t.TableName;
   

   替换SourceDB和TargetDB为你的源库和目标库，索引部分可根据原表实际情况调整。

3. 生成数据插入语句
   对每张表，先开启Identity插入权限，再插入数据：

   SET IDENTITY INSERT TargetDB.TableName ON;
   INSERT INTO TargetDB.TableName SELECT * FROM SourceDB.TableName;
   SET IDENTITY INSERT TargetDB.TableName OFF;
   

   可以把这些语句也通过系统表批量生成，然后统一执行。

方法2：使用Teradata FastExport + FastLoad工具自动化 #

这是批量迁移的高效方案，适合大数据量的表：

• FastExport：导出源表的数据，同时通过查询系统表导出对应的DDL（包含Identity列）。
• FastLoad：先使用导出的DDL在目标库创建表，再加载FastExport导出的数据。
• 编写shell脚本或批处理脚本，循环处理100多张表，自动调用FastExport和FastLoad命令，实现全自动化。

方法3：编写存储过程实现批量复制 #

创建一个存储过程，动态处理每张表：

1. 遍历源库的所有表；
2. 对每张表，生成带Identity列的CREATE TABLE语句并执行；
3. 开启Identity插入权限，插入数据后关闭权限。

示例存储过程框架：

CREATE PROCEDURE CopyTablesWithIdentity(IN SourceDB VARCHAR(128), IN TargetDB VARCHAR(128))
BEGIN
   DECLARE v_TableName VARCHAR(128);
   DECLARE v_CreateStmt VARCHAR(10000);
   DECLARE v_InsertStmt VARCHAR(10000);
   -- 游标遍历源库的表
   DECLARE cur_tables CURSOR FOR
      SELECT TableName FROM DBC.TablesV WHERE DatabaseName = SourceDB AND TableKind = 'T';
   OPEN cur_tables;
   FETCH cur_tables INTO v_TableName;
   WHILE SQLCODE = 0 DO
      -- 生成CREATE TABLE语句（逻辑同方法1）
      SELECT 
         'CREATE TABLE ' || TargetDB || '.' || v_TableName || ' (' || 
         LISTAGG(
            CASE 
               WHEN c.ColumnName IN (SELECT ColumnName FROM DBC.IdentityColumnsV WHERE DatabaseName = SourceDB AND TableName = v_TableName)
               THEN c.ColumnName || ' ' || c.ColumnType || ' GENERATED ALWAYS AS IDENTITY (' || 
                    'START WITH ' || ic.StartValue || ', INCREMENT BY ' || ic.IncrementValue || 
                    CASE WHEN ic.CacheSize IS NOT NULL THEN ', CACHE ' || ic.CacheSize ELSE '' END || ')'
               ELSE c.ColumnName || ' ' || c.ColumnType || 
                    CASE WHEN c.Nullable = 'N' THEN ' NOT NULL' ELSE '' END
            END, ', '
         ) WITHIN GROUP (ORDER BY c.ColumnId) || 
         ') PRIMARY INDEX (' || (SELECT LISTAGG(ColumnName, ', ') FROM DBC.IndexColumnsV WHERE DatabaseName = SourceDB AND TableName = v_TableName AND IndexType = 'P') || ');'
      INTO v_CreateStmt
      FROM DBC.ColumnsV c
      LEFT JOIN DBC.IdentityColumnsV ic ON c.DatabaseName = ic.DatabaseName AND c.TableName = ic.TableName AND c.ColumnName = ic.ColumnName
      WHERE c.DatabaseName = SourceDB AND c.TableName = v_TableName
      GROUP BY TargetDB;
      -- 执行建表
      EXECUTE IMMEDIATE v_CreateStmt;
      -- 生成插入语句
      SET v_InsertStmt = 'SET IDENTITY INSERT ' || TargetDB || '.' || v_TableName || ' ON;' ||
                         'INSERT INTO ' || TargetDB || '.' || v_TableName || ' SELECT * FROM ' || SourceDB || '.' || v_TableName || ';' ||
                         'SET IDENTITY INSERT ' || TargetDB || '.' || v_TableName || ' OFF;';
      -- 执行插入
      EXECUTE IMMEDIATE v_InsertStmt;
      FETCH cur_tables INTO v_TableName;
   END WHILE;
   CLOSE cur_tables;
END;

注意：存储过程需要足够的权限，并且要处理可能的异常情况（比如表已存在等）。

内容的提问来源于stack exchange，提问作者Frank