用c#读取并分析sql2005日志

用过logExplorer的朋友都会被他强悍的功能吸引，我写过一篇详细的操作文档可以参考http://blog.csdn.net/jinjazz/archive/2008/05/19/2459692.aspx我们可以自己用开发工具来实现sql日志的读取，这个应用还是很酷的，具体思路1、首先要了解一个没有公开的系统函数::fn_dblog，他可以读取sql日志，并返回二进制的行数据2、然后要了解sql的二进制数据是如何存储的，这个可以参考我的blog文章http://blog.csdn.net/jinjazz/archive/2008/08/07/2783872.aspx3、用自己擅长的开发工具来分析数据，得到我们需要的信息我用c#写了一个测试样例，分析了int，char，datetime和varchar的日志情况而且没有考虑null和空字符串的保存，希望感兴趣的朋友能和我一起交流打造属于自己的日志分析工具详细的试验步骤以及代码如下：1、首先建立sqlserver的测试环境，我用的sql2005，这个过程不能保证在之前的版本中运行以下sql语句会建立一个dbLogTest数据库，并建立一张log_test表，然后插入3条数据之后把表清空

1. usemaster
2. go
3. createdatabasedbLogTest
4. go
5. usedbLogTest
6. go
7. createtablelog_test(idint,codechar(10),namevarchar(20),datedatetime,memovarchar(100))
8. insertintolog_testselect100,'id001','jinjazz',getdate(),'剪刀'
9. insertintolog_testselect65549,'id002','游客',getdate()-1,'这家伙很懒，没有设置昵称'
10. insertintolog_testselect-999,'id003','这家伙来自火星',getdate()-1000,'a'
12. deletefromlog_test
14. --usemaster
15. --go
16. --dropdatabasedbLogTest

2、我们最终的目的是要找到被我们删掉的数据3、分析日志的c#代码:我已经尽量详细的写了注释

