0

私はうまく機能したメソッドを持っていますが、今ではクエリが変更されており、これが実行されるクライアント マシンの一部が少し能力不足であるという事実を考慮して、CommandTimeout を追加する必要があります。私が抱えている問題は、CommandTimeout の追加が機能しないため、行を使用することです。

プログラム自体は、毎晩 SFTP サーバーからクエリを取得し、クライアント DB に対してクエリを実行し、結果をファイルに書き込み、結果を 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