1. 目标

    ms sql server做大数据量传输的时候，我们大多会用到数据传输服务。现在假设，在开发环境下，我们已经设计好了dts包并且运行良好，接下来我们要做的事情是迁移和部署这个dts数据包。

　　所以，我们需要把设计环境下的dts包保存成结构化的存储文件，并且这个文件导入到目标环境下的ms sql server中，最后添加作业，让ms sql server angent在我们预期的事情执行这个dts包完成数据传输工作。其中需要重点解决的一个问题是，在目标环境中，dts传输的源和目的地会发生改变，需要对它进行配置。

　　2. 解决方案

　　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_success 　　end 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都可以得到比较容易的解决。