加载中…
个人资料
  • 博客等级:
  • 博客积分:
  • 博客访问:
  • 关注人气:
  • 获赠金笔:0支
  • 赠出金笔:0支
  • 荣誉徽章:
正文 字体大小:

Sql server 通过存储过程批量导入txt/csv

(2016-04-19 19:25:21)
1、sql server导入单个txt有很多方法,如
(1)右击数据库→任务→导入数据→数据源选择文件类型;
(2)Bulk  insert 方法:简单的T-Sql语句如下
      Bulk  insert  Test --Test为表或视图名
      From  'e:\test.txt'
      With
      (   fieldterminator='\t',    --列间隔符
          rowterminator='\n'     --行终止符
      )   
2、批量导入方法如下
(1)XP_CMDSHELL + BULK INSERT:
→首先根据text字段创建表Test
→创建存储过程
Create procedure testbulk  @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'+''''+')'     --(注意此处均为单引号,在sql中单引号作为转义字符)
--print @query
exec (@query)
end
drop table #y
→执行存储过程
Exec testbulk 'e:\', '*.txt', 'Test'
(2)XP_CMDSHELL  BCP 公用程序:
→创建存储过程
set quoted_identifier off
go
Create procedure  BCPtest @servername varchar(128),
@DatabaseName varchar(128), @filepath varchar(500), @pattern varchar(100), 
@TableName varchar(128)  --参数分别为服务器名、数据库名、文件路径、文件扩展名和数据库表名
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 fro’m #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)
end
drop table #y
→执行存储过程
Exec BCPtest 'SQL','Bank','e:\','*.txt','Test'

0

阅读 收藏 喜欢 打印举报/Report
  

新浪BLOG意见反馈留言板 欢迎批评指正

新浪简介 | About Sina | 广告服务 | 联系我们 | 招聘信息 | 网站律师 | SINA English | 产品答疑

新浪公司 版权所有