Upsert::execute

public Upsert::execute()

public function execute() {
  if (!$this->preExecute()) {
    return NULL;
  }

  $max_placeholder = 0;
  $values = array();
  foreach ($this->insertValues as $insert_values) {
    foreach ($insert_values as $value) {
      $values[':db_insert_placeholder_' . $max_placeholder++] = $value;
    }
  }

  $last_insert_id = $this->connection->query((string) $this, $values, $this->queryOptions);

  // Re-initialize the values array so that we can re-use this query.
  $this->insertValues = array();

  return $last_insert_id;
}