• 欢迎访问搞代码网站,推荐使用最新版火狐浏览器和Chrome浏览器访问本网站!
  • 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏搞代码吧

MS SQL Server 2000数据转换服务部署_sqlserver

sqlserver 搞代码 3年前 (2018-06-17) 160次浏览 已收录 0个评论

1. 目标

MS SQL Server做大数据量传输的时候,我们大多会用到数据传输服务。现在假设,在开发环境下,我们已经设计好了DTS包并且运行良好,接下来我们要做的事情是迁移和部署这个DTS数据包。所以,我们需要把设计环境下的DTS包保存成结构化的存储文件,并且这个文件导入到目标环境下的MS SQL Server中,最后添加作业,让MS SQL Server Angent在我们预期的事情执行这个DTS包完成数据传输工作。其中需要重点解决的一个问题是,在目标环境中,DTS传输的源和目的地会发生改变,需要对它进行配置。

2. 解决方案

http://www.gaodaima.com/?p=37140MS SQL Server 2000数据转换服务部署_sqlserver

2.1. DTSRun

DTSRun是微软提供的命令用于执行DTS包(包括结构化存储的、存储在SQL Server或存储在Meta Data Services的包)。

dtsrun的用法:
dtsrun
[/?]|
[
    [
        /[~]S server_name[/instance_name]
        { {/[~]U user_name [/[~]P password]} | /E }
    ]
    {    
        {/[~]N package_name }
        | {/[~]G package_guid_string}
        | {/[~]V package_version_guid_string}
    }
    [/[~]M package_password]
    [/[~]F filename]
    [/[~]R repository_database_name]
    [/A global_variable_name:typeid=value]
    [/L log_file_name]
    [/W NT_event_log_completion_status]
    [/Z] [/!X] [/!D] [/!Y] [/!C]
]
具体的用法参看微软的资料。这里需要重点指出的是,通过“/A global_variable_name:typeid=value”选项,我们可以给DTS包传递多个自定义的参数,在DTS包部署的目标环境下,我们用这个选项告诉DTS包服务器名称、用户名、密码等数据库连接信息。通过“/!Y”选项可以获取加密后的DTSRun参数。

2.2. 重新设计DTS包

为了处理DTSRun传入的自定义参数,DTS包需要重新设计。我们可以增加一个ActiveX Script任务,在ActiveX Script任务中通过VB Script或者java Script对DTS编程,并且定义流程,把ActiveX Script任务设置成最开始的一个任务。由于DTS COM对象线程模式与ActiveX Script任务宿主的不一致,需要将ActiveX Script任务工作流属性设置成在主包线程中执行,否则可能会出现调用错误。

下面的例子是ActiveX Script任务中的脚本。例子中的DTS包包含名称为”DBConnection”的数据库连接对象。

‘************************************************************************’ Visual Basic ActiveX Script’************************************************************************Function Main() Dim sDBDataSource Dim sDBCatalog Dim sDBUserID Dim sDBPassword Dim bDBUseTrusted Dim sOLAPServer Dim sOLAPCatalog Dim oPackage Dim oConnection Dim oTask Dim oCustomTask ‘ 获取DTSRun传入的自定义参数 sDBDataSource = DTSGlobalVariables(“DBDataSource”).Value sDBCatalog = DTSGlobalVariables(“DBCatalog”).Value sDBUserID = DTSGlobalVariables(“DBUserID”).Value sDBPassword = DTSGlobalVariables(“DBPassword”).Value bDBUseTrusted = DTSGlobalVariables(“DBUseTrusted”).Value sOLAPServer = DTSGlobalVariables(“OLAPServer”).Value sOLAPCatalog = DTSGlobalVariables(“OLAPCatalog”).Value ‘ 取得当前DTS包对象的技巧 Set oPackage = DTSGlobalVariables.Parent ‘ 取得包中的数据连接对象 Set oConnection = oPackage.Connections(“DBConnection”) ‘ 配置数据源对象的数据连接信息 If bDBUseTrusted Then oConnection.UseTrustedConnection = bDBUseTrusted Else oConnection.UserID = sDBUserID oConnection.Password = sDBPassword End If oConnection.DataSource = sDBDataSource oConnection.Catalog = sDBCatalog Set oConnection = nothing ‘ 配置跟多的信息,这里是OLAP分析服务处理任务 Set oTask = oPackage.Tasks(“DTSTask_DTSOlapProcess.Certificate”) Set oCustomTask = oTask.CustomTask Set oTask = nothing oCustomTask.Properties(“TreeKey”).Value = sOLAPServer & “/” _ & sOLAPCatalog & “/CubeFolder/Certificate” Set oCustomTask = nothing ‘ 返回成功状态 Main = DTSTaskExecResult_SuccessEnd Function

