Транзакции в Drupal 7

Для того, чтобы начать новую транзакцию, необходимо просто прописать $txn = db_transaction( );  в собственном коде. Транзакция будет оставаться открытой до тех пор, пока переменная $txn будет оставаться в области исполнения. Когда переменная $txn будет уничтожена, транзакция будет выполнена. Если ваша транзакция является вложенностью другой, то Drupal выполнит каждую операцию и завершит внешнюю транзакцию только тогда, когда все объекты выйдут из области исполнения, т.е. все запросы пройдут успешно.

В том же случае, если один из запросов в транзакции не удается выполнить, происходит "откат" всех изменений, так называемый "rollback" - возврат данных в первоначальное состояние перед началом транзакции.

Пример:

fields(array(
    	'field1' => 'mystring',
    	'field2' => 5,
  	))
  	->execute();
	my_other_function($id);
	return $id;
  }
  catch (Exception $e) {
	$transaction->rollback();
	watchdog_exception('my_type', $e);
  }
  // $transaction goes out of scope here.  Unless it was rolled back, 
  // it gets automatically commited here.
}


function my_other_function($id) {
  // The transaction is still open here.
  if ($id % 2 == 0) {
	db_update('example')
  	->condition('id', $id)
  	->fields(array('field2' => 10))
  	->execute();
  }
}
?>

Если же появилась необходимость завершить одну из транзакций преждевременно, то для этого нужно "уничтожить" переменную $transaction с помощью функции unset().

Поработаем с транзакциями на примере.

Представим ситуацию, когда есть необходимость обработать большое количество данных для пользователей, операция для которых должна быть сгруппирована. Задача: снятие и зачисление средств из внутренних счетов пользователей на основе записей во временной таблице.

fields('at', array('uid', ‘decrease’, ‘increase’));
      $query->condition('at.timestamp', $time, '>');
      $result = $query->execute();
      while($record = $result->fetchAssoc()) {
        // Remove money from  user account.
        decrease_users_accounts($record[‘uid’], $record[‘decrease’]);
        // Add money to user account.
        increase_users_accounts($record[‘uid’], $record[‘increase’]);
        // Delete temp record from table.
        delete_users_account_record($record[‘uid’]);
      }	
      return TRUE;
    }
    catch (Exception $e) {
      $transaction->rollback();
      watchdog_exception('users_accounts', $e);
    }
  // $transaction goes out of scope here.  Unless it was rolled back, 
  // it gets automatically commited here.
  }

  function decrease_users_accounts($uid, $decrease) {
    // The transaction opens here.
    // Get current user account.
    $current_account = get_user_account($uid);
    $updated_account = $current_account - $decrease;
    // Update user's account record.
    db_update('account_data_table')
      ->condition('uid', $uid)
      ->fields(array('account' => $updated_account))
      ->execute();
  }
  
  function increase_users_accounts($uid, $increase) {
    // Get current user account.
    $current_account = get_user_account($uid);
    $updated_account = $current_account + $increase;
    // Update user's account record.
    db_update('account_data_table')
      ->condition('uid', $uid)
      ->fields(array('account' => $updated_account))
      ->execute();
  }
  
  function delete_users_account_record($uid) {
    // The transaction opens here.
    db_delete('account_tmp_table')
      ->condition('uid', $uid)
      ->execute();
  }
}

?>

Вариант реализации через транзакции сделает невозможным изменение счета пользователя другим функционалом при выполнении этого кода, а также в случае возникновения ошибок во время работы обеспечит сохранение целостности выполнения операции с помощью вызова метода rollback, который вернет все данные в исходное состояние.

В данной статье рассмотрена возможность поддержки транзакций при разработке сайтов на Drupal. Для более подробного ознакомления можно воспользоваться документацией.