1. usingSystem;
2. usingSystem.Collections.Generic;
3. usingSystem.Text;
5. namespaceConsoleapplication21
6. {
7. classPRogram
8. {
9. ///<summary>
10. ///分析sql2005日志，找回被delete的数据，引用请保留以下信息
11. ///作者：jinjazz(csdn的剪刀)
12. ///作者blog：http://blog.csdn.net/jinjazz
13. ///</summary>
14. ///<paramname="args"></param>
15. staticvoidMain(string[]args)
16. {
17. using(System.Data.SqlClient.SqlConnectionconn=newSystem.Data.SqlClient.SqlConnection())
18. {
19. conn.ConnectionString="server=localhost;uid=sa;pwd=sqlgis;database=dbLogTest";
20. conn.Open();
21. using(System.Data.SqlClient.SqlCommandcommand=conn.CreateCommand())
22. {
23. //察看dbo.log_test对象的sql日志
24. command.CommandText=@"SELECTallocunitname,Operation,[RowLogContents0]asr0,[RowLogContents1]asr1
25. from::fn_dblog(null,null)
26. whereallocunitnamelike'dbo.log_test%'and
27. operationin('LOP_INSERT_ROWS','LOP_DELETE_ROWS')";
29. System.Data.SqlClient.SqlDataReaderreader=command.ExecuteReader();
30. //根据表字段的顺序建立字段数组
31. Datacolumn[]columns=newDatacolumn[]
32. {
33. newDatacolumn("id",System.Data.SqlDbType.Int),
34. newDatacolumn("code",System.Data.SqlDbType.Char,10),
35. newDatacolumn("name",System.Data.SqlDbType.VarChar),
36. newDatacolumn("date",System.Data.SqlDbType.DateTime),
37. newDatacolumn("memo",System.Data.SqlDbType.VarChar)
38. };
39. //循环读取日志
40. while(reader.Read())
41. {
42. byte[]data=(byte[])reader["r0"];
44. try
45. {
46. //把二进制数据结构转换为明文
47. TranslateData(data,columns);
48. Console.WriteLine("数据对象{1}的{0}操作：",reader["operation"],reader["allocunitname"]);
49. foreach(Datacolumncincolumns)
50. {
51. Console.WriteLine("{0}={1}",c.Name,c.Value);
52. }
53. Console.WriteLine();
54. }
55. catch
56. {
57. //to-do...
58. }
60. }
61. reader.Close();
62. }
63. conn.Close();
64. }
65. Console.WriteLine("************************日志分析完成");
66. Console.ReadLine();
67. }
68. //自定义的column结构
69. publicclassDatacolumn
70. {
71. publicstringName;
72. publicSystem.Data.SqlDbTypeDataType;
73. publicshortLength=-1;
74. publicobjectValue=null;
75. publicDatacolumn(stringname,System.Data.SqlDbTypetype)
76. {
77. Name=name;
78. DataType=type;
79. }
80. publicDatacolumn(stringname,System.Data.SqlDbTypetype,shortlength)
81. {
82. Name=name;
83. DataType=type;
84. Length=length;
85. }
86. }
87. ///<summary>
88. ///sql二进制结构翻译，这个比较关键，测试环境为sql2005，其他版本没有测过。
89. ///</summary>
90. ///<paramname="data"></param>
91. ///<paramname="columns"></param>
92. staticvoidTranslateData(byte[]data,Datacolumn[]columns)
93. {
94. //我只根据示例写了Char,DateTime,Int三种定长度字段和varchar一种不定长字段，其余的有兴趣可以自己补充
95. //这里没有暂时没有考虑Null和空字符串两种情况，以后会补充。
97. //引用请保留以下信息：
98. //作者：jinjazz
99. //sql的数据行二进制结构参考我的blog
100. //http://blog.csdn.net/jinjazz/archive/2008/08/07/2783872.aspx
101. //行数据从第5个字节开始
102. shortindex=4;
103. //先取定长字段
104. foreach(Datacolumncincolumns)
105. {
106. switch(c.DataType)
107. {
108. caseSystem.Data.SqlDbType.Char:
109. //读取定长字符串，需要根据表结构指定长度
110. c.Value=System.Text.Encoding.Default.GetString(data,index,c.Length);
111. index+=c.Length;
112. break;
113. caseSystem.Data.SqlDbType.DateTime:
114. //读取datetime字段，sql为8字节保存
115. System.DateTimedate=newDateTime(1900,1,1);
116. //前四位1/300秒保存
117. intsecond=BitConverter.ToInt32(data,index);
118. date=date.AddSeconds(second/300);
119. index+=4;
120. //后四位1900-1-1的天数
121. intdays=BitConverter.ToInt32(data,index);
122. date=date.AddDays(days);
123. index+=4;
124. c.Value=date;
125. break;
126. caseSystem.Data.SqlDbType.Int:
127. //读取int字段,为4个字节保存
128. c.Value=BitConverter.ToInt32(data,index);
129. index+=4;
130. break;
131. default:
132. //忽略不定长字段和其他不支持以及不愿意考虑的字段
133. break;
134. }
135. }
136. //跳过三个字节
137. index+=3;
138. //取变长字段的数量,保存两个字节
139. shortvarColumnCount=BitConverter.ToInt16(data,index);
140. index+=2;
141. //接下来,每两个字节保存一个变长字段的结束位置,
142. //所以第一个变长字段的开始位置可以算出来
143. shortstartIndex=(short)(index+varColumnCount*2);
144. //第一个变长字段的结束位置也可以算出来
145. shortendIndex=BitConverter.ToInt16(data,index);
146. //循环变长字段列表读取数据
147. foreach(Datacolumncincolumns)
148. {
149. switch(c.DataType)
150. {
151. caseSystem.Data.SqlDbType.VarChar:
152. //根据开始和结束位置，可以算出来每个变长字段的值
153. c.Value=System.Text.Encoding.Default.GetString(data,startIndex,endIndex-startIndex);
154. //下一个变长字段的开始位置
155. startIndex=endIndex;
156. //获取下一个变长字段的结束位置
157. index+=2;
158. endIndex=BitConverter.ToInt16(data,index);
159. break;
160. default:
161. //忽略定长字段和其他不支持以及不愿意考虑的字段
162. break;
163. }
164. }
165. //获取完毕
166. }
167. }
168. }

4、更改你的sql连接字符串后运行以上代码，会看到如下输出信息：

1. 数据对象dbo.log_test的LOP_INSERT_ROWS操作：
2. id=100
3. code=id001
4. name=jinjazz
5. date=2008-8-718:14:03
6. memo=剪刀
8. 数据对象dbo.log_test的LOP_INSERT_ROWS操作：
9. id=65549
10. code=id002
11. name=游客
12. date=2008-8-618:14:03
13. memo=这家伙很懒，没有设置昵称
15. 数据对象dbo.log_test的LOP_INSERT_ROWS操作：
16. id=-999
17. code=id003
18. name=这家伙来自火星
19. date=2005-11-1118:14:03
20. memo=a
22. 数据对象dbo.log_test的LOP_DELETE_ROWS操作：
23. id=100
24. code=