using System;using System.Collections.Generic;using System.Data;using System.Data.SqlClient;using System.Linq;using System.Text;using EasyDBUtility;namespace CodeGenerator{    /// <summary>    /// 生成sqlserver相关代码    /// </summary>    public class SqlServer    {        //获取所有数据库名称        public const string Get_DataBaseName_SQL = "SELECT Name FROM Master..SysDatabases where Name not in(‘master‘,‘model‘,‘msdb‘,‘tempdb‘) ORDER BY Name";        //获取指定数据库中所有表名        public const string Get_Tables_SQL = "SELECT Name FROM [{0}]..SysObjects Where XType=‘U‘ ORDER BY Name";        //获取指定数据库中所有视图        public const string Get_Views_SQL = "SELECT Name FROM [{0}]..SysObjects Where XType=‘V‘ ORDER BY Name";        //获取指定数据库中所有存储过程        public const string Get_Procedures_SQL = "SELECT Name FROM [{0}]..SysObjects Where XType=‘P‘ ORDER BY Name";        //获取指定表或视图中的所有列信息        public const string Get_Columns_SQL = "select a.name,b.name typeName,a.is_identity,a.is_nullable from sys.columns a " +                    "left join sys.types b on a.user_type_id=b.user_type_id where a.object_id=object_id(‘{0}‘) order by column_id";        //获取指定表中主键信息        public const string GetPKeys_SQL = "Declare @objectid int;Set @objectid=object_id(‘{0}‘);Select col_name(@objectid,colid) " +            "From sysobjects as o Inner Join sysindexes as i On i.name=o.name Inner Join sysindexkeys as k On k.indid=i.indid " +            "Where o.xtype = ‘PK‘ and parent_obj=@objectid and k.id=@objectid";        //获取指定列的数据类型        public const string Get_Type_Name_SQL = "SELECT type_name(user_type_id) as [type_name] FROM sys.columns where [object_id] = object_id(‘{0}‘) and [name] = ‘{1}‘";        /// <summary>        /// 生成业务逻辑层代码        /// </summary>        /// <param name="tableName">表名</param>        /// <param name="connectionString">数据库连接字符串</param>        /// <param name="paramsData">生成参数</param>        /// <returns></returns>        public static string CreateBLL(string tableName, string connectionString, ParamsData paramsData)        {            string primaryKeyName = string.Empty;//主键名称            string primaryKeyTypeName = string.Empty;//主键数据类型            SqlHelper helper = new SqlHelper(connectionString);            helper.AutoClose = false;            //获取表的主键列名称            helper.CreateCommand(string.Format(GetPKeys_SQL, tableName));            object primaryKeyObj = helper.ExecuteScalar();            if (primaryKeyObj != null)            {                primaryKeyName = primaryKeyObj.ToString();                helper.CommandText(string.Format(Get_Type_Name_SQL, tableName, primaryKeyName));                primaryKeyTypeName = helper.ExecuteScalar().ToString();            }            else            {                //获取表的所有列信息                helper.CommandText(string.Format(SqlServer.Get_Columns_SQL, tableName));                List<ColumnsData> columnList = helper.ExecuteReader<ColumnsData>();                ColumnsData columnsData = (from col in columnList where col.Is_identity == true select col).FirstOrDefault();                if (columnsData != null)                {                    primaryKeyName = columnsData.Name;                    primaryKeyTypeName = columnsData.TypeName;                }            }            helper.Close();            if (string.IsNullOrEmpty(primaryKeyName) || string.IsNullOrEmpty(primaryKeyTypeName))            {                throw new Exception("在表“" + tableName + "”中没有找到主键或自增列，无法生成BLL代码！请设置表的主键或自增列后再重试！");            }            string deleteThePrefixTheTableName = frmMain.GetDeleteThePrefixTheTableName(tableName, paramsData);//生成的类名                        string parameterName = primaryKeyName.Substring(0, 1).ToLower() + primaryKeyName.Substring(1);            StringBuilder bll = new StringBuilder();            bll.Append("using System.Collections.Generic;\r\n");            if (paramsData.Architecture == Architecture.反射工厂模式)                bll.Append("using DALFactory;\r\n");            bll.Append("using " + paramsData.IDALNamespace + "\r\n");            bll.Append("using " + paramsData.ModelNamespace + "\r\n\r\n");            bll.Append("namespace " + paramsData.BLLNamespace + "\r\n");            bll.Append("{\r\n    ");            bll.Append("public class " + deleteThePrefixTheTableName + paramsData.BLLSuffix + "\r\n    ");            bll.Append("{\r\n        ");            if (paramsData.Architecture == Architecture.反射工厂模式)            {                bll.Append("private static readonly I" + deleteThePrefixTheTableName + " dal = DataAccess.CreateInstance<I" + deleteThePrefixTheTableName + ">(\""                    + deleteThePrefixTheTableName + paramsData.DALSuffix + "\");\r\n\r\n");            }            else if (paramsData.Architecture == Architecture.简单三层)            {                bll.Append("private static readonly " + deleteThePrefixTheTableName + paramsData.DALSuffix + " dal = new " + deleteThePrefixTheTableName + paramsData.DALSuffix + "();\r\n\r\n");            }            //新增方法            if (paramsData.CreateInsertMethod)            {                bll.Append("        public static bool " + paramsData.InsertMethodName + "(" + deleteThePrefixTheTableName + paramsData.ModelSuffix + " data)\r\n        ");                bll.Append("{\r\n            ");                bll.Append("return dal." + paramsData.InsertMethodName + "(data);\r\n        ");                bll.Append("}\r\n\r\n");            }            //删除            if (paramsData.CreateDeleteMethod)            {                bll.Append("        public static bool " + paramsData.DeleteMethodName + "(" + ChangeToCSharpType(primaryKeyTypeName, false) + " " + parameterName + ")\r\n        ");                bll.Append("{\r\n            ");                bll.Append("return dal." + paramsData.DeleteMethodName + "(" + parameterName + ");\r\n        ");                bll.Append("}\r\n\r\n");            }            //批量删除            if (paramsData.CreateBatchDeleteMethod)            {                bll.Append("        public static bool " + paramsData.BatchDeleteMethodName + "(" + ChangeToCSharpType(primaryKeyTypeName, false) + "[] " + parameterName + ")\r\n        ");                bll.Append("{\r\n            ");                bll.Append("return dal." + paramsData.BatchDeleteMethodName + "(" + parameterName + ");\r\n        ");                bll.Append("}\r\n\r\n");            }            //修改            if (paramsData.CreateUpdateMethod)            {                bll.Append("        public static bool " + paramsData.UpdateMethodName + "(" + deleteThePrefixTheTableName + paramsData.ModelSuffix + " data)\r\n        ");                bll.Append("{\r\n            ");                bll.Append("return  dal." + paramsData.UpdateMethodName + "(data);\r\n        ");                bll.Append("}\r\n\r\n");            }            //查询            if (paramsData.CreateSelectMethod)            {                bll.Append("        public static " + deleteThePrefixTheTableName + paramsData.ModelSuffix + " " + paramsData.SelectMethodName + "(" + ChangeToCSharpType(primaryKeyTypeName, false) + " " + parameterName + ")\r\n        ");                bll.Append("{\r\n            ");                bll.Append("return dal." + paramsData.SelectMethodName + "(" + parameterName + ");\r\n        ");                bll.Append("}\r\n\r\n");            }            //查询所有            if (paramsData.CreateSelectAllMethod)            {                bll.Append("        public static IList<" + deleteThePrefixTheTableName + paramsData.ModelSuffix + "> " + paramsData.SelectAllMethodName + "()\r\n        ");                bll.Append("{\r\n            ");                bll.Append("return dal." + paramsData.SelectAllMethodName + "();\r\n        ");                bll.Append("}\r\n\r\n");            }            bll.Append("    }\r\n");            bll.Append("}");            return bll.ToString();        }}