0
点赞
收藏
分享

微信扫一扫

C# 简单的DBhelp

public class DbHelperSQL
{




private static string connStr = "Data Source=192.168.0.146;Initial Catalog=DB;User ID=sa;PWD=123";


private static SqlConnection conn;


public static SqlConnection Conn
{
get
{
if (conn == null)
{
conn = new SqlConnection(connStr);
conn.Open();
}
if (conn != null && conn.State != ConnectionState.Closed)
{
conn.Close();
conn.Open();
}
else
{
conn.Open();
}
return DbHelperSQL.conn;
}
}




/// <summary>
/// 关闭连接
/// </summary>
public static void closeConn()
{
if (Conn != null && Conn.State != ConnectionState.Closed)
{
Conn.Close();
}
}




/// <summary>
/// 查询操作
/// </summary>
/// <param name="sql"></param>
/// <param name="type"></param>
/// <param name="pars"></param>
/// <returns></returns>
public static SqlDataReader getReader(string sql)
{
SqlCommand cmd = new SqlCommand(sql, Conn);
//cmd.CommandType = type;
//cmd.Parameters.AddRange(pars);
return cmd.ExecuteReader();
}




/// <summary>
/// 执行非查询操作(执行增、删、改操作的),不支持事务
/// </summary>
/// <param name="sql"></param>
/// <param name="type"></param>
/// <param name="pars"></param>
/// <returns></returns>
public static int ExecuteNoneQuery(string sql)
{
int result = 0;


SqlCommand cmd = new SqlCommand(sql, Conn);
//cmd.CommandType = type;
//if (pars != null)
//{
// cmd.Parameters.AddRange(pars);
//}


result = cmd.ExecuteNonQuery();


//关闭连接对象
closeConn();


return result;
}


/// <summary>
/// 非查询操作(执行增、删、改操作的),支持事务,进行批量操作
/// </summary>
/// <param name="sql"></param>
/// <param name="conn"></param>
/// <param name="type"></param>
/// <param name="pars"></param>
/// <returns></returns>
public static int ExecuteNoneQuery(string sql, SqlConnection conn, CommandType type, params SqlParameter[] pars)
{
int result = 0;


//接受外部提供的数据连接对象,并且此连接在本次操作后不要关闭
SqlCommand cmd = new SqlCommand(sql, conn);
cmd.CommandType = type;
cmd.Parameters.AddRange(pars);


result = cmd.ExecuteNonQuery();


return result;
}


/// <summary>
/// 获取单个值,首行首列
/// </summary>
/// <param name="sql"></param>
/// <param name="type"></param>
/// <param name="pars"></param>
/// <returns></returns>
public static object GetScalar(string sql, CommandType type, params SqlParameter[] pars)
{
object obj = null;


SqlCommand cmd = new SqlCommand(sql, Conn);
cmd.CommandType = type;
cmd.Parameters.AddRange(pars);


obj = cmd.ExecuteScalar();


//关闭连接对象
closeConn();


return obj;
} }
private void LoadEmployee()
{
string sql = String.Format("SELECT * FROM {0}", DBEmployee);
SqlDataReader reader = DbHelperSQL.getReader(sql);
while (reader.Read())
{
Employee e = new Employee();
e.Id = Convert.ToInt32(reader["Id"]);
e.Passport = reader["Passport"].ToString();
e.Password = reader["Password"].ToString();
e.Name = reader["Name"].ToString();

;
ListEmployee.Add(e);
}
}

举报

相关推荐

0 条评论