寻求基于SQL Server中table1动态生成目标表的Python或SQL实现方案

针对你遇到的从动态结构表table1自动创建对应业务表的需求，我来帮你完善T-SQL代码，同时也提供一个Python版本的实现，两种方式都能应对table1表名、列名、数据类型动态变化的场景。

T-SQL 完善版方案 #

你的原代码思路是对的，但存在几个问题：循环逻辑没正确遍历所有表、列定义拼接不完整、没处理无长度的数据类型、还有删除原表数据的风险。下面是优化后的代码：

-- 声明变量
DECLARE @tablename VARCHAR(255), @createSql NVARCHAR(MAX)

-- 用游标遍历所有唯一的表名
DECLARE tableCursor CURSOR FOR
SELECT DISTINCT tablename FROM dbo.table1

OPEN tableCursor
FETCH NEXT FROM tableCursor INTO @tablename

WHILE @@FETCH_STATUS = 0
BEGIN
    -- 拼接当前表的所有列定义（SQL Server 2017+ 支持STRING_AGG）
    SELECT @createSql = CONCAT(
        'CREATE TABLE ', QUOTENAME(@tablename), ' (',
        STRING_AGG(
            CONCAT(
                QUOTENAME([column]), ' ',
                datatype,
                CASE WHEN datatype = 'varchar' AND length > 0 THEN CONCAT('(', length, ')') ELSE '' END
            ),
            ', '
        ),
        ')'
    )
    FROM dbo.table1
    WHERE tablename = @tablename

    -- 打印SQL（调试用，正式环境可以注释）
    PRINT @createSql
    -- 执行创建表的SQL
    EXEC sp_executesql @createSql

    FETCH NEXT FROM tableCursor INTO @tablename
END

CLOSE tableCursor
DEALLOCATE tableCursor

代码说明： #

• 使用游标遍历所有唯一表名，比原循环逻辑更可靠，不会因为删除原表数据导致异常
• 用STRING_AGG函数自动拼接所有列的定义，不用手动处理逗号分隔
• 通过CASE语句判断：只有varchar类型且长度大于0时才添加长度括号，date、float等类型自动忽略长度
• 用QUOTENAME处理表名和列名，避免特殊字符导致的语法错误

如果你的SQL Server版本低于2017，不支持STRING_AGG，可以替换成FOR XML PATH的拼接方式：

SELECT @createSql = CONCAT(
    'CREATE TABLE ', QUOTENAME(@tablename), ' (',
    STUFF(
        (SELECT CONCAT(', ', QUOTENAME([column]), ' ', datatype,
            CASE WHEN datatype = 'varchar' AND length > 0 THEN CONCAT('(', length, ')') ELSE '' END)
         FROM dbo.table1
         WHERE tablename = @tablename
         FOR XML PATH('')),
        1, 2, ''
    ),
    ')'
)

Python 解决方案 #

如果你更倾向用Python实现，这里提供一个基于pyodbc的版本，适配跨数据库场景（只需调整连接字符串即可）：

import pyodbc

# 数据库连接配置，根据你的实际环境修改
conn_str = (
    r'DRIVER={SQL Server};'
    r'SERVER=你的服务器名;'
    r'DATABASE=你的数据库名;'
    r'UID=你的用户名;'
    r'PWD=你的密码;'
)

# 连接数据库
conn = pyodbc.connect(conn_str)
cursor = conn.cursor()

# 获取所有唯一表名
cursor.execute("SELECT DISTINCT tablename FROM table1")
table_names = [row[0] for row in cursor.fetchall()]

for table_name in table_names:
    # 获取当前表的所有列信息
    cursor.execute("SELECT column, datatype, length FROM table1 WHERE tablename = ?", (table_name,))
    columns = cursor.fetchall()

    # 拼接列定义
    column_defs = []
    for col in columns:
        col_name, data_type, length = col
        if data_type.lower() == 'varchar' and length > 0:
            col_def = f"[{col_name}] {data_type}({length})"
        else:
            col_def = f"[{col_name}] {data_type}"
        column_defs.append(col_def)
    
    # 生成创建表的SQL
    create_sql = f"CREATE TABLE [{table_name}] ({', '.join(column_defs)})"
    print(create_sql)  # 调试用，正式运行可注释
    cursor.execute(create_sql)
    conn.commit()

# 关闭连接
cursor.close()
conn.close()

代码说明： #

• 用pyodbc连接SQL Server，其他数据库可替换为psycopg2（PostgreSQL）、mysql-connector-python等对应库
• 先获取所有唯一表名，再逐个处理每个表的列定义
• 同样通过判断数据类型来决定是否添加长度参数
• 执行完每个CREATE TABLE后记得commit，确保表被持久化创建

不管用哪种方式，都建议先在测试环境运行，确认生成的SQL语句正确后再到生产环境执行，避免意外问题。

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