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 |