注册 登录
  • 欢迎访问开心洋葱网站,在线教程,推荐使用最新版火狐浏览器和Chrome浏览器访问本网站,欢迎加入开心洋葱 QQ群
  • 为方便开心洋葱网用户,开心洋葱官网已经开启复制功能!
  • 欢迎访问开心洋葱网站,手机也能访问哦~欢迎加入开心洋葱多维思维学习平台 QQ群
  • 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏开心洋葱吧~~~~~~~~~~~~~!
  • 由于近期流量激增,小站的ECS没能经的起亲们的访问,本站依然没有盈利,如果各位看如果觉着文字不错,还请看官给小站打个赏~~~~~~~~~~~~~!

C#三层架构之数据库访问层代码

OC/C/C++ 水墨上仙 3058次浏览 已收录 手机上查看

C#三层架构之数据库访问层代码

using System;
using System.Data;
using System.Data.SqlClient;
using System.Configuration;
namespace DbBase
{
 public abstract class Base
 {
  #region "Fields of base calss"
  protected static string strConn = ConfigurationSettings.AppSettings["strConnection"];
  protected static string strSQL;
  #endregion
  
  #region "Properties of base class"
    }
  #endregion
  #region "Functions of base class"
  public Base()
  {
   //
   // TODO: Add constructor logic here
   //
  }
  /// <summary>
  /// executing SQL commands
  /// </summary>
  /// <param name="strSQL">string</param>
  /// <returns>return int</returns>
  protected static int ExecuteSql(string strSQL)
  {
   SqlConnection myCn = new SqlConnection(strConn);   
   SqlCommand myCmd = new SqlCommand(strSQL,myCn);
   try
   {
    myCn.Open();
    myCmd.ExecuteNonQuery();
    return 0;
   }
   catch(System.Data.SqlClient.SqlException e)
   {    
    throw new Exception(e.Message);
   }
   finally
   {
    myCmd.Dispose();
    myCn.Close();
   }
  }
  /// <summary>
  ///executing SQL commands
  /// </summary>
  /// <param name="strSQL">要执行的SQL语句,为字符串类型string</param>
  /// <returns>返回执行情况,整形int</returns>
  protected static int ExecuteSqlEx(string strSQL)
  {
   SqlConnection myCn = new SqlConnection(strConn);   
   SqlCommand myCmd = new SqlCommand(strSQL,myCn);
   
   try
   {
    myCn.Open();    
    SqlDataReader myReader = myCmd.ExecuteReader();
    if(myReader.Read())
    {
     return 0;
    } 
    else
    {
     throw new Exception("Value Unavailable!");
    }
   }
   catch(System.Data.SqlClient.SqlException e)
   {        
    throw new Exception(e.Message);
   }
   finally
   {
    myCmd.Dispose();
    myCn.Close();
   }
  }
  /// <summary>
  /// get dataset
  /// </summary>
  /// <param name="strSQL">(string)</param>
  /// <returns>(DataSet)</returns>
  protected static DataSet ExecuteSql4Ds(string strSQL)
  {
   SqlConnection myCn = new SqlConnection(strConn);   
   try
   {
    myCn.Open();
    SqlDataAdapter sda = new SqlDataAdapter(strSQL,myCn);
    DataSet ds = new DataSet("ds");
    sda.Fill(ds);
    return ds;
   }
   catch(System.Data.SqlClient.SqlException e)
   {    
    throw new Exception(e.Message);
   }
   finally
   {
    myCn.Close();
   }
  }
  /// <summary>
  /// get single value
  /// </summary>
  /// <param name="strSQL">(string)</param>
  /// <returns>(int)</returns>
  protected static int ExecuteSql4Value(string strSQL)
  {
   SqlConnection myCn = new SqlConnection(strConn);   
   SqlCommand myCmd = new SqlCommand(strSQL,myCn);
   try
   {
    myCn.Open();
    object r = myCmd.ExecuteScalar();
    if(Object.Equals(r,null))
    {
     throw new Exception("value unavailable!");
    }
    else
    {
     return (int)r;
    }    
   }
   catch(System.Data.SqlClient.SqlException e)
   {    
    throw new Exception(e.Message);
   }
   finally
   {
    myCmd.Dispose();
    myCn.Close();
   }
  }  
  /// <summary>
  /// get object
  /// </summary>
  /// <param name="strSQL">(string)</param>
  /// <returns>(object)</returns>
  protected static object ExecuteSql4ValueEx(string strSQL)
  {
   SqlConnection myCn = new SqlConnection(strConn);   
   SqlCommand myCmd = new SqlCommand(strSQL,myCn);
   try
   {
    myCn.Open();
    object r = myCmd.ExecuteScalar();
    if(Object.Equals(r,null))
    {
     throw new Exception("object unavailable!");
    }
    else
    {
     return r;
    }    
   }
   catch(System.Data.SqlClient.SqlException e)
   {    
    throw new Exception(e.Message);
   }
   finally
   {
    myCmd.Dispose();
    myCn.Close();
   }
  }
  /// <summary>
  /// execute multipul SQL commands 
  /// </summary>
  /// <param name="strSQLs">string</param>
  /// <returns>int</returns>
  protected static int ExecuteSqls(string[] strSQLs)
  {
   SqlConnection myCn = new SqlConnection(strConn);   
   SqlCommand myCmd = new SqlCommand();   
   int j=strSQLs.Length;
   try
   {
    myCn.Open();    
   }
   catch(System.Data.SqlClient.SqlException e)
   {
    throw new Exception(e.Message);
   }
   SqlTransaction myTrans = myCn.BeginTransaction();
   try
   {           
    myCmd.Connection = myCn;    
    myCmd.Transaction = myTrans;
    foreach(string str in strSQLs)
    {
     myCmd.CommandText = str;
     myCmd.ExecuteNonQuery();
    }
    myTrans.Commit();
    return 0;
   }
   catch(System.Data.SqlClient.SqlException e)
   {   
    myTrans.Rollback();
    throw new Exception(e.Message);
   }
   finally
   {
    myCmd.Dispose();
    myCn.Close();
   }
  }
  #endregion
 }
}


开心洋葱 , 版权所有丨如未注明 , 均为原创丨未经授权请勿修改 , 转载请注明C#三层架构之数据库访问层代码
喜欢 (0)
[开心洋葱]
分享 (0)
关于作者:
水墨上仙
……
加载中……