使用输入参数创建过程时出现语法错误

Question

我收到了这个错误

消息 103010，第 16 级，状态 1，第 1 行
解析错误在第 33 行，第 15 列：'@sas_token' 附近的语法不正确

以下是我正在关注的指南供参考：

https://docs.microsoft.com/en-us/azure/synapse-analytics/sql-data-warehouse/quickstart-bulk-load-copy-tsql-examples#b-shared-access-signatures-sas-with-crlf-as-the-row-terminator-windows-style-new-line

https://docs.microsoft.com/en-us/azure/synapse-analytics/sql/develop-stored-procedures#stored-procedures-in-synapse-sql

我尝试了注释部分，因为我认为它无法识别引号，但它仍然不起作用

CREATE PROCEDURE dbo.bulk_load 
    @sas_token VARCHAR(500)
AS
BEGIN
    --DECLARE @sas varchar(500)
    --SET @sas = ''''+ @sas_token + ''''
    IF OBJECT_ID('dbo.ITEM_INFORMATION') IS NOT NULL
        DROP TABLE dbo.ITEM_INFORMATION;

    CREATE TABLE dbo.ITEM_INFORMATION 
    (
        model VARCHAR(20),
        col1 VARCHAR(15),
        col2 VARCHAR(3),
        col3 VARCHAR(255)
    );

    COPY INTO dbo.ITEM_INFORMATION
    FROM 'https://server.blob.core.windows.net/container/subfolder/file.csv' 
         WITH (FILE_TYPE = 'CSV',
               FIRSTROW = 2,
               CREDENTIAL = (
                             IDENTITY = 'Shared Access Signature',
                             SECRET = @sas_token --@sas also tried '''' + @sas_token + ''''
                            )
            );
END

这个过程将像这样从 Python 中调用：

def update_database(sas_token):

    #Runs the stored procedure to load the data from Azure storage to table.
    #Uses the password stored in user environment variable.
    
    server = 'server.database.windows.net'
    database = 'database'
    username = 'username'
    if 'server_password' not in os.environ:
        print("Missing environment variable 'server_password' containing database password.")
    password = os.getenv('server_password') 
    driver= '{ODBC Driver 17 for SQL Server}'
    sql = f'EXEC dbo.bulk_load, {sas_token};'
    connection = pyodbc.connect('DRIVER='+driver+';SERVER='+server+';PORT=1433;DATABASE='+database+';UID='+username+';PWD='+ password)
    connection.autocommit = True
    connection.execute(sql)
    connection.close()

Answer 1

这应该有效。我已经动态创建了 Copy 命令并将 SAS 令牌传递给它。一旦我创建了复制命令，我就会执行命令。打印语句，我用它作为测试。 高温

CREATE PROCEDURE dbo.bulk_load 
    @sas_token VARCHAR(500)
AS
BEGIN
    --DECLARE @sas varchar(500)
    --SET @sas = ''''+ @sas_token + ''''
    declare @query varchar(max) 
    IF OBJECT_ID('dbo.ITEM_INFORMATION') IS NOT NULL
        DROP TABLE dbo.ITEM_INFORMATION;

    CREATE TABLE dbo.ITEM_INFORMATION 
    (
        SSN VARCHAR(20),
        Name VARCHAR(15)
    );

    SELECT @query  ='
    COPY INTO dbo.ITEM_INFORMATION
    FROM ''https://server.blob.core.windows.net/container/subfolder/file.csv''
         WITH (FILE_TYPE = ''CSV'',
               FIELDTERMINATOR = ''',''',
               FIRSTROW = 2,
               ROWTERMINATOR = ''\n'',
               CREDENTIAL = (
                             IDENTITY = ''Shared Access Signature'',
                             SECRET =  '''+@sas_token+'''
                             )
            );'
            print @query
            exec(@query)
END