?? database.cs
字號:
using System;
using System.Data;
using System.Collections;
using System.Data.SqlClient;
using System.Configuration;
namespace MyLibrary.DataAccessLayer
{
// 數據庫接口類
public class DataBase
{
//私有變量，數據庫連接
protected SqlConnection Connection;
protected string ConnectionString;
//構造函數
public DataBase()
{
ConnectionString = ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;
}
//保護方法，打開數據庫連接
private void Open()
{
//判斷數據庫連接是否存在
if (Connection == null)
{
//不存在，新建并打開
Connection = new SqlConnection(ConnectionString);
Connection.Open();
}
else
{
//存在，判斷是否處于關閉狀態
if (Connection.State.Equals(ConnectionState.Closed))
Connection.Open(); //連接處于關閉狀態，重新打開
}
}
//公有方法，關閉數據庫連接
public void Close()
{
if (Connection.State.Equals(ConnectionState.Open))
{
Connection.Close(); //連接處于打開狀態，關閉連接
}
}
/// <summary>
/// 析構函數，釋放非托管資源
/// </summary>
~DataBase()
{
try
{
if (Connection != null)
Connection.Close();
}
catch{}
try
{
Dispose();
}
catch{}
}
//公有方法，釋放資源
public void Dispose()
{
if (Connection != null) // 確保連接被關閉
{
Connection.Dispose();
Connection = null;
}
}
//公有方法，根據Sql語句，返回是否查詢到記錄
public bool GetRecord(string XSqlString)
{
Open();
SqlDataAdapter adapter = new SqlDataAdapter(XSqlString, Connection);
DataSet dataset = new DataSet();
adapter.Fill(dataset);
Close();
if (dataset.Tables[0].Rows.Count > 0)
{
return true;
}
else
{
return false;
}
}
//公有方法，返回Sql語句獲得的數據值
//SqlString的格式：select count(*) from XXX where ...
// select max(XXX) from YYY where ...
public int GetRecordCount(string XSqlString)
{
string SCount;
Open();
SqlCommand Cmd = new SqlCommand(XSqlString,Connection);
SCount = Cmd.ExecuteScalar().ToString().Trim();
if (SCount=="")
SCount="0";
Close();
return Convert.ToInt32(SCount);
}
//公有方法，根據XWhere更新數據表XTableName中的某些紀錄
//XTableName--表名
//XHT--哈希表，鍵為字段名，值為字段值
public DataSet AdvancedSearch(string XTableName, Hashtable XHT)
{
int Count = 0;
string Fields = "";
foreach(DictionaryEntry Item in XHT)
{
if (Count != 0)
{
Fields += " and ";
}
Fields += Item.Key.ToString();
Fields += " like '%";
Fields += Item.Value.ToString();
Fields += "%'";
Count++;
}
Fields += " ";
string SqlString = "select * from " + XTableName + " where " + Fields;
Open();
SqlDataAdapter Adapter = new SqlDataAdapter(SqlString, Connection);
DataSet Ds = new DataSet();
Adapter.Fill(Ds);
Close();
return Ds;
}
//私有方法，獲得一個用來調用存儲過程的SqlCommand
//輸入：
// ProcName - 存儲過程名
// Params - 用來調用存儲過程的參數表
private SqlCommand CreateCommand(string ProcName, SqlParameter[] Prams)
{
Open();
SqlCommand Cmd = new SqlCommand(ProcName, Connection);
Cmd.CommandType = CommandType.StoredProcedure;
if (Prams != null)
{
foreach (SqlParameter Parameter in Prams)
Cmd.Parameters.Add(Parameter);
}
return Cmd;
}
//公有方法，實例化一個用于調用存儲過程的參數
//輸入：
// ParamName - 參數名稱
// DbType - 參數類型
// Size - 參數大小
// Direction - 傳遞方向
// Value - 值
public SqlParameter MakeParam(string ParamName, SqlDbType DbType, Int32 Size, ParameterDirection Direction, object Value)
{
SqlParameter Param;
if(Size > 0)
Param = new SqlParameter(ParamName, DbType, Size);
else Param = new SqlParameter(ParamName, DbType);
Param.Direction = Direction;
if (Value != null)
Param.Value = Value;
return Param;
}
//公有方法，實例化一個用于調用存儲過程的輸入參數
//輸入：
// ParamName - 參數名稱
// DbType - 參數類型
// Size - 參數大小
// Value - 值
public SqlParameter MakeInParam(string ParamName, SqlDbType DbType, int Size, object Value)
{
return MakeParam(ParamName, DbType, Size, ParameterDirection.Input, Value);
}
//公有方法，調用存儲過程(不帶參數)
//輸入：
// ProcName存儲過程名
//輸出：
// 對Update、Insert、Delete操作返回影響到的行數，其他情況為-1
public int RunProc(string ProcName)
{
int Count = -1;
SqlCommand Cmd = CreateCommand(ProcName, null);
Count = Cmd.ExecuteNonQuery();
Close();
return Count;
}
//公有方法，調用存儲過程(帶參數)
//輸入：
// ProcName - 存儲過程名
// Params - 用來調用存儲過程的參數表
//輸出：
// 對Update、Insert、Delete操作返回影響到的行數，其他情況為-1
public int RunProc(string ProcName, SqlParameter[] Params)
{
int Count = -1;
SqlCommand Cmd = CreateCommand(ProcName, Params);
Count = Cmd.ExecuteNonQuery();
Close();
return Count;
}
//公有方法，調用存儲過程(不帶參數)
//輸入：
// ProcName存儲過程名
//輸出：
// 將執行結果以SqlDataReader返回
//注意：使用后主意調用SqlDataReader.Close()方法
public SqlDataReader RunProcGetReader(string ProcName)
{
SqlCommand Cmd = CreateCommand(ProcName, null);
return Cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
}
//公有方法，調用存儲過程(帶參數)
//輸入：
// ProcName - 存儲過程名
// Params - 存儲過程需要的參數
//輸出：
// 將執行結果以SqlDataReader返回
//注意：使用后主意調用SqlDataReader.Close()方法
public SqlDataReader RunProcGetReader(string ProcName, SqlParameter[] Params)
{
SqlCommand Cmd = CreateCommand(ProcName, Params);
return Cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
}
//公有方法，調用存儲過程(帶參數)
//輸入：
// ProcName - 存儲過程名
// Params - 存儲過程需要的參數
//輸出：
// 將執行結果以SqlDataReader返回
//注意：使用后主意調用SqlDataReader.Close()方法
public int RunProcGetCount(string ProcName, SqlParameter[] Params)
{
SqlCommand Cmd = CreateCommand(ProcName, Params);
string SCount;
SCount = Cmd.ExecuteScalar().ToString().Trim();
if (SCount == "")
SCount = "0";
Close();
return Convert.ToInt32(SCount);
}
//公有方法，調用存儲過程(不帶參數)
//輸入：
// ProcName存儲過程名
//輸出：
// 將執行結果以DataSet返回
public DataSet GetDataSet(string ProcName)
{
Open();
SqlDataAdapter adapter = new SqlDataAdapter(ProcName, Connection);
DataSet dataset = new DataSet();
adapter.Fill(dataset);
Close();
return dataset;
}
//公有方法，調用存儲過程(不帶參數)
//輸入：
// ProcName存儲過程名
//輸出：
// 將執行結果以DataSet返回
public DataSet GetDataSet(string ProcName, SqlParameter[] Params)
{
Open();
SqlCommand Cmd = CreateCommand(ProcName, Params);
SqlDataAdapter adapter = new SqlDataAdapter(Cmd);
DataSet dataset = new DataSet();
adapter.Fill(dataset);
Close();
return dataset;
}
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -