1: class Program

   2: {

   3:     static void Main()

   4:     {

   5:  

   6:         string invalidSql = "SELECT * FROM {InvalidTable}";

   7:         string validSql = "SELECT * FROM {ValidTable}";

   8:  

   9:  

  10:         Database db = DatabaseFactory.CreateDatabase();

  11:         using (TransactionScope scope = new TransactionScope())

  12:         {

  13:             DbCommand commandWithInvalidSql = db.GetSqlStringCommand(invalidSql);

  14:             DbCommand commandWithValidSql = db.GetSqlStringCommand(validSql);

  15:  

  16:             try

  17:             {

  18:                 db.ExecuteReader(commandWithInvalidSql);

  19:             }

  20:             catch

  21:             { }

  22:  

  23:             db.ExecuteReader(commandWithValidSql);

  24:         }

  25:     }

  26: } 

   1: public virtual IDataReader ExecuteReader(DbCommand command)

   2: {

   3:     ConnectionWrapper wrapper = GetOpenConnection(false);

   4:  

   5:     try

   6:     {

   7: //

   8: // JS-L: I moved the PrepareCommand inside the try because it can fail.

   9: //

  10: PrepareCommand(command, wrapper.Connection);

  11:  

  12: //

  13: // If there is a current transaction, we'll be using a shared connection, so we don't

  14: // want to close the connection when we're done with the reader.

  15: //

  16: if (Transaction.Current != null)

  17:     return DoExecuteReader(command, CommandBehavior.Default);

  18: else

  19:     return DoExecuteReader(command, CommandBehavior.CloseConnection);

  20:     }

  21:     catch

  22:     {

  23: wrapper.Connection.Close();

  24: throw;

  25:     }

  26: } 

  27: