用到C#做开发的,要么使用ADO.Net来进行SQL语句操作,要么用LINQ to SQL,或者直接自己封装一个类来方便自己对数据库进行操作。而SQLHelper类就是微软自家提供的一个开源的数据库操作类。
如果自己水平够高的话,也可以自己封装一个类来进行操作的,比如我们公司就有自己一套数据库操作的底层,生成的是Model,Services和Repository三个类,Services和Repository这两个主要是封装好了对应的SQL语句操作,到时候需要进行insert或者update操作直接调用即可,比如update(model),无需一条一条的写SQL语句这么麻烦。
回到主题,先放上我现在用的SQLHelper类的源码,其中常用的方法有ExecuteScalar(),ExecuteNonQuery(),ExecuteList()
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Configuration; using System.Data.SqlClient; using System.Data; using System.Reflection; namespace DAL { public class SqlHelper { //Database connection strings public static readonly string ConnectionString = ConfigurationManager.ConnectionStrings["CR_sqlStr"].ConnectionString; //封装连接字符串属性 private static SqlConnection _con=null; public static SqlConnection Con { get { if (SqlHelper._con==null) { SqlHelper._con = new SqlConnection(); } if (SqlHelper._con.ConnectionString=="") { SqlHelper._con.ConnectionString = SqlHelper.ConnectionString; } return SqlHelper._con; } set { SqlHelper._con = value; } } #region ExecuteScalar ////// 执行Sql 语句 /// /// Sql/或存储过程 /// 类型 /// 参数 ///执行结果对象 public static int ExecuteScalar(string commandText, CommandType commandType, params SqlParameter[] param) { int count = 0; using (SqlHelper.Con) { using (SqlCommand cmd = new SqlCommand(commandText, SqlHelper.Con)) { try { cmd.CommandType = commandType; if (param != null) { cmd.Parameters.AddRange(param); } SqlHelper.Con.Open(); count = Convert.ToInt32(cmd.ExecuteScalar()); } catch (Exception) { count = 0; throw; } } } return count; } #endregion #region ExecuteNonQuery ////// 执行sql命令 /// /// /// /// sql语句/参数化sql语句/存储过程名 /// ///受影响的行数 public static int ExecuteNonQuery(string commandText, CommandType commandType, params SqlParameter[] param) { int result = 0; using (SqlHelper.Con) { using (SqlCommand cmd = new SqlCommand(commandText, SqlHelper.Con)) { try { cmd.CommandType = commandType; if (param != null) { cmd.Parameters.AddRange(param); } SqlHelper.Con.Open(); result = cmd.ExecuteNonQuery(); } catch (Exception) { result = 0; } } } return result; } #endregion #region ExecuteEntity ////// 执行返回一条记录的泛型对象 /// ///泛型类型 /// 语句或存储过程名 /// 命令类型 /// 参数数组 ///实体对象 public static T ExecuteEntity(string commandText, CommandType commandType, params SqlParameter[] param) { T obj = default(T); using (SqlHelper.Con) { using (SqlCommand cmd = new SqlCommand(commandText, SqlHelper.Con)) { cmd.CommandType = commandType; cmd.Parameters.AddRange(param); SqlHelper.Con.Open(); SqlDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection); while (reader.Read()) { obj = SqlHelper.ExecuteDataReader (reader); } } } return obj; } #endregion #region ExecuteDataReader /// /// 执行返回一条记录的泛型对象 /// ///泛型类型 /// 只进只读对象 ///泛型对象 private static T ExecuteDataReader(IDataReader reader) { T obj = default(T); try { Type type = typeof(T); obj = (T)Activator.CreateInstance(type);//从当前程序集里面通过反射的方式创建指定类型的对象 //obj = (T)Assembly.Load(OracleHelper._assemblyName).CreateInstance(OracleHelper._assemblyName + "." + type.Name);//从另一个程序集里面通过反射的方式创建指定类型的对象 PropertyInfo[] propertyInfos = type.GetProperties();//获取指定类型里面的所有属性 foreach (PropertyInfo propertyInfo in propertyInfos) { for (int i = 0; i < reader.FieldCount; i++) { string fieldName = reader.GetName(i); if (fieldName.ToLower() == propertyInfo.Name.ToLower()) { object val = reader[propertyInfo.Name];//读取表中某一条记录里面的某一列 if (val != null && val != DBNull.Value) { if (val.GetType() == typeof(decimal) || val.GetType() == typeof(int)) { propertyInfo.SetValue(obj, Convert.ToInt32(val), null); } else if (val.GetType() == typeof(DateTime)) { propertyInfo.SetValue(obj, Convert.ToDateTime(val), null); } else if (val.GetType() == typeof(string)) { propertyInfo.SetValue(obj, Convert.ToString(val), null); } } break; } } } } catch (Exception) { throw; } return obj; } #endregion #region ExecuteList /// /// 执行返回多条记录的泛型集合对象 /// ///泛型类型 /// 语句或存储过程名 /// 命令类型 /// 命令参数数组 ///泛型集合对象 public static ListExecuteList (string commandText, CommandType commandType, params SqlParameter[] param) { List list = new List (); using (SqlHelper.Con) { using (SqlCommand cmd = new SqlCommand(commandText, SqlHelper.Con)) { try { cmd.CommandType = commandType; if (param != null) { cmd.Parameters.AddRange(param); } SqlHelper.Con.Open(); SqlDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection); while (reader.Read()) { T obj = SqlHelper.ExecuteDataReader (reader); list.Add(obj); } } catch (Exception) { list = null; } } } return list; } #endregion #region ExecuteDataSet /// /// 执行返回多条记录的dataset /// /// sql或存储过程 /// 命令类型 /// 参数数组 ///DataSet public static DataSet ExecuteDataSet(string commandText,CommandType commandType, params SqlParameter[] param) { using (SqlHelper.Con) { using (SqlCommand cmd = new SqlCommand(commandText, SqlHelper.Con)) { cmd.CommandType = commandType; if (param != null) { cmd.Parameters.AddRange(param); } using (SqlDataAdapter da = new SqlDataAdapter(cmd)) { DataSet ds = new DataSet(); da.Fill(ds); return ds; } } } } #endregion } }
为什么说是我用的呢,因为由于需求不一样,所以会在SQLHelper这个类里面添加自己需要的操作,比如这里就比微软官方的多了一个获取List的方法
接下来就说下怎么用
1.现在web.config文件中配置好数据库连接字符串
2.然后…就可以用了
通过MVC三层结构,我们会把所需要操作的数据库表的字段写成一个Model类,假如我们需要获取这个数据库表里面的所有数据,我们可以通过List的方式进行存储进来
下面是我最近写的一个HolidayRemind接口用到的
List HolidayList = SqlHelper.ExecuteList("select * from HolidayRemind where Remind = 0", CommandType.Text); //List t = SqlHelper.ExecuteList("SQL语句", CommandType); //CommandType是一个枚举的数据类型,Text是SQL文本命令,StoredProcedure是存储过程的名称,TableDirect是表的名称
其他的一些操作也是类似如此。
不过你们也会发现,如果对数据库进行大量的增删改查操作,需要写非常多行的这种SqlHelper.方法名(“数据库语句”,CommandType);语句,所以有什么好的办法呢,还是最好自己封装一个操作类了最方便了。