Update of /cvsroot/koha/koha/C4 In directory usw-pr-cvs1:/tmp/cvs-serv4942/C4 Modified Files: Tag: rel-1-2 Database.pm Log Message: Commiting the uncrufted Database module into the stable branch Index: Database.pm =================================================================== RCS file: /cvsroot/koha/koha/C4/Database.pm,v retrieving revision 1.2.2.1 retrieving revision 1.2.2.2 diff -C2 -r1.2.2.1 -r1.2.2.2 *** Database.pm 25 Apr 2002 21:59:55 -0000 1.2.2.1 --- Database.pm 30 Apr 2002 09:30:52 -0000 1.2.2.2 *************** *** 1,3 **** ! package C4::Database; #assumes C4/Database use strict; --- 1,5 ---- ! package C4::Database; #asummes C4/Database ! ! #requires DBI.pm to be installed use strict; *************** *** 6,15 **** use vars qw($VERSION @ISA @EXPORT); - # set the version for version checking $VERSION = 0.01; @ISA = qw(Exporter); ! @EXPORT = qw(&C4Connect &sqlinsert &sqlupdate &getmax &makelist ! &OpacConnect); sub C4Connect { --- 8,16 ---- use vars qw($VERSION @ISA @EXPORT); $VERSION = 0.01; @ISA = qw(Exporter); ! @EXPORT = qw(&C4Connect); ! sub C4Connect { *************** *** 40,133 **** } - sub Opaconnect { - my $dbname="c4"; - # my $dbh = DBI->connect("dbi:Pg:dbname=$dbname", "chris", ""); - my $database='c4test'; - my $hostname='localhost'; - my $user='hdl'; - my $pass='testing'; - my $dbh=DBI->connect("DBI:mysql:$database:$hostname",$user,$pass); - return $dbh; - } ! sub sqlinsert { ! my ($table,%data)=@_; ! my $dbh=C4Connect; ! my $query="INSERT INTO $table \("; ! while (my ($key,$value) = each %data){ ! if ($key ne 'type' && $key ne 'updtype'){ ! $query=$query."$key,"; ! } ! } ! $query=~ s/\,$/\)/; ! $query=$query." VALUES ("; ! while (my ($key,$value) = each %data){ ! if ($key ne 'type' && $key ne 'updtype'){ ! $query=$query."'$value',"; ! } ! } ! $query=~ s/\,$/\)/; ! print $query; ! my $sth=$dbh->prepare($query); ! $sth->execute; ! $sth->finish; ! $dbh->disconnect; ! } ! ! sub sqlupdate { ! my ($table,$keyfld,$keyval,%data)=@_; ! my $dbh=C4Connect; ! my $query="UPDATE $table SET "; ! my @sets; ! my @keyarr = split("\t",$keyfld); ! my @keyvalarr = split("\t",$keyval); ! my $numkeys = @keyarr; ! while (my ($key,$value) = each %data){ ! if (($key ne 'type')&&($key ne 'updtype')){ ! my $temp = " ".$key."='".$value."' "; ! push(@sets,$temp); ! } ! } ! my $fsets = join(",", @sets); ! $query=$query.$fsets." WHERE $keyarr[0] = '$keyvalarr[0]'"; ! if ($numkeys > 1) { ! my $i = 1; ! while ($i < $numkeys) { ! $query=$query." AND $keyarr[$i] = '$keyvalarr[$i]'"; ! $i++; ! } ! } ! # $query=~ s/\,$/\)/; ! print $query; ! my $sth=$dbh->prepare($query); ! $sth->execute; ! $sth->finish; ! $dbh->disconnect; ! } ! ! ! sub getmax { ! my ($table,$item)=@_; ! my $dbh=C4Connect; ! my $sth=$dbh->prepare("Select max($item) from $table"); ! $sth->execute; ! my $data=$sth->fetchrow_hashref; ! $sth->finish; ! $dbh->disconnect; ! return($data); ! } ! ! sub makelist { ! my ($table,$kfld,$dfld)=@_; ! my $data; ! my $dbh=C4Connect; ! my $sth=$dbh->prepare("Select $kfld,$dfld from $table order by $dfld"); ! $sth->execute; ! while (my $drec=$sth->fetchrow_hashref) { ! $data = $data."\t".$drec->{$kfld}."\t".$drec->{$dfld}; ! } ! $sth->finish; ! $dbh->disconnect; ! return($data); ! } ! END { } # module clean-up code here (global destructor) --- 41,44 ---- } ! END { }