亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

C# 通用數據訪問類（SqlHelper）

系統 2008 0

注:本文轉自 http://www.tzwhx.com/newOperate/html/3/31/312/13080.html
Visual C# 動態操作 SQL Server 數據庫實例教程：通用數據訪問類（SqlHelper）

本文介紹的通用數據庫訪問類，是本人的 個人網站 實際使用的一個基類，它是一組通用的訪問數據庫的代碼集，在本人網站對數據庫的訪問絕大部分都使用這一個類。其主要功能有：

1. 判斷數據庫是否存在 ？

2. 判斷數據庫表是否存在 ？

3. 判斷數據庫存儲過程是否存在 ？

4. 判斷視圖是否存在 ？

5.自動創建數據庫

6.自動創建數據庫表、存儲過程

7.不帶參數的 SQL 語句ExecuteNonQuery的執行方法

8.執行一條不返回結果的SqlCommand。通過指定專用的連接字符串，執行一個不需要返回值的SqlCommand命令。

9.執行一條不返回結果的SqlCommand。通過一個已經存在的數據庫事件處理

10執行一條不返回結果的SqlCommand，通過一個已經存在的數據庫事物處理

11.執行一條返回結果集的SqlCommand命令，通過專用的連接字符串。

12.執行一條返回第一條記錄第一列的SqlCommand命令，通過專用的連接字符串。

13.執行一條返回第一條記錄第一列的SqlCommand命令，通過已經存在的數據庫連接。

其代碼清單如下：

using System;
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Collections;
using System.Data.SqlClient;

///


/// 數據庫的通用訪問代碼
/// 此類為抽象類，不允許實例化，在應用時直接調用即可
///
public abstract class SqlHelper
{
//獲取數據庫連接字符串，其屬于靜態變量且只讀，項目中所有文檔可以直接使用，但不能修改
public static readonly string ConnectionStringLocalTransaction = ConfigurationManager.ConnectionStrings["MysqldataConnectionString"].ConnectionString;

// 哈希表用來存儲緩存的參數信息，哈希表可以存儲任意類型的參數。
private static Hashtable parmCache = Hashtable.Synchronized(new Hashtable());

///


///判斷數據庫是否存在
/// 通過指定專用的連接字符串，執行一個不需要返回值的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;
}
}
}
///

返回頁頭
///判斷數據庫表是否存在
/// 通過指定專用的連接字符串，執行一個不需要返回值的SqlCommand命令。
///
///
/// 使用示例：
/// bool databaseExist = SqlHelper.CheckExistsDatebase(dataBaseNameStr);
///
///
///
public static bool CheckExistsTable(string dataBaseNameStr, string tablename)
{
string connstring = "server=“服務器名”;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;
}
}
}
/// 返回頁頭
///判斷數據庫存儲過程是否存在
/// 通過指定專用的連接字符串，執行一個不需要返回值的SqlCommand命令。
///
///
/// 使用示例：
/// bool databaseExist = SqlHelper.CheckExistsDatebase(dataBaseNameStr);
///
///
///
///
public static bool CheckExistsProc(string dataBaseNameStr, string procName)
{
string connstring = "server=“服務器名”;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=“服務器名”;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;
//存在
}
}
}
/// 返回頁頭
///調用ExecuteNonQuery()執行 創建數據庫
/// 通過指定專用的連接字符串，執行一個不需要返回值的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;
}
///
///調用ExecuteNonQuery()執行 創建數據庫表、存儲過程
/// 通過指定專用的連接字符串，執行一個不需要返回值的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();
}
}
}

///


///不帶參數的 SQL 語句ExecuteNonQuery的執行方法
/// 通過指定專用的連接字符串，執行一個不需要返回值的SqlCommand命令。
/// 使用參數數組形式提供參數列表
///
///
/// 使用示例：
/// int result = ExecuteNonQuery(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
///
///
///
///
///
/// 返回一個數值表示此SqlCommand命令執行后影響的行數
public static int ExecuteNonQuery(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{

SqlCommand cmd = new SqlCommand();
using (SqlConnection conn = new SqlConnection(connectionString))
{
//通過PrePareCommand方法將參數逐個加入到SqlCommand的參數集合中
PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters);
int val = cmd.ExecuteNonQuery();

//清空SqlCommand中的參數列表
cmd.Parameters.Clear();
return val;
}
}

///


///執行一條不返回結果的SqlCommand，通過一個已經存在的數據庫連接
/// 使用參數數組提供參數
///
///
/// 使用示例：
/// int result = ExecuteNonQuery(conn, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
///
///
///
///
///
/// 返回一個數值表示此SqlCommand命令執行后影響的行數
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;
}

///


/// 執行一條不返回結果的SqlCommand，通過一個已經存在的數據庫事物處理
/// 使用參數數組提供參數
///
///
/// 使用示例：
/// int result = ExecuteNonQuery(trans, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
///
///
///
///
///
/// 返回一個數值表示此SqlCommand命令執行后影響的行數
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;
}

