C#代码生成器源代码

//------------------------------------------------------------------------------ // 创建标识: Copyright (C) 2007 Socansoft.com 版权所有 // 创建描述: SocanCode代码生成器自动创建 // // 功能描述: 数据库操作基类 // // 修改标识: // 修改描述: //------------------------------------------------------------------------------ using System; using System.Collections.Generic; using System.Collections.Specialized; using System.Data; using System.Text; using System.Data.SqlClient; using System.Configuration; using System.Collections; using System.Runtime.Serialization.Formatters.Binary; using System.IO; using System.Xml; using System.Reflection; namespace DBUtility { /// <summary> /// 数据访问基础类(基于SQLServer) /// </summary> public abstract class SqlHelper { //数据库连接字符串(web.config来配置) public static readonly string Connection = ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString; /// <summary> /// 分页获取数据 /// </summary> /// <param name="connectionString">连接字符串</param> /// <param name="tblName">表名</param> /// <param name="fldName">字段名</param> /// <param name="pageSize">页大小</param> /// <param name="pageIndex">第几页</param> /// <param name="fldSort">排序字段</param> /// <param name="sort">升序/降序</param> /// <param name="strCondition">条件(不需要where)</param> /// <param name="pageCount">页数</param> /// <param name="count">记录条数</param> /// <param name="strSql">SQL语句</param> /// <returns></returns> public static DataSet PageList(string connectionString, string tblName, int pageSize, int pageIndex, string fldSort, bool sort, string condition, out int count) { string sql = PageHelper.GetPagerSQL(condition, pageSize, pageIndex, fldSort, tblName, sort); count = GetCount(connectionString, tblName, condition); return Query(connectionString, sql); } /// <summary> /// 获取表数据量 /// </summary> /// <param name="connectionString">连接字符串</param> /// <param name="tblName">表名</param> /// <returns></returns> public static int GetCount(string connectionString, string tblName, string condition) { StringBuilder sql = new StringBuilder(string.Format("select count(*) from {0}", tblName)); if (!string.IsNullOrEmpty(condition)) { sql.Append(string.Format(" where {0}", condition)); } DataSet ds = Query(connectionString, sql.ToString()); if (ds.Tables[0].Rows[0][0] != null) { return int.Parse(ds.Tables[0].Rows[0][0].ToString()); } else { return 0; } } #region 执行简单SQL语句 /// <summary> /// 获取表某个字段的最大值 /// </summary> /// <param name="FieldName"></param> /// <param name="TableName"></param> /// <returns></returns> public static int GetMaxID(string connectionString, string FieldName, string TableName) { string strSql = "select max(" + FieldName + ") from " + TableName; DataSet ds = Query(connectionString, strSql); if (ds.Tables[0].Rows[0][0] != DBNull.Value) return int.Parse(ds.Tables[0].Rows[0][0].ToString()); else return 0; } /// <summary> /// 检测一个记录是否存在(SqlParameter语句方式) /// </summary> /// <param name="strSql"></param> /// <param name="cmdParms"></param> /// <returns></returns> public static bool Exists(string connectionString, string strSql, params SqlParameter[] cmdParms) { DataSet ds = Query(connectionString, strSql, cmdParms); return int.Parse(ds.Tables[0].Rows[0][0].ToString()) > 0; } /// <summary> /// 执行SQL语句，返回影响的记录数 /// </summary> /// <param name="SQLString">SQL语句</param> /// <returns>影响的记录数</returns> public static int ExecuteSql(string connectionString, string SQLString) { using (SqlConnection connection = new SqlConnection(connectionString)) { using (SqlCommand cmd = new SqlCommand(SQLString, connection)) { try { connection.Open(); int rows = cmd.ExecuteNonQuery(); return rows; } catch (System.Data.SqlClient.SqlException E) { connection.Close(); throw new Exception(E.Message); } } } } /// <summary> /// 执行SQL语句，返回记录的个数 /// </summary> /// <param name="SQLString">SQL语句</param> /// <returns>影响的记录数</returns> public static int ExecuteCountSql(string connectionString, string SQLString) { using (SqlConnection connection = new SqlConnection(connectionString)) { using (SqlCommand cmd = new SqlCommand(SQLString, connection)) { try { connection.Open(); SqlDataReader dr = cmd.ExecuteReader(); dr.Read(); int count = int.Parse(dr[0].ToString()); return count; } catch (System.Data.SqlClient.SqlException E) { connection.Close(); throw new Exception(E.Message); } } } } /// <summary> /// 执行多条SQL语句，实现数据库事务。 /// </summary> /// <param name="SQLStringList">多条SQL语句</param> public static void ExecuteSqlTran(string connectionString, List<string> SQLStringList) { using (SqlConnection conn = new SqlConnection(connectionString)) { conn.Open(); SqlCommand cmd = new SqlCommand(); cmd.Connection = conn; SqlTransaction tx = conn.BeginTransaction(); cmd.Transaction = tx; try { for (int n = 0; n < SQLStringList.Count; n++) { string strsql = SQLStringList[n].ToString(); if (strsql.Trim().Length > 1) { cmd.CommandText = strsql; cmd.ExecuteNonQuery(); } } tx.Commit(); } catch (System.Data.SqlClient.SqlException E) { tx.Rollback(); throw new Exception(E.Message); } } } /// <summary> /// 执行带一个存储过程参数的的SQL语句。 /// </summary> /// <param name="SQLString">SQL语句</param> /// <param name="content">参数内容,比如一个字段是格式复杂的文章，有特殊符号，可以通过这个方式添加</param> ///