gosa-si/server/events/databases.pm

   1 package databases;
   2 use Exporter;
   3 @ISA = qw(Exporter);
   4 my @events = (
   5     "get_events",
   6     "query_jobdb",
   7     "count_jobdb",
   8     "delete_jobdb_entry",
   9     "clear_jobdb",
  10     "update_status_jobdb_entry",
  11     "query_packages_list",
  12     "count_packages_list",
  13     "query_fai_server",
  14     "count_fai_server",
  15     "query_fai_release",
  16     "count_fai_release",
  17     );
  18 @EXPORT = @events;
  19
  20 use strict;
  21 use warnings;
  22 use GOSA::GosaSupportDaemon;
  23 use Data::Dumper;
  24 use utf8;
  25
  26 BEGIN {}
  27
  28 END {}
  29
  30 ### Start ######################################################################
  31
  32 #&main::read_configfile($main::cfg_file, %cfg_defaults);
  33
  34 sub get_events {
  35     return \@events;
  36 }
  37
  38 sub query_fai_releases{ return &query_db( @_ ); }
  39 sub query_fai_server{ return &query_db( @_ ) ; }
  40 sub query_packages_list { return &query_db( @_ ) ; }
  41 sub query_jobdb { return &query_db( @_ ) ; }
  42 sub query_db {
  43     my ($msg, $msg_hash, $session_id) = @_ ;
  44     my $header = @{$msg_hash->{'header'}}[0];
  45     my $target = @{$msg_hash->{'target'}}[0];
  46     my $source = @{$msg_hash->{'source'}}[0];
  47     my $table;
  48     my $db;
  49     if( $header =~ /query_jobdb/ ) {
  50         $table = $main::job_queue_tn;
  51         $db = $main::job_db;
  52     } elsif( $header =~ /query_packages_list/ ) {
  53         $table = $main::packages_list_tn;
  54         $db = $main::packages_list_db;
  55     } elsif( $header =~ /query_fai_server/ ) {
  56         $table = $main::fai_server_tn;
  57         $db = $main::fai_server_db;
  58     } elsif( $header =~ /count_fai_release/ ) {
  59         $table = $main::fai_release_tn;
  60         $db = $main::fai_server_db;
  61     }
  62
  63
  64     # prepare sql statement and execute query
  65     my $select= &get_select_statement($msg, $msg_hash);
  66     my $where= &get_where_statement($msg, $msg_hash);
  67     my $limit= &get_limit_statement($msg, $msg_hash);
  68     my $orderby= &get_orderby_statement($msg, $msg_hash);
  69     my $sql_statement= "SELECT $select FROM $table $where $orderby $limit";
  70     my $res_hash = $db->select_dbentry($sql_statement);
  71
  72     my $out_xml = &db_res2si_msg($res_hash, $header, $target, $source);
  73     $out_xml =~ s/<\/xml>/<session_id>$session_id<\/session_id><\/xml>/;
  74     my @out_msg_l = ( $out_xml );
  75     return @out_msg_l;
  76 }
  77
  78 sub count_fai_release{ return &count_db( @_ ); }
  79 sub count_fai_server{ return &count_db( @_ ); }
  80 sub count_packages_list{ return &count_db( @_ ); }
  81 sub count_jobdb{ return &count_db( @_ ); }
  82 sub count_db {
  83     my ($msg, $msg_hash, $session_id) = @_;
  84     my $header = @{$msg_hash->{'header'}}[0];
  85     my $target = @{$msg_hash->{'target'}}[0];
  86     my $source = @{$msg_hash->{'source'}}[0];
  87     my $table;
  88     my $db;
  89
  90     if( $header =~ /count_jobdb/ ) {
  91         $table = $main::job_queue_tn;
  92         $db = $main::job_db;
  93     } elsif( $header =~ /count_packages_list/ ) {
  94         $table = $main::packages_list_tn;
  95         $db = $main::packages_list_db;
  96     } elsif( $header =~ /count_fai_server/ ) {
  97         $table = $main::fai_server_tn;
  98         $db = $main::fai_server_db;
  99     } elsif( $header =~ /count_fai_release/ ) {
 100         $table = $main::fai_release_tn;
 101         $db = $main::fai_server_db;
 102     }
 103
 104
 105     # prepare sql statement and execute query
 106     my $res_hash = $db->select_dbentry("SELECT * FROM $table");
 107
 108     my $count = keys(%{$res_hash});
 109     my $out_xml= "<xml><header>answer</header><source>$target</source><target>$source</target><count>$count</count><session_id>$session_id</session_id></xml>";
 110     my @out_msg_l = ( $out_xml );
 111     return @out_msg_l;
 112 }
 113
 114 sub delete_jobdb_entry {
 115     my ($msg, $msg_hash, $session_id) = @_ ;
 116     my $target = @{$msg_hash->{'target'}}[0];
 117     my $source = @{$msg_hash->{'source'}}[0];
 118
 119     # prepare query sql statement
 120     my $table= $main::job_queue_tn;
 121     my $where= &get_where_statement($msg, $msg_hash);
 122     my $sql_statement = "DELETE FROM $table $where";
 123
 124     # execute db query
 125     my $db_res = $main::job_db->del_dbentry($sql_statement);
 126
 127     my $res;
 128     if( $db_res > 0 ) {
 129         $res = 0 ;
 130     } else {
 131         $res = 1;
 132     }
 133
 134     # prepare xml answer
 135     my $out_xml = "<xml><header>answer</header><source>$target</source><target>$source</target><answer1>$res</answer1><session_id>$session_id</session_id></xml>";
 136     my @out_msg_l = ( $out_xml );
 137     return @out_msg_l;
 138
 139 }
 140
 141
 142 sub clear_jobdb {
 143     my ($msg, $msg_hash, $session_id) = @_ ;
 144     my $target = @{$msg_hash->{'target'}}[0];
 145     my $source = @{$msg_hash->{'source'}}[0];
 146
 147     my $error= 0;
 148     my $out_xml= "<xml><answer1>1</answer1></xml>";
 149
 150     my $table= $main::job_queue_tn;
 151
 152     my $sql_statement = "DELETE FROM $table";
 153     my $db_res = $main::job_db->del_dbentry($sql_statement);
 154     if( not $db_res > 0 ) { $error++; };
 155
 156     if( $error == 0 ) {
 157         $out_xml = "<xml><header>answer</header><source>$target</source><target>$source</target><answer1>0</answer1><session_id>$session_id</session_id></xml>";
 158     }
 159     my @out_msg_l = ( $out_xml );
 160     return @out_msg_l;
 161 }
 162
 163
 164 sub update_status_jobdb_entry {
 165     my ($msg, $msg_hash, $session_id) = @_ ;
 166     my $target = @{$msg_hash->{'target'}}[0];
 167     my $source = @{$msg_hash->{'source'}}[0];
 168
 169     my $error= 0;
 170     my $out_xml= "<xml><header>answer</header><source>$target</source><target>$source</target><answer1>1</answer1><session_id>$session_id</session_id></xml>";
 171
 172     my @len_hash = keys %{$msg_hash};
 173     if( 0 == @len_hash) {  $error++; };
 174
 175     # prepare query sql statement
 176     if( $error == 0) {
 177         my $table= $main::job_queue_tn;
 178         my $where= &get_where_statement($msg, $msg_hash);
 179         my $update= &get_update_statement($msg, $msg_hash);
 180
 181         # conditions
 182         # no timestamp update if status eq waiting
 183         my $sql_statement = "SELECT * FROM $table $where AND status='processing'";
 184         my $res_hash = $main::job_db->select_dbentry($sql_statement);
 185         if( (0 != keys(%$res_hash)) && ($update =~ /timestamp/i) ) {
 186             $error ++;
 187             $out_xml = "<answer1>1</answer1><error_string>there is no timestamp update allowed while status is 'processing'</error_string>";
 188         }
 189
 190         if( $error == 0 ) {
 191             my $sql_statement = "UPDATE $table $update $where";
 192             # execute db query
 193             my $db_res = $main::job_db->update_dbentry($sql_statement);
 194
 195             # check success of db update
 196             if( not $db_res > 0 ) { $error++; };
 197         }
 198     }
 199
 200     if( $error == 0) {
 201         $out_xml = "<answer1>0</answer1>";
 202     }
 203
 204     my $out_msg = sprintf("<xml><header>answer</header><source>%s</source><target>%s</target>%s<session_id>$session_id</session_id></xml>", $target, $source, $out_xml);
 205     my @out_msg_l = ( $out_msg );
 206     return @out_msg_l;
 207 }
 208
 209 1;