File Coverage

blib/lib/SQL/Composer/Upsert.pm

Criterion	Covered	Total	%
statement	24	25	96.0
branch	5	6	83.3
condition	1	2	50.0
subroutine	5	5	100.0
pod	0	1	0.0
total	35	39	89.7

package SQL::Composer::Upsert;

use strict;
use warnings;

use SQL::Composer::Insert;

our @ISA; BEGIN { @ISA = ('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__