File Coverage

blib/lib/SQL/Composer/Upsert.pm

Criterion	Covered	Total	%
statement	26	27	96.3
branch	5	6	83.3
condition	1	2	50.0
subroutine	5	5	100.0
pod	0	1	0.0
total	37	41	90.2

package SQL::Composer::Upsert;

use strict;
use warnings;

use base 'SQL::Composer::Insert';

use SQL::Composer::Insert;

sub new {
    my $class = shift;
    my (%params) = @_;

    my $driver = $params{driver}
      || die 'Cannot create an Upsert object without specifying a `driver`';

    my $self = $class->SUPER::new(%params);
    my $sql  = $self->{sql};

    if ($driver =~ m/sqlite/i) {
        $sql =~ s/^INSERT /INSERT OR REPLACE /;
    }
    elsif ($driver =~ m/mysql/i) {
        $sql .= ' ON DUPLICATE KEY UPDATE ' . (
            join ', ' => map {
                my $c = $self->_quote($_);
                ($c . ' = VALUES(' . $c . ')')
            } @{$self->{columns}}
        );
    }
    elsif ($driver =~ m/pg/i) {
        $sql .= ' ON CONFLICT DO UPDATE';
    }
    else {
        die 'The Upsert `driver` (' . $driver . ') is not supported';
    }

    $self->{sql} = $sql;

    return $self;
}

1;
__END__