usingSystem.Collections.Generic;
usingSystem.Text;
usingSystem.Data;
usingSystem.Data.SqlClient;
usingSystem.Configuration;
namespaceADODoNETDemo
{
///
///针对SQLServer数据库操作的通用类
///作者：周公
///日期：2009-01-08
///Version:1.0
/// publicclassSqlDbHelper
{
privatestringconnectionString;
///
///设置数据库连接字符串
/// publicstringConnectionString
{
set{connectionString=value;}
}
///
///构造函数
/// publicSqlDbHelper()
:this(ConfigurationManager.ConnectionStrings["Conn"].ConnectionString)
{
}
///
///构造函数
/// ///
数据库连接字符串
publicSqlDbHelper(stringconnectionString)
{
this.connectionString=connectionString;
}
///
///执行一个查询，并返回结果集
///
///要执行的查询SQL文本命令
///返回查询结果集
publicDataTableExecuteDataTable(stringsql)
{
returnExecuteDataTable(sql,CommandType.Text,null);
}
///
///执行一个查询,并返回查询结果
///
///要执行的SQL语句
///要执行的查询语句的类型，如存储过程或者SQL文本命令
///返回查询结果集
publicDataTableExecuteDataTable(stringsql,CommandTypecommandType)
{
returnExecuteDataTable(sql,commandType,null);
}
///
///执行一个查询,并返回查询结果
///
///要执行的SQL语句
///要执行的查询语句的类型，如存储过程或者SQL文本命令
///Transact-SQL语句或存储过程的参数数组
///
publicDataTableExecuteDataTable(stringsql,CommandTypecommandType,SqlParameter[]parameters)
{
DataTabledata=newDataTable();//实例化DataTable，用于装载查询结果集
using(SqlConnectionconnection=newSqlConnection(connectionString))
{
using(SqlCommandcommand=newSqlCommand(sql,connection))
{
command.CommandType=commandType;//设置command的CommandType为指定的CommandType
//如果同时传入了参数，则添加这些参数
if(parameters!=null)
{
foreach(SqlParameterparameterinparameters)
{
command.Parameters.Add(parameter);
}
}
//通过包含查询SQL的SqlCommand实例来实例化SqlDataAdapter
SqlDataAdapteradapter=newSqlDataAdapter(command);
adapter.Fill(data);//填充DataTable
}
}
returndata;
}
///
///
///
///要执行的查询SQL文本命令
///
publicSqlDataReaderExecuteReader(stringsql)
{
returnExecuteReader(sql,CommandType.Text,null);
}
///
///
///
///要执行的SQL语句
///要执行的查询语句的类型，如存储过程或者SQL文本命令
///
publicSqlDataReaderExecuteReader(stringsql,CommandTypecommandType)
{
returnExecuteReader(sql,commandType,null);
}
///
///
///
///要执行的SQL语句
///要执行的查询语句的类型，如存储过程或者SQL文本命令
///Transact-SQL语句或存储过程的参数数组
///
publicSqlDataReaderExecuteReader(stringsql,CommandTypecommandType,SqlParameter[]parameters)
{
SqlConnectionconnection=newSqlConnection(connectionString);
SqlCommandcommand=newSqlCommand(sql,connection);
//如果同时传入了参数，则添加这些参数
if(parameters!=null)
{
foreach(SqlParameterparameterinparameters)
{
command.Parameters.Add(parameter);
}
}
connection.Open();
//CommandBehavior.CloseConnection参数指示关闭Reader对象时关闭与其关联的Connection对象
returncommand.ExecuteReader(CommandBehavior.CloseConnection);
}
///
///
///
///要执行的查询SQL文本命令
///
publicObjectExecuteScalar(stringsql)
{
returnExecuteScalar(sql,CommandType.Text,null);
}
///
///
///
///要执行的SQL语句
///要执行的查询语句的类型，如存储过程或者SQL文本命令
///
publicObjectExecuteScalar(stringsql,CommandTypecommandType)
{
returnExecuteScalar(sql,commandType,null);
}
///
///
///
///要执行的SQL语句
///要执行的查询语句的类型，如存储过程或者SQL文本命令
///Transact-SQL语句或存储过程的参数数组
///
publicObjectExecuteScalar(stringsql,CommandTypecommandType,SqlParameter[]parameters)
{
objectresult=null;
using(SqlConnectionconnection=newSqlConnection(connectionString))
{
using(SqlCommandcommand=newSqlCommand(sql,connection))
{
command.CommandType=commandType;//设置command的CommandType为指定的CommandType
//如果同时传入了参数，则添加这些参数
if(parameters!=null)
{
foreach(SqlParameterparameterinparameters)
{
command.Parameters.Add(parameter);
}
}
connection.Open();//打开数据库连接
result=command.ExecuteScalar();
}
}
returnresult;//返回查询结果的第一行第一列，忽略其它行和列
}
///
///对数据库执行增删改操作
///
///要执行的查询SQL文本命令
///
publicintExecuteNonQuery(stringsql)
{
returnExecuteNonQuery(sql,CommandType.Text,null);
}
///
///对数据库执行增删改操作
///
///要执行的SQL语句
///要执行的查询语句的类型，如存储过程或者SQL文本命令
///
publicintExecuteNonQuery(stringsql,CommandTypecommandType)
{
returnExecuteNonQuery(sql,commandType,null);
}
///
///对数据库执行增删改操作
///
///要执行的SQL语句
///要执行的查询语句的类型，如存储过程或者SQL文本命令
///Transact-SQL语句或存储过程的参数数组
///
publicintExecuteNonQuery(stringsql,CommandTypecommandType,SqlParameter[]parameters)
{
intcount=0;
using(SqlConnectionconnection=newSqlConnection(connectionString))
{
using(SqlCommandcommand=newSqlCommand(sql,connection))
{
command.CommandType=commandType;//设置command的CommandType为指定的CommandType
//如果同时传入了参数，则添加这些参数
if(parameters!=null)
{
foreach(SqlParameterparameterinparameters)
{
command.Parameters.Add(parameter);
}
}
connection.Open();//打开数据库连接
count=command.ExecuteNonQuery();
}
}
returncount;//返回执行增删改操作之后，数据库中受影响的行数
}
///
///返回当前连接的数据库中所有由用户创建的数据库
///
///
publicDataTableGetTables()
{
DataTabledata=null;
using(SqlConnectionconnection=newSqlConnection(connectionString))
{
connection.Open();//打开数据库连接
data=connection.GetSchema("Tables");
}
returndata;
}
}
}
