C#逐行讀取文本文件

1.前言

　　有兩個日志文件Arrive和Done，里面分別保存了程序處理一個報文的日志信息，Arrive里面保存的是報文的到達時間，Done里面保存的是報文處理完成的時間，現在想知道每個報文的處理時間是多長。如果靠人工在兩個日志文件中逐個報文對比的話需要花很長的時間，於是想到了將兩個報文的信息存儲到數據庫中，再利用數據庫的強大處理功能來獲得每個報文的處理時間。

2.實現

　　有了想法，立刻着手實現。

2.1定義數據庫

　　在數據庫中增加一個LOG_INFO的表，語法如下：

create table LOG_INFO
(
  FILE_NAME   CHAR(15) not null,
  ARRIVE_TIME DATE,
  DEAL_TIME   DATE
);

2.2報文解析入庫

　　讀文件並寫入數據庫：

        private void btnStart_Click(object sender, EventArgs e)
        {
            String line, time, filename, sql;
            int i = 0, result = 0;
            OracleConnection conn = new OracleConnection(connectionString);
            conn.Open();
            for (i = 0; i < 8; i++)
            {
                switch (i)
                { 
                    case 0:
                        lblCurrFile.Text = "Arrive3.log";
                        break;
                    case 1:
                        lblCurrFile.Text = "Arrive2.log";
                        break;
                    case 2:
                        lblCurrFile.Text = "Arrive1.log";
                        break;
                    case 3:
                        lblCurrFile.Text = "Arrive.log";
                        break;
                    case 4:
                        lblCurrFile.Text = "Done3.log";
                        break;
                    case 5:
                        lblCurrFile.Text = "Done2.log";
                        break;
                    case 6:
                        lblCurrFile.Text = "Done1.log";
                        break;
                    case 7:
                        lblCurrFile.Text = "Done.log";
                        break;
                    default:                     
                        break;
                }
                if (File.Exists(tbxPath.Text + lblCurrFile.Text))
                {
                    try
                    {
                        using (StreamReader sr = new StreamReader(tbxPath.Text + lblCurrFile.Text)) 
                        {
                            while ((line = sr.ReadLine()) != null) 
                            {
                                if (lbxReportInfo.Items.Count > 100)
                                {
                                    lbxReportInfo.Items.Clear();
                                }
                                else
                                {
                                    lbxReportInfo.Items.Add(line);
                                }
                                time = line.Substring(1, 19);
                                filename = line.Substring(22, 15);

                                if (lblCurrFile.Text.Substring(0, 4).Equals("Arri"))
                                    sql = String.Format("insert into LOG_INFO(FILE_NAME,ARRIVE_TIME) values('{0}',TO_DATE('{1}','YYYY-MM-DD HH24:MI:SS'))", filename, time);
                                else
                                    sql = String.Format("update LOG_INFO set DEAL_TIME=TO_DATE('{0}','YYYY-MM-DD HH24:MI:SS') where FILE_NAME='{1}'", time, filename);
                                // 入庫
                                try
                                {
                                    OracleCommand cmd = new OracleCommand(sql, conn);
                                    result = cmd.ExecuteNonQuery();
                                    cmd.Dispose();
                                }
                                catch(Exception ex)
                                {
                                    lblMsg.Text = ex.Message;
                                }
                            }
                        }
                    }
                    catch (Exception ex)
                    {
                        lblMsg.Text = ex.Message;
                    }
                }
                else
                {
                    continue;
                }
            }
            conn.Close();
        }

　　數據庫是Oracle 11g，連接字符串格式如下：

　　private string connectionString = "server=xxx;uid=xxx;pwd=xxx";

2.3計算報文處理時間

　　在PL/SQL命令窗口中輸入如下命令：

　　select (deal_time-arrive_time)*24*60*60 from log_info;

　　可以得到每個報文的處理時間。由於deal_time-arrive_time的結果單位是天，通過*24*60*60將其轉換為秒。當然也可以通過*24*60轉換為分鍾，具體看需要。

　　當然也可以加上一些查詢條件，比如想得到處理時間大於100秒的記錄就可以這樣寫：

　　select (deal_time-arrive_time)*24*60*60 from log_info where (deal_time-arrive_time)*24*60*60>100;

　　查詢結果如下：

SQL> select (deal_time-arrive_time)*24*60*60 from log_info where (deal_time-arrive_time)*24*60*60>100;
 
(DEAL_TIME-ARRIVE_TIME)*24*60*
------------------------------
                           285
                           322
                           124
                           136
                           124
                           129
                           261
 
7 rows selected
 
SQL> 

3.總結

　　程序在WinXP SP3+VS2010+Oracle 11g下測試通過。