SqlHelper.cs
2016-01-22 09:20
447 查看
public class SqlHelper { #region comm sql public static int ExecuteNonQuery(string cmdText, params SqlParameter[] parameters) { using (SqlConnection connection = new SqlConnection(connectionString)) { using (SqlCommand command = new SqlCommand(cmdText, connection)) { if (parameters != null) command.Parameters.AddRange(parameters); if (connection.State == ConnectionState.Closed) connection.Open(); return command.ExecuteNonQuery(); } } } public static object ExecuteScalar(string cmdText, params SqlParameter[] parameters) { using (SqlConnection connection = new SqlConnection(connectionString)) { using (SqlCommand command = new SqlCommand(cmdText, connection)) { if (parameters != null) command.Parameters.AddRange(parameters); if (connection.State == ConnectionState.Closed) connection.Open(); return command.ExecuteScalar(); } } } public static DataTable ExecuteDataTable(string cmdText, params SqlParameter[] parameters) { using (SqlConnection connection = new SqlConnection(connectionString)) { using (SqlCommand command = new SqlCommand(cmdText, connection)) { if (parameters != null) command.Parameters.AddRange(parameters); if (connection.State == ConnectionState.Closed) connection.Open(); DataSet dataset = new DataSet(); SqlDataAdapter apdater = new SqlDataAdapter(command); apdater.Fill(dataset); return dataset.Tables[0]; } } } public static DataSet ExecuteDataSet(string cmdText, params SqlParameter[] parameters) { using (SqlConnection connection = new SqlConnection(connectionString)) { using (SqlCommand command = new SqlCommand(cmdText, connection)) { if (parameters != null) command.Parameters.AddRange(parameters); if (connection.State == ConnectionState.Closed) connection.Open(); DataSet dataset = new DataSet(); SqlDataAdapter sda = new SqlDataAdapter(command); sda.Fill(dataset); return dataset; } } } public static SqlDataReader ExecuteReader(string cmdText, params SqlParameter[] parameters) { SqlConnection connection = new SqlConnection(connectionString); { using (SqlCommand command = new SqlCommand(cmdText, connection)) { if (parameters != null) command.Parameters.AddRange(parameters); if (connection.State == ConnectionState.Closed) connection.Open(); return command.ExecuteReader(); } } } #endregion #region storedProcedure public static int ExecuteNonQuerySp(string cmdText, params SqlParameter[] parameters) { using (SqlConnection connection = new SqlConnection(connectionString)) { using (SqlCommand command = new SqlCommand(cmdText, connection)) { if (parameters != null) command.Parameters.AddRange(parameters); if (connection.State == ConnectionState.Closed) connection.Open(); command.CommandType = CommandType.StoredProcedure; return command.ExecuteNonQuery(); } } } public static object ExecuteScalarSp(string cmdText, params SqlParameter[] parameters) { using (SqlConnection connection = new SqlConnection(connectionString)) { using (SqlCommand command = new SqlCommand(cmdText, connection)) { if (parameters != null) command.Parameters.AddRange(parameters); if (connection.State == ConnectionState.Closed) connection.Open(); command.CommandType = CommandType.StoredProcedure; return command.ExecuteScalar(); } } } public static DataTable ExecuteDataTableSp(string cmdText, params SqlParameter[] parameters) { using (SqlConnection connection = new SqlConnection(connectionString)) { using (SqlCommand command = new SqlCommand(cmdText, connection)) { if (parameters != null) command.Parameters.AddRange(parameters); if (connection.State == ConnectionState.Closed) connection.Open(); command.CommandType = CommandType.StoredProcedure; DataSet dataset = new DataSet(); SqlDataAdapter apdater = new SqlDataAdapter(command); apdater.Fill(dataset); return dataset.Tables[0]; } } } public static SqlDataReader ExecuteReaderSp(string cmdText, params SqlParameter[] parameters) { SqlConnection connection = new SqlConnection(connectionString); { using (SqlCommand command = new SqlCommand(cmdText, connection)) { if (parameters != null) command.Parameters.AddRange(parameters); if (connection.State == ConnectionState.Closed) connection.Open(); command.CommandType = CommandType.StoredProcedure; return command.ExecuteReader(CommandBehavior.CloseConnection); } } } public static DataSet ExecuteDataSetSp(string cmdText, params SqlParameter[] parameters) { using (SqlConnection conn = new SqlConnection(connectionString)) { using (SqlCommand comm = new SqlCommand(cmdText, conn)) { if (parameters != null) comm.Parameters.AddRange(parameters); if (conn.State == ConnectionState.Closed) conn.Open(); comm.CommandType = CommandType.StoredProcedure; DataSet ds = new DataSet(); SqlDataAdapter sda = new SqlDataAdapter(comm); sda.Fill(ds); return ds; } } } #endregion }
View Code
相关文章推荐
- oracle批量插入数据
- Oracle 的 JDBC 驱动必须实现 JDBC 3.0 规范
- 正确使用SQL Server中的count()函数
- 给各位聚聚和大大介绍一个开源项目 Expression2Sql(二)
- MySql不同版本安装
- [数据库] SQL查询语句表行列转换及一行数据转换成两列
- iOS Sqlite3 Demo 及 FMDB Demo
- mysql笔记02 创建高性能的索引
- Nodejs+Extjs+Mongodb开发第一天 Nodejs环境搭建
- oracle case when 语句
- Oracle异机恢复处理
- SQL Server中避免触发镜像SUSPEND的N种方法
- MySQL中由load data语句引起死锁的解决案例
- 详解MySQL中的死锁情况以及对死锁的处理方法
- 数据库Oracle学习资料
- Mysql分区技术 --创建分区表
- java 并发插入数据到oracle
- 自定义SQL函数 实现SPlit字符截取功能
- Oracle数据操作之默认0为' '
- 十步完全理解SQL