Return to thread001.test CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / sqlite3 / test

sqlite3

    1: # 2007 September 7
    2: #
    3: # The author disclaims copyright to this source code.  In place of
    4: # a legal notice, here is a blessing:
    5: #
    6: #    May you do good and not evil.
    7: #    May you find forgiveness for yourself and forgive others.
    8: #    May you share freely, never taking more than you give.
    9: #
   10: #***********************************************************************
   11: #
   12: # $Id: thread001.test,v 1.1.1.1 2012/02/21 17:04:16 misho Exp $
   13: 
   14: set testdir [file dirname $argv0]
   15: 
   16: source $testdir/tester.tcl
   17: if {[run_thread_tests]==0} { finish_test ; return }
   18: 
   19: set ::enable_shared_cache [sqlite3_enable_shared_cache]
   20: 
   21: set ::NTHREAD 10
   22: 
   23: # Run this test three times: 
   24: # 
   25: #    1) All threads use the same database handle.
   26: #    2) All threads use their own database handles.
   27: #    3) All threads use their own database handles, shared-cache is enabled.
   28: #
   29: #
   30: #
   31: foreach {tn same_db shared_cache} [list \
   32:          1  1       0                   \
   33:          2  0       0                   \
   34:          3  0       1                   \
   35: ] {
   36:   # Empty the database.
   37:   #
   38:   catchsql { DROP TABLE ab; }
   39: 
   40:   do_test thread001.$tn.0 {
   41:     db close
   42:     sqlite3_enable_shared_cache $shared_cache
   43:     sqlite3_enable_shared_cache $shared_cache
   44:   } $shared_cache
   45:   sqlite3 db test.db -fullmutex 1 -key xyzzy
   46: 
   47:   set dbconfig ""
   48:   if {$same_db} {
   49:     set dbconfig [list set ::DB [sqlite3_connection_pointer db]]
   50:   }
   51: 
   52:   # Set up a database and a schema. The database contains a single
   53:   # table with two columns. The first column ("a") is an INTEGER PRIMARY 
   54:   # KEY. The second contains the md5sum of all rows in the table with
   55:   # a smaller value stored in column "a".
   56:   #
   57:   do_test thread001.$tn.1 {
   58:     execsql {
   59:       CREATE TABLE ab(a INTEGER PRIMARY KEY, b);
   60:       CREATE INDEX ab_i ON ab(b);
   61:       INSERT INTO ab SELECT NULL, md5sum(a, b) FROM ab;
   62:       SELECT count(*) FROM ab;
   63:     }
   64:   } {1}
   65:   do_test thread001.$tn.2 {
   66:     execsql {
   67:       SELECT 
   68:         (SELECT md5sum(a, b) FROM ab WHERE a < (SELECT max(a) FROM ab)) ==
   69:         (SELECT b FROM ab WHERE a = (SELECT max(a) FROM ab))
   70:     }
   71:   } {1}
   72:   do_test thread001.$tn.3 {
   73:     execsql { PRAGMA integrity_check }
   74:   } {ok}
   75: 
   76:   set thread_program {
   77:     #sqlthread parent {puts STARTING..}
   78:     set needToClose 0
   79:     if {![info exists ::DB]} {
   80:       set ::DB [sqlthread open test.db xyzzy]
   81:       #sqlthread parent "puts \"OPEN $::DB\""
   82:       set needToClose 1
   83:     }
   84:   
   85:     for {set i 0} {$i < 100} {incr i} {
   86:       # Test that the invariant is true.
   87:       do_test t1 {
   88:         execsql {
   89:           SELECT 
   90:             (SELECT md5sum(a, b) FROM ab WHERE a < (SELECT max(a) FROM ab)) ==
   91:             (SELECT b FROM ab WHERE a = (SELECT max(a) FROM ab))
   92:         }
   93:       } {1}
   94:   
   95:       # Add another row to the database.
   96:       execsql { INSERT INTO ab SELECT NULL, md5sum(a, b) FROM ab }
   97:     }
   98:   
   99:     if {$needToClose} {
  100:       #sqlthread parent "puts \"CLOSE $::DB\""
  101:       sqlite3_close $::DB
  102:     }
  103:     #sqlthread parent "puts \"DONE\""
  104:   
  105:     list OK
  106:   }
  107:   
  108:   # Kick off $::NTHREAD threads:
  109:   #
  110:   array unset finished
  111:   for {set i 0} {$i < $::NTHREAD} {incr i} {
  112:     thread_spawn finished($i) $dbconfig $thread_procs $thread_program
  113:   }
  114:   
  115:   # Wait for all threads to finish,  then check they all returned "OK".
  116:   #
  117:   for {set i 0} {$i < $::NTHREAD} {incr i} {
  118:     if {![info exists finished($i)]} {
  119:       vwait finished($i)
  120:     }
  121:     do_test thread001.$tn.4.$i {
  122:       set ::finished($i)
  123:     } OK
  124:   }
  125:   
  126:   # Check the database still looks Ok.
  127:   #
  128:   do_test thread001.$tn.5 {
  129:     execsql { SELECT count(*) FROM ab; }
  130:   } [expr {1 + $::NTHREAD*100}]
  131:   do_test thread001.$tn.6 {
  132:     execsql {
  133:       SELECT 
  134:         (SELECT md5sum(a, b) FROM ab WHERE a < (SELECT max(a) FROM ab)) ==
  135:         (SELECT b FROM ab WHERE a = (SELECT max(a) FROM ab))
  136:     }
  137:   } {1}
  138:   do_test thread001.$tn.7 {
  139:     execsql { PRAGMA integrity_check }
  140:   } {ok}
  141: }
  142: 
  143: sqlite3_enable_shared_cache $::enable_shared_cache
  144: set sqlite_open_file_count 0
  145: finish_test