SQL Server 数据库访问通用类（更新）

lygyh9985825

　　对SQL Server数据库的操作，最常见的有如下五种：


　　1.非连接式查询，获取DataTable。
　　2.连接式查询，获取DataReader。
　　3.查询结果只有1行1列，获取单一数据。
　　4.对数据库进行增、删、改操作，进行数据编辑。
　　5.判断与数据库是否已连接。（更新）
　　针对以上情况，分享的一个SQL Server数据库访问通用类。该通用类可用于ASP.NET和C/S系统中开发。

　　
1.非连接式查询，获取DataTable。
　　利用SqlDataAdapter对象的Fill()返回DataTable的结果集。


View Code


#region 执行一个查询，并返回结果集
///
/// 执行一个查询，并返回结果集
///
/// 要查询的SQL文本命令
/// 查询结果集
public DataTable ExecuteDataTable(string sql)
{
return ExecuteDataTable(sql, CommandType.Text, null);
}
///
/// 执行一个查询，并返回结果集
///
/// 要查询的SQL文本命令
/// 查询语句类型，存储过程或SQL文本命令
/// 查询结果集
public DataTable ExecuteDataTable(string sql, CommandType commandType)
{
return ExecuteDataTable(sql, commandType, null);
}
///
/// 执行一个查询，并返回结果集
///
/// 要查询的SQL文本命令
/// 查询语句类型，存储过程或SQL文本命令
/// T-SQL语句或存储过程的参数组
/// 查询结果集
public DataTable ExecuteDataTable(string sql, CommandType commandType, SqlParameter[] parameters)
{
//实例化DataTable，用于装载查询结果集
DataTable data = new DataTable();
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand command = new SqlCommand(sql, connection))
{
//指定CommandType
command.CommandType = commandType;
if (parameters != null)
{
foreach (SqlParameter parameter in parameters)
{
command.Parameters.Add(parameter);
}
}
//实例化SqlDataAdapter
SqlDataAdapter adapter = new SqlDataAdapter(command);
//填充DataTable
                adapter.Fill(data);
}
}
return data;
}
#endregion
　　
2.连接式查询，获取DataReader。
　　利用SqlReader()返回DataReader对象实例。


View Code


#region 返回一个DataReader对象实例
///
/// 返回一个DataReader对象实例
///
/// 要查询的SQL文本命令
/// DataReader对象实例
public SqlDataReader ExecuteReader(string sql)
{
return ExecuteReader(sql, CommandType.Text, null);
}
///
/// 返回一个DataReader对象实例
///
/// 要查询的SQL文本命令
/// 要执行的查询语句的类型，存储过程或SQL文本命令
/// DataReader对象实例
public SqlDataReader ExecuteReader(string sql, CommandType commandType)
{
return ExecuteReader(sql, commandType, null);
}
///
/// 返回一个DataReader对象实例
///
/// 要查询的SQL文本命令
/// 要执行的查询语句的类型，存储过程或SQL文本命令
/// T-SQL语句或存储过程的参数数组
/// DataReader对象实例
public SqlDataReader ExecuteReader(string sql, CommandType commandType, SqlParameter[] parameters)
{
SqlConnection connection = new SqlConnection(connectionString);
SqlCommand command = new SqlCommand(sql, connection);
if (parameters != null)
{
foreach (SqlParameter parameter in parameters)
{
command.Parameters.Add(parameter);
}
}
connection.Open();
//参数CommandBehavior.CloseConnection表示，关闭Reader对象的同时关闭Connection对象
return command.ExecuteReader(CommandBehavior.CloseConnection);
}
#endregion
　　
3.查询结果只有1行1列，获取单一数据。
　　利用SqlCommand的ExecuteScalar()。


View Code


#region 执行查询结果，返回第一行的第一列
///
/// 执行查询结果，返回第一行的第一列
///
/// 要查询的SQL文本命令
/// 返回第一行的第一列
public object ExecuteScalar(string sql)
{
return ExecuteScalar(sql, CommandType.Text, null);
}
///
/// 执行查询结果，返回第一行的第一列
///
/// 要查询的SQL文本命令
/// 要执行的查询语句的类型，存储过程或SQL文本命令
/// 返回第一行的第一列
public object ExecuteScalar(string sql, CommandType commandType)
{
return ExecuteScalar(sql, commandType, null);
}
///
/// 执行查询结果，返回第一行的第一列
///
/// 要查询的SQL文本命令
/// 要执行的查询语句的类型，存储过程或SQL文本命令
/// T-SQL语句或存储过程的参数数组
/// 返回第一行的第一列
public object ExecuteScalar(string sql, CommandType commandType, SqlParameter[] parameters)
{
object result = null;
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand command = new SqlCommand(sql, connection))
{
command.CommandType = commandType;
if (parameters != null)
{
foreach (SqlParameter parameter in parameters)
{
command.Parameters.Add(parameter);
}
}
connection.Open();
result = command.ExecuteScalar();
}
}
return result;
}
#endregion
　　
4.对数据库进行增、删、改操作，进行数据编辑。
　　利用ExecuteNonQuery()。


