我的简易SQL查询分析器

原来一直搞ASP.NET，现在工作又主要搞WinFrom，真的很不习惯，一个控件那么多事件和属性，做什么都要不停地查MSDN

今天工作没事情做，为了能熟悉一下Winform里的控件，自己就做点小小东西来熟悉一下。

鄙人不才，不是很会写博客，今天深圳下好大的雨，都淋湿了，一回来就想和大家分享一下自己的成果，知识来自于网路，服务于网络，大家不要喷，谢谢！

先是一个简单的输入服务和帐号信息的登录窗体，其实可以把服务换成CommBox控件绑定本地电脑的SQL服务，鄙人不才，没有弄出来，如果你知道怎么搞，给点意见：

登录示例图如下：

如果数据量大，获取每个数据库中表以及字段信息，会有点慢，所以TreeView每点击一个节点就加载一个节点下的内容，但是没加载的节点前不是+号，感觉不知道怎么解决，纠结……

所有的数据库、表以及字段可以拖拉到TextBox空间中，本来想用RichTextBox的，因为可以变色，但是好像没有TextBox支持拖拉的事件以及属性，可能还有其他的办法吧，知道的也可以告诉一下我，查询效果图如下所示：

主要代码如下：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using System.Data.SqlClient;

namespace DBManager
{
public abstract class SQLHelper
 {
/// <summary>
/// Get SqlDataReader object
/// </summary>
/// <param name="strSql"></param>
/// <param name="dataBaseName"></param>
/// <returns></returns>
public static SqlDataReader ExecuteReader(string connectionString,string strSql,string dataBaseName)
 {
try
 {
SqlConnection conn = new SqlConnection(string.Format(connectionString, dataBaseName));
 conn.Open();
SqlCommand cmd = new SqlCommand(strSql, conn);
return cmd.ExecuteReader(CommandBehavior.CloseConnection);
 }
catch (Exception ex)
 {
throw new Exception(ex.Message);
 }
 }

/// <summary>
/// Get DataTable
/// </summary>
/// <param name="strSql"></param>
/// <param name="dataBaseName"></param>
/// <returns></returns>
public static DataTable GetDataTable(string connectionString, string strSql, string dataBaseName)
 {
using (SqlConnection conn = new SqlConnection(string.Format(connectionString, dataBaseName)))
 {
 conn.Open();
SqlDataAdapter sda = new SqlDataAdapter(strSql, conn);
DataSet ds = new DataSet();
sda.Fill(ds,"table");
return ds.Tables["table"];
 }
 }

/// <summary>
/// Check SQL
/// </summary>
/// <param name="strSql"></param>
/// <param name="dataBaseName"></param>
/// <param name="?"></param>
/// <returns></returns>
public static bool CheckSQL(string connectionString, string strSql, string dataBaseName, out string errorMsg)
 {
bool bReturn = true;
SqlConnection conn = new SqlConnection(string.Format(connectionString, dataBaseName));
 conn.Open();
try
 {
SqlCommand cmd = new SqlCommand(strSql, conn);
 cmd.ExecuteNonQuery();
errorMsg = string.Empty;
 }
catch (Exception ex)
 {
bReturn = false;
errorMsg = ex.Message;
 }
return bReturn;
 }

/// <summary>
/// Check Connection
/// </summary>
/// <param name="connectionSql"></param>
/// <param name="errorMsg"></param>
/// <returns></returns>
public static bool CheckConnection(string connectionString,out string errorMsg)
 {
bool bReturn = true;
try
 {
SqlConnection conn = new SqlConnection(connectionString);
 conn.Open();
errorMsg = string.Empty;
 conn.Close();
return bReturn;
 }
catch (Exception ex)
 {
bReturn = false;
errorMsg = ex.Message;
return bReturn;
 }
 }
 }
}

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Xml;
using System.IO;

