| Index: third_party/sqlite/sqlite-src-3070603/test/thread001.test
|
| diff --git a/third_party/sqlite/sqlite-src-3070603/test/thread001.test b/third_party/sqlite/sqlite-src-3070603/test/thread001.test
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..9b788aafaf18444bf112d545fee1f0655db32783
|
| --- /dev/null
|
| +++ b/third_party/sqlite/sqlite-src-3070603/test/thread001.test
|
| @@ -0,0 +1,145 @@
|
| +# 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
|
| +
|
| + 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]
|
| + #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
|
|
|