2017-10-06 31 views
0

我有一直担任我很好的方法,但现在查询已经改变,我需要添加的CommandTimeout允许的事实,一些客户机上,这是执行有点动力不足。我遇到的问题是使用线路作为添加CommandTimeout不起作用。C#的CommandTimeout使用的语句问题

程序本身每晚从SFTP服务器拉下查询,然后对客户端数据库执行查询,将结果写入文件,然后将结果发送回SFTP服务器。

我无法提高客户端计算机上查询(只读访问)的效率,所以我坚持使用这种方法。

public void DumpTableToFile(string connection, string destinationFile, string QueryToExec) 
    { 
     string logDirectory = VariableStorage.logDirectory; 
     string Practice = VariableStorage.Practice; 

     try 
     { 
      SqlConnection conn = new SqlConnection(connection); 
      conn.Open(); 

      using (var command = new SqlCommand(QueryToExec, conn)) 
      using (var reader = command.ExecuteReader()) 

      using (var outFile = File.CreateText(destinationFile)) 
      { 
       string[] columnNames = GetColumnNames(reader).ToArray(); 
       int numFields = columnNames.Length; 
       outFile.WriteLine(string.Join("\t", columnNames)); 
       if (reader.HasRows) 
       { 
        while (reader.Read()) 
        { 
         string[] columnValues = 
          Enumerable.Range(0, numFields) 
             .Select(i => reader.GetValue(i).ToString()) 
             .Select(field => string.Concat("", field.Replace("\"", "\"\""), "")) 
             .ToArray(); 

         outFile.WriteLine(string.Join("\t", columnValues)); 
        } 
       } 
      } 
     } 
     catch (Exception e) 
     { 
      Program log = new Program(); 
      log.WriteToLog(" Error: " + e); 
      SendEmailReport(Practice + " - Data Collection Error", " Error: " + e); 
     } 
    } 

回答

0

好的,找到了答案。我不得不删除Using语句。

  var command = new SqlCommand(QueryToExec, conn); 
      command.CommandTimeout = 300; 
      var reader = command.ExecuteReader(); 
      var outFile = File.CreateText(destinationFile);