OLD | NEW |
| (Empty) |
1 # 2010 April 13 | |
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 # This file implements regression tests for SQLite library. The | |
12 # focus of this file is testing the operation of the library in | |
13 # "PRAGMA journal_mode=WAL" mode. | |
14 # | |
15 | |
16 set testdir [file dirname $argv0] | |
17 source $testdir/tester.tcl | |
18 source $testdir/lock_common.tcl | |
19 source $testdir/wal_common.tcl | |
20 source $testdir/malloc_common.tcl | |
21 ifcapable !wal {finish_test ; return } | |
22 | |
23 set a_string_counter 1 | |
24 proc a_string {n} { | |
25 global a_string_counter | |
26 incr a_string_counter | |
27 string range [string repeat "${a_string_counter}." $n] 1 $n | |
28 } | |
29 db func a_string a_string | |
30 | |
31 #------------------------------------------------------------------------- | |
32 # When a rollback or savepoint rollback occurs, the client may remove | |
33 # elements from one of the hash tables in the wal-index. This block | |
34 # of test cases tests that nothing appears to go wrong when this is | |
35 # done. | |
36 # | |
37 do_test wal3-1.0 { | |
38 execsql { | |
39 PRAGMA cache_size = 2000; | |
40 PRAGMA page_size = 1024; | |
41 PRAGMA auto_vacuum = off; | |
42 PRAGMA synchronous = normal; | |
43 PRAGMA journal_mode = WAL; | |
44 PRAGMA wal_autocheckpoint = 0; | |
45 BEGIN; | |
46 CREATE TABLE t1(x); | |
47 INSERT INTO t1 VALUES( a_string(800) ); /* 1 */ | |
48 INSERT INTO t1 SELECT a_string(800) FROM t1; /* 2 */ | |
49 INSERT INTO t1 SELECT a_string(800) FROM t1; /* 4 */ | |
50 INSERT INTO t1 SELECT a_string(800) FROM t1; /* 8 */ | |
51 INSERT INTO t1 SELECT a_string(800) FROM t1; /* 16 */ | |
52 INSERT INTO t1 SELECT a_string(800) FROM t1; /* 32 */ | |
53 INSERT INTO t1 SELECT a_string(800) FROM t1; /* 64 */ | |
54 INSERT INTO t1 SELECT a_string(800) FROM t1; /* 128*/ | |
55 INSERT INTO t1 SELECT a_string(800) FROM t1; /* 256 */ | |
56 INSERT INTO t1 SELECT a_string(800) FROM t1; /* 512 */ | |
57 INSERT INTO t1 SELECT a_string(800) FROM t1; /* 1024 */ | |
58 INSERT INTO t1 SELECT a_string(800) FROM t1; /* 2048 */ | |
59 INSERT INTO t1 SELECT a_string(800) FROM t1 LIMIT 1970; /* 4018 */ | |
60 COMMIT; | |
61 PRAGMA cache_size = 10; | |
62 } | |
63 wal_frame_count test.db-wal 1024 | |
64 } 4056 | |
65 | |
66 for {set i 1} {$i < 50} {incr i} { | |
67 | |
68 do_test wal3-1.$i.1 { | |
69 set str [a_string 800] | |
70 execsql { UPDATE t1 SET x = $str WHERE rowid = $i } | |
71 lappend L [wal_frame_count test.db-wal 1024] | |
72 execsql { | |
73 BEGIN; | |
74 INSERT INTO t1 SELECT a_string(800) FROM t1 LIMIT 100; | |
75 ROLLBACK; | |
76 PRAGMA integrity_check; | |
77 } | |
78 } {ok} | |
79 | |
80 # Check that everything looks OK from the point of view of an | |
81 # external connection. | |
82 # | |
83 sqlite3 db2 test.db | |
84 do_test wal3-1.$i.2 { | |
85 execsql { SELECT count(*) FROM t1 } db2 | |
86 } 4018 | |
87 do_test wal3-1.$i.3 { | |
88 execsql { SELECT x FROM t1 WHERE rowid = $i } | |
89 } $str | |
90 do_test wal3-1.$i.4 { | |
91 execsql { PRAGMA integrity_check } db2 | |
92 } {ok} | |
93 db2 close | |
94 | |
95 # Check that the file-system in its current state can be recovered. | |
96 # | |
97 forcecopy test.db test2.db | |
98 forcecopy test.db-wal test2.db-wal | |
99 forcedelete test2.db-journal | |
100 sqlite3 db2 test2.db | |
101 do_test wal3-1.$i.5 { | |
102 execsql { SELECT count(*) FROM t1 } db2 | |
103 } 4018 | |
104 do_test wal3-1.$i.6 { | |
105 execsql { SELECT x FROM t1 WHERE rowid = $i } | |
106 } $str | |
107 do_test wal3-1.$i.7 { | |
108 execsql { PRAGMA integrity_check } db2 | |
109 } {ok} | |
110 db2 close | |
111 } | |
112 | |
113 proc byte_is_zero {file offset} { | |
114 if {[file size test.db] <= $offset} { return 1 } | |
115 expr { [hexio_read $file $offset 1] == "00" } | |
116 } | |
117 | |
118 do_multiclient_test i { | |
119 | |
120 set testname(1) multiproc | |
121 set testname(2) singleproc | |
122 set tn $testname($i) | |
123 | |
124 do_test wal3-2.$tn.1 { | |
125 sql1 { | |
126 PRAGMA page_size = 1024; | |
127 PRAGMA journal_mode = WAL; | |
128 } | |
129 sql1 { | |
130 CREATE TABLE t1(a, b); | |
131 INSERT INTO t1 VALUES(1, 'one'); | |
132 BEGIN; | |
133 SELECT * FROM t1; | |
134 } | |
135 } {1 one} | |
136 do_test wal3-2.$tn.2 { | |
137 sql2 { | |
138 CREATE TABLE t2(a, b); | |
139 INSERT INTO t2 VALUES(2, 'two'); | |
140 BEGIN; | |
141 SELECT * FROM t2; | |
142 } | |
143 } {2 two} | |
144 do_test wal3-2.$tn.3 { | |
145 sql3 { | |
146 CREATE TABLE t3(a, b); | |
147 INSERT INTO t3 VALUES(3, 'three'); | |
148 BEGIN; | |
149 SELECT * FROM t3; | |
150 } | |
151 } {3 three} | |
152 | |
153 # Try to checkpoint the database using [db]. It should be possible to | |
154 # checkpoint everything except the table added by [db3] (checkpointing | |
155 # these frames would clobber the snapshot currently being used by [db2]). | |
156 # | |
157 # After [db2] has committed, a checkpoint can copy the entire log to the | |
158 # database file. Checkpointing after [db3] has committed is therefore a | |
159 # no-op, as the entire log has already been backfilled. | |
160 # | |
161 do_test wal3-2.$tn.4 { | |
162 sql1 { | |
163 COMMIT; | |
164 PRAGMA wal_checkpoint; | |
165 } | |
166 byte_is_zero test.db [expr $AUTOVACUUM ? 4*1024 : 3*1024] | |
167 } {1} | |
168 do_test wal3-2.$tn.5 { | |
169 sql2 { | |
170 COMMIT; | |
171 PRAGMA wal_checkpoint; | |
172 } | |
173 list [byte_is_zero test.db [expr $AUTOVACUUM ? 4*1024 : 3*1024]] \ | |
174 [byte_is_zero test.db [expr $AUTOVACUUM ? 5*1024 : 4*1024]] | |
175 } {0 1} | |
176 do_test wal3-2.$tn.6 { | |
177 sql3 { | |
178 COMMIT; | |
179 PRAGMA wal_checkpoint; | |
180 } | |
181 list [byte_is_zero test.db [expr $AUTOVACUUM ? 4*1024 : 3*1024]] \ | |
182 [byte_is_zero test.db [expr $AUTOVACUUM ? 5*1024 : 4*1024]] | |
183 } {0 1} | |
184 } | |
185 catch {db close} | |
186 | |
187 #------------------------------------------------------------------------- | |
188 # Test that that for the simple test: | |
189 # | |
190 # CREATE TABLE x(y); | |
191 # INSERT INTO x VALUES('z'); | |
192 # PRAGMA wal_checkpoint; | |
193 # | |
194 # in WAL mode the xSync method is invoked as expected for each of | |
195 # synchronous=off, synchronous=normal and synchronous=full. | |
196 # | |
197 foreach {tn syncmode synccount} { | |
198 1 off | |
199 {} | |
200 2 normal | |
201 {test.db-wal normal test.db normal} | |
202 3 full | |
203 {test.db-wal normal test.db-wal normal test.db-wal normal test.db normal} | |
204 } { | |
205 | |
206 proc sync_counter {args} { | |
207 foreach {method filename id flags} $args break | |
208 lappend ::syncs [file tail $filename] $flags | |
209 } | |
210 do_test wal3-3.$tn { | |
211 forcedelete test.db test.db-wal test.db-journal | |
212 | |
213 testvfs T | |
214 T filter {} | |
215 T script sync_counter | |
216 sqlite3 db test.db -vfs T | |
217 | |
218 execsql "PRAGMA synchronous = $syncmode" | |
219 execsql { PRAGMA journal_mode = WAL } | |
220 execsql { CREATE TABLE filler(a,b,c); } | |
221 | |
222 set ::syncs [list] | |
223 T filter xSync | |
224 execsql { | |
225 CREATE TABLE x(y); | |
226 INSERT INTO x VALUES('z'); | |
227 PRAGMA wal_checkpoint; | |
228 } | |
229 T filter {} | |
230 set ::syncs | |
231 } $synccount | |
232 | |
233 db close | |
234 T delete | |
235 } | |
236 | |
237 #------------------------------------------------------------------------- | |
238 # When recovering the contents of a WAL file, a process obtains the WRITER | |
239 # lock, then locks all other bytes before commencing recovery. If it fails | |
240 # to lock all other bytes (because some other process is holding a read | |
241 # lock) it should retry up to 100 times. Then return SQLITE_PROTOCOL to the | |
242 # caller. Test this (test case wal3-4.3). | |
243 # | |
244 # Also test the effect of hitting an SQLITE_BUSY while attempting to obtain | |
245 # the WRITER lock (should be the same). Test case wal3-4.4. | |
246 # | |
247 proc lock_callback {method filename handle lock} { | |
248 lappend ::locks $lock | |
249 } | |
250 do_test wal3-4.1 { | |
251 testvfs T | |
252 T filter xShmLock | |
253 T script lock_callback | |
254 set ::locks [list] | |
255 sqlite3 db test.db -vfs T | |
256 execsql { SELECT * FROM x } | |
257 lrange $::locks 0 3 | |
258 } [list {0 1 lock exclusive} {1 7 lock exclusive} \ | |
259 {1 7 unlock exclusive} {0 1 unlock exclusive} \ | |
260 ] | |
261 do_test wal3-4.2 { | |
262 db close | |
263 set ::locks [list] | |
264 sqlite3 db test.db -vfs T | |
265 execsql { SELECT * FROM x } | |
266 lrange $::locks 0 3 | |
267 } [list {0 1 lock exclusive} {1 7 lock exclusive} \ | |
268 {1 7 unlock exclusive} {0 1 unlock exclusive} \ | |
269 ] | |
270 proc lock_callback {method filename handle lock} { | |
271 if {$lock == "1 7 lock exclusive"} { return SQLITE_BUSY } | |
272 return SQLITE_OK | |
273 } | |
274 puts " Warning: This next test case causes SQLite to call xSleep(1) 100 times." | |
275 puts " Normally this equates to a 100ms delay, but if SQLite is built on unix" | |
276 puts " without HAVE_USLEEP defined, it may be 100 seconds." | |
277 do_test wal3-4.3 { | |
278 db close | |
279 set ::locks [list] | |
280 sqlite3 db test.db -vfs T | |
281 catchsql { SELECT * FROM x } | |
282 } {1 {locking protocol}} | |
283 | |
284 puts " Warning: Same again!" | |
285 proc lock_callback {method filename handle lock} { | |
286 if {$lock == "0 1 lock exclusive"} { return SQLITE_BUSY } | |
287 return SQLITE_OK | |
288 } | |
289 do_test wal3-4.4 { | |
290 db close | |
291 set ::locks [list] | |
292 sqlite3 db test.db -vfs T | |
293 catchsql { SELECT * FROM x } | |
294 } {1 {locking protocol}} | |
295 db close | |
296 T delete | |
297 | |
298 | |
299 #------------------------------------------------------------------------- | |
300 # Only one client may run recovery at a time. Test this mechanism. | |
301 # | |
302 # When client-2 tries to open a read transaction while client-1 is | |
303 # running recovery, it fails to obtain a lock on an aReadMark[] slot | |
304 # (because they are all locked by recovery). It then tries to obtain | |
305 # a shared lock on the RECOVER lock to see if there really is a | |
306 # recovery running or not. | |
307 # | |
308 # This block of tests checks the effect of an SQLITE_BUSY or SQLITE_IOERR | |
309 # being returned when client-2 attempts a shared lock on the RECOVER byte. | |
310 # | |
311 # An SQLITE_BUSY should be converted to an SQLITE_BUSY_RECOVERY. An | |
312 # SQLITE_IOERR should be returned to the caller. | |
313 # | |
314 do_test wal3-5.1 { | |
315 faultsim_delete_and_reopen | |
316 execsql { | |
317 PRAGMA journal_mode = WAL; | |
318 CREATE TABLE t1(a, b); | |
319 INSERT INTO t1 VALUES(1, 2); | |
320 INSERT INTO t1 VALUES(3, 4); | |
321 } | |
322 faultsim_save_and_close | |
323 } {} | |
324 | |
325 testvfs T -default 1 | |
326 T script method_callback | |
327 | |
328 proc method_callback {method args} { | |
329 if {$method == "xShmBarrier"} { | |
330 incr ::barrier_count | |
331 if {$::barrier_count == 2} { | |
332 # This code is executed within the xShmBarrier() callback invoked | |
333 # by the client running recovery as part of writing the recovered | |
334 # wal-index header. If a second client attempts to access the | |
335 # database now, it reads a corrupt (partially written) wal-index | |
336 # header. But it cannot even get that far, as the first client | |
337 # is still holding all the locks (recovery takes an exclusive lock | |
338 # on *all* db locks, preventing access by any other client). | |
339 # | |
340 # If global variable ::wal3_do_lockfailure is non-zero, then set | |
341 # things up so that an IO error occurs within an xShmLock() callback | |
342 # made by the second client (aka [db2]). | |
343 # | |
344 sqlite3 db2 test.db | |
345 if { $::wal3_do_lockfailure } { T filter xShmLock } | |
346 set ::testrc [ catch { db2 eval "SELECT * FROM t1" } ::testmsg ] | |
347 T filter {} | |
348 db2 close | |
349 } | |
350 } | |
351 | |
352 if {$method == "xShmLock"} { | |
353 foreach {file handle spec} $args break | |
354 if { $spec == "2 1 lock shared" } { | |
355 return SQLITE_IOERR | |
356 } | |
357 } | |
358 | |
359 return SQLITE_OK | |
360 } | |
361 | |
362 # Test a normal SQLITE_BUSY return. | |
363 # | |
364 T filter xShmBarrier | |
365 set testrc "" | |
366 set testmsg "" | |
367 set barrier_count 0 | |
368 set wal3_do_lockfailure 0 | |
369 do_test wal3-5.2 { | |
370 faultsim_restore_and_reopen | |
371 execsql { SELECT * FROM t1 } | |
372 } {1 2 3 4} | |
373 do_test wal3-5.3 { | |
374 list $::testrc $::testmsg | |
375 } {1 {database is locked}} | |
376 db close | |
377 | |
378 # Test an SQLITE_IOERR return. | |
379 # | |
380 T filter xShmBarrier | |
381 set barrier_count 0 | |
382 set wal3_do_lockfailure 1 | |
383 set testrc "" | |
384 set testmsg "" | |
385 do_test wal3-5.4 { | |
386 faultsim_restore_and_reopen | |
387 execsql { SELECT * FROM t1 } | |
388 } {1 2 3 4} | |
389 do_test wal3-5.5 { | |
390 list $::testrc $::testmsg | |
391 } {1 {disk I/O error}} | |
392 | |
393 db close | |
394 T delete | |
395 | |
396 #------------------------------------------------------------------------- | |
397 # When opening a read-transaction on a database, if the entire log has | |
398 # already been copied to the database file, the reader grabs a special | |
399 # kind of read lock (on aReadMark[0]). This set of test cases tests the | |
400 # outcome of the following: | |
401 # | |
402 # + The reader discovering that between the time when it determined | |
403 # that the log had been completely backfilled and the lock is obtained | |
404 # that a writer has written to the log. In this case the reader should | |
405 # acquire a different read-lock (not aReadMark[0]) and read the new | |
406 # snapshot. | |
407 # | |
408 # + The attempt to obtain the lock on aReadMark[0] fails with SQLITE_BUSY. | |
409 # This can happen if a checkpoint is ongoing. In this case also simply | |
410 # obtain a different read-lock. | |
411 # | |
412 catch {db close} | |
413 testvfs T -default 1 | |
414 do_test wal3-6.1.1 { | |
415 forcedelete test.db test.db-journal test.db wal | |
416 sqlite3 db test.db | |
417 execsql { PRAGMA auto_vacuum = off } | |
418 execsql { PRAGMA journal_mode = WAL } | |
419 execsql { | |
420 CREATE TABLE t1(a, b); | |
421 INSERT INTO t1 VALUES('o', 't'); | |
422 INSERT INTO t1 VALUES('t', 'f'); | |
423 } | |
424 } {} | |
425 do_test wal3-6.1.2 { | |
426 sqlite3 db2 test.db | |
427 sqlite3 db3 test.db | |
428 execsql { BEGIN ; SELECT * FROM t1 } db3 | |
429 } {o t t f} | |
430 do_test wal3-6.1.3 { | |
431 execsql { PRAGMA wal_checkpoint } db2 | |
432 } {0 4 4} | |
433 | |
434 # At this point the log file has been fully checkpointed. However, | |
435 # connection [db3] holds a lock that prevents the log from being wrapped. | |
436 # Test case 3.6.1.4 has [db] attempt a read-lock on aReadMark[0]. But | |
437 # as it is obtaining the lock, [db2] appends to the log file. | |
438 # | |
439 T filter xShmLock | |
440 T script lock_callback | |
441 proc lock_callback {method file handle spec} { | |
442 if {$spec == "3 1 lock shared"} { | |
443 # This is the callback for [db] to obtain the read lock on aReadMark[0]. | |
444 # Disable future callbacks using [T filter {}] and write to the log | |
445 # file using [db2]. [db3] is preventing [db2] from wrapping the log | |
446 # here, so this is an append. | |
447 T filter {} | |
448 db2 eval { INSERT INTO t1 VALUES('f', 's') } | |
449 } | |
450 return SQLITE_OK | |
451 } | |
452 do_test wal3-6.1.4 { | |
453 execsql { | |
454 BEGIN; | |
455 SELECT * FROM t1; | |
456 } | |
457 } {o t t f f s} | |
458 | |
459 # [db] should be left holding a read-lock on some slot other than | |
460 # aReadMark[0]. Test this by demonstrating that the read-lock is preventing | |
461 # the log from being wrapped. | |
462 # | |
463 do_test wal3-6.1.5 { | |
464 db3 eval COMMIT | |
465 db2 eval { PRAGMA wal_checkpoint } | |
466 set sz1 [file size test.db-wal] | |
467 db2 eval { INSERT INTO t1 VALUES('s', 'e') } | |
468 set sz2 [file size test.db-wal] | |
469 expr {$sz2>$sz1} | |
470 } {1} | |
471 | |
472 # Test that if [db2] had not interfered when [db] was trying to grab | |
473 # aReadMark[0], it would have been possible to wrap the log in 3.6.1.5. | |
474 # | |
475 do_test wal3-6.1.6 { | |
476 execsql { COMMIT } | |
477 execsql { PRAGMA wal_checkpoint } db2 | |
478 execsql { | |
479 BEGIN; | |
480 SELECT * FROM t1; | |
481 } | |
482 } {o t t f f s s e} | |
483 do_test wal3-6.1.7 { | |
484 db2 eval { PRAGMA wal_checkpoint } | |
485 set sz1 [file size test.db-wal] | |
486 db2 eval { INSERT INTO t1 VALUES('n', 't') } | |
487 set sz2 [file size test.db-wal] | |
488 expr {$sz2==$sz1} | |
489 } {1} | |
490 | |
491 db3 close | |
492 db2 close | |
493 db close | |
494 | |
495 do_test wal3-6.2.1 { | |
496 forcedelete test.db test.db-journal test.db wal | |
497 sqlite3 db test.db | |
498 sqlite3 db2 test.db | |
499 execsql { PRAGMA auto_vacuum = off } | |
500 execsql { PRAGMA journal_mode = WAL } | |
501 execsql { | |
502 CREATE TABLE t1(a, b); | |
503 INSERT INTO t1 VALUES('h', 'h'); | |
504 INSERT INTO t1 VALUES('l', 'b'); | |
505 } | |
506 } {} | |
507 | |
508 T filter xShmLock | |
509 T script lock_callback | |
510 proc lock_callback {method file handle spec} { | |
511 if {$spec == "3 1 unlock exclusive"} { | |
512 T filter {} | |
513 set ::R [db2 eval { | |
514 BEGIN; | |
515 SELECT * FROM t1; | |
516 }] | |
517 } | |
518 } | |
519 do_test wal3-6.2.2 { | |
520 execsql { PRAGMA wal_checkpoint } | |
521 } {0 4 4} | |
522 do_test wal3-6.2.3 { | |
523 set ::R | |
524 } {h h l b} | |
525 do_test wal3-6.2.4 { | |
526 set sz1 [file size test.db-wal] | |
527 execsql { INSERT INTO t1 VALUES('b', 'c'); } | |
528 set sz2 [file size test.db-wal] | |
529 expr {$sz2 > $sz1} | |
530 } {1} | |
531 do_test wal3-6.2.5 { | |
532 db2 eval { COMMIT } | |
533 execsql { PRAGMA wal_checkpoint } | |
534 set sz1 [file size test.db-wal] | |
535 execsql { INSERT INTO t1 VALUES('n', 'o'); } | |
536 set sz2 [file size test.db-wal] | |
537 expr {$sz2 == $sz1} | |
538 } {1} | |
539 | |
540 db2 close | |
541 db close | |
542 T delete | |
543 | |
544 #------------------------------------------------------------------------- | |
545 # When opening a read-transaction on a database, if the entire log has | |
546 # not yet been copied to the database file, the reader grabs a read | |
547 # lock on aReadMark[x], where x>0. The following test cases experiment | |
548 # with the outcome of the following: | |
549 # | |
550 # + The reader discovering that between the time when it read the | |
551 # wal-index header and the lock was obtained that a writer has | |
552 # written to the log. In this case the reader should re-read the | |
553 # wal-index header and lock a snapshot corresponding to the new | |
554 # header. | |
555 # | |
556 # + The value in the aReadMark[x] slot has been modified since it was | |
557 # read. | |
558 # | |
559 catch {db close} | |
560 testvfs T -default 1 | |
561 do_test wal3-7.1.1 { | |
562 forcedelete test.db test.db-journal test.db wal | |
563 sqlite3 db test.db | |
564 execsql { | |
565 PRAGMA journal_mode = WAL; | |
566 CREATE TABLE blue(red PRIMARY KEY, green); | |
567 } | |
568 } {wal} | |
569 | |
570 T script method_callback | |
571 T filter xOpen | |
572 proc method_callback {method args} { | |
573 if {$method == "xOpen"} { return "reader" } | |
574 } | |
575 do_test wal3-7.1.2 { | |
576 sqlite3 db2 test.db | |
577 execsql { SELECT * FROM blue } db2 | |
578 } {} | |
579 | |
580 T filter xShmLock | |
581 set ::locks [list] | |
582 proc method_callback {method file handle spec} { | |
583 if {$handle != "reader" } { return } | |
584 if {$method == "xShmLock"} { | |
585 catch { execsql { INSERT INTO blue VALUES(1, 2) } } | |
586 catch { execsql { INSERT INTO blue VALUES(3, 4) } } | |
587 } | |
588 lappend ::locks $spec | |
589 } | |
590 do_test wal3-7.1.3 { | |
591 execsql { SELECT * FROM blue } db2 | |
592 } {1 2 3 4} | |
593 do_test wal3-7.1.4 { | |
594 set ::locks | |
595 } {{4 1 lock shared} {4 1 unlock shared} {5 1 lock shared} {5 1 unlock shared}} | |
596 | |
597 set ::locks [list] | |
598 proc method_callback {method file handle spec} { | |
599 if {$handle != "reader" } { return } | |
600 if {$method == "xShmLock"} { | |
601 catch { execsql { INSERT INTO blue VALUES(5, 6) } } | |
602 } | |
603 lappend ::locks $spec | |
604 } | |
605 do_test wal3-7.2.1 { | |
606 execsql { SELECT * FROM blue } db2 | |
607 } {1 2 3 4 5 6} | |
608 do_test wal3-7.2.2 { | |
609 set ::locks | |
610 } {{5 1 lock shared} {5 1 unlock shared} {4 1 lock shared} {4 1 unlock shared}} | |
611 | |
612 db close | |
613 db2 close | |
614 T delete | |
615 | |
616 #------------------------------------------------------------------------- | |
617 # | |
618 do_test wal3-8.1 { | |
619 forcedelete test.db test.db-journal test.db wal | |
620 sqlite3 db test.db | |
621 sqlite3 db2 test.db | |
622 execsql { | |
623 PRAGMA auto_vacuum = off; | |
624 PRAGMA journal_mode = WAL; | |
625 CREATE TABLE b(c); | |
626 INSERT INTO b VALUES('Tehran'); | |
627 INSERT INTO b VALUES('Qom'); | |
628 INSERT INTO b VALUES('Markazi'); | |
629 PRAGMA wal_checkpoint; | |
630 } | |
631 } {wal 0 5 5} | |
632 do_test wal3-8.2 { | |
633 execsql { SELECT * FROM b } | |
634 } {Tehran Qom Markazi} | |
635 do_test wal3-8.3 { | |
636 db eval { SELECT * FROM b } { | |
637 db eval { INSERT INTO b VALUES('Qazvin') } | |
638 set r [db2 eval { SELECT * FROM b }] | |
639 break | |
640 } | |
641 set r | |
642 } {Tehran Qom Markazi Qazvin} | |
643 do_test wal3-8.4 { | |
644 execsql { | |
645 INSERT INTO b VALUES('Gilan'); | |
646 INSERT INTO b VALUES('Ardabil'); | |
647 } | |
648 } {} | |
649 db2 close | |
650 | |
651 faultsim_save_and_close | |
652 testvfs T -default 1 | |
653 faultsim_restore_and_reopen | |
654 T filter xShmLock | |
655 T script lock_callback | |
656 | |
657 proc lock_callback {method file handle spec} { | |
658 if {$spec == "1 7 unlock exclusive"} { | |
659 T filter {} | |
660 set ::r [catchsql { SELECT * FROM b } db2] | |
661 } | |
662 } | |
663 sqlite3 db test.db | |
664 sqlite3 db2 test.db | |
665 do_test wal3-8.5 { | |
666 execsql { SELECT * FROM b } | |
667 } {Tehran Qom Markazi Qazvin Gilan Ardabil} | |
668 do_test wal3-8.6 { | |
669 set ::r | |
670 } {1 {locking protocol}} | |
671 | |
672 db close | |
673 db2 close | |
674 | |
675 faultsim_restore_and_reopen | |
676 sqlite3 db2 test.db | |
677 T filter xShmLock | |
678 T script lock_callback | |
679 proc lock_callback {method file handle spec} { | |
680 if {$spec == "1 7 unlock exclusive"} { | |
681 T filter {} | |
682 set ::r [catchsql { SELECT * FROM b } db2] | |
683 } | |
684 } | |
685 unset ::r | |
686 do_test wal3-8.5 { | |
687 execsql { SELECT * FROM b } | |
688 } {Tehran Qom Markazi Qazvin Gilan Ardabil} | |
689 do_test wal3-8.6 { | |
690 set ::r | |
691 } {1 {locking protocol}} | |
692 | |
693 db close | |
694 db2 close | |
695 T delete | |
696 | |
697 #------------------------------------------------------------------------- | |
698 # When a connection opens a read-lock on the database, it searches for | |
699 # an aReadMark[] slot that is already set to the mxFrame value for the | |
700 # new transaction. If it cannot find one, it attempts to obtain an | |
701 # exclusive lock on an aReadMark[] slot for the purposes of modifying | |
702 # the value, then drops back to a shared-lock for the duration of the | |
703 # transaction. | |
704 # | |
705 # This test case verifies that if an exclusive lock cannot be obtained | |
706 # on any aReadMark[] slot (because there are already several readers), | |
707 # the client takes a shared-lock on a slot without modifying the value | |
708 # and continues. | |
709 # | |
710 set nConn 50 | |
711 if { [string match *BSD $tcl_platform(os)] } { set nConn 25 } | |
712 do_test wal3-9.0 { | |
713 forcedelete test.db test.db-journal test.db wal | |
714 sqlite3 db test.db | |
715 execsql { | |
716 PRAGMA page_size = 1024; | |
717 PRAGMA journal_mode = WAL; | |
718 CREATE TABLE whoami(x); | |
719 INSERT INTO whoami VALUES('nobody'); | |
720 } | |
721 } {wal} | |
722 for {set i 0} {$i < $nConn} {incr i} { | |
723 set c db$i | |
724 do_test wal3-9.1.$i { | |
725 sqlite3 $c test.db | |
726 execsql { UPDATE whoami SET x = $c } | |
727 execsql { | |
728 BEGIN; | |
729 SELECT * FROM whoami | |
730 } $c | |
731 } $c | |
732 } | |
733 for {set i 0} {$i < $nConn} {incr i} { | |
734 set c db$i | |
735 do_test wal3-9.2.$i { | |
736 execsql { SELECT * FROM whoami } $c | |
737 } $c | |
738 } | |
739 | |
740 set sz [expr 1024 * (2+$AUTOVACUUM)] | |
741 do_test wal3-9.3 { | |
742 for {set i 0} {$i < ($nConn-1)} {incr i} { db$i close } | |
743 execsql { PRAGMA wal_checkpoint } | |
744 byte_is_zero test.db [expr $sz-1024] | |
745 } {1} | |
746 do_test wal3-9.4 { | |
747 db[expr $nConn-1] close | |
748 execsql { PRAGMA wal_checkpoint } | |
749 set sz2 [file size test.db] | |
750 byte_is_zero test.db [expr $sz-1024] | |
751 } {0} | |
752 | |
753 do_multiclient_test tn { | |
754 do_test wal3-10.$tn.1 { | |
755 sql1 { | |
756 PRAGMA page_size = 1024; | |
757 CREATE TABLE t1(x); | |
758 PRAGMA journal_mode = WAL; | |
759 PRAGMA wal_autocheckpoint = 100000; | |
760 BEGIN; | |
761 INSERT INTO t1 VALUES(randomblob(800)); | |
762 INSERT INTO t1 SELECT randomblob(800) FROM t1; -- 2 | |
763 INSERT INTO t1 SELECT randomblob(800) FROM t1; -- 4 | |
764 INSERT INTO t1 SELECT randomblob(800) FROM t1; -- 8 | |
765 INSERT INTO t1 SELECT randomblob(800) FROM t1; -- 16 | |
766 INSERT INTO t1 SELECT randomblob(800) FROM t1; -- 32 | |
767 INSERT INTO t1 SELECT randomblob(800) FROM t1; -- 64 | |
768 INSERT INTO t1 SELECT randomblob(800) FROM t1; -- 128 | |
769 INSERT INTO t1 SELECT randomblob(800) FROM t1; -- 256 | |
770 INSERT INTO t1 SELECT randomblob(800) FROM t1; -- 512 | |
771 INSERT INTO t1 SELECT randomblob(800) FROM t1; -- 1024 | |
772 INSERT INTO t1 SELECT randomblob(800) FROM t1; -- 2048 | |
773 INSERT INTO t1 SELECT randomblob(800) FROM t1; -- 4096 | |
774 INSERT INTO t1 SELECT randomblob(800) FROM t1; -- 8192 | |
775 COMMIT; | |
776 CREATE INDEX i1 ON t1(x); | |
777 } | |
778 | |
779 expr {[file size test.db-wal] > [expr 1032*9000]} | |
780 } 1 | |
781 | |
782 do_test wal3-10.$tn.2 { | |
783 sql2 {PRAGMA integrity_check} | |
784 } {ok} | |
785 } | |
786 | |
787 finish_test | |
OLD | NEW |