View Code


#region 对数据库进行增删改操作
///
/// 对数据库进行增删改操作
///
/// 要执行的SQL文本命令
/// 返回受影响的函数
public int ExecuteNonQuery(string sql)
{
return ExecuteNonQuery(sql, CommandType.Text, null);
}
///
/// 对数据库进行增删改操作
///
/// 要执行的SQL文本命令
/// 要执行的查询语句的类型，存储过程或SQL文本命令
/// 返回受影响的函数
public int ExecuteNonQuery(string sql, CommandType commandType)
{
return ExecuteNonQuery(sql, commandType, null);
}
///
/// 对数据库进行增删改操作
///
/// 要执行的SQL文本命令
/// 要执行的查询语句的类型，存储过程或SQL文本命令
/// T-SQL语句或存储过程的参数数组
/// 返回受影响的函数
public int ExecuteNonQuery(string sql, CommandType commandType, SqlParameter[] parameters)
{
int count = 0;
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand command = new SqlCommand(sql, connection))
{
command.CommandType = commandType;
if (parameters != null)
{
foreach (SqlParameter parameter in parameters)
{
command.Parameters.Add(parameter);
}
}
connection.Open();
count = command.ExecuteNonQuery();
}
}
return count;
}

#endregion
　　
5.判断与数据库是否连接（更新）


View Code


#region 判断数据库是否连接
///
/// 判断数据库是否连接
///
/// 是否连接
public bool IsConnected()
{
SqlConnection connection = new SqlConnection(connectionString);
try
{
if (connection.State != ConnectionState.Open)
{
connection.Open();
}
return true;
}
catch
{
return false;
}
}
#endregion
　　
该类全部代码


View Code


