0

我有一个对我很有帮助的方法，但是现在查询已经改变，我需要添加一个 CommandTimeout以考虑到执行此操作的某些客户端机器功率不足的事实。我遇到的问题是使用行添加 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);
        }
    }
4

1 回答 1

0

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

            var command = new SqlCommand(QueryToExec, conn);
            command.CommandTimeout = 300;
            var reader = command.ExecuteReader();
            var outFile = File.CreateText(destinationFile);
于 2017-10-06T01:02:55.033 回答