root/trunk/lib/Data/ObjectDriver/Driver/DBI/Pg.pm @ 6

# $Id$

package Data::ObjectDriver::Driver::DBI::Pg;
use strict;
use base qw( Data::ObjectDriver::Driver::DBI );

sub init_db {
    my $driver = shift;
    my $dbh = $driver->SUPER::init_db(@_);
    $dbh->do("set timezone to 'UTC'");
    $dbh;
}

sub bind_param_attributes {
    my ($driver, $data_type) = @_;
    if ($data_type && $data_type eq 'blob') {
        return { pg_type => DBD::Pg::PG_BYTEA() };
    }
    return undef;
}

sub sequence_name {
    my $driver = shift;
    my($class) = @_;
    return join '_', $class->datasource, 'seq';
} 

sub generate_id {
    my $driver = shift;
    my($class) = @_;
    my $seq = $driver->sequence_name($class);
    my $dbh = $driver->rw_handle($class->properties->{db});
    my $sth = $dbh->prepare("SELECT NEXTVAL('$seq')")
        or return $driver->error($dbh->errstr);
    $sth->execute
        or return $driver->error($dbh->errstr);
    $sth->bind_columns(undef, \my($id));
    $sth->fetch;
    $sth->finish;
    $id;
}

1;