File Coverage

blib/lib/Lemonldap/NG/Common/Conf/RDBI.pm

Criterion	Covered	Total	%
statement	9	46	19.5
branch	0	12	0.0
condition			n/a
subroutine	3	5	60.0
pod	0	2	0.0
total	12	65	18.4

package Lemonldap::NG::Common::Conf::RDBI;

use strict;
use Lemonldap::NG::Common::Conf::Serializer;
use Lemonldap::NG::Common::Conf::_DBI;

our $VERSION = '1.4.0';
our @ISA     = qw(Lemonldap::NG::Common::Conf::_DBI);

sub store {
    my ( $self, $fields ) = @_;
    $self->{noQuotes} = 1;
    $fields = $self->serialize($fields);

    my $req;
    my $lastCfg = $self->lastCfg;

    if ( $lastCfg == $fields->{cfgNum} ) {
        $req = $self->_dbh->prepare(
"UPDATE $self->{dbiTable} SET field=?, value=? WHERE cfgNum=? AND field=?"
        );

    }
    else {
        $req = $self->_dbh->prepare(
            "INSERT INTO $self->{dbiTable} (cfgNum,field,value) VALUES (?,?,?)"
        );
    }
    unless ($req) {
        $self->logError;
        return UNKNOWN_ERROR;
    }
    $self->_dbh->{AutoCommit} = 0;
    while ( my ( $k, $v ) = each %$fields ) {
        my @execValues;
        if ( $lastCfg == $fields->{cfgNum} ) {
            @execValues = ( $k, $v, $fields->{cfgNum}, $k );
        }
        else { @execValues = ( $fields->{cfgNum}, $k, $v ); }
        unless ( $req->execute(@execValues) ) {
            $self->logError;
            $self->_dbh->do("ROLLBACK");
            $self->_dbh->{AutoCommit} = 1;
            return UNKNOWN_ERROR;
        }
    }
    $self->_dbh->do("COMMIT");
    $self->_dbh->{AutoCommit} = 1;
    return $fields->{cfgNum};
}

sub load {
    my ( $self, $cfgNum, $fields ) = @_;
    $fields = $fields ? join( ",", @$fields ) : '*';
    my $sth =
      $self->_dbh->prepare( "SELECT cfgNum,field,value from "
          . $self->{dbiTable}
          . " WHERE cfgNum=?" );
    $sth->execute($cfgNum);
    my ( $res, @row );
    while ( @row = $sth->fetchrow_array ) {
        $res->{ $row[1] } = $row[2];
    }
    unless ($res) {
        $Lemonldap::NG::Common::Conf::msg .=
          "No configuration $cfgNum found \n";
        return 0;
    }
    $res->{cfgNum} = $cfgNum;
    return $self->unserialize($res);
}

1;
__END__