OLD | NEW |
(Empty) | |
| 1 # 2013 May 14 |
| 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 # Test some specific circumstances to do with shared cache mode. |
| 13 # |
| 14 |
| 15 |
| 16 set testdir [file dirname $argv0] |
| 17 source $testdir/tester.tcl |
| 18 if {[run_thread_tests]==0} { finish_test ; return } |
| 19 db close |
| 20 set ::testprefix sharedA |
| 21 |
| 22 set ::enable_shared_cache [sqlite3_enable_shared_cache 1] |
| 23 |
| 24 #------------------------------------------------------------------------- |
| 25 # |
| 26 do_test 0.1 { |
| 27 sqlite3 db1 test.db |
| 28 sqlite3 db2 test.db |
| 29 |
| 30 db1 eval { |
| 31 CREATE TABLE t1(x); |
| 32 INSERT INTO t1 VALUES(randomblob(100)); |
| 33 INSERT INTO t1 SELECT randomblob(100) FROM t1; |
| 34 INSERT INTO t1 SELECT randomblob(100) FROM t1; |
| 35 INSERT INTO t1 SELECT randomblob(100) FROM t1; |
| 36 INSERT INTO t1 SELECT randomblob(100) FROM t1; |
| 37 INSERT INTO t1 SELECT randomblob(100) FROM t1; |
| 38 INSERT INTO t1 SELECT randomblob(100) FROM t1; |
| 39 CREATE INDEX i1 ON t1(x); |
| 40 } |
| 41 |
| 42 db1 eval { |
| 43 BEGIN; |
| 44 DROP INDEX i1; |
| 45 } |
| 46 |
| 47 db2 close |
| 48 |
| 49 db1 eval { |
| 50 INSERT INTO t1 SELECT randomblob(100) FROM t1; |
| 51 ROLLBACK; |
| 52 PRAGMA integrity_check; |
| 53 } |
| 54 } {ok} |
| 55 |
| 56 db1 close |
| 57 forcedelete test.db |
| 58 |
| 59 |
| 60 #------------------------------------------------------------------------- |
| 61 # |
| 62 do_test 1.1 { |
| 63 sqlite3 db1 test.db |
| 64 sqlite3 db2 test.db |
| 65 db2 eval { |
| 66 CREATE TABLE t1(x); |
| 67 INSERT INTO t1 VALUES(123); |
| 68 } |
| 69 db1 eval { |
| 70 SELECT * FROM t1; |
| 71 CREATE INDEX i1 ON t1(x); |
| 72 } |
| 73 } {123} |
| 74 |
| 75 do_test 1.2 { |
| 76 db2 eval { SELECT * FROM t1 ORDER BY x; } |
| 77 |
| 78 db1 eval { |
| 79 BEGIN; DROP INDEX i1; |
| 80 } |
| 81 db1 close |
| 82 |
| 83 db2 eval { SELECT * FROM t1 ORDER BY x; } |
| 84 } {123} |
| 85 |
| 86 do_test 1.3 { |
| 87 db2 close |
| 88 } {} |
| 89 |
| 90 #------------------------------------------------------------------------- |
| 91 # |
| 92 # sqlite3RollbackAll() loops through all attached b-trees and rolls |
| 93 # back each one separately. Then if the SQLITE_InternChanges flag is |
| 94 # set, it resets the schema. Both of the above steps must be done |
| 95 # while holding a mutex, otherwise another thread might slip in and |
| 96 # try to use the new schema with the old data. |
| 97 # |
| 98 # The following sequence of tests attempt to verify that the actions |
| 99 # taken by sqlite3RollbackAll() are thread-atomic (that they cannot be |
| 100 # interrupted by a separate thread.) |
| 101 # |
| 102 # Note that a TCL interpreter can only be used within the thread in which |
| 103 # it was originally created (because it uses thread-local-storage). |
| 104 # The tvfs callbacks must therefore only run on the main thread. |
| 105 # There is some trickery in the read_callback procedure to ensure that |
| 106 # this is the case. |
| 107 # |
| 108 testvfs tvfs |
| 109 |
| 110 # Set up two databases and two database connections. |
| 111 # |
| 112 # db1: main(test.db), two(test2.db) |
| 113 # db2: main(test.db) |
| 114 # |
| 115 # The cache for test.db is shared between db1 and db2. |
| 116 # |
| 117 do_test 2.1 { |
| 118 forcedelete test.db test.db2 |
| 119 sqlite3 db1 test.db -vfs tvfs |
| 120 db1 eval { ATTACH 'test.db2' AS two } |
| 121 |
| 122 db1 eval { |
| 123 CREATE TABLE t1(x); |
| 124 INSERT INTO t1 VALUES(1); |
| 125 INSERT INTO t1 VALUES(2); |
| 126 INSERT INTO t1 VALUES(3); |
| 127 CREATE TABLE two.t2(x); |
| 128 INSERT INTO t2 SELECT * FROM t1; |
| 129 } |
| 130 |
| 131 sqlite3 db2 test.db -vfs tvfs |
| 132 db2 eval { SELECT * FROM t1 } |
| 133 } {1 2 3} |
| 134 |
| 135 # Create a prepared statement on db2 that will attempt a schema change |
| 136 # in test.db. Meanwhile, start a transaction on db1 that changes |
| 137 # the schema of test.db and that creates a rollback journal on test2.db |
| 138 # |
| 139 do_test 2.2 { |
| 140 set ::STMT [sqlite3_prepare db2 "CREATE INDEX i1 ON t1(x)" -1 tail] |
| 141 db1 eval { |
| 142 BEGIN; |
| 143 CREATE INDEX i1 ON t1(x); |
| 144 INSERT INTO t2 VALUES('value!'); |
| 145 } |
| 146 } {} |
| 147 |
| 148 # Set up a callback that will cause db2 to try to execute its |
| 149 # schema change when db1 accesses the journal file of test2.db. |
| 150 # |
| 151 # This callback will be invoked after the content of test.db has |
| 152 # be rolled back but before the schema has been reset. If the |
| 153 # sqlite3RollbackAll() operation is not thread-atomic, then the |
| 154 # db2 statement in the callback will see old content with the newer |
| 155 # schema, which is wrong. |
| 156 # |
| 157 tvfs filter xRead |
| 158 tvfs script read_callback |
| 159 unset -nocomplain ::some_time_laster |
| 160 unset -nocomplain ::thread_result |
| 161 proc read_callback {call file args} { |
| 162 if {[string match *test.db2-journal $file]} { |
| 163 tvfs filter {} ;# Ensure that tvfs callbacks to do run on the |
| 164 # child thread |
| 165 sqlthread spawn ::thread_result [subst -nocommands { |
| 166 sqlite3_step $::STMT |
| 167 set rc [sqlite3_finalize $::STMT] |
| 168 }] |
| 169 after 1000 { set ::some_time_later 1 } |
| 170 vwait ::some_time_later |
| 171 } |
| 172 } |
| 173 do_test 2.3 { db1 eval ROLLBACK } {} |
| 174 |
| 175 # Verify that the db2 statement invoked by the callback detected the |
| 176 # schema change. |
| 177 # |
| 178 if {[info exists ::thread_result]==0} { vwait ::thread_result } |
| 179 do_test 2.4 { |
| 180 list $::thread_result [sqlite3_errmsg db2] |
| 181 } {SQLITE_SCHEMA {database schema has changed}} |
| 182 |
| 183 db1 close |
| 184 db2 close |
| 185 tvfs delete |
| 186 |
| 187 sqlite3_enable_shared_cache $::enable_shared_cache |
| 188 finish_test |
OLD | NEW |