标题: 用T-SQL导入文件数据到SQL Server
ljjk5
元帅
Rank: 1


荣誉会员奖章
UID 46706
精华 1
积分 99426
帖子 49690
威望 554
金币 48489
热心 505
阅读权限 100
注册 2007-2-25
状态 离线
用T-SQL导入文件数据到SQL Server

在我们的工作中,经常需要连续输入多个文件的数据到SQL Server的表中,有时需要从相同或者不同的目录中,同时将文件中的数据倒入。在这篇文章中,我们将讨论如何同时把一个目录中的文件的数据倒入到SQL Server中。  
    试验环境
    我们先创建整个试验的环境。创建文件目录“C:\MyImport”,和三个文件a.csv、b.csv和c.csv,文件内容如下。同时,在SQL Server中创建一个表用来存放导入的数据。
        C:\MyImport\a.csv  
        1, MAK, A9411792711, 3400.25  
        2, Claire, A9411452711, 24000.33  
        3, Sam, A5611792711, 1200.34  
        C:\MyImport\b.csv  
        11, Rubon, 9671792711, 400.14  
        22, Mike, 9418952711, 4000.56  
        39, Hsu, 75611792511, 1230.00  
        C:\MyImport\c.csv  
        69, Lucy, 8411992710, 305.11  
        45, Grace, 3413452713, 246.52  
        33, Saint, 5461795716, 1278.70  
        Create Database Bank
        Go
        Use Bank
        go
        Create table Account
        (
            [ID] int, Name Varchar(100),  
            AccountNo varchar(100), Balance money
        )
        Go
        Create table logtable  
        (
            id int identity(1,1),  
            Query varchar(1000),  
            Importeddate datetime default getdate()
        )         
    方法 1: XP_CMDSHELL 和BULK INSERT
    这个方法使用xp_cmdshell和Bulk Insert的SQL命令把一个目录中的文件倒入到SQL Server的表中。

创建存储过程

    在数据库中产生这个存储过程,这个存储过程有三个参数:文件路径,文件扩展名和数据库的表名。

Create procedure usp_ImportMultipleFiles @filepath varchar(500),  
@pattern varchar(100), @TableName varchar(128)
as
set quoted_identifier off
declare @query varchar(1000)
declare @max1 int
declare @count1 int
Declare @filename varchar(100)
set @count1 =0
create table #x (name varchar(200))
set @query =’master.dbo.xp_cmdshell "dir ’+@filepath+@pattern +’ /b"’
insert #x exec (@query)
delete from #x where name is NULL
select identity(int,1,1) as ID, name into #y from #x  
drop table #x
set @max1 = (select max(ID) from #y)
--print @max1
--print @count1
While @count1 <= @max1
begin
set @count1=@count1+1
set @filename = (select name from #y where [id] = @count1)
set @Query =’BULK INSERT ’+ @Tablename + ’ FROM "’+ @Filepath+@Filename+’"  
WITH ( FIELDTERMINATOR = ",",ROWTERMINATOR = "\n")’
--print @query
exec (@query)
insert into logtable (query) select @query
end

drop table #y
执行
执行上面的存储过程,参数如下:
例1:输入所有的c:\myimport目录下的.csv文件到Account表中
Exec usp_ImportMultipleFiles ’c:\myimport\’, ’*.csv’, ’Account’

例2:输入所有的c:\myimport目录下的文件到Account表中
Exec usp_ImportMultipleFiles ’c:\myimport\’, ’*.*’, ’Account’
    方法 2: XP_CMDSHELL 和 BCP 公用程序
    这个方法使用 "xp_cmdshell" 和 "BCP.exe" 倒入一个目录下的文件到SQL Server的表中。这个存储过程以服务器名、数据库名、文件路径、文件扩展名和数据库表名作为参数。
    注意:确信你运行SQL Server Agent的帐户具有访问你输入的文件夹和服务器的权限。
创建存储过程:
set quoted_identifier off
go
Create procedure usp_ImportMultipleFilesBCP @servername varchar(128),
@DatabaseName varchar(128), @filepath varchar(500), @pattern varchar(100),  
@TableName varchar(128)
as
declare @query varchar(1000)
declare @max1 int
declare @count1 int
Declare @filename varchar(100)
set @count1 =0
create table #x (name varchar(200))
set @query =’master.dbo.xp_cmdshell "dir ’+@filepath+@pattern +’ /b"’
insert #x exec (@query)
delete from #x where name is NULL
select identity(int,1,1) as ID, name into #y from #x  
drop table #x
set @max1 = (select max(ID) from #y)
--print @max1
--print @count1
--select * from #y
While @count1 <= @max1
begin
set @count1=@count1+1
set @filename = (select name from #y where [id] = @count1)
set @Query =’bcp "’+ @databasename+’.dbo.’+@Tablename + ’"  
in "’+ @Filepath+@Filename+’" -S’ + @servername + ’ -T -c -r\n -t,’
set @Query = ’MASTER.DBO.xp_cmdshell ’+ "’"+  @query +"’"
--print @query
EXEC ( @query)
insert into logtable (query) select @query
end

drop table #y   

网友 ljjk5 签名 - 网友社区 ===
顶部
[广告] 免费域名(Free Subdomain) 免费空间(Free hosting) PR查询(Google Pagerank)



当前时区 GMT+8, 现在时间是 2008-10-12 14:47
信产部ICP备案:京ICP备05066424号 北京市公安局网监备案:1101050648号

Powered by Discuz! 5.5.0
清除 Cookies - 联系我们 - 网友俱乐部 - Archiver - WAP