Open-ILS/src/perlmods/lib/OpenILS/Application/Storage.pm

   1 package OpenILS::Application::Storage;
   2 use OpenILS::Application;
   3 use base qw/OpenILS::Application/;
   4
   5 use OpenSRF::EX qw/:try/;
   6 use OpenSRF::Utils::Logger qw/:level/;
   7
   8 # Pull this in so we can adjust it's @ISA
   9 use OpenILS::Application::Storage::CDBI (1);
  10 use OpenILS::Application::Storage::FTS;
  11
  12
  13 # the easy way to get to the logger...
  14 my $log = "OpenSRF::Utils::Logger";
  15
  16 our $QParser;
  17 our $WRITE = 0;
  18 our $IGNORE_XACT_ID_FAILURE = 0;
  19
  20 sub DESTROY {};
  21
  22 sub initialize {
  23
  24     my $conf = OpenSRF::Utils::SettingsClient->new;
  25
  26     $log->debug('Initializing ' . __PACKAGE__ . '...', DEBUG);
  27
  28     my $db_driver = $conf->config_value( apps => 'open-ils.storage' => app_settings => databases => 'driver');
  29     my $driver = "OpenILS::Application::Storage::Driver::$db_driver";
  30
  31     $log->debug("Attempting to load $driver ...", DEBUG);
  32
  33     $driver->use;
  34     if ($@) {
  35         $log->debug( "Can't load $driver!  :  $@", ERROR );
  36         $log->error( "Can't load $driver!  :  $@");
  37         throw OpenSRF::EX::PANIC ( "Can't load $driver!  :  $@" );
  38     }
  39
  40     $log->debug("$driver loaded successfully", DEBUG);
  41
  42     # Suck in the method publishing modules
  43     @OpenILS::Application::Storage::CDBI::ISA = ( $driver );
  44
  45     OpenILS::Application::Storage::Publisher->use;
  46     if ($@) {
  47         $log->debug("FAILURE LOADING Publisher!  $@", ERROR);
  48         throw OpenSRF::EX::PANIC ( "FAILURE LOADING Publisher!  :  $@" );
  49     }
  50
  51     $log->debug("We seem to be OK...",DEBUG);
  52 }
  53
  54 sub child_init {
  55
  56     $log->debug('Running child_init for ' . __PACKAGE__ . '...', DEBUG);
  57
  58     my $conf = OpenSRF::Utils::SettingsClient->new;
  59
  60     $log->debug('Calling the Driver child_init', DEBUG);
  61     OpenILS::Application::Storage::CDBI->child_init(
  62         $conf->config_value( apps => 'open-ils.storage' => app_settings => databases => 'database')
  63     );
  64
  65     if (OpenILS::Application::Storage::CDBI->db_Main()) {
  66         $log->debug("Success initializing driver!", DEBUG);
  67
  68         my $db_driver = $conf->config_value( apps => 'open-ils.storage' => app_settings => databases => 'driver');
  69         $QParser = 'OpenILS::Application::Storage::Driver::'.$db_driver.'::QueryParser';
  70         $QParser->use;
  71
  72         if($@) {
  73             $log->debug( "Can't load $QParser!  :  $@", ERROR );
  74             $log->error( "Can't load $QParser!  :  $@");
  75         } else {
  76             return 1;
  77         }
  78     }
  79
  80     $log->debug("FAILURE initializing driver!", ERROR);
  81     return 0;
  82 }
  83
  84 sub begin_xaction {
  85     my $self = shift;
  86     my $client = shift;
  87
  88     local $WRITE = 1;
  89
  90     $log->debug(" XACT --> 'BEGIN'ing transaction for session ".$client->session->session_id,DEBUG);
  91     try {
  92         OpenILS::Application::Storage::CDBI->db_Main->begin_work;
  93         $client->session->session_data( xact_id => $client->session->session_id );
  94     } catch Error with {
  95         throw OpenSRF::DomainObject::oilsException->new(
  96             statusCode => 500,
  97             status => "Could not BEGIN transaction!",
  98         );
  99     };
 100     return 1;
 101
 102 }
 103 __PACKAGE__->register_method(
 104     method      => 'begin_xaction',
 105     api_name    => 'open-ils.storage.transaction.begin',
 106     api_level   => 1,
 107     argc        => 0,
 108 );
 109
 110 sub savepoint_placeholder {
 111     return 1;
 112 }
 113 __PACKAGE__->register_method(
 114     method      => 'savepoint_placeholder',
 115     api_name    => 'open-ils.storage.savepoint.set',
 116     api_level   => 1,
 117     argc        => 1,
 118 );
 119 __PACKAGE__->register_method(
 120     method      => 'savepoint_placeholder',
 121     api_name    => 'open-ils.storage.savepoint.release',
 122     api_level   => 1,
 123     argc        => 1,
 124 );
 125 __PACKAGE__->register_method(
 126     method      => 'savepoint_placeholder',
 127     api_name    => 'open-ils.storage.savepoint.rollback',
 128     api_level   => 1,
 129     argc        => 1,
 130 );
 131
 132 sub commit_xaction {
 133     my $self = shift;
 134     my $client = shift;
 135
 136     local $WRITE = 1;
 137
 138     try {
 139         OpenILS::Application::Storage::CDBI->db_Main->commit;
 140         $client->session->session_data( xact_id => '' );
 141     } catch Error with {
 142         throw OpenSRF::DomainObject::oilsException->new(
 143             statusCode => 500,
 144             status => "Could not COMMIT  transaction!",
 145         );
 146     };
 147     return 1;
 148 }
 149 __PACKAGE__->register_method(
 150     method      => 'commit_xaction',
 151     api_name    => 'open-ils.storage.transaction.commit',
 152     api_level   => 1,
 153     argc        => 0,
 154 );
 155
 156
 157 sub current_xact {
 158     my $self = shift;
 159     my $client = shift;
 160
 161     return $client->session->session_data( 'xact_id' );
 162 }
 163 __PACKAGE__->register_method(
 164     method      => 'current_xact',
 165     api_name    => 'open-ils.storage.transaction.current',
 166     api_level   => 1,
 167     argc        => 0,
 168 );
 169
 170 sub rollback_xaction {
 171     my $self = shift;
 172     my $client = shift;
 173
 174     local $WRITE = 1;
 175
 176     $log->debug(" XACT --> 'ROLLBACK'ing transaction for session ".$client->session->session_id,DEBUG);
 177     $client->session->session_data( xact_id => '' );
 178     return OpenILS::Application::Storage::CDBI->db_Main->rollback;
 179 }
 180 __PACKAGE__->register_method(
 181     method      => 'rollback_xaction',
 182     api_name    => 'open-ils.storage.transaction.rollback',
 183     api_level   => 1,
 184     argc        => 0,
 185 );
 186
 187
 188 sub _cdbi2Hash {
 189     my $self = shift;
 190     my $obj = shift;
 191     return { map { ( $_ => $obj->$_ ) } ($obj->columns('All')) };
 192 }
 193
 194 sub _cdbi_list2AoH {
 195     my $self = shift;
 196     my @objs = @_;
 197     return [ map { $self->_cdbi2Hash($_) } @objs ];
 198 }
 199
 200 1;