代码生成工具之事物使用片段

IDbConnection connection = new SqlConnection(SysPara.ConnectionString);//默认为SQL SERVER
                    if (connection == null)
                    {
                        return;
                    }
                    if (connection.State != ConnectionState.Open)
                    {
                        connection.Open();
                    }
                    string strError = "";
                    IDbTransaction transaction = connection.BeginTransaction();
                    try
                    {
 Guid RetailVouchID = Add(RetailVouchModel, connection, transaction);
  if (transaction != null)
                        {

  string strRetailVouchSql = String.Format("DELETE FROM [RetailVouch] WHERE fchrRetailVouchID in ({0})", where);
                                        int RetailVouchSqlNum = SqlAccess.ExecuteNonQuery(transaction, CommandType.Text, strRetailVouchSql.ToString());

    transaction.Commit();

transaction.Rollback();

 catch (Exception ex)
                    {
                        MessageBox.Show(ex.Message);
                        transaction.Rollback();
                    }
                    finally
                    {
                        if (connection.State == ConnectionState.Open)
                        {
                            connection.Close();
                        }
                    }