/[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 188 by dpavlin, Sat Nov 29 19:07:00 2003 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;
15    use Carp;
16    
17  use DBI;  use DBI;
18    
# Line 35  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 63  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 160  sub fetch { Line 169  sub fetch {
169                  } else {                  } else {
170                          # if no match is found when searching from beginning                          # if no match is found when searching from beginning
171                          # of word in index, try substring match anywhere                          # of word in index, try substring match anywhere
172                          $sql2 = "select ord from $field where upper(item) like '%'||upper(?)||'%'";                          $sql2 = "select ord from $field where upper(item) like '% '||upper(?)||'%'";
173                          $sth = $self->{dbh}->prepare($sql2) || die "sql2: $sql2; ".$self->{dbh}->errstr();                          $sth = $self->{dbh}->prepare($sql2) || die "sql2: $sql2; ".$self->{dbh}->errstr();
174                          $sth->execute($where) || die "sql2: $sql2; ".$self->{dbh}->errstr();                          $sth->execute($where) || die "sql2: $sql2; ".$self->{dbh}->errstr();
175                          if (my $row = $sth->fetchrow_hashref) {                          if (my $row = $sth->fetchrow_hashref) {
# Line 192  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 210  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.188  
changed lines
  Added in v.348
  ViewVC Help
Powered by ViewVC 1.1.26