CloudyCity / laravel-builder-macros

     * @param array $data

     * @return string

     */

    public function compileReplace(Builder $query, array $data)

    {

        // Essentially we will force every insert to be treated as a batch insert which

        // simply makes creating the SQL easier for us since we can utilize the same

        // basic routine regardless of an amount of records given to us to insert.

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

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

            $data = [$data];

        }

        $columns = $this->columnize(array_keys(reset($data)));

        // We need to build a list of parameter place-holders of values that are bound

        // to the query. Each insert should have the exact same amount of parameter

        // bindings so we will loop through the record and parameterize them all.

        $values = [];

        foreach ($data as $record) {

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

        }

        $values = implode(', ', $values);

        return "REPLACE INTO {$table} ({$columns}) VALUES {$values}";

    }

    /**

     * Compile an insert ignore statement into SQL.

     * @param array $data

     * @return string

     */

    public function compileInsertIgnore(Builder $query, array $data)

    {

        // Essentially we will force every insert to be treated as a batch insert which

        // simply makes creating the SQL easier for us since we can utilize the same

        // basic routine regardless of an amount of records given to us to insert.

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

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

            $data = [$data];

        }

        $columns = $this->columnize(array_keys(reset($data)));

        // We need to build a list of parameter place-holders of values that are bound

        // to the query. Each insert should have the exact same amount of parameter

        // bindings so we will loop through the record and parameterize them all.

        $values = [];

        foreach ($data as $record) {

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

        }

        $values = implode(', ', $values);

        return "INSERT IGNORE INTO {$table} ({$columns}) VALUES {$values}";

    }

    /**

     * Compile an insert update statement into SQL.