| # 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.10 2009/03/26 14:48:07 danielk1977 Exp $ |
| |
| set testdir [file dirname $argv0] |
| |
| source $testdir/tester.tcl |
| if {[run_thread_tests]==0} { finish_test ; return } |
| |
| set ::enable_shared_cache [sqlite3_enable_shared_cache] |
| |
| 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 -fullmutex 1 -key xyzzy |
| |
| 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 { |
| #sqlthread parent {puts STARTING..} |
| set needToClose 0 |
| if {![info exists ::DB]} { |
| set ::DB [sqlthread open test.db xyzzy] |
| #sqlthread parent "puts \"OPEN $::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} { |
| #sqlthread parent "puts \"CLOSE $::DB\"" |
| sqlite3_close $::DB |
| } |
| #sqlthread parent "puts \"DONE\"" |
| |
| 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} |
| } |
| |
| sqlite3_enable_shared_cache $::enable_shared_cache |
| set sqlite_open_file_count 0 |
| finish_test |