namespace DBManager
{
public partial class initFrom : Form
 {
public mainFrom mf;
public initFrom()
 {
 InitializeComponent();
 }

/// <summary>
/// 创建xml
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void btnOK_Click(object sender, EventArgs e)
 {
if (this.CheckInput())
 {
string connectionString = "Data Source={0}; Database={1};UID={2};PWD={3};";
string errorMsg = string.Empty;
if (SQLHelper.CheckConnection(string.Format(connectionString,this.txtDataSource.Text.Trim(),
"master",
this.txtUserID.Text.Trim(),
this.txtPassword.Text.Trim()), out errorMsg))
 {
this.mf = new mainFrom(this.txtDataSource.Text.Trim(), this.txtUserID.Text.Trim(), this.txtPassword.Text.Trim());
 mf.Show();
this.Hide();
 }
else
 {
 MessageBox.Show(errorMsg);
 }
 }
else
 {
MessageBox.Show("Please input TextBox!");
 }
 }

private bool CheckInput()
 {
foreach (Control control in this.Controls)
 {
if (control is TextBox)
 {
TextBox txtBox = control as TextBox;
if (string.IsNullOrEmpty(txtBox.Text.Trim()))
return false;
 }
 }
return true;
 }
 }
}

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Data.SqlClient;

namespace DBManager
{
public partial class mainFrom : Form
 {
private string connectionString = string.Empty;
private string dataSource = string.Empty;
private string userID = string.Empty;
public mainFrom()
 {
 InitializeComponent();
this.splitContainer1.Panel1.SizeChanged += new System.EventHandler(this.splitContainer1_Panel1_SizeChanged);
this.toolStripStatusLabel1.Text = string.Format("系统当前时间：{0}", DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss"));
this.timer1.Interval = 1000;
this.timer1.Start();
this.connectionString = "Data Source=XU_HAPPY_YOU-PC; Database={0};UID=sa;PWD=616888521;";
this.dataSource = "XU_HAPPY_YOU-PC";
this.userID = "sa";
 }

public mainFrom(string dataSource, string userID, string password)
 {
 InitializeComponent();
this.splitContainer1.Panel1.SizeChanged += new System.EventHandler(this.splitContainer1_Panel1_SizeChanged);
this.toolStripStatusLabel1.Text = string.Format("系统当前时间：{0}", DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss"));
this.timer1.Interval = 1000;
this.timer1.Start();
this.connectionString = string.Format("Data Source={0}; Database={1};UID={2};PWD={3};", dataSource, "{0}", userID, password);
this.dataSource = dataSource;
this.userID = userID;
 }

private void mainFrom_Load(object sender, EventArgs e)
 {
this.InitTreeView();
 }

private void InitTreeView()
 {
IList<string> listDataBaseName = this.GetDataBaseNameList();
this.treeViewDataBase.ImageList = this.GetImageList();
this.treeViewDataBase.Nodes.Add("root", string.Format("{0}(DataBaseManager {1}))", this.dataSource, this.userID), "server");
this.treeViewDataBase.Nodes[0].Nodes.Add("database", "DataBases", "directory", "directory");
foreach (string dataBaseName in listDataBaseName)
 {
this.treeViewDataBase.Nodes[0].Nodes[0].Nodes.Add(dataBaseName, dataBaseName, "database", "database");
 }
 }

/// <summary>
/// get image list
/// </summary>
/// <returns></returns>
private ImageList GetImageList()
 {
ImageList myImageList = new ImageList();
myImageList.Images.Add("server", global::DBManager.Properties.Resources.server);
myImageList.Images.Add("directory", global::DBManager.Properties.Resources.directory);
myImageList.Images.Add("database", global::DBManager.Properties.Resources.database);
myImageList.Images.Add("table", global::DBManager.Properties.Resources.table);
myImageList.Images.Add("column", global::DBManager.Properties.Resources.column);
return myImageList;
 }

/// <summary>
/// get database name list
/// </summary>
/// <returns></returns>
private IList<string> GetDataBaseNameList()
 {
IList<string> list = new List<string>();
string strSql = "SELECT name FROM master..sysdatabases WHERE name NOT IN('master','model','msdb','tempdb','northwind','pubs')";
SqlDataReader sdr = SQLHelper.ExecuteReader(this.connectionString,strSql, "master");
while (sdr.Read())
 {
list.Add(sdr[0].ToString());
 }
 sdr.Close();
return list;
 }

/// <summary>
/// get database table name
/// </summary>
/// <param name="dataBaseName"></param>
/// <returns></returns>
private IList<string> GetDataBaseTableNameList(string dataBaseName)
 {
IList<string> list = new List<string>();
string strSql = "SELECT name FROM sysobjects WHERE xtype='U' AND name NOT IN('sysdiagrams') AND status>=0 ORDER BY name";
SqlDataReader sdr = SQLHelper.ExecuteReader(this.connectionString,strSql, dataBaseName);
while (sdr.Read())
 {
list.Add(sdr[0].ToString());
 }
 sdr.Close();
return list;
 }

/// <summary>
/// get field info
/// </summary>
/// <param name="tableName"></param>
/// <param name="dataBaseName"></param>
/// <returns></returns>
private DataTable GetFieldInfoDataTable(string tableName, string dataBaseName)
 {
StringBuilder strSql = new StringBuilder("SELECT sc.name fieldName,");
strSql.Append("st.name typeName,st.length length ");
strSql.Append("FROM syscolumns sc LEFT JOIN systypes st ");
strSql.Append("ON sc.xtype=st.xtype ");
strSql.Append("WHERE st.name NOT IN('sysname') ");
strSql.AppendFormat("AND sc.id=object_id('{0}')", tableName);
return SQLHelper.GetDataTable(this.connectionString,strSql.ToString(), dataBaseName);
 }

private IList<string> GetFieldInfoList(string tableName, string dataBaseName)
 {
IList<string> list = new List<string>();
DataTable dt = this.GetFieldInfoDataTable(tableName, dataBaseName);
for (int i = 0; i < dt.Rows.Count; i++)
 {
list.Add(string.Format("{0}({1}({2}))", dt.Rows[i]["fieldName"].ToString(), dt.Rows[i]["typeName"].ToString(), dt.Rows[i]["length"].ToString()));
 }
return list;
 }

/// <summary>
/// node click
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void treeViewDataBase_NodeMouseClick(object sender, TreeNodeMouseClickEventArgs e)
 {
if (e.Node.Level == 2)
 {
IList<string> list = this.GetDataBaseTableNameList(e.Node.Text);
this.treeViewDataBase.Nodes[0].Nodes[0].Nodes[e.Node.Index].Nodes.Clear();
foreach (string tableName in list)
 {
this.treeViewDataBase.Nodes[0].Nodes[0].Nodes[e.Node.Index].Nodes.Add(tableName, tableName, "table", "table");
 }
 }
else if (e.Node.Level == 3)
 {
IList<string> list = this.GetFieldInfoList(e.Node.Text, e.Node.Parent.Text);
this.treeViewDataBase.Nodes[0].Nodes[0].Nodes[e.Node.Parent.Index].Nodes[e.Node.Index].Nodes.Clear();
foreach (string fieldInfo in list)
 {
this.treeViewDataBase.Nodes[0].Nodes[0].Nodes[e.Node.Parent.Index].Nodes[e.Node.Index].Nodes.Add(fieldInfo, fieldInfo, "column", "column");
 }
 }
 }

private void splitContainer1_Panel1_SizeChanged(object sender, EventArgs e)
 {
this.treeViewDataBase.Width = this.splitContainer1.Panel1.Width;
 }

private void timer1_Tick(object sender, EventArgs e)
 {
this.toolStripStatusLabel1.Text = string.Format("系统当前时间：{0}", DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss"));
 }

/// <summary>
/// execute
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void toolStripButton1_Click(object sender, EventArgs e)
 {
string dataBaseName = this.GetDataBaseName(this._selectednode);
string strSql = this.txtSql.Text.Trim();
if (string.IsNullOrEmpty(strSql))
 {
MessageBox.Show("Please input SQL!");
 }
else
 {
string errorMsg=string.Empty;
if (SQLHelper.CheckSQL(this.connectionString,strSql, dataBaseName, out errorMsg))
 {
try
 {
DataTable dt = SQLHelper.GetDataTable(this.connectionString,strSql, dataBaseName);
this.dataGVSQL.DataSource = dt;
this.toolStripStatusLabel2.Visible = true;
this.toolStripStatusLabel2.Image = global::DBManager.Properties.Resources.smallsuccess;
this.toolStripStatusLabel2.Text = "Query execulted successfully.";
this.toolStripStatuslblTotal.Visible = true;
this.toolStripStatuslblTotal.Text = string.Format(" Total:{0}", dt.Rows.Count);
 }
catch (Exception)
 {
DialogResult dr = MessageBox.Show("SQL Execute error!", "Error", MessageBoxButtons.YesNo, MessageBoxIcon.Error);
this.toolStripStatusLabel2.Visible = true;
this.toolStripStatusLabel2.Image = global::DBManager.Properties.Resources.smallfail;
this.toolStripStatusLabel2.Text = "Query completed with errors.";
if (dr == DialogResult.Yes || dr == DialogResult.No)
 {
this.Close();
 Application.Exit();
 }
 }
 }
else
 {
this.toolStripStatusLabel2.Visible = true;
this.toolStripStatusLabel2.Image = global::DBManager.Properties.Resources.smallfail;
this.toolStripStatusLabel2.Text = "Query completed with errors.";
 MessageBox.Show(errorMsg);
 }
 }
 }

/// <summary>
/// get database name
/// </summary>
/// <param name="level"></param>
/// <returns></returns>
private string GetDataBaseName(TreeNode node)
 {
string dataBaseName = string.Empty;
switch (node.Level)
 {
case 2:
dataBaseName = node.Text;
break;
case 3:
dataBaseName = node.Parent.Text;
break;
case 4:
dataBaseName = node.Parent.Parent.Text;
break;
default:
break;
 }
return dataBaseName;
 }

#region Drag
//定义被选择的项
private TreeNode _selectednode;
private void treeViewDataBase_AfterSelect(object sender, TreeViewEventArgs e)
 {
try
 {
_selectednode = e.Node;
 }
catch { }
 }
/// <summary>
/// 对选中项指定Move的“开始拖动操作”
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void treeViewDataBase_ItemDrag(object sender, ItemDragEventArgs e)
 {
if (!(this._selectednode.Level == 0 || this._selectednode.Level == 1))
 {
this.DoDragDrop(this._selectednode, DragDropEffects.Move);
 }
 }
/// <summary>
/// 添加MouseDown是因为,MouseDown先执行AfterSelect，所以在没有AfterSelect时，MouseDown要先选中被选取项
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void treeViewDataBase_MouseDown(object sender, MouseEventArgs e)
 {
try
 {
if ((e.Button & MouseButtons.Left) == MouseButtons.Left)
 {
this._selectednode = this.treeViewDataBase.GetNodeAt(e.X, e.Y);
this.treeViewDataBase.SelectedNode = this._selectednode;
 }
 }
catch { }
 }
private void textSql_DragEnter(object sender, DragEventArgs e)
 {
try
 {
TreeNode node = (TreeNode)e.Data.GetData(typeof(TreeNode));
if (node != null)
 {
e.Effect = DragDropEffects.Move;
 }
else
 {
Cursor = Cursors.No;
 }
 }
catch { }
finally { Cursor = Cursors.Default; }
 }
private void textSql_DragDrop(object sender, DragEventArgs e)
 {
try
 {
TreeNode node = (TreeNode)e.Data.GetData(typeof(TreeNode));
if (node != null)
 {
if (!(node.Level == 0 || node.Level == 1))
 {
if (node.Level == 4)
 {
this.txtSql.Text += " " + node.Text.Substring(0, node.Text.IndexOf('('));
 }
else
 {
this.txtSql.Text += " " + node.Text;
 }
 }
 }
else
 {
Cursor = Cursors.No;
 }
 }
catch { }
finally { Cursor = Cursors.Default; }
 }
#endregion

/// <summary>
/// 给第一列数据加上索引
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void dataGVSQL_RowPostPaint(object sender, DataGridViewRowPostPaintEventArgs e)
 {
Rectangle rectangle = new Rectangle(e.RowBounds.Location.X,
 e.RowBounds.Location.Y,
this.dataGVSQL.RowHeadersWidth - 4,
 e.RowBounds.Height);
TextRenderer.DrawText(e.Graphics, (e.RowIndex + 1).ToString(),
this.dataGVSQL.RowHeadersDefaultCellStyle.Font,
 rectangle,
this.dataGVSQL.RowHeadersDefaultCellStyle.ForeColor,
TextFormatFlags.VerticalCenter | TextFormatFlags.Right);
 }
 }
}

由于时间仓促，可能有一些问题，请不要见怪，谢谢！

下载地址：下载地址1 下载地址2

版权所有，转载请注明出处！

一切伟大的行动和思想，都有一个微不足道的开始。微不足道的我，正在吸取知识的土壤，希望能取得成功！不嫌弃我微不足道的，愿交天下好友！