| OLD | NEW |
| (Empty) |
| 1 # 2014 December 04 | |
| 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 | |
| 13 set testdir [file dirname $argv0] | |
| 14 source $testdir/tester.tcl | |
| 15 source $testdir/wal_common.tcl | |
| 16 set testprefix e_walauto | |
| 17 | |
| 18 # Do not run this test on OpenBSD, as it depends on read() and mmap both | |
| 19 # accessing the same coherent view of the "test.db-shm" file. This doesn't | |
| 20 # work on OpenBSD. | |
| 21 # | |
| 22 if {$tcl_platform(os) == "OpenBSD"} { | |
| 23 finish_test | |
| 24 return | |
| 25 } | |
| 26 | |
| 27 proc read_nbackfill {} { | |
| 28 seek $::shmfd 96 | |
| 29 binary scan [read $::shmfd 4] n nBackfill | |
| 30 set nBackfill | |
| 31 } | |
| 32 proc read_mxframe {} { | |
| 33 seek $::shmfd 16 | |
| 34 binary scan [read $::shmfd 4] n mxFrame | |
| 35 set mxFrame | |
| 36 } | |
| 37 | |
| 38 # Assuming that the main db for database handle | |
| 39 # | |
| 40 proc do_autocommit_threshold_test {tn value} { | |
| 41 | |
| 42 set nBackfillSaved [read_nbackfill] | |
| 43 while {1} { | |
| 44 db eval { INSERT INTO t1 VALUES(randomblob(100), randomblob(100)) } | |
| 45 if {[read_mxframe] >= $value} break | |
| 46 } | |
| 47 | |
| 48 set nBackfillNew [read_nbackfill] | |
| 49 uplevel [list do_test $tn "expr $nBackfillNew > $nBackfillSaved" 1] | |
| 50 } | |
| 51 | |
| 52 # EVIDENCE-OF: R-30135-06439 The wal_autocheckpoint pragma can be used | |
| 53 # to invoke this interface from SQL. | |
| 54 # | |
| 55 # All tests in this file are run twice - once using the | |
| 56 # sqlite3_wal_autocheckpoint() API, and once using "PRAGMA | |
| 57 # wal_autocheckpoint". | |
| 58 # | |
| 59 foreach {tn code} { | |
| 60 1 { | |
| 61 proc autocheckpoint {db value} { | |
| 62 uplevel [list $db eval "PRAGMA wal_autocheckpoint = $value"] | |
| 63 } | |
| 64 } | |
| 65 | |
| 66 2 { | |
| 67 proc autocheckpoint {db value} { | |
| 68 uplevel [list sqlite3_wal_autocheckpoint $db $value] | |
| 69 return $value | |
| 70 } | |
| 71 } | |
| 72 } { | |
| 73 | |
| 74 eval $code | |
| 75 | |
| 76 reset_db | |
| 77 execsql { PRAGMA auto_vacuum = 0 } | |
| 78 do_execsql_test 1.$tn.0 { PRAGMA journal_mode = WAL } {wal} | |
| 79 do_execsql_test 1.$tn.1 { CREATE TABLE t1(a, b) } | |
| 80 set shmfd [open "test.db-shm" rb] | |
| 81 | |
| 82 # EVIDENCE-OF: R-41531-51083 Every new database connection defaults to | |
| 83 # having the auto-checkpoint enabled with a threshold of 1000 or | |
| 84 # SQLITE_DEFAULT_WAL_AUTOCHECKPOINT pages. | |
| 85 # | |
| 86 do_autocommit_threshold_test 1.$tn.2 1000 | |
| 87 db eval { INSERT INTO t1 VALUES(randomblob(100), randomblob(100)) } | |
| 88 do_autocommit_threshold_test 1.$tn.3 1000 | |
| 89 | |
| 90 # EVIDENCE-OF: R-38128-34102 The sqlite3_wal_autocheckpoint(D,N) is a | |
| 91 # wrapper around sqlite3_wal_hook() that causes any database on database | |
| 92 # connection D to automatically checkpoint after committing a | |
| 93 # transaction if there are N or more frames in the write-ahead log file. | |
| 94 # | |
| 95 do_test 1.$tn.4 { | |
| 96 db eval { INSERT INTO t1 VALUES(randomblob(100), randomblob(100)) } | |
| 97 autocheckpoint db 100 | |
| 98 } {100} | |
| 99 do_autocommit_threshold_test 1.$tn.5 100 | |
| 100 | |
| 101 do_test 1.$tn.6 { | |
| 102 db eval { INSERT INTO t1 VALUES(randomblob(100), randomblob(100)) } | |
| 103 autocheckpoint db 500 | |
| 104 } {500} | |
| 105 do_autocommit_threshold_test 1.$tn.7 500 | |
| 106 | |
| 107 # EVIDENCE-OF: R-26993-43540 Passing zero or a negative value as the | |
| 108 # nFrame parameter disables automatic checkpoints entirely. | |
| 109 # | |
| 110 do_test 1.$tn.7 { | |
| 111 autocheckpoint db 0 ;# Set to zero | |
| 112 for {set i 0} {$i < 10000} {incr i} { | |
| 113 db eval { INSERT INTO t1 VALUES(randomblob(100), randomblob(100)) } | |
| 114 } | |
| 115 expr {[file size test.db-wal] > (5 * 1024 * 1024)} | |
| 116 } 1 | |
| 117 do_test 1.$tn.8 { | |
| 118 sqlite3_wal_checkpoint_v2 db truncate | |
| 119 file size test.db-wal | |
| 120 } 0 | |
| 121 do_test 1.$tn.9 { | |
| 122 autocheckpoint db -4 ;# Set to a negative value | |
| 123 for {set i 0} {$i < 10000} {incr i} { | |
| 124 db eval { INSERT INTO t1 VALUES(randomblob(100), randomblob(100)) } | |
| 125 } | |
| 126 expr {[file size test.db-wal] > (5 * 1024 * 1024)} | |
| 127 } 1 | |
| 128 | |
| 129 # EVIDENCE-OF: R-10203-42688 The callback registered by this function | |
| 130 # replaces any existing callback registered using sqlite3_wal_hook(). | |
| 131 # | |
| 132 set ::wal_hook_callback 0 | |
| 133 proc wal_hook_callback {args} { incr ::wal_hook_callback ; return 0 } | |
| 134 do_test 1.$tn.10.1 { | |
| 135 db wal_hook wal_hook_callback | |
| 136 db eval { INSERT INTO t1 VALUES(randomblob(100), randomblob(100)) } | |
| 137 db eval { INSERT INTO t1 VALUES(randomblob(100), randomblob(100)) } | |
| 138 set ::wal_hook_callback | |
| 139 } 2 | |
| 140 do_test 1.$tn.10.2 { | |
| 141 autocheckpoint db 100 | |
| 142 db eval { INSERT INTO t1 VALUES(randomblob(100), randomblob(100)) } | |
| 143 db eval { INSERT INTO t1 VALUES(randomblob(100), randomblob(100)) } | |
| 144 set ::wal_hook_callback | |
| 145 } 2 | |
| 146 | |
| 147 # EVIDENCE-OF: R-17497-43474 Likewise, registering a callback using | |
| 148 # sqlite3_wal_hook() disables the automatic checkpoint mechanism | |
| 149 # configured by this function. | |
| 150 do_test 1.$tn.11.1 { | |
| 151 sqlite3_wal_checkpoint_v2 db truncate | |
| 152 file size test.db-wal | |
| 153 } 0 | |
| 154 do_test 1.$tn.11.2 { | |
| 155 autocheckpoint db 100 | |
| 156 for {set i 0} {$i < 1000} {incr i} { | |
| 157 db eval { INSERT INTO t1 VALUES(randomblob(100), randomblob(100)) } | |
| 158 } | |
| 159 expr {[file size test.db-wal] < (1 * 1024 * 1024)} | |
| 160 } 1 | |
| 161 do_test 1.$tn.11.3 { | |
| 162 db wal_hook wal_hook_callback | |
| 163 for {set i 0} {$i < 1000} {incr i} { | |
| 164 db eval { INSERT INTO t1 VALUES(randomblob(100), randomblob(100)) } | |
| 165 } | |
| 166 expr {[file size test.db-wal] < (1 * 1024 * 1024)} | |
| 167 } 0 | |
| 168 | |
| 169 # EVIDENCE-OF: R-33080-59193 Checkpoints initiated by this mechanism | |
| 170 # are PASSIVE. | |
| 171 # | |
| 172 set ::busy_callback_count 0 | |
| 173 proc busy_callback {args} { | |
| 174 incr ::busy_callback_count | |
| 175 return 0 | |
| 176 } | |
| 177 do_test 1.$tn.12.1 { | |
| 178 sqlite3_wal_checkpoint_v2 db truncate | |
| 179 autocheckpoint db 100 | |
| 180 db busy busy_callback | |
| 181 db eval { INSERT INTO t1 VALUES(randomblob(100), randomblob(100)) } | |
| 182 db eval { INSERT INTO t1 VALUES(randomblob(100), randomblob(100)) } | |
| 183 } {} | |
| 184 do_test 1.$tn.12.2 { | |
| 185 sqlite3 db2 test.db | |
| 186 db2 eval { BEGIN; SELECT * FROM t1 LIMIT 10; } | |
| 187 read_nbackfill | |
| 188 } {0} | |
| 189 do_test 1.$tn.12.3 { | |
| 190 for {set i 0} {$i < 1000} {incr i} { | |
| 191 db eval { INSERT INTO t1 VALUES(randomblob(100), randomblob(100)) } | |
| 192 } | |
| 193 read_nbackfill | |
| 194 } {2} | |
| 195 do_test 1.$tn.12.4 { | |
| 196 set ::busy_callback_count | |
| 197 } {0} | |
| 198 db2 close | |
| 199 | |
| 200 do_test 1.$tn.12.5 { | |
| 201 db eval { INSERT INTO t1 VALUES(randomblob(100), randomblob(100)) } | |
| 202 read_nbackfill | |
| 203 } {1559} | |
| 204 | |
| 205 db close | |
| 206 close $shmfd | |
| 207 } | |
| 208 | |
| 209 finish_test | |
| OLD | NEW |