2.3. 保存为结构化的存储文件

这个过程相当的简单,通过企业管理器可以完成。另存为的结构化存储文件就是我们要分发的DTS包。

2.4. 导入到MS SQL Server

我们需要通过DTS编程来实现这个过程。需要强调的是,下面这段示例需要在ApartmentState为STA线程中才可以正确的被调用。

public void Go(){ DTS.Package2Class pkg = new DTS.Package2Class(); DTS.Application app = new DTS.ApplicationClass(); //从SQL SERVER中删除已经存在的同名DTS包 try { pkg.RemoveFromSQLServer( DBServer, DBSUserID, DBSPassword, DTS.DTSSQLServerStorageFlags.DTSSQLStgFlag_Default, “”, “”, PkgName ); } catch { } //取得待分发DTS包(结构化的存储文件)的包信息,这里假定包中只包含一个版本 DTS.SavedPackageInfos infos = pkg.GetSavedPackageInfos(UNCFile); DTS.SavedPackageInfo info = infos.Item(1); object obj1 = null; object obj2 = null; string sPkgID = info.PackageID; string sVerID = info.VersionID; string sPkgName = info.PackageName; //载入结构化的存储文件 pkg.LoadFromStorageFile( UNCFile, PkgPwd, sPkgID, sVerID, sPkgName, ref obj1 ); //保存到SQL Server中 pkg.SaveToSQLServerAs( PkgName, DBServer, DBSUserID, DBSPassword, DTS.DTSSQLServerStorageFlags.DTSSQLStgFlag_Default, PkgOwnerPwd, PkgOperatorPwd, “”, ref obj2, false); pkg.UnInitialize(); //检查是否保存成功 DTS.PackageSQLServer pkgSQLServer = app.GetPackageSQLServer( DBServer, DBSUserID, DBSPassword, DTS.DTSSQLServerStorageFlags.DTSSQLStgFlag_Default ); DTS.PackageInfos infs = pkgSQLServer.EnumPackageInfos(PkgName, true, “”); if (infs.EOF) throw new Exception(“DTS包导入到数据库失败。”); DTS.PackageInfo inf = infs.Next(); mPkgID = inf.PackageID; mVerID = inf.VersionID;}

2.5. 添加作业

添加作业可以用传统的方式,用SQL语句可做到,不做详细说明。MS SQL Server更是提供一系列的存储过程对作业进行修改,以达到用户预期的效果。

3. 小结

文章到此已经达到我们的目标。总体上说,2.2这步的实现有些困难,在实现过程当中也碰到过很多困难,有一些是在新闻组中得到的解答,其它的步骤查看MSDN都可以得到比较容易的解决。

欢迎大家阅读《MS SQL Server 2000数据转换服务部署_sqlserver,跪求各位点评,若觉得好的话请收藏本文,by 搞代码


喜欢 (0)
[搞代码]
分享 (0)
发表我的评论
取消评论

表情 贴图 加粗 删除线 居中 斜体 签到

Hi,您需要填写昵称和邮箱!

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址