C#调用SSIS包及读取DataReader目标
生活随笔
收集整理的這篇文章主要介紹了
C#调用SSIS包及读取DataReader目标
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
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.Default);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都要設置。
轉載于:https://www.cnblogs.com/bflyman/p/4744545.html
總結
以上是生活随笔為你收集整理的C#调用SSIS包及读取DataReader目标的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Docker在Ubuntu16.04上安
- 下一篇: windows mysqldump 不