学习使用LogParser分析exchange日志

using (IdentityScope c = new IdentityScope("mossadmin", "inet", "password")) //通过网络邻居访问时提供域中号密码
{
var logs = System.IO.Directory.GetFiles(LogPath, "*.log") //遍历目录内所有文件，筛选出大于等于上次更新文件
   .Where(f => int.Parse(f.Substring(f.LastIndexOf('') + 7, 8)) >= _config.fileDT)
   .OrderBy(f => int.Parse(f.Substring(f.LastIndexOf('') + 7, 8)))
   .ToList();

if (logs.Count > 0)
{
    DelOldLog(_config);
    logs.ForEach(f =>
    {
         bind(f,_config.MacName);
         _config.fileDT = int.Parse(f.Substring(f.LastIndexOf('') + 7, 8));
         _config.modifyDT = new FileInfo(f).LastWriteTime;
     });
 }
}

static void bind(string logPath,string macName)
        {
            LogQuery oLogQuery = new LogQuery();//调用LogPaser日志查询类库
           
            TsvInputFormat oTsvInputFormat = new TsvInputFormat();//声明日志格式类型
             LogRecordSet oRecordSet;
           string query = string.Empty;
             
            DataTable dt = new DataTable();
             #region 所有的条数--Log中包含“reccode=”的行数
            query = @"select * from '" + logPath + "' where [event-id]='RECEIVE'";
 
            oTsvInputFormat.nSkipLines = 4;
            oTsvInputFormat.iCodepage = 65001;
 
            oRecordSet = oLogQuery.Execute(query, oTsvInputFormat);
            for (int i = 0; i < oRecordSet.getColumnCount(); i++)
            {
                 dt.Columns.Add(oRecordSet.getColumnName(i));
             }
             dt.Columns.Add("MacName");
            //取得所有的資料
             for (; !oRecordSet.atEnd(); oRecordSet.moveNext())
            {
                 DataRow dr = dt.NewRow();
                 for (int i = 0; i < oRecordSet.getColumnCount()-1; i++)
                 {
                     dr[oRecordSet.getColumnName(i)] = oRecordSet.getRecord().getValue(oRecordSet.getColumnName(i));
                }
                 dr["MacName"] = macName;
                dt.Rows.Add(dr);
            }
 
             oRecordSet.close();
            #endregion
            
  SqlBulkCopy sqlbulkcopy = new SqlBulkCopy(connectionString, SqlBulkCopyOptions.UseInternalTransaction);
  sqlbulkcopy.DestinationTableName = "LM_webLog";//数据库中的表名
  sqlbulkcopy.WriteToServer(dt);
 
 Console.WriteLine(dt.Rows.Count + ":" + logPath);
}