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