/[cvs]/nfo/perl/libs/App/Process.pm
ViewVC logotype

Diff of /nfo/perl/libs/App/Process.pm

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

revision 1.1 by joko, Thu Feb 20 18:41:48 2003 UTC revision 1.5 by joko, Sat Jun 19 01:51:21 2004 UTC
# Line 2  Line 2 
2  ##  $Id$  ##  $Id$
3  ## ----------------------------------------------------------------------  ## ----------------------------------------------------------------------
4  ##  $Log$  ##  $Log$
5    ##  Revision 1.5  2004/06/19 01:51:21  joko
6    ##  don't do any "Task"-handling (would require db "oefcore")
7    ##
8    ##  Revision 1.4  2003/12/03 00:21:38  joko
9    ##  + minor fix to '_bootDatabases': instantiate the DSC-container if no ref to it exists
10    ##
11    ##  Revision 1.3  2003/06/06 03:14:16  joko
12    ##  enhanced database connection bootstrapping:
13    ##    - boot default ones
14    ##    - boot-on-demand
15    ##    - protection for multiple redundant connections
16    ##
17    ##  Revision 1.2  2003/03/27 15:43:05  joko
18    ##  minor fix: new comment/remark
19    ##
20  ##  Revision 1.1  2003/02/20 18:41:48  joko  ##  Revision 1.1  2003/02/20 18:41:48  joko
21  ##  + initial commit  ##  + initial commit
22  ##  ##
23  ## ----------------------------------------------------------------------  ## ----------------------------------------------------------------------
24    
25    
26    =pod
27    
28      This could also be called App::Component, App::Bean or whatever.
29      Since it conducts various things of the OEF framework,
30      it should probably be better renamed to OEF::App::Xyz, hmmm!?
31      OEF::App::Bean? OEF::App::Bimbo? Yakka and Bimbo...
32    
33    =cut
34    
35    
36  package App::Process;  package App::Process;
37    
38  use strict;  use strict;
# Line 43  sub constructor { Line 68  sub constructor {
68    #$self->{boot} = BizWorks::Boot->new( use_databases => [qw( oefcore )] );    #$self->{boot} = BizWorks::Boot->new( use_databases => [qw( oefcore )] );
69    #$self->{app}->{use_databases} =|| [qw( oefcore )];    #$self->{app}->{use_databases} =|| [qw( oefcore )];
70    $self->_bootDatabases();    $self->_bootDatabases();
71      
72      return;
73    
74    # if no "guid" is given ....    # if no "guid" is given ....
75    if (!$self->{guid}) {    if (!$self->{guid}) {
# Line 111  sub getGuid { Line 138  sub getGuid {
138    
139  sub _bootDatabases {  sub _bootDatabases {
140    my $self = shift;    my $self = shift;
 #print Dumper($self->{config}->{databases});  
   
   #print Dumper($self);  
   #exit;  
   
   #my $dbkeys = shift;  
   my $dbkeys;  
141    
142      # re-enabled as of 2003-05-16: Now accepts db-keys via method-args again!
143      my $dbkeys = shift;
144      
145      #my $dbkeys;
146    my $dbcfg;    my $dbcfg;
   my $container = DesignPattern::Object->fromPackage('Data::Storage::Container');  
147        
148    if (my $dbkey_raw = $self->{app}->{use_databases}) {    # A - Build list of db-keys to boot
149      if (ref $dbkey_raw eq 'ARRAY') {    
150        $dbkeys = $dbkey_raw;    # FIXME: CACHE THIS! JUST BOOT STORAGES INTO CONTAINER IF NOT ALREADY DONE!
151      } else {    # WATCH OUT FOR GLOBAL USED RESOURCES!
152        #$self->{app}->{instance}->_bootDatabases();    if (not ref $self->{DSC} eq 'Data::Storage::Container') {
153        my @dbkeys = split(/,\s|,/, $dbkey_raw);      $self->{DSC} = DesignPattern::Object->fromPackage('Data::Storage::Container');
       #$self->_bootDatabases(\@dbkeys);  
       $dbkeys = \@dbkeys;  
     }  
154    }    }
155      
156      # Check if database keys were specified explicitely
157      # as default inside the application container ...
158      # new of 2003-05-16: Just do this if no dbkeys have been passed in via args.
159      $dbkeys ||= $self->_get_dbkeys_app_defaults();
160    
161    # just boot specified databases    # ... if yes, just boot specified databases...
162    if ($dbkeys) {    if ($dbkeys) {
163      $self->log("Using Database(s): " . join(', ', @{$dbkeys}), 'info');    
164        $self->log("Using database(s): " . join(', ', @{$dbkeys}), 'info');
165      foreach (@$dbkeys) {      foreach (@$dbkeys) {
166        $dbcfg->{$_} = $self->{app}->{config}->{databases}->{$_};        $dbcfg->{$_} = $self->{app}->{config}->{databases}->{$_};
167      }      }
168            
169    # boot all databases    # ... otherwise boot all databases.
170    } else {    } else {
171        $self->log("Using all databases.", 'info');
172      $dbcfg = $self->{app}->{config}->{databases};      $dbcfg = $self->{app}->{config}->{databases};
173    }    }
174    
   foreach (keys %$dbcfg) {  
     $container->addConfig($_, $dbcfg->{$_});  
   }  
175    
176    $container->initLocators();    # B - Propagate stuff to application -config and -resource slots etc.
177    $container->initStorages();    # TODO: refactor: abstract this out
178    
179    foreach (keys %{$container->{storage}}) {    # B.1 - Initialize config
180      $self->{app}->{storage}->{$_} = $container->{storage}->{$_};    foreach (keys %$dbcfg) {
181        $self->{DSC}->addConfig($_, $dbcfg->{$_});
182    }    }
183    
184      # B.2 - Initialize resources
185      $self->{DSC}->initLocators();
186      $self->{DSC}->initStorages();
187        
188    # trace    # B.3 - Establish symbols inside the application container
189      #print Dumper($self);    # as references to the storage handle instances inside the
190      # storage container singleton.
191      # In other words: spread the refs
192      # FIXME: This should be cleared up somehow!    ;-)
193      foreach (keys %{$self->{DSC}->{storage}}) {
194        $self->{app}->{storage}->{$_} = $self->{DSC}->{storage}->{$_};
195      }
196        
197  }  }
198    
199    sub _get_dbkeys_app_defaults {
200      my $self = shift;
201      my $dbkeys;
202      if (my $dbkey_raw = $self->{app}->{use_databases}) {
203        if (ref $dbkey_raw eq 'ARRAY') {
204          $dbkeys = $dbkey_raw;
205        } else {
206          #$self->{app}->{instance}->_bootDatabases();
207          my @dbkeys = split(/,\s|,/, $dbkey_raw);
208          #$self->_bootDatabases(\@dbkeys);
209          $dbkeys = \@dbkeys;
210        }
211      }
212      return $dbkeys;
213    }
214    
215  sub _shutdownDatabases {  sub _shutdownDatabases {
216    my $self = shift;    my $self = shift;
217    foreach my $dbkey (keys %{$self->{app}->{storage}}) {    foreach my $dbkey (keys %{$self->{app}->{storage}}) {
218      #print "SHUTDOWN $dbkey", "\n";      #print "SHUTDOWN $dbkey", "\n";
219      $self->{app}->{storage}->{$dbkey}->disconnect();      #print Dumper($self->{app}->{storage}->{$dbkey});
220        my $handle = $self->{app}->{storage}->{$dbkey};
221        #print ref $handle, "\n";
222        #next if not $handle or not ref $handle or ref($handle) =~ m/(ARRAY|HASH)/;
223        next if not $handle or not ref $handle or ref($handle) !~ m/(Data::Storage|DBI)/;
224        $handle->disconnect();
225    }    }
226  }  }
227    
228  =pod  #=pod
229  sub DESTROY {  sub DESTROY {
230    my $self = shift;    my $self = shift;
231    $self->_shutdownDatabases();    $self->_shutdownDatabases();
232  }  }
233  =cut  #=cut
234    
235    
236    sub activate_resources {
237      my $self = shift;
238      my $args = shift;
239      $self->_bootDatabases($args);
240    }
241    
242    sub resource_is_active {
243      my $self = shift;
244      my $key = shift;
245      # FIXME: Enhance this!
246      #print "key: $key", "\n";
247      #print Dumper($self->{DSC}->{storage});
248      return 1 if exists $self->{DSC}->{storage}->{$key};
249    }
250    
251  1;  1;
252  __END__  __END__
Legend:
Removed from v.1.1  
changed lines
  Added in v.1.5
MailToCvsAdmin">MailToCvsAdmin
 ViewVC Help
Powered by ViewVC 1.1.26 RSS 2.0 feed