2019獨角獸企業(yè)重金招聘Python工程師標(biāo)準(zhǔn)>>>

/*----------------------------------------------------------------Copyright (C) 2016 KeeSoft文件名：DBFactory.cs文件功能描述：數(shù)據(jù)庫操作基礎(chǔ)類創(chuàng)建標(biāo)識：KeeSoft - 20161012 ----------------------------------------------------------------*/using System; using System.Collections; using System.Collections.Generic; using System.Configuration; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Data; using System.Data.SqlClient;namespace KeeSoft.DBHelper {/// <summary>/// 數(shù)據(jù)庫基本操作工廠/// </summary>public class DBFactory{//全局連接代碼private static string GlobalConnection = "Server=.;Initial Catalog={0};User ID=sa;Password=123";//哈希表存儲緩存參數(shù)private static Hashtable parmCache = Hashtable.Synchronized(new Hashtable());/// <summary>/// 通過SQL命令進行數(shù)據(jù)庫操作/// </summary>/// <param name="_dataname">數(shù)據(jù)庫名</param>/// <param name="commandType">命令類型</param>/// <param name="commandText">命令語句</param>/// <param name="commandParameters">參數(shù)化查詢時,參數(shù)數(shù)組</param>/// <returns>返回受影響的行數(shù)</returns>public static int ExecuteNonQuery(string _dataname, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters){SqlCommand cmd = new SqlCommand();using (SqlConnection conn = new SqlConnection(string.Format(GlobalConnection,_dataname))){PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters);int val = cmd.ExecuteNonQuery();cmd.Parameters.Clear();return val;}}/// <summary>/// 通過SQL讀取命令 游標(biāo)讀取數(shù)據(jù)/// </summary>/// <param name="_dataname">數(shù)據(jù)庫名</param>/// <param name="commandType">命令類型</param>/// <param name="commandText">命令語句</param>/// <param name="commandParameters">參數(shù)化查詢時,參數(shù)數(shù)組</param>/// <returns>返回一個 SqlDataReader類</returns>public static SqlDataReader ExecuteReader(string _dataname, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters){SqlCommand cmd = new SqlCommand();SqlConnection conn = new SqlConnection(string.Format(GlobalConnection, _dataname));try{PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters);SqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection);cmd.Parameters.Clear();return rdr;}catch{conn.Close();throw;}}/// <summary>/// 通過SQL讀取命令 數(shù)據(jù)存入DataSet/// </summary>/// <param name="_dataname">數(shù)據(jù)庫名</param>/// <param name="commandType">命令類型</param>/// <param name="commandText">命令語句</param>/// <param name="commandParameters">參數(shù)化查詢時,參數(shù)數(shù)組</param>/// <returns>返回一個 SqlDataReader類</returns>public static DataSet GetDataSet(string _dataname, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters){SqlCommand cmd = new SqlCommand();SqlConnection conn = new SqlConnection(string.Format(GlobalConnection, _dataname));PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters);SqlDataAdapter doa = new SqlDataAdapter(cmd);DataSet ds = new DataSet();doa.Fill(ds);return ds;}/// <summary>/// 通過SQL讀取命令 數(shù)據(jù)存入DataSet/// </summary>/// <param name="_dataname">數(shù)據(jù)庫名</param>/// <param name="_sql">命令語句</param>/// <returns></returns>public static DataSet GetDataSet(string _dataname, string _sql){return GetDataSet(_dataname, CommandType.Text, _sql);}/// <summary>/// 通過SQL命令 返回第一行第一列的值/// </summary>/// <remarks>/// e.g.: /// Object obj = ExecuteScalar(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));/// </remarks>/// <param name="connectionString">a valid connection string for a SqlConnection</param>/// <param name="commandType">the CommandType (stored procedure, text, etc.)</param>/// <param name="commandText">the stored procedure name or T-SQL command</param>/// <param name="commandParameters">an array of SqlParamters used to execute the command</param>/// <returns>An object that should be converted to the expected type using Convert.To{Type}</returns>public static object ExecuteScalar(string _dataname, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters){SqlCommand cmd = new SqlCommand();using (SqlConnection connection = new SqlConnection(string.Format(GlobalConnection, _dataname))){PrepareCommand(cmd, connection, null, cmdType, cmdText, commandParameters);object val = cmd.ExecuteScalar();cmd.Parameters.Clear();return val;}}/// <summary>/// add parameter array to the cache/// </summary>/// <param name="cacheKey">Key to the parameter cache</param>/// <param name="cmdParms">an array of SqlParamters to be cached</param>public static void CacheParameters(string cacheKey, params SqlParameter[] commandParameters){parmCache[cacheKey] = commandParameters;}/// <summary>/// Retrieve cached parameters/// </summary>/// <param name="cacheKey">key used to lookup parameters</param>/// <returns>Cached SqlParamters array</returns>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++)clonedParms[i] = (SqlParameter)((ICloneable)cachedParms[i]).Clone();return clonedParms;}/// <summary>/// Prepare a command for execution/// </summary>/// <param name="cmd">SqlCommand object</param>/// <param name="conn">SqlConnection object</param>/// <param name="trans">SqlTransaction object</param>/// <param name="cmdType">Cmd type e.g. stored procedure or text</param>/// <param name="cmdText">Command text, e.g. Select * from Products</param>/// <param name="cmdParms">SqlParameters to use in the command</param>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);}}} }

?

轉(zhuǎn)載于:https://my.oschina.net/kee1986/blog/791887

總結(jié)

以上是生活随笔為你收集整理的KeeSoft.DBHelper.DBFactory 数据库访问类的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。