index 8bd357fb69b2acf34ee0491855685907b601228e..2032db279b100b7469c2892da23ca85ee788ef49 100644 (file)
use GOSA::GosaSupportDaemon;
use threads;
use Time::HiRes qw(usleep);
-use utf8;
my $col_names = {};
my $lock = $self->{db_lock};
while( -f $lock ) {
#&main::daemon_log("(".((defined $funcname)?$funcname:"").") Lock (PID ".$$.") $lock found",8);
- sleep 1;
+ usleep 100;
}
open($self->{db_lock_handle},'>',$self->{db_lock});
}
$col_names->{ $table_name } = $col_names_ref;
- my $col_names_string = join(', ', @col_names);
- my $sql_statement = "CREATE TABLE IF NOT EXISTS $table_name ( $col_names_string )";
+ my $col_names_string = join("', '", @col_names);
+ my $sql_statement = "CREATE TABLE IF NOT EXISTS $table_name ( '$col_names_string' )";
&create_lock($self,'create_table');
$self->{dbh}->do($sql_statement);
&remove_lock($self,'create_table');
}
+sub exec_statementlist {
+ my $self = shift;
+ my $sql_list = shift;
+ my @db_answer;
+
+ &create_lock($self,'exec_statement');
+ foreach my $sql (@$sql_list) {
+ @db_answer = @{$self->{dbh}->selectall_arrayref($sql)};
+ }
+ &remove_lock($self, 'exec_statement');
+
+ return \@db_answer;
+}
+
sub count_dbentries {
my ($self, $table)= @_;
my $error= 0;