public function Connection::pushTransaction in Drupal driver for SQL Server and SQL Azure 8.2

Same name and namespace in other branches

1. 8 drivers/lib/Drupal/Driver/Database/sqlsrv/Connection.php \Drupal\Driver\Database\sqlsrv\Connection::pushTransaction()
2. 3.0.x drivers/lib/Drupal/Driver/Database/sqlsrv/Connection.php \Drupal\Driver\Database\sqlsrv\Connection::pushTransaction()

Summary of pushTransaction

Parameters

string $name:

DatabaseTransactionSettings $settings:

Return value

void

Throws

DatabaseTransactionNameNonUniqueException

Overrides Connection::pushTransaction

File

drivers/lib/Drupal/Driver/Database/sqlsrv/Connection.php, line 921

Definition of Drupal\Driver\Database\sqlsrv\Connection

Class

Connection

Temporary tables: temporary table support is done by means of global temporary tables (#) to avoid the use of DIRECT QUERIES. You can enable and disable the use of direct queries with $this->driver_settings->defaultDirectQuery =…

Namespace

Drupal\Driver\Database\sqlsrv

Code

public function pushTransaction($name, $settings = null) {
  if ($settings == null) {
    $settings = DatabaseTransactionSettings::GetDefaults();
  }
  if (!$this
    ->supportsTransactions()) {
    return;
  }
  if (isset($this->transactionLayers[$name])) {
    throw new DatabaseTransactionNameNonUniqueException($name . " is already in use.");
  }
  $started = false;

  // If we're already in a transaction.
  // TODO: Transaction scope Options is not working properly
  // for first level transactions. It assumes that - always - a first level
  // transaction must be started.
  if ($this
    ->inTransaction()) {
    switch ($settings
      ->Get_ScopeOption()) {
      case DatabaseTransactionScopeOption::RequiresNew():
        $this
          ->query_execute('SAVE TRANSACTION ' . $name);
        $started = true;
        break;
      case DatabaseTransactionScopeOption::Required():

        // We are already in a transaction, do nothing.
        break;
      case DatabaseTransactionScopeOption::Supress():

        // The only way to supress the ambient transaction is to use a new connection
        // during the scope of this transaction, a bit messy to implement.
        throw new Exception('DatabaseTransactionScopeOption::Supress not implemented.');
    }
  }
  else {
    if ($settings
      ->Get_IsolationLevel() != DatabaseTransactionIsolationLevel::Ignore()) {
      $current_isolation_level = strtoupper($this->connection
        ->Scheme()
        ->UserOptions()
        ->IsolationLevel());

      // Se what isolation level was requested.
      $level = $settings
        ->Get_IsolationLevel()
        ->__toString();
      if (strcasecmp($current_isolation_level, $level) !== 0) {
        $this
          ->query_direct("SET TRANSACTION ISOLATION LEVEL {$level}");
      }
    }

    // In order to start a transaction current statement cursors
    // must be closed.
    foreach ($this->statement_cache as $statement) {
      $statement
        ->closeCursor();
    }
    $this->connection
      ->beginTransaction();
  }

  // Store the name and settings in the stack.
  $this->transactionLayers[$name] = array(
    'settings' => $settings,
    'active' => true,
    'name' => $name,
    'started' => $started,
  );
}