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 |