SQL Server 2008中定时任务之数据抽取

2019年6月11日 236次阅读 来源: miss晴天

该数据抽取通过SQLServer2008中的xp_cmdshell实现，
将E:\ABC\Files*下的指定文件首先写入到E:\ABC\Files\out.csv中，
然后把E:\ABC\Files\UT_StockData*下的UT_StockData开头的文件写入到out.csv，通过读取out.csv将表名读取到dimp.dbo.t_ws_bo_filename表中,再通过读取表中的表名，抽取数据到数据库中，抽取完成后，再将文件移动到E:\ABC\File_H\文件夹中去；
该抽取只适合单个数据库表；
用到的windows命令：
dir 显示文件路径,
bulk insert数据插入,
move移动文件或文件夹
抽取的定时作业通过SQLServer2008代理服务实现。

代码实现：

-- 允许配置高级选项
EXEC sp_configure 'show advanced options', 1
go
-- 重新配置
RECONFIGURE
Go
-- 启用xp_cmdshell
EXEC sp_configure 'xp_cmdshell', 1
Go
--重新配置
RECONFIGURE
GO

-- =============================================
-- Author:      <Author,,Name>
-- Create date: <Create Date,,>
-- Description: <Description,,>
-- =============================================
--定义变量和设置变量

----将E:\ABC\Files\*下所有文件写到E:\ABC\Files\out.csv中
declare  @dirUrl  varchar(200)
declare  @fileName  varchar(200)
declare @sql varchar(300)
Set   @dirUrl = 'E:\ABC\Files\'
Set   @fileName = 'out.csv'
Set   @sql = 'dir  E:\ABC\Files\UT_StockData* /B >     '+@dirUrl+@fileName
EXEC master..xp_cmdshell @sql
Go


----将out.csv中的内容写入到数据库中文件表
declare  @dirUrl  varchar(200)
declare  @fileName  varchar(200)
declare @sql varchar(300)
Set   @dirUrl = 'E:\ABC\Files\'
Set   @fileName = 'out.csv'
--删除原来表中的数据
delete from dimp.dbo.t_ws_bo_filename

Set @sql = 'bcp [dimp].[dbo].[t_ws_bo_filename]  in  "'+@dirUrl+@fileName+'" -c -t","  -k -S"127.0.0.1" -U"dimp" -P"123456"'
exec  master..xp_cmdshell @sql
Go



declare  @dirUrl  varchar(200)
declare @urlFile varchar(200)
declare yoa cursor for
select fileUrl from dimp.dbo.t_ws_bo_filename order by fileUrl
open yoa
    Fetch Next From yoa into @urlFile
    while(@@Fetch_Status=0)
        begin
            declare @sql varchar(300)
            Set   @dirUrl = 'E:\ABC\Files\'

            Set @sql = @dirUrl+@urlFile
            exec ('BULK INSERT [dimp].[dbo].[tmp_user]  FROM '''+@sql+''' WITH (FIELDTERMINATOR = '','', FIRSTROW = 2)')
            --调用存储过程
            --exec dbo.sp_add_stock
            Fetch Next From yoa into @urlFile
        end
close yoa
Deallocate yoa
GO

--移动文件,将原来文件夹下的文件移动另一个文件中
declare @sql varchar(300)
declare  @sdirUrl  varchar(200)
declare  @ddirUrl  varchar(200)
Set   @sdirUrl = 'E:\ABC\Files\'
Set   @ddirUrl = 'E:\ABC\File_H\'
Set   @sql = 'move /Y '+ @sdirUrl + 'UT_StockData* '+@ddirUrl
exec master..xp_cmdshell @sql
GO


-- 允许配置高级选项
EXEC sp_configure 'show advanced options', 1
Go
-- 重新配置
RECONFIGURE
Go
-- 启用xp_cmdshell
EXEC sp_configure 'xp_cmdshell', 0
Go
--重新配置
RECONFIGURE
GO
    原文作者：miss晴天
    原文地址: https://www.jianshu.com/p/ce81d89658f1
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。
点赞