java中通过jacob调用dts进行数据导入导出

在一个项目中需要金蝶软件对接，但是业务服务器和财务服务器相隔很远（中间经过好几台服务器，有内网也有外网），从一个内网向另一个内网中传输时，需要外网辅助，因为不让原始数据受污染，使用了DTS数据同步到另一台服务器，然后再上传至外网。

sqlserver下 调用dts

EXEC master.dbo.xp_cmdshell 'dtsrun  /S /E /N"MyPack" /A"begintime":8=2013-06-01 /A"endtime":8=2013-08-20'

create table dtsSync(
beginDate datetime,
endDate datetime,
execDate datetime primary key
)
insert into dtsSync values('2013-08-01', '2013-08-23', getdate());

declare @beginDate varchar(10), @endDate varchar(10), @command varchar(255)
select @beginDate=convert(varchar(10), max(endDate) + 1,120) from dtsSync
set @endDate=convert(varchar(10),getdate(),120)
set @command='dtsrun  /S /E /N"MyPack" /A"begintime":8=' + @beginDate + ' /A"endtime":8=' + @endDate
print @command
EXEC master.dbo.xp_cmdshell @command
select @endDate=convert(varchar(10),max(dt_signDate),120) from rpt_xiaoshou
insert into dtsSync values(@beginDate, @endDate, getdate())

第一步:
下载jacob http://danadler.com/jacob/jacobBin_17.zip 解压后将dll文件放到%JAVA_HOME%\jre\bin

和 %JAVA_HOME%\bin（如果不放：java.lang.UnsatisfiedLinkError: no jacob in java.library.path）

目录下,将jar文件放到%JAVA_HOME%\jre\lib\ext目录下(各种报错，还是放到工程中吧),不用再配置环境变量

第二步:
创建dts文件
直接用sqlserver2000的导入导出工具创建一个dts任务,并保存为存储结构文件,放到比如d:\temp\dts\dts_test.dts

第三步:
通过java调用dts文件执行数据导入导出

package dbf;

import java.text.SimpleDateFormat;
import java.util.Date;
import com.jacob.activeX.*;
import com.jacob.com.*;

public class ExportDts {
public void exportdbf() {

SimpleDateFormat localTime  =   new  SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

String importFileName = "D:/temp/dbf"; //这里导出的DBF要存放的路径
String DtsPath = "D:/temp/dts/dts_test.dts";  //这里是DTS文件的路径

try {
System.out.println("start:" + localTime.format(new Date()));

ActiveXComponent app = new ActiveXComponent("DTS.Package2");

Dispatch.callN(app, "LoadFromStorageFile",new Variant[] {new Variant(DtsPath),new Variant("")});

//重新设置路径
Dispatch DTSconns = Dispatch.get(app,"Connections").toDispatch();
Dispatch DTSconn = Dispatch.callN(DTSconns,"Item",new Variant[]{new Variant(2)}).toDispatch();
Dispatch.put(DTSconn,"DataSource",new String(importFileName));

//执行
Dispatch.callN(app, "Execute", new Variant[] {});

//得到执行的结果
Dispatch DTSsteps = Dispatch.get(app,"Steps").toDispatch();
Dispatch DTSstep = Dispatch.callN(DTSsteps,"Item",new Variant[]{new Variant(1)}).toDispatch();
Variant ResultValue = Dispatch.get(DTSstep,"ExecutionResult");

if(ResultValue.toInt()==0){
System.out.println("导出成功");

}else{
System.out.println("导出失败");

}
System.out.println("end:" + localTime.format(new Date()));
} catch (Exception ex) {
ex.printStackTrace();
}
}
}