注:本文轉(zhuǎn)自
http://www.tzwhx.com/newOperate/html/3/31/312/13080.html
Visual C# 動態(tài)操作 SQL Server 數(shù)據(jù)庫實(shí)例教程:通用數(shù)據(jù)訪問類(SqlHelper)
本文介紹的通用數(shù)據(jù)庫訪問類,是本人的
個人網(wǎng)站
實(shí)際使用的一個基類,它是一組通用的訪問數(shù)據(jù)庫的代碼集,在本人網(wǎng)站對數(shù)據(jù)庫的訪問絕大部分都使用這一個類。其主要功能有:
1.
判斷數(shù)據(jù)庫是否存在
?
2.
判斷數(shù)據(jù)庫表是否存在
?
3.
判斷數(shù)據(jù)庫存儲過程是否存在
?
4.
判斷視圖是否存在
?
5.自動創(chuàng)建數(shù)據(jù)庫
6.自動創(chuàng)建數(shù)據(jù)庫表、存儲過程
7.不帶參數(shù)的 SQL 語句ExecuteNonQuery的執(zhí)行方法
8.執(zhí)行一條不返回結(jié)果的SqlCommand。通過指定專用的連接字符串,執(zhí)行一個不需要返回值的SqlCommand命令。
9.執(zhí)行一條不返回結(jié)果的SqlCommand。通過一個已經(jīng)存在的數(shù)據(jù)庫事件處理
10執(zhí)行一條不返回結(jié)果的SqlCommand,通過一個已經(jīng)存在的數(shù)據(jù)庫事物處理
11.執(zhí)行一條返回結(jié)果集的SqlCommand命令,通過專用的連接字符串。
12.執(zhí)行一條返回第一條記錄第一列的SqlCommand命令,通過專用的連接字符串。
13.執(zhí)行一條返回第一條記錄第一列的SqlCommand命令,通過已經(jīng)存在的數(shù)據(jù)庫連接。
其代碼清單如下:
using System;
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Collections;
using System.Data.SqlClient;
///
/// 數(shù)據(jù)庫的通用訪問代碼
/// 此類為抽象類,不允許實(shí)例化,在應(yīng)用時直接調(diào)用即可
///
public abstract class SqlHelper
{
//獲取數(shù)據(jù)庫連接字符串,其屬于靜態(tài)變量且只讀,項(xiàng)目中所有文檔可以直接使用,但不能修改
public static readonly string ConnectionStringLocalTransaction = ConfigurationManager.ConnectionStrings["MysqldataConnectionString"].ConnectionString;
// 哈希表用來存儲緩存的參數(shù)信息,哈希表可以存儲任意類型的參數(shù)。
private static Hashtable parmCache = Hashtable.Synchronized(new Hashtable());
///
///判斷數(shù)據(jù)庫是否存在
/// 通過指定專用的連接字符串,執(zhí)行一個不需要返回值的SqlCommand命令。
///
///
/// 使用示例:
/// bool databaseExist = SqlHelper.CheckExistsDatebase(dataBaseNameStr);
///
///
///
public static bool CheckExistsDatebase(string dataBaseName)
{
string connstring = SqlHelper.ConnectionStringLocalTransaction;
String dataBaseNameStr = "select count(1) From master.dbo.sysdatabases where name='" + dataBaseName + "'";
using (SqlConnection con = new SqlConnection(connstring))
{
con.Open();
SqlCommand cmd = new SqlCommand(dataBaseNameStr, con);
int result = Convert.ToInt32(cmd.ExecuteScalar());
if (result == 0)
{
return false;
}
else
{
return true;
}
}
}
///
返回頁頭
///判斷數(shù)據(jù)庫表是否存在
/// 通過指定專用的連接字符串,執(zhí)行一個不需要返回值的SqlCommand命令。
///
///
/// 使用示例:
/// bool databaseExist = SqlHelper.CheckExistsDatebase(dataBaseNameStr);
///
///
///
public static bool CheckExistsTable(string dataBaseNameStr, string tablename)
{
string connstring = "server=“服務(wù)器名”;database='" + dataBaseNameStr + "'" + ";Trusted_Connection=SSPI";
String tableNameStr = "select count(1) from sysobjects where name = '" + tablename + "'";
using (SqlConnection con = new SqlConnection(connstring))
{
con.Open();
SqlCommand cmd = new SqlCommand(tableNameStr, con);
int result = Convert.ToInt32(cmd.ExecuteScalar());
if (result == 0)
{
return false;
}
else
{
return true;
}
}
}
///
返回頁頭
///判斷數(shù)據(jù)庫存儲過程是否存在
/// 通過指定專用的連接字符串,執(zhí)行一個不需要返回值的SqlCommand命令。
///
///
/// 使用示例:
/// bool databaseExist = SqlHelper.CheckExistsDatebase(dataBaseNameStr);
///
///
///
///
public static bool CheckExistsProc(string dataBaseNameStr, string procName)
{
string connstring = "server=“服務(wù)器名”;database='" + dataBaseNameStr + "'" + ";Trusted_Connection=SSPI";
//String procNameStr = "select count(1) from sysobjects where name = '" + procName + "'";
String procNameStr = "select count(1) from sysobjects where name = '" + procName + "'" + " AND type = 'P'";
using (SqlConnection con = new SqlConnection(connstring))
{
con.Open();
SqlCommand cmd = new SqlCommand(procNameStr, con);
int result = Convert.ToInt32(cmd.ExecuteScalar());
if (result == 0)
{
return false;
//不存在
}
else
{
con.Close();
return true;
//存在
}
}
}
///
返回頁頭
///判斷視圖是否存在
///
///
/// 使用示例:
/// bool databaseExist = SqlHelper.CheckExistsDatebase(dataBaseNameStr);
///
///
///
///
public static bool CheckExistsView(string dataBaseNameStr, string tablename, string ViewName)
{
string connstring = "server=“服務(wù)器名”;database='" + dataBaseNameStr + "'" + ";Trusted_Connection=SSPI";
String viewNameStr = "select count(1) from sysobjects where name = '" + ViewName + "'" + " AND type = 'V'";
using (SqlConnection con = new SqlConnection(connstring))
{
con.Open();
SqlCommand cmd = new SqlCommand(viewNameStr, con);
int result = Convert.ToInt32(cmd.ExecuteScalar());
if (result == 0)
{
return false;
//不存在
}
else
{
con.Close();
return true;
//存在
}
}
}
///
返回頁頭
///調(diào)用ExecuteNonQuery()執(zhí)行 創(chuàng)建數(shù)據(jù)庫
/// 通過指定專用的連接字符串,執(zhí)行一個不需要返回值的SqlCommand命令。
///
///
/// 使用示例:
/// SqlHelper.CreateSqlDatabase(connstring, "master", CreateStr);
///
///
///
///
///
public static bool CreateSqlDatabase(string connstring, string DatabaseName, string CreateStr)
{
//
using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connstring))
{
SqlCommand Command = new System.Data.SqlClient.SqlCommand(CreateStr, conn);
conn.Open();
Command.Connection.ChangeDatabase(DatabaseName);
try
{
Command.ExecuteNonQuery();
}
catch (System.Exception ex)
{
Command.Connection.Close();
throw ex;
}
finally
{
Command.Connection.Close();
}
}
return true;
}
///
///調(diào)用ExecuteNonQuery()執(zhí)行 創(chuàng)建數(shù)據(jù)庫表、存儲過程
/// 通過指定專用的連接字符串,執(zhí)行一個不需要返回值的SqlCommand命令。
///
///
/// 使用示例:
/// SqlHelper.CreateSqlTable(connstring, TableStr);
///
///
///
///
public static bool CreateSqlTable(string connstring, string CreateStr)
{
//
using (SqlConnection conn = new SqlConnection(connstring))
{
SqlCommand Command = new SqlCommand(CreateStr, conn);
conn.Open();
try
{
Command.ExecuteNonQuery();
return true;
}
catch (System.Exception ex)
{
return false;
}
finally
{
Command.Connection.Close();
}
}
}
///
///不帶參數(shù)的 SQL 語句ExecuteNonQuery的執(zhí)行方法
/// 通過指定專用的連接字符串,執(zhí)行一個不需要返回值的SqlCommand命令。
/// 使用參數(shù)數(shù)組形式提供參數(shù)列表
///
///
/// 使用示例:
/// int result = ExecuteNonQuery(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
///
///
///
///
///
///
返回一個數(shù)值表示此SqlCommand命令執(zhí)行后影響的行數(shù)
public static int ExecuteNonQuery(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{
SqlCommand cmd = new SqlCommand();
using (SqlConnection conn = new SqlConnection(connectionString))
{
//通過PrePareCommand方法將參數(shù)逐個加入到SqlCommand的參數(shù)集合中
PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters);
int val = cmd.ExecuteNonQuery();
//清空SqlCommand中的參數(shù)列表
cmd.Parameters.Clear();
return val;
}
}
///
///執(zhí)行一條不返回結(jié)果的SqlCommand,通過一個已經(jīng)存在的數(shù)據(jù)庫連接
/// 使用參數(shù)數(shù)組提供參數(shù)
///
///
/// 使用示例:
/// int result = ExecuteNonQuery(conn, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
///
///
///
///
///
///
返回一個數(shù)值表示此SqlCommand命令執(zhí)行后影響的行數(shù)
public static int ExecuteNonQuery(SqlConnection connection, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{
SqlCommand cmd = new SqlCommand();
PrepareCommand(cmd, connection, null, cmdType, cmdText, commandParameters);
int val = cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
return val;
}
///
/// 執(zhí)行一條不返回結(jié)果的SqlCommand,通過一個已經(jīng)存在的數(shù)據(jù)庫事物處理
/// 使用參數(shù)數(shù)組提供參數(shù)
///
///
/// 使用示例:
/// int result = ExecuteNonQuery(trans, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
///
///
///
///
///
///
返回一個數(shù)值表示此SqlCommand命令執(zhí)行后影響的行數(shù)
public static int ExecuteNonQuery(SqlTransaction trans, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{
SqlCommand cmd = new SqlCommand();
PrepareCommand(cmd, trans.Connection, trans, cmdType, cmdText, commandParameters);
int val = cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
return val;
}
///
/// 執(zhí)行一條返回結(jié)果集的SqlCommand命令,通過專用的連接字符串。
/// 使用參數(shù)數(shù)組提供參數(shù)
///
///
/// 使用示例:
/// SqlDataReader r = ExecuteReader(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
///
///
///
///
///
///
返回一個包含結(jié)果的SqlDataReader
public static SqlDataReader ExecuteReader(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{
SqlCommand cmd = new SqlCommand();
SqlConnection conn = new SqlConnection(connectionString);
// 在這里使用try/catch處理是因?yàn)槿绻椒ǔ霈F(xiàn)異常,則SqlDataReader就不存在,
//CommandBehavior.CloseConnection的語句就不會執(zhí)行,觸發(fā)的異常由catch捕獲。
//關(guān)閉數(shù)據(jù)庫連接,并通過throw再次引發(fā)捕捉到的異常。
try
{
PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters);
SqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
cmd.Parameters.Clear();
return rdr;
}
catch
{
conn.Close();
throw;
}
}
///
/// 執(zhí)行一條返回第一條記錄第一列的SqlCommand命令,通過專用的連接字符串。
/// 使用參數(shù)數(shù)組提供參數(shù)
///
///
/// 使用示例:
/// Object obj = ExecuteScalar(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
///
///
///
///
///
///
返回一個object類型的數(shù)據(jù),可以通過 Convert.To{Type}方法轉(zhuǎn)換類型
public static object ExecuteScalar(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{
SqlCommand cmd = new SqlCommand();
using (SqlConnection connection = new SqlConnection(connectionString))
{
PrepareCommand(cmd, connection, null, cmdType, cmdText, commandParameters);
object val = cmd.ExecuteScalar();
cmd.Parameters.Clear();
return val;
}
}
///
/// 執(zhí)行一條返回第一條記錄第一列的SqlCommand命令,通過已經(jīng)存在的數(shù)據(jù)庫連接。
/// 使用參數(shù)數(shù)組提供參數(shù)
///
///
/// 使用示例:
/// Object obj = ExecuteScalar(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
///
///
///
///
///
///
返回一個object類型的數(shù)據(jù),可以通過 Convert.To{Type}方法轉(zhuǎn)換類型
public static object ExecuteScalar(SqlConnection connection, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{
SqlCommand cmd = new SqlCommand();
PrepareCommand(cmd, connection, null, cmdType, cmdText, commandParameters);
object val = cmd.ExecuteScalar();
cmd.Parameters.Clear();
return val;
}
///
/// 緩存參數(shù)數(shù)組
///
///
///
public static void CacheParameters(string cacheKey, params SqlParameter[] commandParameters)
{
parmCache[cacheKey] = commandParameters;
}
///
/// 獲取被緩存的參數(shù)
///
///
///
返回緩存的參數(shù)數(shù)組
public static SqlParameter[] GetCachedParameters(string cacheKey)
{
SqlParameter[] cachedParms = (SqlParameter[])parmCache[cacheKey];
if (cachedParms == null)
return null;
//新建一個參數(shù)的克隆列表
SqlParameter[] clonedParms = new SqlParameter[cachedParms.Length];
//通過循環(huán)為克隆參數(shù)列表賦值
for (int i = 0, j = cachedParms.Length; i < j; i++)
//使用clone方法復(fù)制參數(shù)列表中的參數(shù)
clonedParms[i] = (SqlParameter)((ICloneable)cachedParms[i]).Clone();
return clonedParms;
}
///
/// 為執(zhí)行命令準(zhǔn)備命令參數(shù)
///
///
///
///
///
///
///
private static void PrepareCommand(SqlCommand cmd, SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText, SqlParameter[] cmdParms)
{
//判斷數(shù)據(jù)庫連接狀態(tài)
if (conn.State != ConnectionState.Open)
conn.Open();
cmd.Connection = conn;
cmd.CommandText = cmdText;
//判斷是否需要事物處理
if (trans != null)
cmd.Transaction = trans;
cmd.CommandType = cmdType;
if (cmdParms != null)
{
foreach (SqlParameter parm in cmdParms)
cmd.Parameters.Add(parm);
}
}
}
返回頁頭
以上代碼中,大多數(shù)都加了注釋,Using除處理對命名空間的引用外,當(dāng) Using用“{}”定義一個范圍,在語句完成時會自動釋放語句內(nèi)所使用的資源。參數(shù)數(shù)據(jù)的添加由PrepareCommand方法來完成。
C# 通用數(shù)據(jù)訪問類(SqlHelper)