2001年4月份，我在博客中發過一個小工具，它是一個用ASP.NET寫的SQL SERVER的輔助小工具。
在這期間，有些人貌似對那個工具比較有興趣，所以我常能收到索要源代碼的郵件。
正好，我上月又發布了我的MVC框架，因此打算用【我的ASP.NET MVC框架】來重寫這個工具，
并開源。
工具的特點：
1. 采用ASP.NET編寫，并借助MyMVC框架。
2. 為了更好地接近桌面程序的操作體驗，網站采用純AJAX的方式實現。
3. 界面使用了 JQuery Easy UI
4. 代碼的語法著色使用了 syntaxhighlighter (JavaScript類庫)
工具的定位：只是輔助工具，因此功能有限，但要將有限的功能做得盡量好。
下面將分別介紹工具所能完成的功能，以及關鍵的實現代碼。
說明：工具的所有源代碼可以在本文的結尾處下載。
項目介紹
整個工具的源代碼結構如下：
|
項目由Visual Studio 2008創建，包含三個部分：
1. WebApp：一個ASP.NET網站，它是工具的可運行部分。
網站只包含一些HTML, CSS, JavaScript，DLL文件。
2. MyMvcEx：一個類庫項目，它提供了MyMVC框架的二個IActionResult接口的實現類，
用于向瀏覽器客戶端輸出DataTable, DataSet
3. SqlServerSmallToolLib：運行網站所需的所有后臺代碼，
包括：Controller，BLL類，等等。
|
MyMVC框架發揮的作用
從前面的項目介紹中，我們可以看到，整個網站沒有一個ASPX文件，只有HTML文件，
所有對服務器的調用全由AJAX來實現，比如：下面的【比較數據庫】的代碼片段：
$.ajax({
cache: false, dataType: "json", type: "GET",
url: '/AjaxService/CompareDB.cspx',
data:{ srcConnId: $("#hfSrcConnId").val(),
destConnId: $("#hfDestConnId").val(),
srcDB: $("#cboSrcDB").combobox("getValue"),
destDB: $("#cboDestDB").combobox("getValue") ,
flag: flag
},
在服務端，我只要實現這樣一個C#方法就可以響應客戶端的請求了：
[Action]
public object CompareDB(string srcConnId, string destConnId, string srcDB, string destDB, string flag)
{
var result = CompareDBHelper.CompareDB(srcConnId, destConnId, srcDB, destDB, flag);
return new JsonResult(result);
}
至于說：JS發起的請求是如何調用到這個C#方法的，以及這個C#方法在調用時的參數和返回值的處理，全由MyMVC框架來實現。
對于開發AJAX來說，可以不用關心這個問題，只要寫出一個C#方法給JS調用就可以了。
引用MyMVC是件很簡單的事情，只需要在web.config中做如下的配置即可：
<httpHandlers>
<add path="*.cspx" verb="*" type="MyMVC.AjaxHandlerFactory, MyMVC" validate="true" />
</httpHandlers>
再補充一點：如果不喜歡看到Action方法包含較多的輸入參數，也可以使用下面的方法：
public class CompareDbOption
{
public string SrcConnId;
public string DestConnId;
public string SrcDb;
public string DestDb;
public string Flag;
}
[Action]
public object CompareDB(CompareDbOption option)
{
var result = CompareDBHelper.CompareDB(option.SrcConnId, option.DestConnId,
option.SrcDb, option.DestDb, option.Flag);
return new JsonResult(result);
}
如果您喜歡在瀏覽器的客戶端中使用jquery以及jquery.form.js插件，
您會發現在服務端再借助MyMVC框架來實現AJAX實在是太方便了。
再來一個添加連接的代碼片段：
Html表單代碼：
<div id="divConnectionDialog" style="padding:10px; width: 420px; height: 320px; display: none;" title="新增/編輯 數據庫連接信息">
<form id="formConnection" method="post" action="/AjaxService/SubmitConnectionInfo.cspx">
<table cellpadding="4" cellspacing="0" style="width: 100%; border: 0px;">
<tr><td>服務器IP/Name</td><td>
<input id="txtServerIP" name="ServerIP" type="text" class="myTextbox" style="width: 220px" />
</td></tr>
<tr><td>登錄方式</td><td>
<select id="cboSSPI" name="SSPI" style="width: 222px" panelWidth="222">
<option value="false">用戶名／密碼</option>
<option value="true">Windows連接</option>
</select>
</td></tr>
<tr><td>登錄名</td><td>
<input id="txtUserName" name="UserName" type="text" class="myTextbox" style="width: 220px" />
</td></tr>
<tr><td>登錄密碼</td><td>
<input id="txtPassword" name="Password" type="text" class="myTextbox" style="width: 220px" />
</td></tr>
<tr><td></td><td>
<input id="hfConnectionId" name="ConnectionId" type="hidden" value="" />
</td></tr>
</table>
<div><span id="spanWait" style="display: none;" class="waitText">請稍后......</span></div>
</form>
</div>
JavaScript提交表單代碼：
function SubmitConnectionForm(){
if( ValidateForm() == false ) return false;
$("#formConnection").ajaxSubmit({
success: function(responseText, statusText) {
if (responseText == "update OK" ){
$('#divConnectionDialog').dialog('close');
// 省略后面的代碼。
服務端C#代碼：
[Action]
public string SubmitConnectionInfo(ConnectionInfo info)
{
if( string.IsNullOrEmpty(info.ServerIP) )
throw new MyMessageException("ServerIP is empty.");
if( info.SSPI == false && string.IsNullOrEmpty(info.UserName) )
throw new MyMessageException("UserName is empty.");
bool isAdd = string.IsNullOrEmpty(info.ConnectionId);
if( isAdd ) {
info.ConnectionId = Guid.NewGuid().ToString();
ConnectionManager.AddConnection(info);
return info.ConnectionId;
}
else {
ConnectionManager.UpdateConnection(info);
return "update OK";
}
}
public sealed class ConnectionInfo
{
public string ConnectionId;
public string ServerIP;
public string UserName;
public string Password;
public bool SSPI;
public int Priority;
}
在整個工具的開發過程中，由于使用了MyMVC框架以及JQuery，AJAX的實現簡直是太容易了。
MyMVC框架的下載地址：http://www.rzrgm.cn/fish-li/archive/2012/02/21/2361982.html
工具主界面
工具啟動后，將能看到下面的主界面：
主界面的左邊的【工具列表】中包含二個獨立的功能模塊。
右邊的上方區域是所有的數據庫連接的列表。
建議在初次使用時，將自己所需要訪問的SQL SERVER連接參數配置好。
這個工具可以管理多個連接，而且會根據連接的使用頻率來排序，以方便操作。
如果需要創建一個連接，可以點擊工具欄中的【新增連接】按鍵，將出現以下對話框。
工具可以支持二種連接方式：1. Windows信任連接，2. 用戶名/密碼連接。
數據庫連接列表的部分網頁代碼：
<div region="center" style="overflow:hidden;" title="數據庫連接列表" iconCls="icon-Relation">
<div class="easyui-layout" fit="true" border="false">
<div region="center">
<table id="tblConnList"></table>
</div>
<div region="south" split="true" style="height:220px; padding: 10px;" title="操作說明" iconCls="icon-help">
<p>1. “新增連接”，“刪除連接”，“設置連接”用于維護連接記錄。</p>
<p>2. “打開連接”將根據選擇的連接，打開 Database 對象瀏覽頁面。</p>
</div>
</div>
</div>
連接采用XML文件來保存，相關的操作代碼：
internal static class ConnectionManager
{
private static List<ConnectionInfo> s_list = null;
private static readonly Encoding DefaultEncoding = System.Text.Encoding.Unicode;
private static readonly string s_savePath = Path.Combine(HttpRuntime.AppDomainAppPath, @"App_Data\Connection.xml");
static ConnectionManager()
{
try {
string appDataPath = Path.Combine(HttpRuntime.AppDomainAppPath, "App_Data");
if( Directory.Exists(appDataPath) == false )
Directory.CreateDirectory(appDataPath);
}
catch { }
}
[MethodImpl(MethodImplOptions.Synchronized)]
public static List<ConnectionInfo> GetList()
{
EnsureListLoaded();
// 調用這個方法應該會比“修改”的次數會少很多，所以決定在這里排序。
return (from c in s_list orderby c.Priority descending select c).ToList();
}
[MethodImpl(MethodImplOptions.Synchronized)]
public static void AddConnection(ConnectionInfo info)
{
EnsureListLoaded();
s_list.Add(info);
SaveListToFile();
}
[MethodImpl(MethodImplOptions.Synchronized)]
public static void RemoveConnection(string ConnectionId)
{
EnsureListLoaded();
int index = -1;
for( int i = 0; i < s_list.Count; i++ )
if( s_list[i].ConnectionId == ConnectionId ) {
index = i;
break;
}
if( index >= 0 ) {
s_list.RemoveAt(index);
SaveListToFile();
}
}
[MethodImpl(MethodImplOptions.Synchronized)]
public static void UpdateConnection(ConnectionInfo info)
{
EnsureListLoaded();
ConnectionInfo exist = s_list.FirstOrDefault(x => x.ConnectionId == info.ConnectionId);
if( exist != null ) {
exist.ServerIP = info.ServerIP;
exist.UserName = info.UserName;
exist.Password = info.Password;
exist.SSPI = info.SSPI;
// 注意：其它沒列出的成員，表示不需要在此更新。
SaveListToFile();
}
}
[MethodImpl(MethodImplOptions.Synchronized)]
public static ConnectionInfo GetConnectionInfoById(string connectionId, bool increasePriority)
{
if( string.IsNullOrEmpty(connectionId) )
throw new ArgumentNullException("connectionId");
EnsureListLoaded();
ConnectionInfo exist = s_list.FirstOrDefault(x => x.ConnectionId == connectionId);
if( exist == null )
throw new MyMessageException("connectionId is invalid.");
if( increasePriority ) {
exist.Priority++;
SaveListToFile();
}
return exist;
}
private static void EnsureListLoaded()
{
if( s_list == null ) {
try {
s_list = XmlHelper.XmlDeserializeFromFile<List<ConnectionInfo>>(s_savePath, DefaultEncoding);
}
catch {
s_list = new List<ConnectionInfo>();
}
}
}
private static void SaveListToFile()
{
if( s_list == null || s_list.Count == 0 ) {
try {
File.Delete(s_savePath);
}
catch { }
}
else {
XmlHelper.XmlSerializeToFile(s_list, s_savePath, DefaultEncoding);
}
}
}
服務端的Action實現代碼：
[Action]
public object GetAllConnectionInfo()
{
List<ConnectionInfo> list = ConnectionManager.GetList();
ConnectionInfoDataGridJsonResult result = new ConnectionInfoDataGridJsonResult();
result.total = list.Count;
result.rows = list;
return new JsonResult(result);
}
[Action]
public string SubmitConnectionInfo(ConnectionInfo info)
{
if( string.IsNullOrEmpty(info.ServerIP) )
throw new MyMessageException("ServerIP is empty.");
if( info.SSPI == false && string.IsNullOrEmpty(info.UserName) )
throw new MyMessageException("UserName is empty.");
bool isAdd = string.IsNullOrEmpty(info.ConnectionId);
if( isAdd ) {
info.ConnectionId = Guid.NewGuid().ToString();
ConnectionManager.AddConnection(info);
return info.ConnectionId;
}
else {
ConnectionManager.UpdateConnection(info);
return "update OK";
}
}
[Action]
public void DeleteConnection(string connectionId)
{
if( string.IsNullOrEmpty(connectionId) )
throw new MyMessageException("connectionId is empty.");
ConnectionManager.RemoveConnection(connectionId);
}
[Action]
public string TestConnection(ConnectionInfo info)
{
BaseBLL instance = BaseBLL.GetInstance(null);
return instance.TestConnection(info);
}
Database 瀏覽器
在主界面的【數據庫連接列表】中，選擇一個連接，然后點擊工具欄上的【打開連接】按鍵，即可進入【Database 瀏覽器】界面。
在這個工具中，如果需要查看某個數據庫對象的定義，只需要點擊相應的對象節點就可以了：
為了操作方便，工具提供多標簽查看功能：
獲取數據庫對象列表的關鍵代碼：
private static readonly string s_QueryDatabaseListScript =
"SELECT dtb.name AS [Database_Name] FROM master.sys.databases AS dtb " +
"WHERE (CAST(case when dtb.name in ('master','model','msdb','tempdb') then 1 else dtb.is_distributor end AS bit)=0 " +
" and CAST(isnull(dtb.source_database_id, 0) AS bit)=0) " +
"ORDER BY [Database_Name] ASC";
protected override List<string> GetDatabaseNames(DbConnection connection)
{
return ExecuteQueryToStringList(connection, s_QueryDatabaseListScript);
}
private static readonly string s_GetObjectNamesFormat =
"select name from ( SELECT obj.name AS [Name], " +
"CAST( case when obj.is_ms_shipped = 1 then 1 " +
" when ( select major_id from sys.extended_properties " +
" where major_id = obj.object_id and minor_id = 0 and class = 1 and name = N'microsoft_database_tools_support') " +
" is not null then 1 else 0 " +
"end AS bit) AS [IsSystemObject] " +
"FROM sys.all_objects AS obj where obj.type in ({0}) )as tables where [IsSystemObject] = 0 ORDER BY [Name] ASC ";
private static readonly string s_ProcedureType = " N'P', N'PC' ";
private static readonly string s_FunctionType = " N'FN', N'IF', N'TF', N'FS', N'FT' ";
private static readonly string s_TableType = " N'U' ";
private static readonly string s_ViewType = " N'V' ";
protected override List<string> GetDbProcedureNames(DbConnection connection)
{
//string sql = "select name from sys.objects where type='P' order by name";
string sql = string.Format(s_GetObjectNamesFormat, s_ProcedureType);
return ExecuteQueryToStringList(connection, sql);
}
protected override List<string> GetDbFunctionNames(DbConnection connection)
{
//string sql = "select name from sys.objects where type='FN' order by name";
string sql = string.Format(s_GetObjectNamesFormat, s_FunctionType);
return ExecuteQueryToStringList(connection, sql);
}
protected override List<string> GetDbTableNames(DbConnection connection)
{
//string sql = "select name from sys.objects where type='U' where name != 'sysdiagrams' order by name";
string sql = string.Format(s_GetObjectNamesFormat, s_TableType);
return ExecuteQueryToStringList(connection, sql);
}
protected override List<string> GetDbViewNames(DbConnection connection)
{
//string sql = "select name from sys.objects where type='V' order by name";
string sql = string.Format(s_GetObjectNamesFormat, s_ViewType);
return ExecuteQueryToStringList(connection, sql);
}
查看數據庫對象的定義腳本的實現代碼：
protected override ItemCode GetProcedureItem(DbConnection connection, string name)
{
string query = string.Format("SELECT definition FROM sys.sql_modules JOIN sys.objects ON sys.sql_modules.object_id = sys.objects.object_id AND type in ({1}) and name = '{0}'", name, s_ProcedureType);
string script = TryExecuteQuery(connection, query);
return new ItemCode(name, ItemType.Procedure, script);
}
protected override ItemCode GetFunctionItem(DbConnection connection, string name)
{
string query = string.Format("SELECT definition FROM sys.sql_modules JOIN sys.objects ON sys.sql_modules.object_id = sys.objects.object_id AND type in ({1}) and name = '{0}'", name, s_FunctionType);
string script = TryExecuteQuery(connection, query);
return new ItemCode(name, ItemType.Function, script);
}
protected override ItemCode GetViewItem(DbConnection connection, string name)
{
string query = string.Format("SELECT definition FROM sys.sql_modules JOIN sys.objects ON sys.sql_modules.object_id = sys.objects.object_id AND type in ({1}) and name = '{0}'", name, s_ViewType);
string script = TryExecuteQuery(connection, query);
return new ItemCode(name, ItemType.View, script);
}
protected override ItemCode GetTableItem(DbConnection connection, string name)
{
string script = null;
try {
script = SmoHelper.ScriptTable(connection, null, name);
if( string.IsNullOrEmpty(script) )
script = s_CannotGetScript;
}
catch( Exception ex ) {
script = ex.Message;
}
return new ItemCode(name, ItemType.Table, script);
}
搜索數據庫
您可以在上圖所示界面的左邊樹控件中，選擇一個節點，右擊，然后選擇“在數據庫中搜索”，此時會出現如下對話框：
在上圖的對話框中，點擊確定按鍵后，可出現下面的查找結果：
說明：匹配行就會高亮顯示。
搜索數據庫對象的相關代碼：
[Action]
public object SearchDB(string connectionId, string dbName, string searchWord,
int wholeMatch, int caseSensitive, string searchScope, string limitCount)
{
if( string.IsNullOrEmpty(searchWord) )
throw new ArgumentNullException("searchWord");
BaseBLL instance = BaseBLL.GetInstance(connectionId);
DbOjbectType types = CompareDBHelper.GetDbOjbectTypeByFlag(searchScope);
List<ItemCode> list = instance.GetDbAllObjectScript(instance.ConnectionInfo, dbName, types);
List<SearchResultItem> result = new List<SearchResultItem>(list.Count);
int limitResultCount = 0;
int.TryParse(limitCount, out limitResultCount);
FishWebLib.StringSearcher searcher =
FishWebLib.StringSearcher.GetStringSearcher(searchWord, (wholeMatch == 1), (caseSensitive == 1));
foreach( ItemCode code in list ) {
if( limitResultCount != 0 && result.Count >= limitResultCount )
break;
if( code.SqlScript.IndexOf(searchWord, StringComparison.OrdinalIgnoreCase) >= 0 ) {
string[] lines = instance.SplitCodeToLineArray(code.SqlScript);
for( int i = 0; i < lines.Length; i++ )
if( searcher.IsMatch(lines[i]) ) {
SearchResultItem item = new SearchResultItem();
item.LineNumber = i + 1;
item.ObjectName = code.Name;
item.ObjectType = code.Type.ToString();
item.SqlScript = code.SqlScript;
result.Add(item);
break;
}
}
}
return new JsonResult(result);
}
public List<ItemCode> GetDbAllObjectScript(ConnectionInfo info, string dbName, DbOjbectType type)
{
List<ItemCode> list = new List<ItemCode>();
string connectionString = GetDbConnectionString(info, dbName);
using( DbConnection connection = CreateConnection(connectionString) ) {
connection.Open();
if( (type & DbOjbectType.Table) == DbOjbectType.Table ) {
List<string> nameList = GetDbTableNames(connection);
foreach( string name in nameList )
list.Add(GetTableItem(connection, name));
}
if( (type & DbOjbectType.Procedure) == DbOjbectType.Procedure ) {
List<string> nameList = GetDbProcedureNames(connection);
foreach( string name in nameList )
list.Add(GetProcedureItem(connection, name));
}
if( (type & DbOjbectType.Function) == DbOjbectType.Function ) {
List<string> nameList = GetDbFunctionNames(connection);
foreach( string name in nameList )
list.Add(GetFunctionItem(connection, name));
}
if( (type & DbOjbectType.View) == DbOjbectType.View ) {
List<string> nameList = GetDbViewNames(connection);
foreach( string name in nameList )
list.Add(GetViewItem(connection, name));
}
}
return list;
}
復制存儲過程工具
為了演示這個功能，先需要創建一個數據庫。我創建了一個數據庫：TestMyTool，它沒有任何數據庫對象，如下圖
然后，從主界面中啟動【復制存儲過程工具】，
接著選擇：數據庫連接，數據庫對象，
點擊【刷新列表】按鍵，將看到以下結果：
我們可以選擇要復制的（存儲過程，視圖，自定義函數）對象：
最后點擊【開始復制】按鍵，即可完成復制過程。
此時數據庫TestMyTool的顯示結果為：
此功能的核心部分實現代碼：
[Action]
public string CopyProcedures(string srcConnId, string destConnId, string srcDB, string destDB,
string spNames, string viewNames, string funcNames)
{
BaseBLL instance1 = BaseBLL.GetInstance(srcConnId);
BaseBLL instance2 = BaseBLL.GetInstance(destConnId);
if( instance1.GetType() != instance2.GetType() )
throw new Exception("數據庫的種類不一致，不能執行復制操作。");
if( srcConnId == destConnId && srcDB == destDB )
throw new Exception("無效的操作。");
List<ItemCode> procedures = instance1.GetDbAllObjectScript(instance1.ConnectionInfo, srcDB, spNames, viewNames, funcNames);
return instance2.UpdateProcedures(instance2.ConnectionInfo, destDB, procedures);
}
public List<ItemCode> GetDbAllObjectScript(ConnectionInfo info,
string dbName, string spNames, string viewNames, string funcNames)
{
List<ItemCode> list = new List<ItemCode>();
string connectionString = GetDbConnectionString(info, dbName);
using( DbConnection connection = CreateConnection(connectionString) ) {
connection.Open();
if( string.IsNullOrEmpty(spNames) == false ) {
foreach( string name in spNames.Split(new char[] { ';' }, StringSplitOptions.RemoveEmptyEntries) )
list.Add(GetProcedureItem(connection, name));
}
if( string.IsNullOrEmpty(funcNames) == false ) {
foreach( string name in funcNames.Split(new char[] { ';' }, StringSplitOptions.RemoveEmptyEntries) )
list.Add(GetFunctionItem(connection, name));
}
if( string.IsNullOrEmpty(viewNames) == false ) {
foreach( string name in viewNames.Split(new char[] { ';' }, StringSplitOptions.RemoveEmptyEntries) )
list.Add(GetViewItem(connection, name));
}
}
return list;
}
public override string UpdateProcedures(ConnectionInfo info, string dbName, List<ItemCode> list)
{
string connectionString = GetDbConnectionString(info, dbName);
using( DbConnection connection = CreateConnection(connectionString) ) {
connection.Open();
DbCommand command = connection.CreateCommand();
foreach(ItemCode item in list) {
command.CommandText = GetDeleteObjectScript(item.Name, item.Type);
command.ExecuteNonQuery();
command.CommandText = string.Format(s_CreateObjectFormat, item.SqlScript.Replace("'", "''"));
command.ExecuteNonQuery();
}
}
return string.Format("操作成功，共復制了 {0} 個對象。", list.Count);
}
數據庫比較工具
為了方便后面的介紹，我將復制全部的存儲過程到TestMyTool，這個過程將省略貼圖。
不僅如此，我還對其中的一個存儲過程做了一點修改。
然后，在程序主界面中，啟動【數據庫比較工具】，
接著選擇：數據庫連接，數據庫對象，
點擊【開始比較數據庫】按鈕后，將能看到以下比較結果。
每個數據庫對象的定義中，第一個不匹配的行將以高亮行顯示。
為了能讓您知道不匹配行的出現位置，工具還會顯示不匹配行的前后5行代碼。
此功能的核心部分實現代碼：
internal static class CompareDBHelper
{
public sealed class ThreadParam
{
public BaseBLL Instance;
public string DbName;
public DbOjbectType DbOjbectType;
public List<ItemCode> Result;
public Exception Exception;
public ThreadParam(BaseBLL instance, string dbName, DbOjbectType type)
{
this.Instance = instance;
this.DbName = dbName;
this.DbOjbectType = type;
this.Result = new List<ItemCode>();
}
}
private static void ThreadWorkAction(object obj)
{
ThreadParam param = (ThreadParam)obj;
try {
param.Result = param.Instance.GetDbAllObjectScript(param.Instance.ConnectionInfo, param.DbName, param.DbOjbectType);
}
catch( Exception ex ) {
param.Exception = ex;
}
}
public static DbOjbectType GetDbOjbectTypeByFlag(string flag)
{
if( string.IsNullOrEmpty(flag) )
return DbOjbectType.None;
DbOjbectType types = DbOjbectType.None;
if( flag.IndexOf('T') >= 0 )
types |= DbOjbectType.Table;
if( flag.IndexOf('V') >= 0 )
types |= DbOjbectType.View;
if( flag.IndexOf('P') >= 0 )
types |= DbOjbectType.Procedure;
if( flag.IndexOf('F') >= 0 )
types |= DbOjbectType.Function;
return types;
}
public static List<CompareResultItem> CompareDB(string srcConnId, string destConnId, string srcDB, string destDB, string flag)
{
BaseBLL instance1 = BaseBLL.GetInstance(srcConnId);
BaseBLL instance2 = BaseBLL.GetInstance(destConnId);
if( instance1.GetType() != instance2.GetType() )
throw new Exception("數據庫的種類不一致，比較沒有意義。");
DbOjbectType types = GetDbOjbectTypeByFlag(flag);
ThreadParam param1 = new ThreadParam(instance1, srcDB, types);
ThreadParam param2 = new ThreadParam(instance2, destDB, types);
Thread thread1 = new Thread(ThreadWorkAction);
Thread thread2 = new Thread(ThreadWorkAction);
thread1.Start(param1);
thread2.Start(param2);
thread1.Join();
thread2.Join();
if( param1.Exception != null )
throw param1.Exception;
if( param2.Exception != null )
throw param2.Exception;
List<ItemCode> list1 = param1.Result;
List<ItemCode> list2 = param2.Result;
List<CompareResultItem> result = new List<CompareResultItem>();
ItemCode dest = null;
// 按數據庫對象類別分次比較。
for( int typeIndex = 0; typeIndex < 4; typeIndex++ ) {
ItemType currentType = (ItemType)typeIndex;
foreach( ItemCode item1 in list1 ) {
// 如果不是當前要比較的對象類別，則跳過。
if( item1.Type != currentType )
continue;
dest = null;
foreach( ItemCode item2 in list2 ) {
if( item1.Type == item2.Type && string.Compare(item1.Name, item2.Name, true) == 0 ) {
dest = item2;
break;
}
}
if( dest == null ) {
CompareResultItem cri = new CompareResultItem();
cri.ObjectType = item1.TypeText;
cri.ObjectName = item1.Name;
cri.LineNumber = -1;
cri.SrcLine = string.Empty;
cri.DestLine = string.Empty;
cri.Reason = "源數據庫中存在，而目標數據庫中不存在。";
result.Add(cri);
continue;
}
else {
if( item1.SqlScript == dest.SqlScript )
continue;
// 開始比較代碼了。
CompareResultItem cri = null;
string[] lines1 = instance1.SplitCodeToLineArray(item1.SqlScript);
string[] lines2 = instance1.SplitCodeToLineArray(dest.SqlScript);
for( int i = 0; i < lines1.Length; i++ ) {
if( i >= lines2.Length ) {
// 目標對象的代碼行數比較少
cri = new CompareResultItem();
cri.ObjectType = item1.TypeText;
cri.ObjectName = item1.Name;
cri.LineNumber = i + 1;
GetNearLines(lines1, lines2, i, cri);
cri.Reason = "目標對象中已沒有對應行數的代碼。";
result.Add(cri);
break;
}
string s1 = lines1[i].Trim();
string s2 = lines2[i].Trim();
if( string.Compare(s1, s2, true) != 0 ) {
cri = new CompareResultItem();
cri.ObjectType = item1.TypeText;
cri.ObjectName = item1.Name;
cri.LineNumber = i + 1;
GetNearLines(lines1, lines2, i, cri);
cri.Reason = "代碼不一致。";
result.Add(cri);
break;
}
}
if( cri != null )
continue; // 比較下一個對象
if( lines2.Length > lines1.Length ) {
// 目標對象的代碼行數比較少
cri = new CompareResultItem();
cri.ObjectType = item1.TypeText;
cri.ObjectName = item1.Name;
cri.LineNumber = lines1.Length + 1;
GetNearLines(lines1, lines2, lines1.Length, cri);
cri.Reason = "源對象中已沒有對應行數的代碼。";
result.Add(cri);
break;
}
}
}
foreach( ItemCode item2 in list2 ) {
// 如果不是當前要比較的對象類別，則跳過。
if( item2.Type != currentType )
continue;
dest = null;
foreach( ItemCode item1 in list1 ) {
if( item1.Type == item2.Type && string.Compare(item1.Name, item2.Name, true) == 0 ) {
dest = item2;
break;
}
}
if( dest == null ) {
CompareResultItem cri = new CompareResultItem();
cri.ObjectType = item2.TypeText;
cri.ObjectName = item2.Name;
cri.LineNumber = -2;
cri.SrcLine = string.Empty;
cri.DestLine = string.Empty;
cri.Reason = "目標數據庫中存在，而源數據庫中不存在。";
result.Add(cri);
continue;
}
}
}
return result;
}
private static void GetNearLines(string[] lines1, string[] lines2, int index, CompareResultItem cri)
{
int firstLine;
cri.SrcLine = GetOneNearLines(lines1, index, out firstLine);
cri.SrcFirstLine = firstLine;
cri.DestLine = GetOneNearLines(lines2, index, out firstLine);
cri.DestFirstLine = firstLine;
}
private static string GetOneNearLines(string[] lines, int index, out int firstLine)
{
firstLine = -1;
System.Text.StringBuilder sb = new System.Text.StringBuilder();
int start = index - 5;
for( int i = 0; i < 11; i++ )
if( start + i >= 0 && start + i < lines.Length ) {
if( firstLine < 0 )
firstLine = start + i + 1;
sb.AppendLine(lines[start + i]);
}
return sb.ToString();
}
}
查看表結構定義
工具可以讓您輕松地查看一個表結構的定義：
也可以一次查看多個表的定義：
還可一下子得到整個數據庫的所有對象的創建腳本：
此功能的核心部分實現代碼：
public class AjaxDataTable
{
[Action]
public object TableDescribe(string connectionId, string dbName, string tableName)
{
if( string.IsNullOrEmpty(connectionId) || string.IsNullOrEmpty(dbName) || string.IsNullOrEmpty(tableName) )
throw new ArgumentException("connString or tableName is null.");
BaseBLL instance = BaseBLL.GetInstance(connectionId);
DataTable table = instance.GetTableFields(instance.ConnectionInfo, dbName, tableName);
return new MyMvcEx.DataTableResult(table);
}
[Action]
public object MultiTableDescribe(string connectionId, string dbName, string tableNames)
{
if( string.IsNullOrEmpty(connectionId) || string.IsNullOrEmpty(dbName) || string.IsNullOrEmpty(tableNames) )
throw new ArgumentException("connString or tableName is null.");
BaseBLL instance = BaseBLL.GetInstance(connectionId);
DataSet ds = instance.GetTables(instance.ConnectionInfo, dbName, tableNames);
return new MyMvcEx.DataSetResult(ds);
}
}
修改運行環境
到目前為止，這個工具還只能在Visual Studio中運行，顯然它與我們經常見到的【工具】有較大的差別。
如果您希望可以方便地運行這個工具，那么可以安裝我的另一個小工具來快速地啟動當前這個工具，
那個工具的下載地址：【ASP.NET程序也能像WinForm程序一樣運行】
然后，就可以在Windows資源管理器中啟動這個小工具：
現在是不是很像一個桌面程序了？
您甚至也可以創建一個開始菜單項，或者一個快捷方式來啟動這個小工具，
具體方法可參考博客：【ASP.NET程序也能像WinForm程序一樣運行】
關于此工具的補充說明
這個小工具只實現了一些簡單的功能，而且主要集中在查看數據庫的定義這塊。
這個工具的早期版本中，有些人提到了要求實現查看數據表的功能。
在今天的版本中，我并沒有實現，但我提供了實現這個功能所必要的一些基礎代碼。
例如，我提供了二個ActionResult （注意：前面小節的Action代碼中，就使用了下面的二個實現類）：
public class DataTableResult : IActionResult
{
private DataTable _table;
public DataTableResult(DataTable table)
{
if( table == null )
throw new ArgumentNullException("table");
_table = table;
}
void IActionResult.Ouput(HttpContext context)
{
context.Response.ContentType = "text/html";
string html = DataTableHelper.TableToHtml(_table);
context.Response.Write(html);
}
}
public class DataSetResult : IActionResult
{
private DataSet _ds;
public DataSetResult(DataSet ds)
{
if( ds == null )
throw new ArgumentNullException("ds");
_ds = ds;
}
void IActionResult.Ouput(HttpContext context)
{
List<DataSetJsonItem> list = new List<DataSetJsonItem>();
for( int i = 0; i < _ds.Tables.Count; i++ ) {
DataTable table = _ds.Tables[i];
string html = DataTableHelper.TableToHtml(table);
list.Add(new DataSetJsonItem { TableName = table.TableName, Html = html });
}
JsonResult json = new JsonResult(list);
(json as IActionResult).Ouput(context);
}
public class DataSetJsonItem
{
public string TableName;
public string Html;
}
}
public static class DataTableHelper
{
public static string TableToHtml(DataTable table)
{
if( table == null )
throw new ArgumentNullException("table");
StringBuilder html = new StringBuilder();
html.AppendLine("<table cellpadding=\"2\" cellspacing=\"1\" class=\"myGridVew\"><thead><tr>");
for( int i = 0; i < table.Columns.Count; i++ )
html.AppendFormat("<th>{0}</th>", HttpUtility.HtmlEncode(table.Columns[i].ColumnName));
html.AppendLine("</tr></thead><tbody>");
object cell = null;
for( int j = 0; j < table.Rows.Count; j++ ) {
html.AppendLine("<tr>");
for( int i = 0; i < table.Columns.Count; i++ ) {
cell = table.Rows[j][i];
if( cell == null || DBNull.Value.Equals(cell) )
html.Append("<td></td>");
else
html.AppendFormat("<td>{0}</td>", HttpUtility.HtmlEncode(cell.ToString()));
}
html.AppendLine("</tr>");
}
html.AppendLine("</tbody></table>");
return html.ToString();
}
}
為了方便地在客戶端將表格顯示地漂亮些，我還提供了一個JS函數：
function SetGridViewColor(){
$("table.myGridVew").each(function(){
$(this).removeClass("myGridVew").addClass("GridView")
.find(">thead>tr").addClass("GridView_HeaderStyle").end()
.find(">tbody>tr")
.filter(':odd').addClass("GridView_AlternatingRowStyle").end()
.filter(':even').addClass("GridView_RowStyle");
});
}
如果您認為很有必要在這個工具中集成數據表的查看（或者查詢數據）的功能，那么可以自行實現（工具是開源的）。
友情提示：使用上面的代碼以及MyMVC框架，實現一個簡單的查看數據是會比較容易的。
今天就寫到這里，希望大家能喜歡這個小工具，以及 MyMVC框架。
點擊此處下載全部代碼
如果，您認為閱讀這篇博客讓您有些收獲，不妨點擊一下右下角的【推薦】按鈕。
如果，您希望更容易地發現我的新博客，不妨點擊一下右下角的【關注 Fish Li】。
因為，我的寫作熱情也離不開您的肯定支持。
感謝您的閱讀，如果您對我的博客所講述的內容有興趣，請繼續關注我的后續博客，我是Fish Li 。
Fish Li （李奇峰）
浙公網安備 33010602011771號