学步园

用过logExplorer的朋友都会被他强悍的功能吸引，我写过一篇详细的操作文档可以参考

http://blog.csdn.net/jinjazz/archive/2008/05/19/2459692.aspx

测试SQL脚本：

use master<br /> go<br /> create database dbLogTest<br /> go<br /> use dbLogTest<br /> go<br /> create table log_test(id int ,code char(10),name varchar(20),date datetime,memo varchar(100))<br /> insert into log_test select 100, 'id001','jinjazz',getdate(),'剪刀'<br /> insert into log_test select 65549,'id002','游客',getdate()-1,'这家伙很懒，没有设置昵称'<br /> insert into log_test select -999,'id003','这家伙来自火星',getdate()-1000,'a'<br /> delete from log_test

实现代码：

using System;<br /> using System.Collections.Generic;<br /> using System.Text;<br /> namespace ConsoleApplication21<br /> {<br /> class Program<br /> {<br /> /// <summary><br /> /// 分析sql2005日志，找回被delete的数据，引用请保留以下信息<br /> /// 作者：jinjazz (csdn的剪刀)<br /> /// 作者blog：http: //blog.csdn.net/jinjazz<br /> /// </summary><br /> /// <param name="args"></param><br /> static void Main(string[] args)<br /> {<br /> using (System.Data.SqlClient.SqlConnection conn = new System.Data.SqlClient.SqlConnection())<br /> {<br /> conn.ConnectionString = "server=localhost;uid=sa;pwd=sqlgis;database=dbLogTest";<br /> conn.Open();<br /> using (System.Data.SqlClient.SqlCommand command = conn.CreateCommand())<br /> {<br /> //察看dbo.log_test对象的sql日志<br /> command.CommandText = @"SELECT allocunitname,operation,[RowLog Contents 0] as r0,[RowLog Contents 1]as r1<br /> from::fn_dblog (null, null)<br /> where allocunitname like 'dbo.log_test%'and<br /> operation in('LOP_INSERT_ROWS','LOP_DELETE_ROWS')";<br /> System.Data.SqlClient.SqlDataReader reader = command.ExecuteReader();<br /> //根据表字段的顺序建立字段数组<br /> Datacolumn[] columns = new Datacolumn[]<br /> {<br /> new Datacolumn("id", System.Data.SqlDbType.Int),<br /> new Datacolumn("code", System.Data.SqlDbType.Char,10),<br /> new Datacolumn("name", System.Data.SqlDbType.VarChar),<br /> new Datacolumn("date", System.Data.SqlDbType.DateTime),<br /> new Datacolumn("memo", System.Data.SqlDbType.VarChar)<br /> };<br /> //循环读取日志<br /> while (reader.Read())<br /> {<br /> byte[] data = (byte[])reader["r0"];</p> <p> try<br /> {<br /> //把二进制数据结构转换为明文<br /> TranslateData(data, columns);<br /> Console.WriteLine("数据对象{1}的{0}操作：", reader["operation"], reader["allocunitname"]);<br /> foreach (Datacolumn c in columns)<br /> {<br /> Console.WriteLine("{0} = {1}", c.Name, c.Value);<br /> }<br /> Console.WriteLine();<br /> }<br /> catch<br /> {<br /> //to-do...<br /> }</p> <p> }<br /> reader.Close();<br /> }<br /> conn.Close();<br /> }<br /> Console.WriteLine("************************日志分析完成");<br /> Console.ReadLine();<br /> }<br /> //自定义的column结构<br /> public class Datacolumn<br /> {<br /> public string Name;<br /> public System.Data.SqlDbType DataType;<br /> public short Length = -1;<br /> public object Value = null;<br /> public Datacolumn(string name, System.Data.SqlDbType type)<br /> {<br /> Name = name;<br /> DataType = type;<br /> }<br /> public Datacolumn(string name,System.Data.SqlDbType type,short length)<br /> {<br /> Name = name;<br /> DataType = type;<br /> Length = length;<br /> }<br /> }<br /> /// <summary><br /> /// sql二进制结构翻译，这个比较关键，测试环境为sql2005，其他版本没有测过。<br /> /// </summary><br /> /// <param name="data"></param><br /> /// <param name="columns"></param><br /> static void TranslateData(byte[] data, Datacolumn[] columns)<br /> {<br /> //我只根据示例写了 Char,DateTime,Int三种定长度字段和varchar一种不定长字段，其余的有兴趣可以自己补充<br /> //这里没有暂时没有考虑Null和空字符串两种情况，以后会补充。<br /> //引用请保留以下信息：<br /> //作者：jinjazz<br /> //sql的数据行二进制结构参考我的blog<br /> //http://blog.csdn.net/jinjazz/archive/2008/08/07/2783872.aspx<br /> //行数据从第5个字节开始<br /> short index = 4;<br /> //先取定长字段<br /> foreach (Datacolumn c in columns)<br /> {<br /> switch (c.DataType)<br /> {<br /> case System.Data.SqlDbType.Char:<br /> //读取定长字符串，需要根据表结构指定长度<br /> c.Value = System.Text.Encoding.Default.GetString(data,index,c.Length);<br /> index += c.Length;<br /> break;<br /> case System.Data.SqlDbType.DateTime:<br /> // 读取datetime字段，sql为8字节保存<br /> System.DateTime date = new DateTime(1900, 1, 1);<br /> // 前四位1/300秒保存<br /> int second = BitConverter.ToInt32(data, index);<br /> date = date.AddSeconds(second/300);<br /> index += 4;<br /> // 后四位1900-1-1的天数<br /> int days = BitConverter.ToInt32(data, index);<br /> date=date.AddDays(days);<br /> index += 4;<br /> c.Value = date;<br /> break;<br /> case System.Data.SqlDbType.Int:<br /> //读取int字段,为4个字节保存<br /> c.Value = BitConverter.ToInt32(data, index);<br /> index += 4;<br /> break;<br /> default:<br /> //忽略不定长字段和其他不支持以及不愿意考虑的字段<br /> break;<br /> }<br /> }<br /> //跳过三个字节<br /> index += 3;<br /> //取变长字段的数量,保存两个字节<br /> short varColumnCount = BitConverter.ToInt16(data, index);<br /> index += 2;<br /> //接下来,每两个字节保存一个变长字段的结束位置,<br /> //所以第一个变长字段的开始位置可以算出来<br /> short startIndex =(short)( index + varColumnCount * 2);<br /> //第一个变长字段的结束位置也可以算出来<br /> short endIndex = BitConverter.ToInt16(data, index);<br /> //循环变长字段列表读取数据<br /> foreach (Datacolumn c in columns)<br /> {<br /> switch (c.DataType)<br /> {<br /> case System.Data.SqlDbType.VarChar:<br /> // 根据开始和结束位置，可以算出来每个变长字段的值<br /> c.Value =System.Text.Encoding.Default.GetString(data, startIndex, endIndex - startIndex);<br /> // 下一个变长字段的开始位置<br /> startIndex = endIndex;<br /> // 获取下一个变长字段的结束位置<br /> index += 2;<br /> endIndex = BitConverter.ToInt16(data, index);<br /> break;<br /> default:<br /> //忽略定长字段和其他不支持以及不愿意考虑的字段<br /> break;<br /> }<br /> }<br /> //获取完毕<br /> }<br /> }<br /> }