Я использую эту хранимую процедуру для загрузки файлов .csv в существующие таблицы, она может вам помочь. Он загрузит все CSV-файлы в папке, соответствующей шаблону, в таблицу. Вы должны передать это
- имя папки, в которой находятся ваши файлы .csv (например, c: \ temp),
- шаблон имени файла (* _daily_export.csv),
- имя таблицы, в которую вы хотите загрузить файлы (например, MyTable)
- флаг, указывающий, хотите ли вы переключать обработанные файлы в подпапку «done» папки (1)
- символ-разделитель (, или;)
- первая строка данных (2, если у вас есть заголовки)
- формат файла (см. http://msdn.microsoft.com/en-us/library/ms178129.aspx)
Он не на 100% надежен (например, избегайте слишком длинных имен файлов или пробелов в них), но вы можете изменить его по своему усмотрению.
-- ============================================================
-- Author: László Tenki
-- Create date: 2011-06-20
-- Description: Data integration script for loading Excel files
-- using the standard MS data connectivity pack
-- Microsoft.ACE.OLEDB.12.0
-- ============================================================
ALTER procedure [di].[genericCSVImporter]
-- parameters for the stored procedure
@folder varchar(500), @fileNamePattern varchar(100),
@table varchar(128), @moveProcessed bit,
@fieldDelimiter varchar(1), @firstRow int, @formatFile nvarchar(25)
as
begin
declare @query varchar(1000)
declare @filename varchar(200)
declare @formatFilePath varchar(200)
declare @dir table ([name] varchar(200))
set @query ='master.dbo.xp_cmdshell "dir ' + @folder + '\' + @fileNamePattern + ' /b"'
set @query = replace(@query, '\\', '\')
insert into @dir exec (@query)
delete from @dir where name is NULL
declare myc cursor for select [name] from @dir where [name]<> 'File Not Found' order by [name]
open myc
fetch next from myc into @filename
while @@fetch_status = 0
begin
set @filename = @folder + '\' + @filename
set @filename = replace(@filename, '\\', '\')
set @formatFilePath = replace(@folder + '\' + @formatFile, '\\', '\')
set @query ='BULK INSERT ' + @table + ' FROM ''' + @filename +
''' WITH (FIELDTERMINATOR = ''' + @fieldDelimiter + ''', ROWTERMINATOR = ''\n'', ' +
'FIRSTROW = ' + cast(@firstRow as nvarchar(10)) + ', CODEPAGE = ''ACP'', ' +
'FORMATFILE=''' + @formatFilePath + ''')'
print @query
exec (@query)
if @moveProcessed=1
begin
set @query = 'master.dbo.xp_cmdshell "copy /Y ' + @filename + ' ' + @folder +'\done"'
exec (@query)
set @query = 'master.dbo.xp_cmdshell "del /Q ' + @filename + '"'
exec (@query)
end
fetch next from myc into @filename
end
close myc
deallocate myc
end