1 { # Based on the change to Class::DBI in OpenILS::Application::Storage. This will
2 # allow us to use TSearch2 via a simple cdbi "search" interface.
3 #-------------------------------------------------------------------------------
10 if (ref($args[-1]) eq 'HASH') {
11 $args[-1]->{_placeholder} = "to_tsquery('default',?)";
13 push @args, {_placeholder => "to_tsquery('default',?)"};
15 $self->_do_search("@@" => @args);
19 { # Every driver needs to provide a 'compile()' method to OpenILS::Application::Storage::FTS.
20 # If that driver wants to support FTI, that is...
21 #-------------------------------------------------------------------------------
22 package OpenILS::Application::Storage::FTS;
23 use OpenSRF::Utils::Logger qw/:level/;
24 my $log = 'OpenSRF::Utils::Logger';
30 $self = ref($self) || $self;
31 $self = bless {} => $self;
33 $self->decompose($term);
35 my $newterm = join('&', $self->words);
38 $newterm = '('.$newterm.')&('. join('|', $self->nots) . ')';
41 $newterm = OpenILS::Application::Storage->driver->quote($newterm);
43 $self->{fts_query} = ["to_tsquery('default',$newterm)"];
44 $self->{fts_query_nots} = [];
45 $self->{fts_op} = '@@';
52 { # The driver package itself just needs a db_Main method for Class::DBI to call.
53 # any other fixups can go in here too... Also, the drivers should subclass the
54 # DBI driver that they are wrapping, or provide a 'quote()' method that calls
55 # the DBD::xxx::quote() method on FTI's behalf.
57 # The dirver MUST be a subclass of Class::DBI and OpenILS::Application::Storage.
58 #-------------------------------------------------------------------------------
59 package OpenILS::Application::Storage::Driver::Pg;
60 use base qw/Class::DBI OpenILS::Application::Storage/;
63 use OpenSRF::Utils::Logger qw/:level/;
65 __PACKAGE__->set_sql( retrieve_limited => 'SELECT * FROM __TABLE__ ORDER BY id LIMIT ?' );
77 return $_dbh if (defined $_dbh and $_dbh->ping);
79 my %attrs = ( %{$self->_default_attributes},
80 RootClass => 'DBIx::ContextualFetch',
81 ShowErrorStatement => 1,
87 FetchHashKeyName => 'NAME_lc',
91 $log->debug(" Default attributes for this DB connection are:\n\t".join("\n\t",map { "$_\t==> $attrs{$_}" } keys %attrs), INTERNAL);
93 $_dbh = DBI->connect( "dbi:Pg:host=$$_db_params{host};dbname=$$_db_params{database}",$$_db_params{user},$$_db_params{pw}, \%attrs );
94 $_dbh->do("SET CLIENT_ENCODING TO 'SQL_ASCII';");
100 return $_dbh->quote(@_)
103 sub tsearch2_trigger {
105 return unless ($self->value);
107 $self->db_Main->selectrow_array(
108 "SELECT to_tsvector('default',?);",
117 #---------------------------------------------------------------------
118 package asset::call_number;
120 __PACKAGE__->table( 'asset.call_number' );
121 __PACKAGE__->sequence( 'asset.call_number_id_seq' );
123 #---------------------------------------------------------------------
126 __PACKAGE__->table( 'asset.copy' );
127 __PACKAGE__->sequence( 'asset.copy_id_seq' );
129 #---------------------------------------------------------------------
130 package biblio::record_entry;
132 __PACKAGE__->table( 'biblio.record_entry' );
133 __PACKAGE__->sequence( 'biblio.record_entry_id_seq' );
135 #---------------------------------------------------------------------
136 package biblio::record_node;
138 __PACKAGE__->table( 'biblio.record_data' );
139 __PACKAGE__->sequence( 'biblio.record_data_id_seq' );
141 #---------------------------------------------------------------------
142 package biblio::record_note;
144 __PACKAGE__->table( 'biblio.record_note' );
145 __PACKAGE__->sequence( 'biblio.record_note_id_seq' );
147 #---------------------------------------------------------------------
150 __PACKAGE__->table( 'actor.usr' );
151 __PACKAGE__->sequence( 'actor.usr_id_seq' );
153 #---------------------------------------------------------------------
154 package actor::org_unit_type;
156 __PACKAGE__->table( 'actor.org_unit_type' );
157 __PACKAGE__->sequence( 'actor.org_unit_type_id_seq' );
159 #---------------------------------------------------------------------
161 #-------------------------------------------------------------------------------
162 package metabib::metarecord;
164 metabib::metarecord->table( 'metabib.metarecord' );
165 metabib::metarecord->sequence( 'metabib.metarecord_id_seq' );
167 #-------------------------------------------------------------------------------
169 #-------------------------------------------------------------------------------
170 package metabib::title_field_entry;
172 metabib::title_field_entry->table( 'metabib.title_field_entry' );
173 metabib::title_field_entry->sequence( 'metabib.title_field_entry_id_seq' );
174 metabib::title_field_entry->columns( Primary => qw/id/ );
175 metabib::title_field_entry->columns( Others => qw/field index_vector/ );
176 metabib::title_field_entry->columns( TEMP => qw/value/ );
178 metabib::title_field_entry->add_trigger(
179 before_create => \&OpenILS::Application::Storage::Driver::Pg::tsearch2_trigger
181 metabib::title_field_entry->add_trigger(
182 before_update => \&OpenILS::Application::Storage::Driver::Pg::tsearch2_trigger
185 #-------------------------------------------------------------------------------
187 #-------------------------------------------------------------------------------
188 package metabib::author_field_entry;
190 metabib::author_field_entry->table( 'metabib.author_field_entry' );
191 metabib::author_field_entry->sequence( 'metabib.author_field_entry_id_seq' );
192 metabib::author_field_entry->columns( Primary => qw/id/ );
193 metabib::author_field_entry->columns( Others => qw/field index_vector/ );
194 metabib::author_field_entry->columns( TEMP => qw/value/ );
196 metabib::author_field_entry->add_trigger(
197 before_create => \&OpenILS::Application::Storage::Driver::Pg::tsearch2_trigger
199 metabib::author_field_entry->add_trigger(
200 before_update => \&OpenILS::Application::Storage::Driver::Pg::tsearch2_trigger
203 #-------------------------------------------------------------------------------
205 #-------------------------------------------------------------------------------
206 package metabib::subject_field_entry;
208 metabib::subject_field_entry->table( 'metabib.subject_field_entry' );
209 metabib::subject_field_entry->sequence( 'metabib.subject_field_entry_id_seq' );
210 metabib::subject_field_entry->columns( Primary => qw/id/ );
211 metabib::subject_field_entry->columns( Others => qw/field index_vector/ );
212 metabib::subject_field_entry->columns( TEMP => qw/value/ );
214 metabib::subject_field_entry->add_trigger(
215 before_create => \&OpenILS::Application::Storage::Driver::Pg::tsearch2_trigger
217 metabib::subject_field_entry->add_trigger(
218 before_update => \&OpenILS::Application::Storage::Driver::Pg::tsearch2_trigger
221 #-------------------------------------------------------------------------------
223 #-------------------------------------------------------------------------------
224 package metabib::keyword_field_entry;
226 metabib::keyword_field_entry->table( 'metabib.keyword_field_entry' );
227 metabib::keyword_field_entry->sequence( 'metabib.keyword_field_entry_id_seq' );
228 metabib::keyword_field_entry->columns( Primary => qw/id/ );
229 metabib::keyword_field_entry->columns( Others => qw/field index_vector/ );
230 metabib::keyword_field_entry->columns( TEMP => qw/value/ );
232 metabib::keyword_field_entry->add_trigger(
233 before_create => \&OpenILS::Application::Storage::Driver::Pg::tsearch2_trigger
235 metabib::keyword_field_entry->add_trigger(
236 before_update => \&OpenILS::Application::Storage::Driver::Pg::tsearch2_trigger
239 #-------------------------------------------------------------------------------
241 #-------------------------------------------------------------------------------
242 package metabib::title_field_entry_source_map;
244 metabib::title_field_entry_source_map->table( 'metabib.title_field_entry_source_map' );
245 metabib::title_field_entry_source_map->table( 'metabib.title_field_entry_source_map_id_seq' );
247 #-------------------------------------------------------------------------------
249 #-------------------------------------------------------------------------------
250 package metabib::author_field_entry_source_map;
252 metabib::author_field_entry_source_map->table( 'metabib.author_field_entry_source_map' );
253 metabib::author_field_entry_source_map->sequence( 'metabib.author_field_entry_source_map_id_seq' );
255 #-------------------------------------------------------------------------------
257 #-------------------------------------------------------------------------------
258 package metabib::subject_field_entry_source_map;
260 metabib::subject_field_entry_source_map->table( 'metabib.subject_field_entry_source_map' );
261 metabib::subject_field_entry_source_map->sequence( 'metabib.subject_field_entry_source_map_id_seq' );
263 #-------------------------------------------------------------------------------