下面給出了一個C#操作MS SQL Server 數據庫的通用類，通過該類可以對數據庫進行任何操作，包括執行SQL語句、執行存儲過程。以下是其詳細實現過程，希望大家共同修改優化之。稍后將介紹如何使用它實現N層的程序設計。
配置web.config文件的鏈接參數
<appSettings>
<!--
connStr參數設置，事例說明：
（1）Sql server數據庫，例如“server=local;database=test;uid=sa;pwd=;”
（2）Access數據庫，例如“data/ex.mdb; user id='admin';Jet OLEDB:database password='admin';”
-->
<add key="connStr" value="server=127.0.0.1;database=DbName;uid=sa;pwd=;" />
</appSettings>
C#代碼
using System;
using System.Data;
using System.Data.SqlClient;
namespace Com.LXJ.Database
{
/// <summary>
/// ConnDB 的摘要說明。
/// </summary>
public class ConnDB
{
protected SqlConnection Connection;
private string connectionString;
/// <summary>
/// 默認構造函數
/// </summary>
public ConnDB()
{
string connStr;
connStr = System.Configuration.ConfigurationSettings.AppSettings["connStr"].ToString();
connectionString = connStr;
Connection = new SqlConnection(connectionString);
}
/// <summary>
/// 帶參數的構造函數
/// </summary>
/// <param name="newConnectionString">數據庫聯接字符串</param>
public ConnDB(string newConnectionString)
{
connectionString = newConnectionString;
Connection = new SqlConnection(connectionString);
}
/// <summary>
/// 完成SqlCommand對象的實例化
/// </summary>
/// <param name="storedProcName"></param>
/// <param name="parameters"></param>
/// <returns></returns>
private SqlCommand BuildCommand(string storedProcName,IDataParameter[] parameters)
{
SqlCommand command = BuildQueryCommand(storedProcName,parameters);
command.Parameters.Add(new SqlParameter("ReturnValue",SqlDbType.Int,4,ParameterDirection.ReturnValue,false,0,0,string.Empty,DataRowVersion.Default,null));
return command;
}
/// <summary>
/// 創建新的SQL命令對象(存儲過程)
/// </summary>
/// <param name="storedProcName"></param>
/// <param name="parameters"></param>
/// <returns></returns>
private SqlCommand BuildQueryCommand(string storedProcName,IDataParameter[] parameters)
{
SqlCommand command = new SqlCommand(storedProcName,Connection);
command.CommandType = CommandType.StoredProcedure;
foreach (SqlParameter parameter in parameters)
{
command.Parameters.Add(parameter);
}
return command;
}
/// <summary>
/// 執行存儲過程,無返回值
/// </summary>
/// <param name="storedProcName"></param>
/// <param name="parameters"></param>
public void ExecuteProcedure(string storedProcName,IDataParameter[] parameters)
{
Connection.Open();
SqlCommand command;
command=BuildQueryCommand(storedProcName,parameters);
command.ExecuteNonQuery();
Connection.Close();
}
/// <summary>
/// 執行存儲過程，返回執行操作影響的行數目
/// </summary>
/// <param name="storedProcName"></param>
/// <param name="parameters"></param>
/// <param name="rowsAffected"></param>
/// <returns></returns>
public int RunProcedure(string storedProcName,IDataParameter[] parameters,out int rowsAffected)
{
int result;
Connection.Open();
SqlCommand command = BuildCommand(storedProcName,parameters);
rowsAffected = command.ExecuteNonQuery();
result = (int)command.Parameters["ReturnValue"].Value;
Connection.Close();
return result;
}
/// <summary>
/// 重載RunProcedure把執行存儲過程的結果放在SqlDataReader中
/// </summary>
/// <param name="storedProcName"></param>
/// <param name="parameters"></param>
/// <returns></returns>
public SqlDataReader RunProcedure(string storedProcName,IDataParameter[] parameters)
{
SqlDataReader returnReader;
Connection.Open();
SqlCommand command = BuildQueryCommand(storedProcName,parameters);
command.CommandType = CommandType.StoredProcedure;
returnReader = command.ExecuteReader(CommandBehavior.CloseConnection);
return returnReader;
}
/// <summary>
/// 重載RunProcedure把執行存儲過程的結果存儲在DataSet中和表tableName為可選參數
/// </summary>
/// <param name="storedProcName"></param>
/// <param name="parameters"></param>
/// <param name="tableName"></param>
/// <returns></returns>
public DataSet RunProcedure(string storedProcName,IDataParameter[] parameters,params string[] tableName)
{
DataSet dataSet = new DataSet();
Connection.Open();
SqlDataAdapter sqlDA = new SqlDataAdapter();
sqlDA.SelectCommand = BuildQueryCommand(storedProcName,parameters);
string flag;
flag = "";
for(int i=0;i<tableName.Length;i++)
flag = tableName[i];
if (flag!="")
sqlDA.Fill(dataSet,tableName[0]);
else
sqlDA.Fill(dataSet);
Connection.Close();
return dataSet;
}
/// <summary>
/// 執行SQL語句，返回數據到DataSet中
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public DataSet ReturnDataSet(string sql)
{
DataSet dataSet=new DataSet();
Connection.Open();
SqlDataAdapter sqlDA=new SqlDataAdapter(sql,Connection);
sqlDA.Fill(dataSet,"objDataSet");
Connection.Close();
return dataSet;
}
/// <summary>
/// 執行SQL語句，返回 DataReader
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public SqlDataReader ReturnDataReader(String sql)
{
Connection.Open();
SqlCommand command = new SqlCommand(sql,Connection);
SqlDataReader dataReader = command.ExecuteReader();
return dataReader;
}
/// <summary>
/// 執行SQL語句，返回記錄數
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public int ReturnRecordCount(string sql)
{
int recordCount = 0;
Connection.Open();
SqlCommand command = new SqlCommand(sql,Connection);
SqlDataReader dataReader = command.ExecuteReader();
while(dataReader.Read())
{
recordCount++;
}
dataReader.Close();
Connection.Close();
return recordCount;
}
/// <summary>
/// 執行SQL語句
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public bool EditDatabase(string sql)
{
bool successState = false;
Connection.Open();
SqlTransaction myTrans = Connection.BeginTransaction();
SqlCommand command = new SqlCommand(sql,Connection,myTrans);
try
{
command.ExecuteNonQuery();
myTrans.Commit();
successState = true;
}
catch
{
myTrans.Rollback();
}
finally
{
Connection.Close();
}
return successState;
}
/// <summary>
/// 關閉數據庫聯接
/// </summary>
public void Close()
{
Connection.Close();
}
}//end class
}//end namespace
內容轉載來源於：http://blog.csdn.net/ecjtuync/article/details/1584535