///


/// 執行一條返回結果集的SqlCommand命令，通過專用的連接字符串。
/// 使用參數數組提供參數
///
///
/// 使用示例：
/// SqlDataReader r = ExecuteReader(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
///
///
///
///
///
/// 返回一個包含結果的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處理是因為如果方法出現異常，則SqlDataReader就不存在，
//CommandBehavior.CloseConnection的語句就不會執行，觸發的異常由catch捕獲。
//關閉數據庫連接，并通過throw再次引發捕捉到的異常。
try
{
PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters);
SqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
cmd.Parameters.Clear();
return rdr;
}
catch
{
conn.Close();
throw;
}
}

///


/// 執行一條返回第一條記錄第一列的SqlCommand命令，通過專用的連接字符串。
/// 使用參數數組提供參數
///
///
/// 使用示例：
/// Object obj = ExecuteScalar(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
///
///
///
///
///
/// 返回一個object類型的數據，可以通過 Convert.To{Type}方法轉換類型
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;
}
}

///


/// 執行一條返回第一條記錄第一列的SqlCommand命令，通過已經存在的數據庫連接。
/// 使用參數數組提供參數
///
///
/// 使用示例：
/// Object obj = ExecuteScalar(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
///
///
///
///
///
/// 返回一個object類型的數據，可以通過 Convert.To{Type}方法轉換類型
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;
}

///


/// 緩存參數數組
///
///
///
public static void CacheParameters(string cacheKey, params SqlParameter[] commandParameters)
{
parmCache[cacheKey] = commandParameters;
}

///


/// 獲取被緩存的參數
///
///
/// 返回緩存的參數數組
public static SqlParameter[] GetCachedParameters(string cacheKey)
{
SqlParameter[] cachedParms = (SqlParameter[])parmCache[cacheKey];

if (cachedParms == null)
return null;

//新建一個參數的克隆列表
SqlParameter[] clonedParms = new SqlParameter[cachedParms.Length];

//通過循環為克隆參數列表賦值
for (int i = 0, j = cachedParms.Length; i < j; i++)
//使用clone方法復制參數列表中的參數
clonedParms[i] = (SqlParameter)((ICloneable)cachedParms[i]).Clone();

return clonedParms;
}

///


/// 為執行命令準備命令參數
///
///
///
///
///
///
///
private static void PrepareCommand(SqlCommand cmd, SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText, SqlParameter[] cmdParms)
{

//判斷數據庫連接狀態
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);
}
}
} 返回頁頭

以上代碼中，大多數都加了注釋，Using除處理對命名空間的引用外，當 Using用“{}”定義一個范圍，在語句完成時會自動釋放語句內所使用的資源。參數數據的添加由PrepareCommand方法來完成。

C# 通用數據訪問類（SqlHelper）


更多文章、技術交流、商務合作、聯系博主

微信掃碼或搜索：z360901061

微信掃一掃加我為好友

QQ號聯系： 360901061

您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點擊下面給點支持吧，站長非常感激您！手機微信長按不能支付解決辦法：請將微信支付二維碼保存到相冊，切換到微信，然后點擊微信右上角掃一掃功能，選擇支付二維碼完成支付。

【本文對您有幫助就好】元

您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧，站長會非常 感謝您的哦！！！

發表我的評論
最新評論 總共0條評論
主站蜘蛛池模板： 四虎在线影视在线影库 | 欧美在线日韩在线 | 大杳蕉伊人狼人久久一本线 | 999在线免费视频 | 国产成人h片视频在线观看 国产成人h综合亚洲欧美在线 | 欧美黄视频在线观看 | 日韩欧美小视频 | 黄色成人免费观看 | 手机看片福利日韩国产 | 美国一级毛片aa | 伊人网站视频 | 亚洲欧美日韩国产精品久久 | 国产亚洲一区二区精品 | 一级无毛片 | 在线成人播放毛片 | 久久综合九色综合精品 | 99精品国产成人a∨免费看 | 欧美特级一级毛片 | 色网在线免费观看 | 高清欧美日本视频免费观看 | 亚洲香蕉国产高清在线播放 | 欧美日本高清动作片www网站 | 看日本真人一一级特黄毛片 | 操操操干干干 | 日本一区二区三区高清福利视频 | 亚洲精品久久99久久一 | 天天干夜夜夜 | 夜夜爱夜夜爽夜夜做夜夜欢 | 欧美精品亚洲人成在线观看 | 欧美黑人乱大交ⅹxxxxx | 激情综合婷婷亚洲图片 | 日韩a一级欧美一级在线播放 | 波多野结中文字幕在线69视频 | 欧美日本一区二区 | 精品国产一区二区二三区在线观看 | 亚洲人成影院午夜网站 | 久久青草社区 | 在线免费福利 | 国产精品久久久影院 | 亚洲精品高清在线一区二区三区 | 久久国产乱子伦免费精品 |