码迷,mamicode.com
首页 > Windows程序 > 详细

C#调用SSIS包及读取DataReader目标

时间:2015-08-20 12:35:14      阅读:147      评论:0      收藏:0      [点我收藏+]

标签:

C#调用SSIS包需要引用两个DLL 。(具体位置在C盘搜索,MSDN和百度提供的路径都不太正确)

Microsoft.SQLServer.ManagedDTS.dll

Microsoft.SqlServer.Dts.DtsClient.dll   

这是MSDN上的例子 https://msdn.microsoft.com/zh-cn/library/ms136025%28v=sql.120%29.aspx

MSDN上的例子只有读取一个DataReader的做法,并且该方法不能加事件。

下面是读取多个DataReader的代码

          string pkgLocation = @"Package1.dtsx"; //包路径
            DtsConnection dtsConnection;
          DtsCommand dtsCommand;
          IDataReader dtsDataReader = null;
          Package pkg;
          Application app;
          DataSet ds = new DataSet();
          app = new Application();
          pkg = app.LoadPackage(pkgLocation, null);


          string dataReaderName = "DataReaderDest";


          dtsConnection = new DtsConnection();
          {
              dtsConnection.m_pkg = pkg;
//              dtsConnection.ConnectionString = string.Format(@"/FILE ""{0}""",pkgLocation); //另一种连接方式。如果用Package则可以加事件
//              dtsConnection.Open();
          }

          dtsCommand = new DtsCommand(dtsConnection);
          dtsCommand.CommandText = dataReaderName;

          List<string> reader = new List<string>() {"DataReaderDest", "DataReaderDest2"}; //DataReader输出名称 集合

          
            List<IDataReader> readers = new List<IDataReader>();
          foreach (var cmdtext in reader)
          {
              dtsCommand.CommandText = cmdtext;
              dtsDataReader = dtsCommand.ExecuteReader(CommandBehavior.SingleResult);
              readers.Add(dtsDataReader);
              Console.WriteLine("读取{0}", cmdtext);
          }

          foreach (var dataReader in readers)
          {
              try
              {
                  DataTable dt = new DataTable();
                  dt.Load(dataReader);
                  Console.WriteLine("数据行{0}", dt.Rows.Count);
                  ds.Tables.Add(dt);
              }
              catch (Exception ex)
              {
                  Console.WriteLine(ex.Message);
              }
              finally
              {
                  dataReader.Close();
              }
          }

          dtsCommand.Dispose();
          return ds;

上面的代码能读取1个以上DataReader但是读取第一个后需要等待30秒才能读取第二个,会在下面的代码卡着

dtsDataReader = dtsCommand.ExecuteReader(CommandBehavior.SingleResult);

原因是包中DataReader的ReadTimeout默认为30000毫秒 设为100毫秒就好了。每一个DataReader都要设置。

C#调用SSIS包及读取DataReader目标

标签:

原文地址:http://www.cnblogs.com/bflyman/p/4744545.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!