/usr/share/perl5/Wiki/Toolkit/Store/Pg.pm is in libwiki-toolkit-perl 0.85-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 | package Wiki::Toolkit::Store::Pg;
use strict;
use vars qw( @ISA $VERSION );
use Wiki::Toolkit::Store::Database;
use Carp qw/carp croak/;
@ISA = qw( Wiki::Toolkit::Store::Database );
$VERSION = 0.07;
=head1 NAME
Wiki::Toolkit::Store::Pg - Postgres storage backend for Wiki::Toolkit
=head1 REQUIRES
Subclasses Wiki::Toolkit::Store::Database.
=head1 SYNOPSIS
See Wiki::Toolkit::Store::Database
=cut
# Internal method to return the data source string required by DBI.
sub _dsn {
my ($self, $dbname, $dbhost, $dbport) = @_;
my $dsn = "dbi:Pg:dbname=$dbname";
$dsn .= ";host=$dbhost" if $dbhost;
$dsn .= ";port=$dbport" if $dbport;
return $dsn;
}
=head1 METHODS
=over 4
=item B<check_and_write_node>
$store->check_and_write_node( node => $node,
checksum => $checksum,
%other_args );
Locks the node, verifies the checksum, calls
C<write_node_post_locking> with all supplied arguments, unlocks the
node. Returns the version of the updated node on successful writing, 0 if
checksum doesn't match, -1 if the change was not applied, croaks on error.
=back
=cut
sub check_and_write_node {
my ($self, %args) = @_;
my ($node, $checksum) = @args{qw( node checksum )};
my $dbh = $self->{_dbh};
$dbh->{AutoCommit} = 0;
my $ok = eval {
$dbh->do("SET TRANSACTION ISOLATION LEVEL SERIALIZABLE");
$self->verify_checksum($node, $checksum) or return 0;
$self->write_node_post_locking( %args );
};
if ($@) {
my $error = $@;
$dbh->rollback;
$dbh->{AutoCommit} = 1;
if ( $error =~ /can't serialize access due to concurrent update/i
or $error =~ /could not serialize access due to concurrent update/i
) {
return 0;
} else {
croak $error;
}
} else {
$dbh->commit;
$dbh->{AutoCommit} = 1;
return $ok;
}
}
sub _get_comparison_sql {
my ($self, %args) = @_;
if ( $args{ignore_case} ) {
return "lower($args{thing1}) = lower($args{thing2})";
} else {
return "$args{thing1} = $args{thing2}";
}
}
sub _get_node_exists_ignore_case_sql {
return "SELECT name FROM node WHERE lower(name) = lower(?) ";
}
1;
|