1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
|
# 2007 April 2
#
# 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.
#
#***********************************************************************
# This file implements regression tests for SQLite library. The
# focus of this file is testing for correct handling of I/O errors
# such as writes failing because the disk is full.
#
# The tests in this file use special facilities that are only
# available in the SQLite test fixture.
#
# $Id: ioerr2.test,v 1.12 2009/06/05 17:09:12 drh Exp $
set testdir [file dirname $argv0]
source $testdir/tester.tcl
ifcapable !integrityck {
finish_test
return
}
do_test ioerr2-1.1 {
execsql {
PRAGMA cache_size = 10;
PRAGMA default_cache_size = 10;
CREATE TABLE t1(a, b, PRIMARY KEY(a, b));
INSERT INTO t1 VALUES(randstr(400,400),randstr(400,400));
INSERT INTO t1 SELECT randstr(400,400), randstr(400,400) FROM t1; -- 2
INSERT INTO t1 SELECT randstr(400,400), randstr(400,400) FROM t1; -- 4
INSERT INTO t1 SELECT randstr(400,400), randstr(400,400) FROM t1; -- 8
INSERT INTO t1 SELECT randstr(400,400), randstr(400,400) FROM t1; -- 16
INSERT INTO t1 SELECT randstr(400,400), randstr(400,400) FROM t1; -- 32
}
} {}
set ::cksum [execsql {SELECT md5sum(a, b) FROM t1}]
proc check_db {testname} {
# Make sure no I/O errors are simulated in this proc.
set ::sqlite_io_error_hit 0
set ::sqlite_io_error_persist 0
set ::sqlite_io_error_pending 0
# Run an integrity-check. If "disk I/O error" is returned, the
# pager must be in error state. In this case open a new database
# connection. Otherwise, try a ROLLBACK, in case a transaction
# is still active.
set rc [catch {execsql {PRAGMA integrity_check}} msg]
if {$rc && ($msg eq "disk I/O error" || $msg eq "database is locked")} {
db close
sqlite3 db test.db
set refcnt 0
} else {
if {$rc || $msg ne "ok"} {
error $msg
}
catch {execsql ROLLBACK}
}
# Check that the database checksum is still $::cksum, and that
# the integrity-check passes.
set ck [execsql {SELECT md5sum(a, b) FROM t1}]
do_test ${testname}.cksum [list set ck $ck] $::cksum
integrity_check ${testname}.integrity
do_test ${testname}.refcnt {
lindex [sqlite3_pager_refcounts db] 0
} 0
}
check_db ioerr2-2
set sql {
PRAGMA cache_size = 10;
PRAGMA default_cache_size = 10;
BEGIN;
DELETE FROM t1 WHERE (oid%7)==0;
INSERT INTO t1 SELECT randstr(400,400), randstr(400,400)
WHERE (random()%7)==0;
UPDATE t1 SET a = randstr(400,400), b = randstr(400,400)
WHERE (random()%7)==0;
ROLLBACK;
}
foreach bPersist [list 0 1] {
set ::go 1
for {set ::N 1} {$::go} {incr ::N} {
db close
sqlite3 db test.db
set ::sqlite_io_error_hit 0
set ::sqlite_io_error_persist $bPersist
set ::sqlite_io_error_pending $::N
foreach {::go res} [catchsql $sql] {}
check_db ioerr2-3.$bPersist.$::N
}
}
foreach bPersist [list 0 1] {
set ::go 1
for {set ::N 1} {$::go} {incr ::N} {
set ::sqlite_io_error_hit 0
set ::sqlite_io_error_persist $bPersist
set ::sqlite_io_error_pending $::N
foreach {::go res} [catchsql $sql] {}
check_db ioerr2-4.[expr {$bPersist+2}].$::N
}
}
do_test ioerr2-5 {
execsql {
CREATE TABLE t2 AS SELECT * FROM t1;
PRAGMA temp_store = memory;
}
set ::sqlite_io_error_persist 0
set ::go 1
set rc [catch {
for {set ::N 2} {$::N<200} {incr ::N} {
db eval {SELECT * FROM t1 WHERE rowid IN (1, 5, 10, 15, 20)} {
set ::sqlite_io_error_hit 0
set ::sqlite_io_error_pending $::N
set sql {UPDATE t2 SET b = randstr(400,400)}
foreach {::go res} [catchsql $sql] {}
}
}
} msg]
list $rc $msg
} {1 {abort due to ROLLBACK}}
if {$::tcl_platform(platform) == "unix"} {
# Cause the call to xAccess used by [pragma temp_store_directory] to
# determine if the specified directory is writable to fail. This causes
# SQLite to report "not a writable directory", which is probably the
# right answer.
#
do_test ioerr2-6 {
set ::sqlite_io_error_hit 0
set ::sqlite_io_error_pending 1
catchsql {PRAGMA temp_store_directory = '/tmp/'}
} {1 {not a writable directory}}
}
do_ioerr_test ioerr2-7 -persist 0 -sqlprep {
PRAGMA cache_size = 10;
PRAGMA auto_vacuum = 1;
CREATE TABLE ab(a, b);
CREATE TABLE de(d, e);
INSERT INTO ab VALUES(1, randstr(200,200));
INSERT INTO ab SELECT a+1, randstr(200,200) FROM ab;
INSERT INTO ab SELECT a+2, randstr(200,200) FROM ab;
INSERT INTO ab SELECT a+4, randstr(200,200) FROM ab;
INSERT INTO ab SELECT a+8, randstr(200,200) FROM ab;
INSERT INTO ab SELECT a+16, randstr(200,200) FROM ab;
INSERT INTO ab SELECT a+32, randstr(200,200) FROM ab;
INSERT INTO ab SELECT a+64, randstr(200,200) FROM ab;
INSERT INTO de SELECT * FROM ab;
} -sqlbody {
BEGIN;
UPDATE ab SET b = randstr(200,200);
UPDATE de SET e = randstr(200,200) WHERE d = (SELECT max(d) FROM de);
DELETE FROM ab;
COMMIT;
}
finish_test
|
