Open-ILS/src/perlmods/lib/OpenILS/Utils/OfflineStore.pm

   1 package OpenILS::Utils::OfflineStore;
   2 use strict; use warnings;
   3
   4 use UNIVERSAL::require;
   5 if ('Class::DBI::Frozen::301'->use) {
   6         use parent 'Class::DBI::Frozen::301';
   7 } elsif ('Class::DBI'->use) {
   8         use parent 'Class::DBI';
   9 } else {
  10         die $@;
  11 }
  12
  13 use DBI;
  14 use OpenSRF::Utils::Config;
  15
  16 our ($_dsn,$_u,$_p);
  17 sub DBFile {
  18         my $class = shift;
  19         my $dsn = shift;
  20         my $u = shift;
  21         my $p = shift;
  22         if ($dsn) {
  23                 $_dsn = $dsn;
  24                 $_u = $u;
  25                 $_p = $p;
  26         }
  27         return $_dsn;
  28 }
  29
  30 our $_dbh;
  31 sub db_Main {
  32         my $self = shift;
  33         return $_dbh if ($_dbh);
  34
  35         $_dbh = DBI->connect($_dsn,$_u,$_p,
  36                 {
  37                         RootClass => 'DBIx::ContextualFetch'
  38                 }
  39         );
  40
  41         return $_dbh;
  42 }
  43
  44
  45 sub disconnect {
  46         $_dbh->disconnect;
  47         $_dbh = undef;
  48 }
  49
  50
  51 package OpenILS::Utils::OfflineStore::Session;
  52 use parent 'OpenILS::Utils::OfflineStore';
  53
  54 sub _create_table {
  55         my $self = shift;
  56         $self->db_Main->do( <<" SQL" );
  57
  58 CREATE TABLE session (
  59         key                             TEXT    UNIQUE PRIMARY KEY,
  60         org                             INTEGER NOT NULL,
  61         description             TEXT,
  62         creator                 INTEGER NOT NULL,
  63         create_time             INTEGER NOT NULL,
  64         in_process              INTEGER NOT NULL DEFAULT 0,
  65         start_time              INTEGER,
  66         end_time                        INTEGER,
  67         num_complete    INTEGER NOT NULL DEFAULT 0
  68 );
  69 CREATE INDEX IF NOT EXISTS session_pkey ON session (key);
  70 CREATE INDEX IF NOT EXISTS session_org ON session (org);
  71 CREATE INDEX IF NOT EXISTS session_creation ON session (create_time);
  72
  73         SQL
  74 }
  75
  76 __PACKAGE__->table('offline.session');
  77 __PACKAGE__->columns( Essential => qw/key org description
  78                 creator create_time in_process start_time end_time num_complete/);
  79 __PACKAGE__->has_many(scripts => 'OpenILS::Utils::OfflineStore::Script');
  80
  81
  82 package OpenILS::Utils::OfflineStore::Script;
  83 use parent 'OpenILS::Utils::OfflineStore';
  84
  85 sub _create_table {
  86         my $self = shift;
  87         $self->db_Main->do( <<" SQL" );
  88
  89 CREATE TABLE script (
  90         id              INTEGER UNIQUE PRIMARY KEY AUTOINCREMENT,
  91         session         TEXT    NOT NULL,
  92         requestor       INTEGER NOT NULL,
  93         create_time     INTEGER NOT NULL,
  94         workstation     TEXT    NOT NULL,
  95         logfile         TEXT    NOT NULL,
  96         time_delta      INTEGER NOT NULL DEFAULT 0,
  97         count                   INTEGER NOT NULL DEFAULT 0
  98 );
  99 CREATE INDEX IF NOT EXISTS script_pkey ON script (id);
 100 CREATE INDEX IF NOT EXISTS script_ws ON script (workstation);
 101 CREATE INDEX IF NOT EXISTS script_session ON script (session);
 102
 103         SQL
 104 }
 105
 106 __PACKAGE__->table('offline.script');
 107 __PACKAGE__->columns( Essential => qw/id session requestor create_time workstation logfile time_delta count/);
 108 __PACKAGE__->has_a(session => 'OpenILS::Utils::OfflineStore::Session');
 109 __PACKAGE__->sequence(qw/offline.script_id_seq/);
 110
 111
 112
 113
 114