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] 下一页 | 
注：本站部分文章源于互联网，版权归原作者所有！如有侵权，请原作者与本站联系，本站将立即删除！ 本站文章除特别注明外均可转载，但需注明出处！ [MinTao学以致用网] 