打印本文 打印本文 关闭窗口 关闭窗口
一个通用数据库访问类(C#,SqlClient)
作者:武汉SEO闵涛  文章来源:敏韬网  点击数4579  更新时间:2007/11/14 11:48:33  文章录入:mintao  责任编辑:mintao
sp;   }
      else /// if something went wrong rollback
      {
       switch( command )
       {
        case COMMAND.DELETE: dbDeleteCommand.Transaction.Rollback(); break;
        case COMMAND.INSERT: dbInsertCommand.Transaction.Rollback(); break;
        case COMMAND.UPDATE: dbUpdateCommand.Transaction.Rollback(); break;
       }
      
       //trans.Rollback();

       bReturn = false;
      }
     }
    }

    return bReturn;
   }


   #region select functions

   /// <summary>
   /// Get the Select reader from the select command
   /// </summary>
   private SqlDataReader SelectReader
   {
    get
    {
     if( dbDataReader != null )
     {
      if( dbDataReader.IsClosed == false )
      {
       dbDataReader.Close();
       dbDataReader = null;
      }
     }

     dbDataReader = dbSelectCommand.ExecuteReader();
     return dbDataReader;
    }
   }

   /// <summary>
   /// Get the Update reader from the update command
   /// </summary>
   private SqlDataReader UpdateReader
   {
    get
    {
     if( dbDataReader.IsClosed == false )
      dbDataReader.Close();

     dbDataReader = dbSelectCommand.ExecuteReader();
     return dbDataReader;
    }
   }

   /// <summary>
   /// Get the Insert Reader from the Insert Command
   /// </summary>
   private SqlDataReader InsertReader
   {
    get
    {
     if( dbDataReader.IsClosed == false )
      dbDataReader.Close();

     dbDataReader = dbSelectCommand.ExecuteReader();
     return dbDataReader;
    }
   }

   /// <summary>
   /// Get the Delete Reader from the Delete Command
   /// </summary>
   private SqlDataReader DeleteReader
   {
    get
    {
     if( dbDataReader != null )
     {
      if( dbDataReader.IsClosed == false )
      {
       dbDataReader.Close();
       dbDataReader = null;
      }
     }

     dbDataReader = dbSelectCommand.ExecuteReader();
     return dbDataReader;
    }
   }

   #endregion


   /// <summary>
   /// Standard Constructor
   /// </summary>
   public DBAccess()
   {
    /// NOTE That we are not setting the commands up the way the wizard would
    /// but building them more generically

    // create the command variables
    dbDataAdapter = new SqlDataAdapter();
    dbConnection = new SqlConnection();
    dbSelectCommand = new SqlCommand();
    dbDeleteCommand = new SqlCommand();
    dbUpdateCommand = new SqlCommand();
    dbInsertCommand = new SqlCommand();

    /// set up the adapter
    dbDataAdapter.DeleteCommand = dbDeleteCommand;
    dbDataAdapter.InsertCommand = dbInsertCommand;
    dbDataAdapter.SelectCommand = dbSelectCommand;
    dbDataAdapter.UpdateCommand = dbUpdateCommand;

    /// make sure everyone knows what conection to use
    dbSelectCommand.Connection = dbConnection;
    dbDeleteCommand.Connection = dbConnection;
    dbUpdateCommand.Connection = dbConnection;
    dbInsertCommand.Connection = dbConnection;

    command = COMMAND.NONE;
    dbDataReader = null;

    dbSelectCommandofAdapter = new SqlCommand();
    dataAdapterCommand = new SqlDataAdapter();
    dataAdapterCommand.SelectCommand = dbSelectCommandofAdapter;
   }

    public void Open()
   {
    /// set up the connection string
    StringBuilder strBuild = new StringBuilder();

  //Connection的属性从配置文件读取
    strBuild.AppendFormat(ConfigurationSettings.AppSettings["DBConnection"]);
    
    dbConnection.ConnectionString = strBuild.ToString();

    try
    {
     dbConnection.Open();
     bOpen = true;
    }
    catch (Exception exp)
    {
     error = exp.Message;
    }

    
   }


   /// <summary>
   /// Close the currently open connection
   /// </summary>
   public void Close()
   {
    if (dbDataReader != null)
    {
     if( dbDataReader.IsClosed == false )
     {
      dbDataReader.Close();
      dbDataReader = null;
     }
    }

    dbConnection.Close();
   }

  }

 

使用示例:

Insert操作,新建用户:

public bool NewUser()
  {
   DBAccess newUserDBAcce

上一页  [1] [2] [3] [4]  下一页

打印本文 打印本文 关闭窗口 关闭窗口