/// <summary> /// /通过SSIS包 将数据导入数据库 /// </summary> /// <param name="dtsxFileName">dtsx文件名</param> /// <param name="csvFileName">csv文件名</param> /// <returns></returns> protected bool FillData2DB(string dtsxFileName, string csvFileName) { string dtsxFile = System.AppDomain.CurrentDomain.BaseDirectory + "DTSX\\" + dtsxFileName;
Microsoft.SqlServer.Dts.Runtime.Wrapper.Application app = new Microsoft.SqlServer.Dts.Runtime.Wrapper.Application();
//Call the dtsx file IDTSPackage90 package = app.LoadPackage(dtsxFile, true, null); //另外还有一种方法叫LoadFromSQLServer package.Connections["File"].ConnectionString = Path.Combine(System.AppDomain.CurrentDomain.BaseDirectory, csvFileName); package.Connections["本地连接"].ConnectionString = ConfigurationSettings.AppSettings["ConnStr"];
DTSExecResult result = package.Execute(); //获取包的执行信息 //string message = string.Empty; //if (result.Equals(DTSExecResult.DTSER_FAILURE)) //{ // for (int i = 0; i < package.Errors.Count; i++) // { // message += package.Errors[i].Description; // } //} //if (!string.IsNullOrEmpty(message)) //{ // throw new Exception(message); //抛出异常 //} if (result.Equals(DTSExecResult.DTSER_SUCCESS)) return true; else return false;
}
