public DataSet SelectDataSet()
   {
    try
    {
     dataAdapterCommand.SelectCommand.Connection = dbConnection;
     DataSet dataset = new DataSet();
     dataAdapterCommand.Fill(dataset);
     return dataset;
    }
    catch (Exception exp)
    {
     error = exp.Message;
     return null;
    }

   }

   /// <summary>
   /// Execute the command that has been set up previously
   /// </summary>
   /// <returns>A boolean value indicating true or false</returns>
   public bool ExecuteCommand()
   {
    bool bReturn = false;
    if( command == COMMAND.NONE )
    {
     return bReturn;
    }
    else if( command == COMMAND.SELECT )
    {
     /// select only returns true as the get reader function will
     /// execute the command

     try
     {
      if( dbDataReader != null )
      {
       dbDataReader.Close();
       dbDataReader = null;
      }

      bReturn = true;
      ///   return bReturn;
     }
     catch( SqlException exp )
     {
      error = "dbException thrown when trying to Select, error given = " + exp.Message + " check the sql";
      return bReturn = false;
     }

    }
    else if( command == COMMAND.DATASET )
    {
     return bReturn;     
    }
    else
    {
     int nAffected = -1;

     if( dbDataReader != null )
     {
      dbDataReader.Close();
      dbDataReader = null;
     }

     /// get the transaction object from the connection
     SqlTransaction trans = dbConnection.BeginTransaction();

     try
     {
      /// create a nested transaction on the connection transaction
      switch( command )
      {
       case COMMAND.DELETE: dbDeleteCommand.Transaction = trans; break;
       case COMMAND.INSERT: dbInsertCommand.Transaction = trans; break;
       case COMMAND.UPDATE: dbUpdateCommand.Transaction = trans; break;
      }

      /// execute the command
      switch( command )
      {
       case COMMAND.DELETE: nAffected = dbDeleteCommand.ExecuteNonQuery(); break;
       case COMMAND.INSERT: nAffected = dbInsertCommand.ExecuteNonQuery(); break;
       case COMMAND.UPDATE: nAffected = dbUpdateCommand.ExecuteNonQuery(); break;
      }

     }
     catch( InvalidOperationException ioexp )
     {
      StringBuilder buildError = new StringBuilder();
      buildError.Append( "InvalidOperationException thrown when trying to " );

      switch( command )
      {
       case COMMAND.DELETE: buildError.Append( "Delete" ); break;
       case COMMAND.INSERT: buildError.Append( "Insert" ); break;
       case COMMAND.UPDATE: buildError.Append( "Update" ); break;
      }

      buildError.Append( ", error given = " + ioexp.Message + " check the sql" );

      error = buildError.ToString();

      return bReturn = false;
     }
     catch( SqlException dbexp )
     {
      StringBuilder buildError = new StringBuilder();
      buildError.Append( "InvalidOperationException thrown when trying to " );

      switch( command )
      {
       case COMMAND.DELETE: buildError.Append( "Delete" ); break;
       case COMMAND.INSERT: buildError.Append( "Insert" ); break;
       case COMMAND.UPDATE: buildError.Append( "Update" ); break;
      }

      buildError.Append( ", error given = " + dbexp.Message + " check the sql" );

      error = buildError.ToString();

      return bReturn = false;
     }
     finally
     {
      /// commit the command
      if( nAffected == 1 )
      {
       switch( command )
       {
        case COMMAND.DELETE: dbDeleteCommand.Transaction.Commit(); break;
        case COMMAND.INSERT: dbInsertCommand.Transaction.Commit(); break;
        case COMMAND.UPDATE: dbUpdateCommand.Transaction.Commit(); break;
       }

       //trans.Commit();

       bReturn = true;
  &nb

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