SQL 服务器错误：必须声明标量变量“@lastrow”

Question

我已经修改了一个在线查询，将 CSV 文件批量导入 SQL 服务器。但是，我的 CSV 在底部有一个备用换行符，因此我为文件中的行数添加了一个计数器，然后在 BULK INSERT 中设置了 LASTROW 参数。

但是，因为我正在循环 BULK INSERT，所以我需要将文件名传递给行计数器。但是当@filllastrow 执行时，我收到错误“必须声明标量变量“@lastrow””。有人可以帮忙吗？

谢谢

罗伯

        declare @filename varchar(255),
        @path     varchar(255),
        @sql      varchar(8000),
        @filllastrow      varchar(8000),
        @cmd      varchar(1000)

declare c1 cursor for SELECT WHICHPATH,WHICHFILE FROM ALLFILENAMES where WHICHFILE like '%.csv%'
open c1
fetch next from c1 into @path,@filename
While @@fetch_status <> -1
 begin
  declare @lastrow varchar(10)
  set  @filllastrow = 'set @lastrow = convert(varchar(10),(SELECT count(*) FROM OPENROWSET( BULK '''+ @path + @filename+''', FORMATFILE = ''E:\ereferrals\MyFormat_Counting.fmt'', MAXERRORS=10) AS a ) - 1)'
  print @filllastrow
  exec (@filllastrow)

 set @sql = 'BULK INSERT eref FROM ''' + @path + @filename + ''' '
       + '     WITH ( 
               FIELDTERMINATOR = '','', 
               ROWTERMINATOR = ''0x0A'', 
               FIRSTROW = 2 ,
               LASTROW = '+convert(varchar,@lastrow)+',
               ERRORFILE = ''e:\ereferrals\probs.log''
            ) '
print @sql
EXECUTE @sql
fetch next from c1 into @path,@filename
end
close c1
deallocate c1

Answer 1

使用sp_executesql 并将@lastrow 参数定义为输出参数。

试试这样的……

declare @filename       nvarchar(255)
       ,@path           nvarchar(255)
       ,@sql            nvarchar(MAX)  --<-- Correct datatype
       ,@filllastrow    nvarchar(MAX)  --<-- Correct datatype
       ,@cmd            nvarchar(1000)


declare c1 cursor for 
SELECT WHICHPATH , WHICHFILE 
FROM ALLFILENAMES 
where WHICHFILE like '%.csv%'

open c1

fetch next from c1 into @path,@filename


While @@fetch_status <> -1
 begin
  declare @lastrow  INT;

  set  @filllastrow = 'SELECT @lastrow = convert(varchar(10),  ISNULL(count(*),2) -1)
                       FROM OPENROWSET( BULK '''+ @path + @filename+'''
                                      , FORMATFILE = ''E:\ereferrals\MyFormat_Counting.fmt''
                                      , MAXERRORS=10) AS a )'


     Exec sp_executesql @filllastrow
                       ,N'@lastrow INT OUTPUT'   --<-- Output parameter
                       ,@lastrow OUTPUT                                 

 set @sql = 'BULK INSERT eref FROM ''' + @path + @filename + ''' '
       + '     WITH ( 
               FIELDTERMINATOR = '','', 
               ROWTERMINATOR = ''0x0A'', 
               FIRSTROW = 2 ,
               LASTROW = @lastrow,   
               ERRORFILE = ''e:\ereferrals\probs.log''
            ) '

   Exec sp_executesql @sql
                     ,N'@lastrow INT'
                     ,@lastrow

fetch next from c1 into @path,@filename
end
close c1
deallocate c1

Answer 2

将'declare @lastrow int' 放在@sql 字符串中，删除类型转换并同时运行两个sql 语句以保持@lastrow 最新。在 EXEC 函数中运行 BULK INSERT 以将参数传递给它。不需要@Filllastrow：

declare @filename varchar(255),
        @path     varchar(255),
        @sql      varchar(8000),
        @cmd      varchar(1000)

declare c1 cursor for SELECT WHICHPATH,WHICHFILE FROM ALLFILENAMES
                        where WHICHFILE like '%.csv%'
open c1
fetch next from c1 into @path,@filename
While @@fetch_status <> -1
 begin
  set  @sql = ' declare @lastrow as int set @lastrow =
       (SELECT count(*) 
       FROM OPENROWSET( BULK '''+ @path + @filename+''', FORMATFILE =
       ''E:\ereferrals\MyFormat_Counting.fmt'', MAXERRORS=10) AS a ) - 1 
       EXEC(''BULK INSERT eref FROM ''''' + @path + @filename + ''''' '
       + '     WITH ( 
               FIELDTERMINATOR = '''','''', 
               ROWTERMINATOR = ''''0x0A'''', 
               FIRSTROW = 2 ,
               LASTROW = '' + @lastrow + '',
               ERRORFILE = ''''e:\ereferrals\probs.log''''
            ) '
print @sql
EXECUTE @sql
fetch next from c1 into @path,@filename
end
close c1
deallocate c1