C# SQL数据库助手类1.0(自用)
2014-04-03 14:27
281 查看
using System; using System.Collections.Generic; using System.Text; using System.Configuration; using System.Data; using System.Data.SqlClient; namespace Erp.DBUtility { public class YSqlHelper { //Sql连接语句 private static string connectionString = ConfigurationManager.AppSettings["ConnectionString"]; /// <summary>执行不带参数的增删改SQL语句或存储过程 ,返回受影响的行数</summary> public static int ExecuteNonQuery(string cmdText, CommandType ct) { int res = 0;//受影响的行数 using (SqlConnection conn = new SqlConnection(connectionString)) { try { conn.Open();//打开数据库链接 using (SqlCommand cmd = new SqlCommand(cmdText, conn)) { cmd.CommandType = ct; res = cmd.ExecuteNonQuery();//执行Sql语句并受影响的行数 } } catch { } finally { if (conn.State == ConnectionState.Open)//判断连接是否处于打开状态 { conn.Close();//关闭与数据库的链接 } } } return res; } /// <summary> 执行带参数的增删改SQL语句或存储过程,返回受影响的行数</summary> public static int ExecuteNonQuery(string cmdText, SqlParameter[] paras, CommandType ct) { int res = 0;//受影响的行数 using (SqlConnection conn = new SqlConnection(connectionString)) { try { conn.Open();//打开数据库链接 using (SqlCommand cmd = new SqlCommand(cmdText, conn)) { cmd.CommandType = ct; cmd.Parameters.AddRange(paras); res = cmd.ExecuteNonQuery();//执行Sql语句并受影响的行数 } } catch { } finally { if (conn.State == ConnectionState.Open)//判断连接是否处于打开状态 { conn.Close();//关闭与数据库的链接 } } } return res; } /// <summary> 执行不带参数的查询SQL语句或存储过程,返回DataTable对象</summary> public static DataTable ExecuteQueryDataTable(string cmdText, CommandType ct) { DataTable dt = new DataTable(); using (SqlConnection conn = new SqlConnection(connectionString)) { try { conn.Open();//打开数据库链接 using (SqlCommand cmd = new SqlCommand(cmdText, conn)) { cmd.CommandType = ct; using (SqlDataReader sdr = cmd.ExecuteReader(CommandBehavior.CloseConnection)) { dt.Load(sdr); } } } catch { } finally { if (conn.State == ConnectionState.Open)//判断连接是否处于打开状态 { conn.Close();//关闭与数据库的链接 } } } return dt; } /// <summary> 执行带参数的查询SQL语句或存储过程,返回DataTable对象</summary> public static DataTable ExecuteQueryDataTable(string cmdText, SqlParameter[] paras, CommandType ct) { DataTable dt = new DataTable(); using (SqlConnection conn = new SqlConnection(connectionString)) { try { conn.Open();//打开数据库链接 using (SqlCommand cmd = new SqlCommand(cmdText, conn)) { cmd.CommandType = ct; cmd.Parameters.AddRange(paras); using (SqlDataReader sdr = cmd.ExecuteReader(CommandBehavior.CloseConnection)) { dt.Load(sdr); } } } catch { } finally { if (conn.State == ConnectionState.Open)//判断连接是否处于打开状态 { conn.Close();//关闭与数据库的链接 } } } return dt; } /// <summary> 执行不带参数的查询SQL语句或存储过程,返回DataSet对象</summary> public static DataSet ExecuteQueryDataSet(string cmdText, CommandType ct) { DataSet ds = new DataSet(); using (SqlConnection conn = new SqlConnection(connectionString)) { try { conn.Open();//打开数据库链接 using (SqlCommand cmd = new SqlCommand(cmdText, conn)) { cmd.CommandType = ct; using (SqlDataAdapter da = new SqlDataAdapter(cmd)) { da.Fill(ds, "ds"); } } } catch { } finally { if (conn.State == ConnectionState.Open)//判断连接是否处于打开状态 { conn.Close();//关闭与数据库的链接 } } } return ds; } /// <summary> 执行带参数的查询SQL语句或存储过程,返回DataSet对象</summary> public static DataSet ExecuteQueryDataSet(string cmdText, SqlParameter[] paras, CommandType ct) { DataSet ds = new DataSet(); using (SqlConnection conn = new SqlConnection(connectionString)) { try { conn.Open();//打开数据库链接 using (SqlCommand cmd = new SqlCommand(cmdText, conn)) { cmd.CommandType = ct; cmd.Parameters.AddRange(paras); using (SqlDataAdapter da = new SqlDataAdapter(cmd)) { da.Fill(ds, "ds"); } } } catch { } finally { if (conn.State == ConnectionState.Open)//判断连接是否处于打开状态 { conn.Close();//关闭与数据库的链接 } } } return ds; } /// <summary>查询数据是否存在</summary> public static bool ExecuteDataIsExistByData(string sqlStr, CommandType commandType) { bool iss = false; DataSet ds = ExecuteQueryDataSet(sqlStr, commandType); for (int i = 0; i < ds.Tables.Count; i++) { if (ds.Tables[i].Rows.Count > 0) iss = true; } return iss; } /// <summary>查询数据是否存在 </summary> public static bool ExecuteDataIsExistByData(string sqlStr, SqlParameter[] paras, CommandType commandType) { bool iss = false; DataSet ds = ExecuteQueryDataSet(sqlStr, paras, commandType); for (int i = 0; i < ds.Tables.Count; i++) { if (ds.Tables[i].Rows.Count > 0) iss = true; } return iss; } /// <summary>查询增删改数据操作是否成功 </summary> public static bool ExecuteDataIsExistByInt(string sqlStr, CommandType commandType) { int ds = ExecuteNonQuery(sqlStr, commandType); bool iss = ds > 0 ? true : false; return iss; } /// <summary>查询增删改数据操作是否成功 </summary> public static bool ExecuteDataIsExistByInt(string sqlStr, SqlParameter[] paras, CommandType commandType) { int ds = ExecuteNonQuery(sqlStr, paras, commandType); bool iss = ds > 0 ? true : false; return iss; } } }
相关文章推荐
- 终极网文助手 v1.0 怎么用
- 成绩录入语音防错小助手V1.0
- 冲顶大会/芝士超人/花椒直播/头脑王者...答题助手升级版 v1.0
- 开心网挣车位助手1.0(内测版)
- QQ聊天记录备份助手 v1.0——搜索、备份、恢复QQ聊天记录文件,重装系统必备
- 小皮助手(电脑玩手机游戏) v1.0 官方版
- CDR配置助手 1.0 绿色免费版
- Happy Backup系统重装备份助手 v1.0 beta 下载
- 华丽的桌面日历/日程助手 SuperHelper1.0
- WIN7封装助手 v 1.0
- 按键助手 1.0 中文免费绿色版
- 新增免费 代理(Proxy)验证助手 自用 支持http/socks
- C# SQL数据库助手类2.0(自用)
- 楚翔文章原创辅助助手1.0
- 站长助手-网站web在线管理程序 v1.0 下载
- vue1.0到vue2.0迁移助手 vue-migration-helper 安装
- 站长助手-网站web在线管理程序 v1.0 下载
- 硬件检测助手 v1.0
- 发布买家助手(淘宝搜索)1.0
- 词汇小助手V1.0——一款跨平台词频统计和外语学习工具