# 2007 September 7

 #

 # The author disclaims copyright to this source code.  In place of

 # a legal notice, here is a blessing:

 #

 #    May you do good and not evil.

 #    May you find forgiveness for yourself and forgive others.

 #    May you share freely, never taking more than you give.

 #

 #***********************************************************************

 #

 # $Id: thread001.test,v 1.5 2008/07/12 14:52:20 drh Exp $

 set testdir [file dirname $argv0]

 source $testdir/tester.tcl

 source $testdir/thread_common.tcl

 if {[info commands sqlthread] eq ""} {

   return

 }

 set ::NTHREAD 10

 # Run this test three times: 

 # 

 #    1) All threads use the same database handle.

 #    2) All threads use their own database handles.

 #    3) All threads use their own database handles, shared-cache is enabled.

 #

 foreach {tn same_db shared_cache} [list \

          1  1       0                   \

          2  0       0                   \

          3  0       1                   \

 ] {

   # Empty the database.

   #

   catchsql { DROP TABLE ab; }

   do_test thread001.$tn.0 {

     db close

     sqlite3_enable_shared_cache $shared_cache

     sqlite3_enable_shared_cache $shared_cache

   } $shared_cache

   sqlite3 db test.db

   set dbconfig ""

   if {$same_db} {

     set dbconfig [list set ::DB [sqlite3_connection_pointer db]]

   }

   # Set up a database and a schema. The database contains a single

   # table with two columns. The first column ("a") is an INTEGER PRIMARY 

   # KEY. The second contains the md5sum of all rows in the table with

   # a smaller value stored in column "a".

   #

   do_test thread001.$tn.1 {

     execsql {

       CREATE TABLE ab(a INTEGER PRIMARY KEY, b);

       CREATE INDEX ab_i ON ab(b);

       INSERT INTO ab SELECT NULL, md5sum(a, b) FROM ab;

       SELECT count(*) FROM ab;

     }

   } {1}

   do_test thread001.$tn.2 {

     execsql {

       SELECT 

         (SELECT md5sum(a, b) FROM ab WHERE a < (SELECT max(a) FROM ab)) ==

         (SELECT b FROM ab WHERE a = (SELECT max(a) FROM ab))

     }

   } {1}

   do_test thread001.$tn.3 {

     execsql { PRAGMA integrity_check }

   } {ok}

   set thread_program {

     set needToClose 0

     if {![info exists ::DB]} {

       set ::DB [sqlthread open test.db]

       set needToClose 1

     }

     for {set i 0} {$i < 100} {incr i} {

       # Test that the invariant is true.

       do_test t1 {

         execsql {

           SELECT 

             (SELECT md5sum(a, b) FROM ab WHERE a < (SELECT max(a) FROM ab)) ==

             (SELECT b FROM ab WHERE a = (SELECT max(a) FROM ab))

         }

       } {1}

       # Add another row to the database.

       execsql { INSERT INTO ab SELECT NULL, md5sum(a, b) FROM ab }

     }

     if {$needToClose} {

       sqlite3_close $::DB

     }

     list OK

   }

   # Kick off $::NTHREAD threads:

   #

   array unset finished

   for {set i 0} {$i < $::NTHREAD} {incr i} {

     thread_spawn finished($i) $dbconfig $thread_procs $thread_program

   }

   # Wait for all threads to finish,  then check they all returned "OK".

   #

   for {set i 0} {$i < $::NTHREAD} {incr i} {

     if {![info exists finished($i)]} {

       vwait finished($i)

     }

     do_test thread001.$tn.4.$i {

       set ::finished($i)

     } OK

   }

   # Check the database still looks Ok.

   #

   do_test thread001.$tn.5 {

     execsql { SELECT count(*) FROM ab; }

   } [expr {1 + $::NTHREAD*100}]

   do_test thread001.$tn.6 {

     execsql {

       SELECT 

         (SELECT md5sum(a, b) FROM ab WHERE a < (SELECT max(a) FROM ab)) ==

         (SELECT b FROM ab WHERE a = (SELECT max(a) FROM ab))

     }

   } {1}

   do_test thread001.$tn.7 {

     execsql { PRAGMA integrity_check }

   } {ok}

 }

 finish_test