/[webpac]/trunk2/lib/WebPAC/Index.pm
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Diff of /trunk2/lib/WebPAC/Index.pm

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

trunk/index_DBI_cache.pm revision 201 by dpavlin, Sat Jan 17 14:00:26 2004 UTC trunk2/lib/WebPac/Index.pm revision 348 by dpavlin, Sun Jun 13 20:20:29 2004 UTC
# Line 6  Line 6 
6  # library). But, that functionality is not used anyway...  # library). But, that functionality is not used anyway...
7  #  #
8    
9  package index_DBI;  package WebPac::Index;
10  use strict qw(vars);  use strict qw(vars);
11  use vars qw($Count);  use vars qw($Count);
12  use HTML::Entities;  use HTML::Entities;
13  use URI::Escape;  use URI::Escape;
14  use locale;  use locale;
15    use Carp;
16    
17  use DBI;  use DBI;
18    
# Line 36  sub bench { Line 37  sub bench {
37    
38  sub new {  sub new {
39          my $class = shift;          my $class = shift;
40          my $self = {};          my $self = {@_};
41          bless($self, $class);          bless($self, $class);
42    
43          my $dbd = shift || die "need dbi_dbd= in [global] section of configuration file";          croak "need dbd" if (! $self->{dbd});
44          my $dsn = shift || die "need dbi_dsn= in [global] section of configuration file";          croak "need dsn" if (! $self->{dsn});
45          my $user = shift || die "need dbi_user= in [global] section of configuration file";          croak "need user" if (! $self->{user});
46          my $passwd = shift || die "need dbi_passwd= in [global] section of configuration file";          croak "need passwd" if (! $self->{passwd});
47    
48          $self->{dbh} = DBI->connect("DBI:$dbd:$dsn",$user,$passwd) || die $DBI::errstr;          $self->{dbh} = DBI->connect("DBI:$self->{dbd}:$self->{dsn}",$self->{user},$self->{passwd}) || die $DBI::errstr;
49          $Count++;          $Count++;
50    
51          $self->bench("connected to $dbd as $user");          $self->bench("connected to $self->{dbd} as $self->{user}");
52    
53            # force SQLite to support binary 0 in data (which shouldn't
54            # happend, but it did to me)
55            eval {
56                    no warnings 'all';
57                    $self->{dbh}->{sqlite_handle_binary_nulls} = 1;
58            };
59    
60          return $self;          return $self;
61  }  }
# Line 64  sub delete_and_create { Line 72  sub delete_and_create {
72  # FIX: this is not a good way to check if table exists!  # FIX: this is not a good way to check if table exists!
73          if ($sth->execute() && $sth->fetchrow_hashref) {          if ($sth->execute() && $sth->fetchrow_hashref) {
74                  my $sql = "drop table $field";                  my $sql = "drop table $field";
75                  my $sth = $self->{dbh}->do($sql) || die "SQL: $sql ".$self->{dbh}->errstr();                  my $sth = $self->{dbh}->do($sql) || warn "SQL: $sql - ".$sth->errstr();
76          }          }
77          $sql = "create table $field (          $sql = "create table $field (
78                          item varchar(255),                          item varchar(255),
# Line 193  sub close { Line 201  sub close {
201    
202                  $self->{dbh}->begin_work || die $self->{dbh}->errstr();                  $self->{dbh}->begin_work || die $self->{dbh}->errstr();
203    
204                  $self->bench("Sorting ".$Table{$table}." items in $table");                  $self->bench("Sorting ".$Table{$table}." (with duplicates) items in $table");
205                  my @keys = sort keys %{$c_table->{$table}};                  my @keys = sort keys %{$c_table->{$table}};
206    
207                  $self->bench("Dumping data into $table");                  $self->bench("Dumping ".($#keys+1)." items into $table");
208                  my $sql = "insert into $table (ord,item,display,count) values (?,?,?,?)";                  my $sql = "insert into $table (ord,item,display,count) values (?,?,?,?)";
209                  my $sth = $self->{dbh}->prepare($sql) || die "sql: $sql; ".$self->{dbh}->errstr();                  my $sth = $self->{dbh}->prepare($sql) || die "sql: $sql; ".$self->{dbh}->errstr();
210    
# Line 211  sub close { Line 219  sub close {
219    
220                  $self->{dbh}->commit || die $self->{dbh}->errstr();                  $self->{dbh}->commit || die $self->{dbh}->errstr();
221          }          }
222    
223            if ($self->{dbd} =~ m/(Pg|SQLite)/) {
224                    $self->{dbh}->do(qq{vacuum}) || warn "vacumming failed. It shouldn't if you are using PostgreSQL or SQLite: ".$self->{dbh}->errstr();
225            }
226    
227          $self->bench("disconnecting from database");          $self->bench("disconnecting from database");
228    
229          $self->{dbh}->disconnect;          $self->{dbh}->disconnect;

Legend:
Removed from v.201  
changed lines
  Added in v.348

  ViewVC Help
Powered by ViewVC 1.1.26