在Synapse专用池中用变量创建无指定列外部表执行报错求助

错误根源：Synapse专用池的CREATE EXTERNAL TABLE语法要求必须显式定义表的列结构，你的代码省略了列定义部分，导致解析器在WITH子句结束后找不到预期的列定义，触发语法错误。

修改后的存储过程代码 #

ALTER PROCEDURE dbo.Staging_Tables_sp
(
    @TableName VARCHAR(MAX),
    @SchemaName VARCHAR(MAX),
    @ColumnDefinition VARCHAR(MAX) -- 新增参数，用于传入目标表的列结构定义
)
AS
BEGIN
    EXEC ('SET ANSI_NULLS ON;
    SET QUOTED_IDENTIFIER ON;
   
    CREATE EXTERNAL TABLE [' + @SchemaName + '].[Staging_' + @TableName +']
    (' + @ColumnDefinition + ') -- 新增列定义部分，对应Parquet文件的实际列结构
    WITH (
    LOCATION = N''/Folder/ParquetFiles/' + @TableName + '/'',
    DATA_SOURCE = [gold_parquet],
    FILE_FORMAT = [ParquetFormat],
    REJECT_TYPE = VALUE,
    REJECT_VALUE = 0)');
END

执行示例 #

假设目标Parquet文件的列结构为ID INT, CustomerName VARCHAR(100), OrderDate DATETIME，执行语句如下：

DECLARE @TableName varchar(max) = 'Table'
DECLARE @SchemaName varchar(max) = 'Schema'
DECLARE @ColumnDef varchar(max) = 'ID INT, CustomerName VARCHAR(100), OrderDate DATETIME'
 
EXECUTE [dbo].[Staging_Tables_sp]
    @TableName = @TableName,
    @SchemaName = @SchemaName,
    @ColumnDefinition = @ColumnDef

补充说明 #

• 若希望自动推断Parquet文件的列结构，可改用CREATE EXTERNAL TABLE AS SELECT (CETAS)语法，先通过外部数据源读取文件获取结构后再创建表；
• 需确保传入的@ColumnDefinition数据类型与Parquet文件的实际列类型匹配，符合Synapse专用池的数据类型规范。

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