PDF.NET框架操作——工具應用（一）

PDF.NET是個開源的項目其解決UI層（WinForm　/　Web）控件數據綁定、映射與查詢； BLL層實體對象查詢（OQL）；DAL層SQL語句和.NET數據訪問代碼映射（查看  SQL-MAP 原理）；由於其工具是VB語言開發，個人將他翻成C#版本，僅供學習和交流，對於初學者和C#初學者有一定能夠幫助；有不足之處大家盡管拍磚，下面進入正題：

1. 程序界面

• 大致思路

通過數據庫連接查詢所有表名——》根據表中列名、描述及字段類型生成實體類對應的屬性——》根據項目需求實體類樣式生成文件

• 所需控件

LookUpEdit（記錄歷史輸入數據）、TextEdit（輸入密碼以掩碼的形式展現）、SimpleButton（觸發操作）、ButtonEdit（選擇文檔輸出目錄）、GridControl（數據展示的容器）、ProgressBar（操作進度條）

• 后台代碼實現

    public partial class runForm : Form
    {
        public runForm()
        {
            InitializeComponent();
            Load += new EventHandler(runForm_Load);

            //鎖定窗口大小
            this.FormBorderStyle = FormBorderStyle.FixedDialog;

            //顯示查詢區域
            this.gvTable.ShowFindPanel();
        }

        void runForm_Load(object sender, EventArgs e)
        {
            connFile = GetConfigFilePath("UserHistory.txt");

            //標准格式 "Data Source=10.10.198.242;Initial Catalog=mesbj;User ID=sa;Password=sa
            //數據庫地址賦值
            DataConnect dc = GetConnect(connFile);
            if (dc == null)
                return;
            lueDataSource.Text = dc.dataSource;
            lueDataBase.Text = dc.dataBase;
            lueUser.Text = dc.user;
            txtPassWord.Text = dc.passWord;

            lueDataSource.Properties.DataSource = sourcelst;
            lueDataBase.Properties.DataSource = baselst;
            lueUser.Properties.DataSource = userlst;
        }

        /// <summary>
        /// 讀取配置文件給界面復制默認值
        /// </summary>
        /// <returns></returns>
        private DataConnect GetConnect(string connPath)
        {
            DataConnect dc = new DataConnect();
            string strcon = File.ReadAllText(connPath, Encoding.UTF8);
            string[] str = strcon.Split(';');
            for (int i = 0; i < str.Count(); i++)
            {
                switch (i)
                {
                    case 0:
                        dc.dataSource = GetConfig(str[i].Split('=')[1], i);
                        break;
                    case 1:
                        dc.dataBase = GetConfig(str[i].Split('=')[1], i);
                        break;
                    case 2:
                        dc.user = GetConfig(str[i].Split('=')[1], i);
                        break;
                    case 3:
                        dc.passWord = GetConfig(str[i].Split('=')[1], i);
                        break;
                    case 4:
                        OutputPath.Text = GetConfig(str[i].Split('=')[1], i);
                        break;
                    default:
                        break;
                }
            }
            return dc;
        }

        /// <summary>
        /// 數據庫連接配置文件
        /// </summary>
        private string connFile { set; get; }

        /// <summary>
        /// 數據庫地址
        /// </summary>
        private List<string> sourcelst { set; get; }

        /// <summary>
        /// 數據庫名稱
        /// </summary>
        private List<string> baselst { set; get; }

        /// <summary>
        /// 用戶
        /// </summary>
        private List<string> userlst { set; get; }

        /// <summary>
        /// 所有表名
        /// </summary>
        private List<string> tables { set; get; }

        /// <summary>
        /// 當前選擇表名
        /// </summary>
        private string scttable { set; get; }

        /// <summary>
        /// 讀取=號最后一個值
        /// </summary>
        /// <param name="str"></param>
        /// <returns></returns>
        private string GetConfig(string str, int i)
        {
            string[] con = str.Split(',');
            switch (i)
            {
                case 0:
                    sourcelst = new List<string>();
                    sourcelst.AddRange(con.ToArray());
                    break;
                case 1:
                    baselst = new List<string>();
                    baselst.AddRange(con.ToArray());
                    break;
                case 2:
                    userlst = new List<string>();
                    userlst.AddRange(con.ToArray());
                    break;
                default:
                    break;
            }
            //獲取最后一項作為默認值
            string config = con[con.Count() - 1];
            return config;
        }

        /// <summary>
        /// 讀取文件路徑
        /// </summary>
        /// <param name="fileName"></param>
        /// <returns></returns>
        private string GetConfigFilePath(string fileName)
        {
            string currenctDir = AppDomain.CurrentDomain.BaseDirectory;//存放路徑
            string configFile = System.IO.Path.Combine(currenctDir, fileName);
            return configFile;
        }

        /// <summary>
        /// lookupEdit 添加控制
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void lueDataSource_ProcessNewValue(object sender, ProcessNewValueEventArgs e)
        {
            LookUpEdit lue = sender as LookUpEdit;
            AddDataSurce(lue);
        }

        /// <summary>
        /// LookUpEdit 輸入字段添加賦值
        /// </summary>
        /// <param name="lue">輸入字段</param>
        private void AddDataSurce(LookUpEdit lue)
        {
            string value = lue.Text;
            if (string.IsNullOrEmpty(value))
                return;
            (lue.Properties.DataSource as List<string>).Add(value);
        }

        /// <summary>
        /// 連接
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnConnect_Click(object sender, EventArgs e)
        {
            DataConnect dc = new DataConnect();
            dc.dataSource = lueDataSource.Text;
            dc.dataBase = lueDataBase.Text;
            dc.user = lueUser.Text;
            dc.passWord = txtPassWord.Text;

            SqlHelper sl = new SqlHelper(dc);

            DataTable dt = SqlHelper.GetTables(@"SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_TYPE = 'BASE TABLE'");

            List<TableName> lst = new List<TableName>();

            tables = new List<string>();
            foreach (DataRow item in dt.Rows)
            {
                tables.Add(item[0].ToString());
                lst.Add(new TableName() { name = item[0].ToString() });
            }
            gcTable.DataSource = lst;

            WriteConninfo();
        }

        /// <summary>
        /// 寫入連接配置
        /// </summary>
        private void WriteConninfo()
        {
            //數據庫地址
            string strconn = @"Data Source=" + WriteConninfo(lueDataSource, sourcelst) + ";Initial Catalog=" + WriteConninfo(lueDataBase, baselst) +
                ";User ID=" + WriteConninfo(lueUser, userlst) + ";Password=" + txtPassWord.Text + ";OutputPath=" + OutputPath.Text;
            File.WriteAllText(connFile, strconn);
        }

        private string WriteConninfo(LookUpEdit lup, List<string> lst)
        {
            lst = new List<string>();
            lst = lup.Properties.DataSource as List<string>;
            if (lst.Contains(lup.Text))
            {
                lst.Remove(lup.Text);
                lst.Add(lup.Text);
            }
            string conn = "";
            foreach (string item in lst)
            {
                conn = conn + item + ",";
            }
            return conn.TrimEnd(',');
        }

        /// <summary>
        /// table 表選中事件,查詢表中所有字段
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void gvTable_FocusedRowChanged(object sender, DevExpress.XtraGrid.Views.Base.FocusedRowChangedEventArgs e)
        {
            TableName dv = gvTable.GetRow(e.FocusedRowHandle) as TableName;
            if (dv == null)
                return;
            string table = dv.name;
            dv.template = true;

            //DataTable dt = SqlHelper.GetTables("Select name from syscolumns Where ID=OBJECT_ID('" + table + "') ");
            //gcColumn.DataSource = dt;
        }

        /// <summary>
        /// 選擇輸出目錄
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void OutputPath_ButtonClick(object sender, ButtonPressedEventArgs e)
        {
            FolderBrowserDialog fbd = new FolderBrowserDialog();

            if (fbd.ShowDialog() == DialogResult.OK)
            {
                this.OutputPath.Text = fbd.SelectedPath; ;
            }
        }

        /// <summary>
        /// 實體類生成
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnMakeFile_Click(object sender, EventArgs e)
        {
            if (tables == null || tables.Count == 0)
            {
                MessageBox.Show("請先連接數據庫", "實體類生成器");
                return;
            }

            if (!Directory.Exists(OutputPath.Text))
            {
                MessageBox.Show("指定的代碼輸出目錄" + OutputPath.Text + "不存在，請在屬性窗口選擇有效的路徑。", "實體類生成器");
                return;
            }

            if (rbtnSelectOneTable.Checked)
            {
                tables = new List<string>();
                foreach (TableName item in gvTable.DataSource as List<TableName>)
                {
                    if (item.template)
                    {
                        tables.Add(item.name);
                    }
                }
            }

            PrgBarMakeFile.Maximum = tables.Count;

            txtMakeLog.Text = "";
            if (string.IsNullOrEmpty(OutputPath.Text))
            {
                MessageBox.Show("OutputPath路徑不能為空！", "實體類生成器");
                return;
            }

            int count = 0;
            foreach (string item in tables)
            {
                count++;
                txtMakeLog.AppendText("正在生成第" + count + " 個實體類文件： " + OutputPath.Text + "\\" + item + ".cs" + "\r\n");
                PrgBarMakeFile.Value = count;
                CreatModelCode(item);
            }
            MessageBox.Show("生成 " + count + " 個實體類文件！", "實體類生成器");

            WriteConninfo();
        }

        /// <summary>
        /// 創建實體類文件內容
        /// </summary>
        /// <param name="tableNam"></param>
        private void CreatModelCode(string tableName)
        {
            //表結構主鍵
            string primaryKey = "";
            //列名集合
            string propertyNames = "";

            DataTable dt = SqlHelper.GetTables("select top 0 * from " + tableName);

            if (dt.PrimaryKey != null && dt.PrimaryKey.Count() > 0)
            {
                primaryKey = dt.PrimaryKey[0].ToString();
            }

            foreach (DataColumn item in dt.Columns)
            {
                propertyNames = propertyNames + ",\"" + item.ColumnName + "\"";
            }
            propertyNames = propertyNames.TrimStart(',');

            StringBuilder sb = new StringBuilder();
            sb.AppendLine("using System;");
            //轉化配置處理
            sb.AppendLine("using System.Collections.Generic;");
            sb.AppendLine("using System.Text;");

            sb.AppendLine();

            //轉化配置處理
            sb.AppendLine("namespace Com.Wisdom.VO");
            sb.AppendLine("{");

            sb.AppendLine(" [Serializable()]");

            //繼承基類，轉化配置處理
            sb.AppendLine(" public partial class " + tableName + " : WsdGenericDto");

            sb.AppendLine(" {");

            //構造函數
            sb.AppendLine("     public " + tableName + "()");
            sb.AppendLine("     {");
            sb.AppendLine("             TableName = " + "\"" + tableName + "\";");
            sb.AppendLine("             EntityMap=EntityMapType.Table;");
            sb.AppendLine("             //IdentityName = \"標識字段名\";");
            sb.AppendLine();
            sb.AppendLine("             //PrimaryKeys.Add(\"主鍵字段名\")");

            sb.AppendLine("     PrimaryKeys.Add(" + "\"" + primaryKey + "\")");
            sb.AppendLine();
            sb.AppendLine("     }");

            sb.AppendLine("         protected override void SetFieldNames()");
            sb.AppendLine("         {");
            sb.AppendLine("            PropertyNames = new string[] { " + propertyNames + "};");
            sb.AppendLine("         }");

            sb.AppendLine();
            sb.AppendLine();

            foreach (DataColumn item in dt.Columns)
            {
                sb.AppendLine();
                sb.AppendLine("         /// <summary>");
                sb.AppendLine("         /// " + GetDescribe(tableName, item.ColumnName));
                sb.AppendLine("         /// </summary>");
                sb.AppendLine("         public " + GetDataType(item) + item.ColumnName);
                sb.AppendLine("         {");
                sb.AppendLine("             get{return getProperty<" + GetDataType(item) + ">(\"" + item.ColumnName + "\");}");
                sb.AppendLine("             set{setProperty(\"" + item.ColumnName + "\",value " + GetMaxValue(item) + ");}");
                sb.AppendLine("         }");
            }

            sb.AppendLine();
            sb.AppendLine();

            sb.AppendLine(" }");

            sb.AppendLine("}");

            string configFile = OutputPath.Text + "\\" + tableName + ".cs";
            File.WriteAllText(configFile, sb.ToString());
        }

        /// <summary>
        /// 獲取列名描述
        /// </summary>
        /// <param name="table"></param>
        /// <param name="column"></param>
        /// <returns></returns>
        private string GetDescribe(string table, string column)
        {
            string describe = "";
            DataTable dt = SqlHelper.GetTables(@"SELECT value FROM   ::fn_listextendedproperty(NULL,'user','dbo','table','" + table + "\'" + ",'column',NULL) WHERE objname='" + column + "\'");
            if (dt != null && dt.Rows != null && dt.Rows.Count > 0)
            {
                describe = dt.Rows[0].ItemArray[0].ToString();
            }
            return describe;
        }

        /// <summary>
        /// 根據表中最大值，處理
        /// </summary>
        /// <param name="column"></param>
        /// <returns></returns>
        private string GetMaxValue(DataColumn column)
        {
            if (column.MaxLength > 0)
            {
                return "," + column.MaxLength.ToString();
            }
            else return "";
        }

        /// <summary>
        /// 判斷表中列是否為空處理，范圍屬性類型
        /// </summary>
        /// <param name="column"></param>
        /// <returns></returns>
        private string GetDataType(DataColumn column)
        {
            if (column.AllowDBNull && column.DataType.IsValueType)
            {
                return column.DataType + "? ";//表字段為空，類屬性中添加？
            }
            else
            {
                return column.DataType.ToString() + " ";
            }
        }
    }

SqlHelper代碼

    public class SqlHelper
    {
        private static string strconn;

        public SqlHelper(DataConnect dc)
        {
            strconn = @"data source=" + dc.dataSource + ";database=" + dc.dataBase + ";user id=" + dc.user + ";password=" + dc.passWord;
        }

        public static DataTable GetTables(string sql)
        {
            DataTable dt = new DataTable();
            try
            {
                using (SqlConnection cnn = new SqlConnection(strconn))
                {
                    cnn.Open();
                    using (SqlCommand cmd = cnn.CreateCommand())
                    {
                        cmd.CommandText = sql;//執行sql
                        DataSet dataset = new DataSet();
                        SqlDataAdapter dapter = new SqlDataAdapter(cmd);
                        dapter.FillSchema(dataset, SchemaType.Source);
                        dapter.Fill(dataset);//將dataset添加到SqlDataAdapter容器中
                        dt = dataset.Tables[0];
                    }
                }
            }
            catch (Exception e)
            {
                MessageBox.Show(e.Message);
            }
            return dt;
        }
    }