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

问题描述

我收到此错误

消息 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()

解决方法

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

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