| Index: third_party/sqlite/sqlite-src-3080704/test/mmap1.test
|
| diff --git a/third_party/sqlite/sqlite-src-3080704/test/mmap1.test b/third_party/sqlite/sqlite-src-3080704/test/mmap1.test
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..ece3e0201ed2aceb86cfc48e0adf7d9266a8c4bc
|
| --- /dev/null
|
| +++ b/third_party/sqlite/sqlite-src-3080704/test/mmap1.test
|
| @@ -0,0 +1,331 @@
|
| +# 2013 March 20
|
| +#
|
| +# The author disclaims copyright to this source code. In place of
|
| +# a legal notice, here is a blessing:
|
| +#
|
| +# May you do good and not evil.
|
| +# May you find forgiveness for yourself and forgive others.
|
| +# May you share freely, never taking more than you give.
|
| +#
|
| +#***********************************************************************
|
| +#
|
| +
|
| +set testdir [file dirname $argv0]
|
| +source $testdir/tester.tcl
|
| +ifcapable !mmap {
|
| + finish_test
|
| + return
|
| +}
|
| +source $testdir/lock_common.tcl
|
| +set testprefix mmap1
|
| +
|
| +proc nRead {db} {
|
| + set bt [btree_from_db $db]
|
| + db_enter $db
|
| + array set stats [btree_pager_stats $bt]
|
| + db_leave $db
|
| + # puts [array get stats]
|
| + return $stats(read)
|
| +}
|
| +
|
| +proc register_rblob_code {dbname seed} {
|
| + return [subst -nocommands {
|
| + set ::rcnt $seed
|
| + proc rblob {n} {
|
| + set ::rcnt [expr (([set ::rcnt] << 3) + [set ::rcnt] + 456) & 0xFFFFFFFF]
|
| + set str [format %.8x [expr [set ::rcnt] ^ 0xbdf20da3]]
|
| + string range [string repeat [set str] [expr [set n]/4]] 1 [set n]
|
| + }
|
| + $dbname func rblob rblob
|
| + }]
|
| +}
|
| +
|
| +# For cases 1.1 and 1.4, the number of pages read using xRead() is 4 on
|
| +# unix and 9 on windows. The difference is that windows only ever maps
|
| +# an integer number of OS pages (i.e. creates mappings that are a multiple
|
| +# of 4KB in size). Whereas on unix any sized mapping may be created.
|
| +#
|
| +foreach {t mmap_size nRead c2init} {
|
| + 1.1 { PRAGMA mmap_size = 67108864 } /[49]/ {PRAGMA mmap_size = 0}
|
| + 1.2 { PRAGMA mmap_size = 53248 } 150 {PRAGMA mmap_size = 0}
|
| + 1.3 { PRAGMA mmap_size = 0 } 344 {PRAGMA mmap_size = 0}
|
| + 1.4 { PRAGMA mmap_size = 67108864 } /[49]/ {PRAGMA mmap_size = 67108864 }
|
| + 1.5 { PRAGMA mmap_size = 53248 } 150 {PRAGMA mmap_size = 67108864 }
|
| + 1.6 { PRAGMA mmap_size = 0 } 344 {PRAGMA mmap_size = 67108864 }
|
| +} {
|
| +
|
| + do_multiclient_test tn {
|
| + sql1 {PRAGMA cache_size=2000}
|
| + sql2 {PRAGMA cache_size=2000}
|
| +
|
| + sql1 {PRAGMA page_size=1024}
|
| + sql1 $mmap_size
|
| + sql2 $c2init
|
| +
|
| + code2 [register_rblob_code db2 0]
|
| +
|
| + sql2 {
|
| + PRAGMA page_size=1024;
|
| + PRAGMA auto_vacuum = 1;
|
| + CREATE TABLE t1(a, b, UNIQUE(a, b));
|
| + INSERT INTO t1 VALUES(rblob(500), rblob(500));
|
| + INSERT INTO t1 SELECT rblob(500), rblob(500) FROM t1; -- 2
|
| + INSERT INTO t1 SELECT rblob(500), rblob(500) FROM t1; -- 4
|
| + INSERT INTO t1 SELECT rblob(500), rblob(500) FROM t1; -- 8
|
| + INSERT INTO t1 SELECT rblob(500), rblob(500) FROM t1; -- 16
|
| + INSERT INTO t1 SELECT rblob(500), rblob(500) FROM t1; -- 32
|
| + }
|
| + do_test $t.$tn.1 {
|
| + sql1 "SELECT count(*) FROM t1; PRAGMA integrity_check ; PRAGMA page_count"
|
| + } {32 ok 77}
|
| +
|
| + # Have connection 2 shrink the file. Check connection 1 can still read it.
|
| + sql2 { DELETE FROM t1 WHERE rowid%2; }
|
| + do_test $t.$tn.2 {
|
| + sql1 "SELECT count(*) FROM t1; PRAGMA integrity_check ; PRAGMA page_count"
|
| + } {16 ok 42}
|
| +
|
| + # Have connection 2 grow the file. Check connection 1 can still read it.
|
| + sql2 { INSERT INTO t1 SELECT rblob(500), rblob(500) FROM t1 }
|
| + do_test $t.$tn.3 {
|
| + sql1 "SELECT count(*) FROM t1; PRAGMA integrity_check ; PRAGMA page_count"
|
| + } {32 ok 79}
|
| +
|
| + # Have connection 2 grow the file again. Check connection 1 is still ok.
|
| + sql2 { INSERT INTO t1 SELECT rblob(500), rblob(500) FROM t1 }
|
| + do_test $t.$tn.4 {
|
| + sql1 "SELECT count(*) FROM t1; PRAGMA integrity_check ; PRAGMA page_count"
|
| + } {64 ok 149}
|
| +
|
| + # Check that the number of pages read by connection 1 indicates that the
|
| + # "PRAGMA mmap_size" command worked.
|
| + do_test $t.$tn.5 { nRead db } $nRead
|
| + }
|
| +}
|
| +
|
| +set ::rcnt 0
|
| +proc rblob {n} {
|
| + set ::rcnt [expr (($::rcnt << 3) + $::rcnt + 456) & 0xFFFFFFFF]
|
| + set str [format %.8x [expr $::rcnt ^ 0xbdf20da3]]
|
| + string range [string repeat $str [expr $n/4]] 1 $n
|
| +}
|
| +
|
| +reset_db
|
| +db func rblob rblob
|
| +
|
| +do_execsql_test 2.1 {
|
| + PRAGMA auto_vacuum = 1;
|
| + PRAGMA mmap_size = 67108864;
|
| + PRAGMA journal_mode = wal;
|
| + CREATE TABLE t1(a, b, UNIQUE(a, b));
|
| + INSERT INTO t1 VALUES(rblob(500), rblob(500));
|
| + INSERT INTO t1 SELECT rblob(500), rblob(500) FROM t1; -- 2
|
| + INSERT INTO t1 SELECT rblob(500), rblob(500) FROM t1; -- 4
|
| + INSERT INTO t1 SELECT rblob(500), rblob(500) FROM t1; -- 8
|
| + INSERT INTO t1 SELECT rblob(500), rblob(500) FROM t1; -- 16
|
| + INSERT INTO t1 SELECT rblob(500), rblob(500) FROM t1; -- 32
|
| + PRAGMA wal_checkpoint;
|
| +} {67108864 wal 0 103 103}
|
| +
|
| +do_execsql_test 2.2 {
|
| + PRAGMA auto_vacuum;
|
| + SELECT count(*) FROM t1;
|
| +} {1 32}
|
| +
|
| +if {[permutation] != "inmemory_journal"} {
|
| + do_test 2.3 {
|
| + sqlite3 db2 test.db
|
| + db2 func rblob rblob
|
| + db2 eval {
|
| + DELETE FROM t1 WHERE (rowid%4);
|
| + PRAGMA wal_checkpoint;
|
| + }
|
| + db2 eval {
|
| + INSERT INTO t1 SELECT rblob(500), rblob(500) FROM t1; -- 16
|
| + SELECT count(*) FROM t1;
|
| + }
|
| + } {16}
|
| +
|
| + do_execsql_test 2.4 {
|
| + PRAGMA wal_checkpoint;
|
| + } {0 24 24}
|
| + db2 close
|
| +}
|
| +
|
| +reset_db
|
| +execsql { PRAGMA mmap_size = 67108864; }
|
| +db func rblob rblob
|
| +do_execsql_test 3.1 {
|
| + PRAGMA auto_vacuum = 1;
|
| +
|
| + CREATE TABLE t1(a, b, UNIQUE(a, b));
|
| + INSERT INTO t1 VALUES(rblob(500), rblob(500));
|
| + INSERT INTO t1 SELECT rblob(500), rblob(500) FROM t1; -- 2
|
| + INSERT INTO t1 SELECT rblob(500), rblob(500) FROM t1; -- 4
|
| + INSERT INTO t1 SELECT rblob(500), rblob(500) FROM t1; -- 8
|
| +
|
| + CREATE TABLE t2(a, b, UNIQUE(a, b));
|
| + INSERT INTO t2 SELECT * FROM t1;
|
| +} {}
|
| +
|
| +do_test 3.2 {
|
| + set nRow 0
|
| + db eval {SELECT * FROM t2 ORDER BY a, b} {
|
| + if {$nRow==4} { db eval { DELETE FROM t1 } }
|
| + incr nRow
|
| + }
|
| + set nRow
|
| +} {8}
|
| +
|
| +#-------------------------------------------------------------------------
|
| +# Ensure that existing cursors using xFetch() pages see changes made
|
| +# to rows using the incrblob API.
|
| +#
|
| +reset_db
|
| +execsql { PRAGMA mmap_size = 67108864; }
|
| +set aaa [string repeat a 400]
|
| +set bbb [string repeat b 400]
|
| +set ccc [string repeat c 400]
|
| +set ddd [string repeat d 400]
|
| +set eee [string repeat e 400]
|
| +
|
| +do_execsql_test 4.1 {
|
| + PRAGMA page_size = 1024;
|
| + CREATE TABLE t1(x);
|
| + INSERT INTO t1 VALUES($aaa);
|
| + INSERT INTO t1 VALUES($bbb);
|
| + INSERT INTO t1 VALUES($ccc);
|
| + INSERT INTO t1 VALUES($ddd);
|
| + SELECT * FROM t1;
|
| + BEGIN;
|
| +} [list $aaa $bbb $ccc $ddd]
|
| +
|
| +do_test 4.2 {
|
| + set ::STMT [sqlite3_prepare db "SELECT * FROM t1 ORDER BY rowid" -1 dummy]
|
| + sqlite3_step $::STMT
|
| + sqlite3_column_text $::STMT 0
|
| +} $aaa
|
| +
|
| +do_test 4.3 {
|
| + foreach r {2 3 4} {
|
| + set fd [db incrblob t1 x $r]
|
| + puts -nonewline $fd $eee
|
| + close $fd
|
| + }
|
| +
|
| + set res [list]
|
| + while {"SQLITE_ROW" == [sqlite3_step $::STMT]} {
|
| + lappend res [sqlite3_column_text $::STMT 0]
|
| + }
|
| + set res
|
| +} [list $eee $eee $eee]
|
| +
|
| +do_test 4.4 {
|
| + sqlite3_finalize $::STMT
|
| +} SQLITE_OK
|
| +
|
| +do_execsql_test 4.5 { COMMIT }
|
| +
|
| +#-------------------------------------------------------------------------
|
| +# Ensure that existing cursors holding xFetch() references are not
|
| +# confused if those pages are moved to make way for the root page of a
|
| +# new table or index.
|
| +#
|
| +reset_db
|
| +execsql { PRAGMA mmap_size = 67108864; }
|
| +do_execsql_test 5.1 {
|
| + PRAGMA auto_vacuum = 2;
|
| + PRAGMA page_size = 1024;
|
| + CREATE TABLE t1(x);
|
| + INSERT INTO t1 VALUES($aaa);
|
| + INSERT INTO t1 VALUES($bbb);
|
| + INSERT INTO t1 VALUES($ccc);
|
| + INSERT INTO t1 VALUES($ddd);
|
| +
|
| + PRAGMA auto_vacuum;
|
| + SELECT * FROM t1;
|
| +} [list 2 $aaa $bbb $ccc $ddd]
|
| +
|
| +do_test 5.2 {
|
| + set ::STMT [sqlite3_prepare db "SELECT * FROM t1 ORDER BY rowid" -1 dummy]
|
| + sqlite3_step $::STMT
|
| + sqlite3_column_text $::STMT 0
|
| +} $aaa
|
| +
|
| +do_execsql_test 5.3 {
|
| + CREATE TABLE t2(x);
|
| + INSERT INTO t2 VALUES('tricked you!');
|
| + INSERT INTO t2 VALUES('tricked you!');
|
| +}
|
| +
|
| +do_test 5.4 {
|
| + sqlite3_step $::STMT
|
| + sqlite3_column_text $::STMT 0
|
| +} $bbb
|
| +
|
| +do_test 5.5 {
|
| + sqlite3_finalize $::STMT
|
| +} SQLITE_OK
|
| +
|
| +#-------------------------------------------------------------------------
|
| +# Test various mmap_size settings.
|
| +#
|
| +foreach {tn1 mmap1 mmap2} {
|
| + 1 6144 167773
|
| + 2 18432 140399
|
| + 3 43008 401302
|
| + 4 92160 253899
|
| + 5 190464 2
|
| + 6 387072 752431
|
| + 7 780288 291143
|
| + 8 1566720 594306
|
| + 9 3139584 829137
|
| + 10 6285312 793963
|
| + 11 12576768 1015590
|
| +} {
|
| + do_multiclient_test tn {
|
| + sql1 {
|
| + CREATE TABLE t1(a PRIMARY KEY);
|
| + CREATE TABLE t2(x);
|
| + INSERT INTO t2 VALUES('');
|
| + }
|
| +
|
| + code1 [register_rblob_code db 0]
|
| + code2 [register_rblob_code db2 444]
|
| +
|
| + sql1 "PRAGMA mmap_size = $mmap1"
|
| + sql2 "PRAGMA mmap_size = $mmap2"
|
| +
|
| + do_test $tn1.$tn {
|
| + for {set i 1} {$i <= 100} {incr i} {
|
| + if {$i % 2} {
|
| + set c1 sql1
|
| + set c2 sql2
|
| + } else {
|
| + set c1 sql2
|
| + set c2 sql1
|
| + }
|
| +
|
| + $c1 {
|
| + INSERT INTO t1 VALUES( rblob(5000) );
|
| + UPDATE t2 SET x = (SELECT md5sum(a) FROM t1);
|
| + }
|
| +
|
| + set res [$c2 {
|
| + SELECT count(*) FROM t1;
|
| + SELECT x == (SELECT md5sum(a) FROM t1) FROM t2;
|
| + PRAGMA integrity_check;
|
| + }]
|
| + if {$res != [list $i 1 ok]} {
|
| + do_test $tn1.$tn.$i {
|
| + set ::res
|
| + } [list $i 1 ok]
|
| + }
|
| + }
|
| + set res 1
|
| + } {1}
|
| + }
|
| +}
|
| +
|
| +
|
| +finish_test
|
|
|