ytake / Laravel-Couchbase

    /**

     * {@inheritdoc}

     */

    public function compileInsert(Builder $query, array $values)

    {

        // keyspace-ref:

        $table = $this->wrapTable($query->from);

        // use-keys-clause:

        $keyClause = $this->wrapKey($query->key);

        // returning-clause

        $returning = implode(', ', $query->returning);

        if (!is_array(reset($values))) {

            $values = [$values];

        }

        $parameters = [];

        foreach ($values as $record) {

            $parameters[] = '('.$this->parameterize($record).')';

        }

        $parameters = (!$keyClause) ? implode(', ', $parameters) : "({$keyClause}, \$parameters)";

        $keyValue = (!$keyClause) ? null : '(KEY, VALUE)';

        return "insert into {$table} {$keyValue} values $parameters RETURNING {$returning}";

    }

    /**

     * {@inheritdoc}

     *

     * @return string

     */

    public function compileUpsert(QueryBuilder $query, array $values)

    {

        // keyspace-ref:

        $table = $this->wrapTable($query->from);

        // use-keys-clause:

        $keyClause = $this->wrapKey($query->key);

        // returning-clause

        $returning = implode(', ', $query->returning);

        if (!is_array(reset($values))) {

            $values = [$values];

        }

        $parameters = [];

        foreach ($values as $record) {

            $parameters[] = '('.$this->parameterize($record).')';

        }

        $parameters = (!$keyClause) ? implode(', ', $parameters) : "({$keyClause}, \$parameters)";

        $keyValue = (!$keyClause) ? null : '(KEY, VALUE)';

        return "UPSERT INTO {$table} {$keyValue} VALUES $parameters RETURNING {$returning}";

    }

}