using System;
using System.Data;
using System.Data.SqlClient;
using System.Configuration;
///
/// SqlDbHelper:操作SQL Server数据库的通用类
/// 作者：李宝亨
/// 日期：2012-03-15
/// Version:1.0
///
public class SqlDbHelper
{
#region 字段
///
/// 私有字段
///
private string connectionString;
#endregion
#region 属性
///
/// 公共属性 数据库连接字符串
///
public string ConnectiongString
{
set { connectionString = value; }
}
#endregion
#region 构造函数
///
/// 构造函数
///
public SqlDbHelper()
{
//修改connectionString为项目中的数据库连接字符串
//connectionString="";
    }
///
/// 构造函数
///
/// 数据库连接字符串
public SqlDbHelper(string strConnectionString)
{
connectionString = strConnectionString;
}
#endregion
#region 判断数据库是否连接
///
/// 判断数据库是否连接
///
/// 是否连接
public bool IsConnected()
{
SqlConnection connection = new SqlConnection(connectionString);
try
{
if (connection.State != ConnectionState.Open)
{
connection.Open();
}
return true;
}
catch
{
return false;
}
}
#endregion
#region 执行一个查询，并返回结果集
///
/// 执行一个查询，并返回结果集
///
/// 要查询的SQL文本命令
/// 查询结果集
public DataTable ExecuteDataTable(string sql)
{
return ExecuteDataTable(sql, CommandType.Text, null);
}
///
/// 执行一个查询，并返回结果集
///
/// 要查询的SQL文本命令
/// 查询语句类型，存储过程或SQL文本命令
/// 查询结果集
public DataTable ExecuteDataTable(string sql, CommandType commandType)
{
return ExecuteDataTable(sql, commandType, null);
}
///
/// 执行一个查询，并返回结果集
///
/// 要查询的SQL文本命令
/// 查询语句类型，存储过程或SQL文本命令
/// T-SQL语句或存储过程的参数组
/// 查询结果集
public DataTable ExecuteDataTable(string sql, CommandType commandType, SqlParameter[] parameters)
{
//实例化DataTable，用于装载查询结果集
DataTable data = new DataTable();
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand command = new SqlCommand(sql, connection))
{
//指定CommandType
command.CommandType = commandType;
if (parameters != null)
{
foreach (SqlParameter parameter in parameters)
{
command.Parameters.Add(parameter);
}
}
//实例化SqlDataAdapter
SqlDataAdapter adapter = new SqlDataAdapter(command);
//填充DataTable
                adapter.Fill(data);
}
}
return data;
}
#endregion
#region 返回一个DataReader对象实例
///
/// 返回一个DataReader对象实例
///
/// 要查询的SQL文本命令
/// DataReader对象实例
public SqlDataReader ExecuteReader(string sql)
{
return ExecuteReader(sql, CommandType.Text, null);
}
///
/// 返回一个DataReader对象实例
///
/// 要查询的SQL文本命令
/// 要执行的查询语句的类型，存储过程或SQL文本命令
/// DataReader对象实例
public SqlDataReader ExecuteReader(string sql, CommandType commandType)
{
return ExecuteReader(sql, commandType, null);
}
///
/// 返回一个DataReader对象实例
///
/// 要查询的SQL文本命令
/// 要执行的查询语句的类型，存储过程或SQL文本命令
/// T-SQL语句或存储过程的参数数组
/// DataReader对象实例
public SqlDataReader ExecuteReader(string sql, CommandType commandType, SqlParameter[] parameters)
{
SqlConnection connection = new SqlConnection(connectionString);
SqlCommand command = new SqlCommand(sql, connection);
if (parameters != null)
{
foreach (SqlParameter parameter in parameters)
{
command.Parameters.Add(parameter);
}
}
connection.Open();
//参数CommandBehavior.CloseConnection表示，关闭Reader对象的同时关闭Connection对象
return command.ExecuteReader(CommandBehavior.CloseConnection);
}
#endregion
#region 执行查询结果，返回第一行的第一列
///
/// 执行查询结果，返回第一行的第一列
///
/// 要查询的SQL文本命令
/// 返回第一行的第一列
public object ExecuteScalar(string sql)
{
return ExecuteScalar(sql, CommandType.Text, null);
}
///
/// 执行查询结果，返回第一行的第一列
///
/// 要查询的SQL文本命令
/// 要执行的查询语句的类型，存储过程或SQL文本命令
/// 返回第一行的第一列
public object ExecuteScalar(string sql, CommandType commandType)
{
return ExecuteScalar(sql, commandType, null);
}
///
/// 执行查询结果，返回第一行的第一列
///
/// 要查询的SQL文本命令
/// 要执行的查询语句的类型，存储过程或SQL文本命令
/// T-SQL语句或存储过程的参数数组
/// 返回第一行的第一列
public object ExecuteScalar(string sql, CommandType commandType, SqlParameter[] parameters)
{
object result = null;
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand command = new SqlCommand(sql, connection))
{
command.CommandType = commandType;
if (parameters != null)
{
foreach (SqlParameter parameter in parameters)
{
command.Parameters.Add(parameter);
}
}
connection.Open();
result = command.ExecuteScalar();
}
}
return result;
}
#endregion
#region 对数据库进行增删改操作
///
/// 对数据库进行增删改操作
///
/// 要执行的SQL文本命令
/// 返回受影响的函数
public int ExecuteNonQuery(string sql)
{
return ExecuteNonQuery(sql, CommandType.Text, null);
}
///
/// 对数据库进行增删改操作
///
/// 要执行的SQL文本命令
/// 要执行的查询语句的类型，存储过程或SQL文本命令
/// 返回受影响的函数
public int ExecuteNonQuery(string sql, CommandType commandType)
{
return ExecuteNonQuery(sql, commandType, null);
}
///
/// 对数据库进行增删改操作
///
/// 要执行的SQL文本命令
/// 要执行的查询语句的类型，存储过程或SQL文本命令
/// T-SQL语句或存储过程的参数数组
/// 返回受影响的函数
public int ExecuteNonQuery(string sql, CommandType commandType, SqlParameter[] parameters)
{
int count = 0;
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand command = new SqlCommand(sql, connection))
{
command.CommandType = commandType;
if (parameters != null)
{
foreach (SqlParameter parameter in parameters)
{
command.Parameters.Add(parameter);
}
}
connection.Open();
count = command.ExecuteNonQuery();
}
}
return count;
}

#endregion
}
　　
　　点此下载SqlDbHelper.cs


　　感谢@酷小孩和各位园友的指正和支持，代码已修正!