package DBIx::CouchLike::Pg;

use strict;
use warnings;
use base qw/ DBIx::CouchLike /;

my @sql_format = (
    q|CREATE TABLE %s_data (id text not null primary key, value text)|,
    q|CREATE TABLE %s_map (design_id text not null, id text not null, key text not null, value text )|,
    q|CREATE INDEX %s_map_idx  ON %s_map (design_id, key)|,
);

my @sql_format_v = (
    q|CREATE TABLE %s_data (id text not null primary key, value text, version integer not null default 0)|,
    q|CREATE TABLE %s_map (design_id text not null, id text not null, key text not null, value text )|,
    q|CREATE INDEX %s_map_idx  ON %s_map (design_id, key)|,
);

sub create_table {
    my $class = shift;
    my $dbh   = shift;
    my $name  = shift;
    my $v     = shift;
    for my $f ( $v ? @sql_format_v : @sql_format ) {
        $dbh->do( sprintf $f, $name, $name );
    }
}

sub _start_with {
    my ( $self, $key, $value ) = @_;
    return ( " $key ~ ? ", "^" . $value );
}

sub _offset_limit_sql {
    my ( $self, $sql, $query, $param ) = @_;

    if ( defined $query->{offset} ) {
        $sql .= q{ OFFSET ? };
        push @$param, $query->{offset};
    }
    if ( defined $query->{limit} ) {
        $sql .= q{ LIMIT ? };
        push @$param, $query->{limit};
    }
    return $sql;
}

1;