index dfd258340ea17aaf73650517fc06ca64c071519d..ece1a356e2c7bc1836b8284cb895c1eded692659 100755 (executable)
use Fcntl ':flock';
use threads;
+
+sub daemon_log {}
+
my %threads;
# Count of threads, if > 1 it corrupts the db
my $count= 10;
my $db_name= "./test.sqlite";
my $lock = $db_name.".si.lock";
-if(stat($lock)) {
- unlink($lock);
-}
-if(stat($db_name)) {
- unlink($db_name)
-}
+#if(stat($lock)) {
+# unlink($lock);
+#}
+#
+#if(stat($db_name)) {
+# unlink($db_name)
+#}
for(my $i=0;$i<$count;$i++) {
$threads{$i}= threads->create(\&check_database);
sub run_test {
my $self= shift;
my $table_name= shift;
- my $sql= "CREATE TABLE IF NOT EXISTS $table_name (id INTEGER, value VARCHAR(255))";
+ my $sql= "CREATE TABLE IF NOT EXISTS $table_name (id INTEGER PRIMARY KEY, status VARCHAR(255) DEFAULT 'none')";
$self->lock();
eval {
$self->{dbh}->do($sql);
$self->unlock();
for(my $i=0;$i<100;$i++) {
- $sql= "INSERT INTO $table_name VALUES ($i, 'test $i')";
+ $sql= "INSERT INTO $table_name (id, status) VALUES (null, 'test $i')";
$self->lock();
eval {
$self->{dbh}->do($sql);