@@ -162,144 +162,6 @@ sub new {
return $self;
}
-
-
-sub addtable {
- my ($self,$arg,$type) = @_;
- return if ! defined $arg or ! ref $arg;
- my @vals = grep { defined $arg->{$_} } @{$arg->cols};
- my $flatargs = join "," => @vals;
- my $qs = join "," => map { '?' } @vals;
- my $maindbh = $self->{masterdbh};
- $SQL = "INSERT INTO bucardo.$type($flatargs) VALUES ($qs)";
- $sth = $maindbh->prepare($SQL) or die "Could not add a table: $!";
- my $args = [map { $arg->{$_} } @vals];
- $sth->execute(@$args);
- $maindbh->commit();
- return if $type ne 'goat';
- return $self->{$type}{id} = $maindbh->selectall_arrayref("SELECT pg_catalog.lastval()")->[0][0];
-}
-
-
-sub remove_customcode {
- my ($self,$arg) = @_;
-
- defined $arg and ref $arg eq 'HASH' or die qq{Argument must be a hashref\n};
-
- my $id = (exists $arg->{id} and length $arg->{id}) ? $arg->{id} : '';
- my $name = (exists $arg->{name} and length $arg->{name}) ? $arg->{name} : '';
- my $code = (exists $arg->{code} and length $arg->{code}) ? $arg->{code} : '';
-
- if (!length $id and !length $name and !length $code) {
- die qq{Did not find required argument\n};
- }
-
- my $dbh = $self->{masterdbh};
-
- if (length $code) {
- $code =~ /^\d+$/ or die qq{Argument 'code' is not numeric\n};
- my $sync = (exists $arg->{sync} and length $arg->{sync}) ? $arg->{sync} : '';
- my $goat = (exists $arg->{goat} and length $arg->{goat}) ? $arg->{goat} : '';
- if (!length $sync and !length $goat) {
- die qq{Did not find required argument sync or goat\n};
- }
- if (length $goat) {
- $goat =~ /^\d+$/ or die qq{Argument goat is not numeric\n};
- $SQL = "DELETE FROM customcode_map WHERE code=? AND goat=?";
- $sth = $dbh->prepare($SQL);
- $count = $sth->execute($code,$goat);
- }
- else {
- $SQL = "DELETE FROM customcode_map WHERE code=? AND sync=?";
- $sth = $dbh->prepare($SQL);
- $count = $sth->execute($code,$sync);
- }
- }
- elsif (length $id) {
- $id =~ /^\d+$/ or die qq{Argument 'id' is not numeric\n};
- $SQL = "DELETE FROM customcode WHERE id = ?";
- $sth = $dbh->prepare($SQL);
- $count = $sth->execute($id);
- }
- else {
- $SQL = "DELETE FROM customcode WHERE name = ?";
- $sth = $dbh->prepare($SQL);
- $count = $sth->execute($name);
- }
- $dbh->commit();
- return $count eq '0E0' ? 0 : $count;
-
-} ## end of remove_customcode
-
-sub make_dbgroup {
- ## Create a named dbgroup if it does not already exist
- my ($self,$dbgname) = @_;
- return if ! defined $dbgname;
- my $dbgroups = $self->get_dbgroups();
- return if exists $dbgroups->{$dbgname};
- $self->glog(qq{Creating new dbgroup named "$dbgname"});
- my $maindbh = $self->{masterdbh};
- $SQL = "INSERT INTO bucardo.dbgroup(name) VALUES (?)";
- my $sth = $maindbh->prepare($SQL);
- $sth->execute($dbgname);
- $maindbh->commit();
- return;
-} ## end of make_dbgroup
-
-
-sub make_herd {
- ## Create a named herd if it does not exist
- my ($self,$herdname) = @_;
- return if ! defined $herdname;
- my $herds = $self->get_herds();
- return if exists $herds->{$herdname};
- $self->glog(qq{Creating new herd named "$herdname"});
- my $maindbh = $self->{masterdbh};
- $SQL = "INSERT INTO bucardo.herd(name) VALUES (?)";
- my $sth = $maindbh->prepare($SQL);
- $sth->execute($herdname);
- $maindbh->commit();
- return;
-} ## end of make_herd
-
-
-sub find_goat {
- ## Return a goat id, given an id, a tablename, or a goat object
- my ($self,$beast,$dbid) = @_;
- my $goats = $self->get_goats();
- my $goatid;
- if (!defined $beast) {
- die "Invalid argument passed to find_goat\n";
- }
-
- if (ref $beast eq 'BCgoat') {
- $goatid = $beast->id;
- }
- elsif ($beast =~ /^\d+$/o) { ## TODO: explicitly disallow numeric table names
- exists $goats->{$beast} or die qq{Unknown goat id: $beast\n};
- $goatid = $beast;
- }
- elsif (! defined $dbid) {
- my @ids = map { $goats->{$_}{id} } grep { $goats->{$_}->{tablename} eq $beast } keys %$goats;
- if ($#ids >= 1) {
- die qq{More than one table named "$beast" found: please specify a database\n};
- }
- $goatid = $ids[0];
- }
- else {
- ($goatid) =
- map { $goats->{$_}{id} }
- grep { $goats->{$_}->{tablename} eq $beast and $goats->{$_}{db} eq $dbid }
- keys %$goats;
- }
- if (!defined $goatid) {
- die qq{Invalid goat given: "$beast"\n};
- }
- return $goatid;
-} ## end of find_goat
-
-
-
sub reload_config {
my ($self) = @_;
Bucardo.pm
b6bb92a9f96b0816060155abdddb8bb731f38f0a
Greg Sabino Mullane
greg@endpoint.com
http://github.com/unilogic/bucardo/commit/71127c4753b5a346f8e92f5844a413f8e4b9fdd9
71127c4753b5a346f8e92f5844a413f8e4b9fdd9
2009-05-11T13:39:58-07:00
2009-05-11T13:39:58-07:00
Remove more unused code
81e1c09ced9d9c021365d3c40559da6023c0f794
Greg Sabino Mullane
greg@endpoint.com