function Upsert::execute

Same name in this branch

11.1.x core/modules/pgsql/src/Driver/Database/pgsql/Upsert.php \Drupal\pgsql\Driver\Database\pgsql\Upsert::execute()

Executes the UPSERT operation.

Return value

int An integer indicating the number of rows affected by the operation. Do not rely on this value as a precise indication of the actual rows affected: different database engines return different values.

Overrides Query::execute

1 method overrides Upsert::execute()

Upsert::execute in core/modules/pgsql/src/Driver/Database/pgsql/Upsert.php: Executes the UPSERT operation.

File

core/lib/Drupal/Core/Database/Query/Upsert.php, line 96

Class

Upsert: General class for an abstracted "Upsert" (UPDATE or INSERT) query operation.

Namespace

Drupal\Core\Database\Query

Code

public function execute() {
    if (!$this->preExecute()) {
        return NULL;
    }
    $max_placeholder = 0;
    $values = [];
    foreach ($this->insertValues as $insert_values) {
        foreach ($insert_values as $value) {
            $values[':db_insert_placeholder_' . $max_placeholder++] = $value;
        }
    }
    $stmt = $this->connection
        ->prepareStatement((string) $this, $this->queryOptions, TRUE);
    try {
        $stmt->execute($values, $this->queryOptions);
        $affected_rows = $stmt->rowCount();
    } 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 $affected_rows;
}