lemonldap-ng/lemonldap-ng-common/lib/Lemonldap/NG/Common/Conf/RDBI.pm
François-Xavier Deltombe dd11694c76 RDBI config storage database handle autocommit set to off
at writing a new config, to on else (#698)
2014-04-04 15:15:14 +00:00

60 lines
1.5 KiB
Perl

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 = $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 ) {
unless ( $req->execute( $fields->{cfgNum}, $k, $v ) ) {
$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__