Add test program, to check concurrent access of sqlite databases.

git-svn-id: https://oss.gonicus.de/repositories/gosa/trunk@13466 594d385d-05f5-0310-b6e9-bd551577e9d8

diff --git a/gosa-si/tests/sqlite-check-concurrency.pl b/gosa-si/tests/sqlite-check-concurrency.pl
new file mode 100755 (executable)
index 0000000..d6c4ce9
--- /dev/null
+++ b/gosa-si/tests/sqlite-check-concurrency.pl
@@ -0,0 +1,83 @@
+#!/usr/bin/perl -W
+
+package GOSA::DBsqlite;
+use strict;
+use warnings;
+
+use DBI;
+use Time::HiRes qw(usleep);
+use Fcntl ':flock';
+use threads;
+
+my %threads;
+# Count of threads, if > 1 it corrupts the db
+my $count= 1;
+my $db_name= "./test.sqlite";
+
+unlink $db_name;
+unlink $db_name.".si.lock";
+
+for(my $i=0;$i<$count;$i++) {
+       $threads{$i}= threads->create(\&check_database);
+}
+
+foreach my $thread (threads->list()) {
+       print $thread->tid()."\n";
+}
+
+sub check_database {
+       $threads{threads->self->tid()}= GOSA::DBsqlite->new($db_name);
+       threads->yield();
+       $threads{threads->self->tid()}->run_test("test");
+
+       return;
+}
+
+
+sub new {
+    my $class = shift;
+    my $db_name = shift;
+
+    my $lock = $db_name.".si.lock";
+    # delete existing lock - instance should be running only once
+    if(stat($lock)) {
+        print STDERR "DEBUG: Removed existing lock file $lock.";
+        unlink($lock);
+    }
+    my $self = {dbh=>undef,db_name=>undef,db_lock=>undef,db_lock_handle=>undef};
+    my $dbh = DBI->connect("dbi:SQLite:dbname=$db_name", "", "", {RaiseError => 0, AutoCommit => 0});
+    $self->{dbh} = $dbh;
+    $self->{db_name} = $db_name;
+    $self->{db_lock} = $lock;
+    bless($self,$class);
+    return($self);
+}
+
+sub lock {
+    my $self = shift;
+    open($self->{db_lock_handle}, ">>".($self->{db_lock})) unless ref $self->{db_lock_handle};
+    flock($self->{db_lock_handle},LOCK_EX);
+    seek($self->{db_lock_handle}, 0, 2);
+}
+
+
+sub unlock {
+    my $self = shift;
+    flock($self->{db_lock_handle},LOCK_UN);
+}
+
+sub run_test {
+       my $self= shift;
+       my $table_name= shift;
+       my $sql= "CREATE TABLE IF NOT EXISTS $table_name (id INTEGER, value VARCHAR(255))";
+       $self->lock();
+    $self->{dbh}->do($sql);
+       $self->unlock();
+          
+       for(my $i=0;$i<10000;$i++) {
+       $sql= "INSERT INTO $table_name VALUES ($i, 'test $i')";
+          $self->lock();
+          $self->{dbh}->do($sql);
+          $self->unlock();
+       }
+}