rn null; case COMMAND.DELETE: return DeleteReader; case COMMAND.INSERT: return InsertReader; case COMMAND.SELECT: return SelectReader; case COMMAND.UPDATE: return UpdateReader; default: return null; } } }
public DataSet GetDataSet { get { switch( command ) { case COMMAND.DATASET: return SelectDataSet(); default: return null; } } }
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();
上一页 [1] [2] [3] [4] 下一页 |