SqlHelper工具类
/**
*┌──────────────────────────────────────────────────────────────┐
*│ 描 述：日志相关的工具类
*│ 作 者：执笔小白
*│ 版 本：1.0
*│ 创建时间：2020-6-13 15:40:56
*└──────────────────────────────────────────────────────────────┘
*┌──────────────────────────────────────────────────────────────┐
*│ 命名空间: WMSTOMESTT
*│ 类 名：ETools
*└──────────────────────────────────────────────────────────────┘
*/
using System.Configuration;
using System.Data;
using System.Data.SqlClient;
namespace HostControl.Util
{
public class MSSqlHelper
{
// 连接字符串
private static readonly string str = ConfigurationManager.ConnectionStrings["MSSqlConStr"].ConnectionString;
/* 返回的是受影响的行数
* ExecuteNonQuery()通常情况下为数据库事务处理的首选，当需要执行插入，删除，修改等操作时，首选ExecuteNonQuery(),不适用于Selete语句，返回永远是-1
* ExecuteNonQuery()执行成功返回的是一受影响的行数，对于"Create Table"和"Drop Table"语句，返回值是0，
* ExecuteNonQuery()操作数据时，可以不使用DataSet直接更改数据库中的数据。
*/
public static int ExecuteNonQuery(string sql, params SqlParameter[] ps)
{
using (SqlConnection con = new SqlConnection(str))
{
using (SqlCommand cmd = new SqlCommand(sql, con))
{
if (ps != null)
{
cmd.Parameters.AddRange(ps);
}
con.Open();
int cc = cmd.ExecuteNonQuery();
con.Close();
return cc;
}
}
}
/* ExecuteScalar()方法也可以用来执行SQL语句，但是executescalar()执行SQL语句后返回值与ExecuteNonQuery()并不相同，
* ExecuteNonQuery()操作后返回的是一个值，而executescalar()操作后则会返回一个对象（object），
* 如果执行的SQL语句是查询语句，则返回结果是查询后的第一行第一列，
* 如果执行的SQL语句不是一个查询语句，则会返回一个未实例化的对象，必须通过类型装换来显示。
*
* executescalar()经常使用当需要返回单一值时的情况。例如当插入一条数据信息时，
* 需要马上知道刚才插入的值，则可以使用executescalar()方法。
*/
public static object ExecuteScalar(string sql, params SqlParameter[] ps)
{
using (SqlConnection con = new SqlConnection(str))
{
using (SqlCommand cmd = new SqlCommand(sql, con))
{
if (ps != null)
{
cmd.Parameters.AddRange(ps);
}
con.Open();//打开数据库
object cc = cmd.ExecuteScalar();
con.Close();
return cc;
}
}
}
/* 快速查询
* ExecuteReader比DataSet而言，DataReader具有较快的访问能力，并且能够使用较少的服务器资源。
* DataReader对象提供了游标形式的读取方式，当从结果行中读取了一行，则游标会继续读取到下一行。
* 通过read方法可以判断数据是否还有下一行，如果存在数据，则继续运行返回true，如果没有数据，则返回false。
*/
public static SqlDataReader ExecuteReader(string sql, params SqlParameter[] ps)
{
SqlConnection con = new SqlConnection(str);
using (SqlCommand cmd = new SqlCommand(sql, con))
{
if (ps != null)
{
cmd.Parameters.AddRange(ps);
}
con.Open();
return cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection); //关闭关联的connection
}
}
/* 通用查询方法
* 为了将数据库的数据填充到dataset中，则必须先使用adapter对象的方法实现填充，当数据填充完成后，
* 开发人员可以将记录添加到dataset对象中，然后使用update方法将数据插入到数据库中。
*/
public static DataSet SelectDataSet(string sql, params SqlParameter[] ps)
{
using (SqlConnection con = new SqlConnection(str))
{
using (SqlDataAdapter da = new SqlDataAdapter(sql, con))
{
if (ps != null)
{
da.SelectCommand.Parameters.AddRange(ps);
}
con.Open();
DataSet dataSet = new DataSet();
da.Fill(dataSet);
con.Close();
return dataSet;
}
}
}
/* 使用DataSet数据集更新数据
* 为了将数据库的数据填充到dataset中，则必须先使用adapter对象的方法实现填充
*/
public static int SqlDataAdapter(string sql, DataSet ds, string tableName)
{
using (SqlConnection con = new SqlConnection(str))
{
using (SqlDataAdapter sa = new SqlDataAdapter(sql, con))
{
SqlCommandBuilder builder = new SqlCommandBuilder(sa);
return sa.Update(ds, tableName);
}
}
}
#region 事务
/// <summary>
/// 返回的是受影响的行数-事务
/// </summary>
/// <param name="sql">多个sql</param>
/// <param name="ps">指定类型的参数</param>
/// <returns></returns>
public static int ExecuteNonQueryTrans(string sql, params SqlParameter[] ps)
{
using (SqlConnection con = new SqlConnection(str))
{
con.Open();
using (SqlTransaction trans = con.BeginTransaction())
{
try
{
using (SqlCommand cmd = new SqlCommand())
{
cmd.Connection = con;
cmd.Transaction = trans;
cmd.CommandText = sql;
if (ps != null)
{
cmd.Parameters.AddRange(ps);
}
int cc = cmd.ExecuteNonQuery();
trans.Commit();
con.Close();
return cc;
}
}
catch (Exception ex)
{
trans.Rollback();
con.Close();
con.Dispose();
throw ex;
}
}
}
}
#endregion
}
}