Загрузить CSV-файлы с помощью функции SQL Server OpenRowSet

Мне нужно загрузить несколько файлов (file1, file2, file3...) в таблицы (Table1, table2, table3...) в БД сервера sql, используя функцию OpenRowset. Все файлы хранятся в C:\download. Я использую следующий запрос, который отлично работает.

INSERT INTO dbo.Table1
SELECT * from OpenRowset('MSDASQL','Driver={Microsoft Text Driver (*.txt;*.csv)};DefaultDir=C:\download;','select * from File1.csv' )

Вопрос в том, как передать имя файла и имя таблицы в качестве параметра.

Спасибо Тони за ваш ответ. Я поместил sql в хранимую процедуру следующим образом. Но он намного медленнее, чем исходный жестко закодированный файл и имена таблиц. Любое предложение ускорить его работу.

ALTER proc [dbo].[ImportFiles]

  @FilePath varchar(100) ,
  @FileName varchar(100),  
  @TableName varchar(250)
AS
BEGIN
DECLARE @SqlStmt nvarchar(max) 
DECLARE @ErrorCode int

SET @SqlStmt='Truncate table dbo.[' + @TableName +']'
EXEC(@SqlStmt);
-- i COULD PUT TRUNCATE statement in the sate statement as insert just before INSERT INTO. 
set @SqlStmt=N'
INSERT INTO '+@TableName+N'
select *
from openrowset(''MSDASQL''
               ,''Driver={Microsoft Access Text Driver (*.txt, *.csv)}; 
                    DefaultDir='+@FilePath+N'''
               ,''select * from "'+@FileName+N'"'')'

  EXEC(@SqlStmt);

sql-server openrowset bulkinsert
person rao    schedule 06.09.2011    source источник
comment
Есть ли причина, по которой вы должны использовать этот метод для импорта данных? Если у вас есть службы SSIS, это может быть лучшим способом выполнить импорт нескольких файлов.   -  person Tony    schedule 06.09.2011
comment
Причина в том, что я мало знаю о службах SSIS, которые я пытался использовать, но мне это не удалось.   -  person rao    schedule 08.09.2011
comment
Динамический SQL, как правило, медленнее, но на сколько вы видите его замедление? Это в два раза медленнее или больше, и будет ли это иметь значение? Если весь процесс занимает минуты, я бы не стал беспокоиться, часы могут быть проблемой, но как часто вы выполняете импорт?   -  person Tony    schedule 09.09.2011

Ответы (1)


arrow_upward
2
arrow_downward

Вам нужно будет построить свой запрос, используя динамический SQL, чтобы передать параметр в функцию OPENROWSET. Затем код для построения динамического SQL можно поместить в хранимую процедуру, чтобы упростить вызов.

Код для динамического создания SQL будет выглядеть примерно так:

DECLARE @tableName varchar(10);
DECLARE @importFile varchar(10);
SET @tableName = 'Table1'
SET @importQuery= 'File1.csv';
EXEC( 'INSERT INTO ' + @tableName + 'SELECT * from OpenRowset(''MSDASQL'',''Driver={Microsoft Text Driver (*.txt;*.csv)};DefaultDir=C:\download;'',''SELECT * FROM ' + @importFile + ''' )'

ПРИМЕЧАНИЕ. Вам нужно будет проверить правильность кавычек, у меня нет доступа к серверу SQL в данный момент, чтобы проверить синтаксис.

person Tony    schedule 06.09.2011