function Insert::execute

File

core/modules/mysql/src/Driver/Database/mysql/Insert.php, line 22

Class

Insert

MySQL implementation of \Drupal\Core\Database\Query\Insert.

Namespace

Code

public function execute() {
  if (!$this->preExecute()) {
    return NULL;
  }
  // If we're selecting from a SelectQuery, finish building the query and
  // pass it back, as any remaining options are irrelevant.
  if (empty($this->fromQuery)) {
    $max_placeholder = 0;
    $values = [];
    foreach ($this->insertValues as $insert_values) {
      foreach ($insert_values as $value) {
        $values[':db_insert_placeholder_' . $max_placeholder++] = $value;
      }
    }
  }
  else {
    $values = $this->fromQuery
      ->getArguments();
  }
  $stmt = $this->connection
    ->prepareStatement((string) $this, $this->queryOptions);
  try {
    $stmt->execute($values, $this->queryOptions);
    $last_insert_id = $this->connection
      ->lastInsertId();
  } catch (\Exception $e) {
    $this->connection
      ->exceptionHandler()
      ->handleExecutionException($e, $stmt, $values, $this->queryOptions);
  }
  // Re-initialize the values array so that we can re-use this query.
  $this->insertValues = [];
  return $last_insert_id;
}