Качете csv файлове с помощта на функцията OpenRowSet на SQL Server

Трябва да кача множество файлове (файл1, файл2, файл3...) в таблици (Таблица1, таблица2, таблица3...) в база данни на 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