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;
20 use strict;
21 use warnings;
22 use GOSA::GosaSupportDaemon;
23 use Data::Dumper;
24 use utf8;
26 BEGIN {}
28 END {}
30 ### Start ######################################################################
32 #&main::read_configfile($main::cfg_file, %cfg_defaults);
34 sub get_events {
35 return \@events;
36 }
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 }
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);
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 }
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;
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 }
105 # prepare sql statement and execute query
106 my $res_hash = $db->select_dbentry("SELECT * FROM $table");
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 }
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];
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";
124 # execute db query
125 my $db_res = $main::job_db->del_dbentry($sql_statement);
127 my $res;
128 if( $db_res > 0 ) {
129 $res = 0 ;
130 } else {
131 $res = 1;
132 }
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;
139 }
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];
147 my $error= 0;
148 my $out_xml= "<xml><answer1>1</answer1></xml>";
150 my $table= $main::job_queue_tn;
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++; };
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 }
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];
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>";
172 my @len_hash = keys %{$msg_hash};
173 if( 0 == @len_hash) { $error++; };
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);
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 }
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);
195 # check success of db update
196 if( not $db_res > 0 ) { $error++; };
197 }
198 }
200 if( $error == 0) {
201 $out_xml = "<answer1>0</answer1>";
202 }
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 }
209 1;