From 98274929e0b46dcd9293bc3ca00e3d0f4dec753f Mon Sep 17 00:00:00 2001
From: janw <janw@594d385d-05f5-0310-b6e9-bd551577e9d8>
Date: Thu, 26 Feb 2009 14:38:01 +0000
Subject: [PATCH] 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
---
 gosa-si/tests/sqlite-check-concurrency.pl | 83 +++++++++++++++++++++++
 1 file changed, 83 insertions(+)
 create mode 100755 gosa-si/tests/sqlite-check-concurrency.pl

diff --git a/gosa-si/tests/sqlite-check-concurrency.pl b/gosa-si/tests/sqlite-check-concurrency.pl
new file mode 100755
index 000000000..d6c4ce9c1
--- /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();
+	}
+}
-- 
2.30.2