blob: 8acdf6f4efe7e006765ae6ea5d8fba56fa1d07c0 [file] [log] [blame]
drh5c4d9702001-08-20 00:33:58 +00001/*
drhb19a2bc2001-09-16 00:13:26 +00002** 2001 September 15
drh5c4d9702001-08-20 00:33:58 +00003**
drhb19a2bc2001-09-16 00:13:26 +00004** The author disclaims copyright to this source code. In place of
5** a legal notice, here is a blessing:
drh5c4d9702001-08-20 00:33:58 +00006**
drhb19a2bc2001-09-16 00:13:26 +00007** May you do good and not evil.
8** May you find forgiveness for yourself and forgive others.
9** May you share freely, never taking more than you give.
drh5c4d9702001-08-20 00:33:58 +000010**
11*************************************************************************
12** Code for testing the pager.c module in SQLite. This code
13** is not included in the SQLite library. It is used for automated
14** testing of the SQLite library.
drh5c4d9702001-08-20 00:33:58 +000015*/
16#include "sqliteInt.h"
drh5c4d9702001-08-20 00:33:58 +000017#include "tcl.h"
18#include <stdlib.h>
19#include <string.h>
drh3088d592008-03-21 16:45:47 +000020#include <ctype.h>
drh5c4d9702001-08-20 00:33:58 +000021
22/*
23** Interpret an SQLite error number
24*/
25static char *errorName(int rc){
26 char *zName;
27 switch( rc ){
28 case SQLITE_OK: zName = "SQLITE_OK"; break;
29 case SQLITE_ERROR: zName = "SQLITE_ERROR"; break;
drh5c4d9702001-08-20 00:33:58 +000030 case SQLITE_PERM: zName = "SQLITE_PERM"; break;
31 case SQLITE_ABORT: zName = "SQLITE_ABORT"; break;
32 case SQLITE_BUSY: zName = "SQLITE_BUSY"; break;
33 case SQLITE_NOMEM: zName = "SQLITE_NOMEM"; break;
34 case SQLITE_READONLY: zName = "SQLITE_READONLY"; break;
35 case SQLITE_INTERRUPT: zName = "SQLITE_INTERRUPT"; break;
36 case SQLITE_IOERR: zName = "SQLITE_IOERR"; break;
37 case SQLITE_CORRUPT: zName = "SQLITE_CORRUPT"; break;
drh5c4d9702001-08-20 00:33:58 +000038 case SQLITE_FULL: zName = "SQLITE_FULL"; break;
39 case SQLITE_CANTOPEN: zName = "SQLITE_CANTOPEN"; break;
40 case SQLITE_PROTOCOL: zName = "SQLITE_PROTOCOL"; break;
drh247be432002-05-10 05:44:55 +000041 case SQLITE_EMPTY: zName = "SQLITE_EMPTY"; break;
42 case SQLITE_SCHEMA: zName = "SQLITE_SCHEMA"; break;
drh247be432002-05-10 05:44:55 +000043 case SQLITE_CONSTRAINT: zName = "SQLITE_CONSTRAINT"; break;
44 case SQLITE_MISMATCH: zName = "SQLITE_MISMATCH"; break;
45 case SQLITE_MISUSE: zName = "SQLITE_MISUSE"; break;
drh8766c342002-11-09 00:33:15 +000046 case SQLITE_NOLFS: zName = "SQLITE_NOLFS"; break;
drh5c4d9702001-08-20 00:33:58 +000047 default: zName = "SQLITE_Unknown"; break;
48 }
49 return zName;
50}
51
52/*
drh90f5ecb2004-07-22 01:19:35 +000053** Page size and reserved size used for testing.
54*/
55static int test_pagesize = 1024;
56
57/*
drh4775ecd2009-07-24 19:01:19 +000058** Dummy page reinitializer
59*/
60static void pager_test_reiniter(DbPage *pNotUsed){
61 return;
62}
63
64/*
drh5c4d9702001-08-20 00:33:58 +000065** Usage: pager_open FILENAME N-PAGE
66**
67** Open a new pager
68*/
69static int pager_open(
70 void *NotUsed,
71 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
72 int argc, /* Number of arguments */
drhc2eef3b2002-08-31 18:53:06 +000073 const char **argv /* Text of each argument */
drh5c4d9702001-08-20 00:33:58 +000074){
drhb2eced52010-08-12 02:41:12 +000075 u32 pageSize;
drh5c4d9702001-08-20 00:33:58 +000076 Pager *pPager;
77 int nPage;
78 int rc;
79 char zBuf[100];
80 if( argc!=3 ){
81 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
82 " FILENAME N-PAGE\"", 0);
83 return TCL_ERROR;
84 }
85 if( Tcl_GetInt(interp, argv[2], &nPage) ) return TCL_ERROR;
danielk197771d5d2c2008-09-29 11:49:47 +000086 rc = sqlite3PagerOpen(sqlite3_vfs_find(0), &pPager, argv[1], 0, 0,
drh4775ecd2009-07-24 19:01:19 +000087 SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE | SQLITE_OPEN_MAIN_DB,
88 pager_test_reiniter);
drh5c4d9702001-08-20 00:33:58 +000089 if( rc!=SQLITE_OK ){
90 Tcl_AppendResult(interp, errorName(rc), 0);
91 return TCL_ERROR;
92 }
danielk19773b8a05f2007-03-19 17:44:26 +000093 sqlite3PagerSetCachesize(pPager, nPage);
danielk1977a1644fd2007-08-29 12:31:25 +000094 pageSize = test_pagesize;
drhfa9601a2009-06-18 17:22:39 +000095 sqlite3PagerSetPagesize(pPager, &pageSize, -1);
drhfe63d1c2004-09-08 20:13:04 +000096 sqlite3_snprintf(sizeof(zBuf),zBuf,"%p",pPager);
drh5c4d9702001-08-20 00:33:58 +000097 Tcl_AppendResult(interp, zBuf, 0);
98 return TCL_OK;
99}
100
101/*
102** Usage: pager_close ID
103**
104** Close the given pager.
105*/
106static int pager_close(
107 void *NotUsed,
108 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
109 int argc, /* Number of arguments */
drhc2eef3b2002-08-31 18:53:06 +0000110 const char **argv /* Text of each argument */
drh5c4d9702001-08-20 00:33:58 +0000111){
112 Pager *pPager;
113 int rc;
114 if( argc!=2 ){
115 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
116 " ID\"", 0);
117 return TCL_ERROR;
118 }
drhe8f52c52008-07-12 14:52:20 +0000119 pPager = sqlite3TestTextToPtr(argv[1]);
danielk19773b8a05f2007-03-19 17:44:26 +0000120 rc = sqlite3PagerClose(pPager);
drh5c4d9702001-08-20 00:33:58 +0000121 if( rc!=SQLITE_OK ){
122 Tcl_AppendResult(interp, errorName(rc), 0);
123 return TCL_ERROR;
124 }
125 return TCL_OK;
126}
127
128/*
129** Usage: pager_rollback ID
130**
131** Rollback changes
132*/
133static int pager_rollback(
134 void *NotUsed,
135 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
136 int argc, /* Number of arguments */
drhc2eef3b2002-08-31 18:53:06 +0000137 const char **argv /* Text of each argument */
drh5c4d9702001-08-20 00:33:58 +0000138){
139 Pager *pPager;
140 int rc;
141 if( argc!=2 ){
142 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
143 " ID\"", 0);
144 return TCL_ERROR;
145 }
drhe8f52c52008-07-12 14:52:20 +0000146 pPager = sqlite3TestTextToPtr(argv[1]);
danielk19773b8a05f2007-03-19 17:44:26 +0000147 rc = sqlite3PagerRollback(pPager);
drh5c4d9702001-08-20 00:33:58 +0000148 if( rc!=SQLITE_OK ){
149 Tcl_AppendResult(interp, errorName(rc), 0);
150 return TCL_ERROR;
151 }
152 return TCL_OK;
153}
154
155/*
156** Usage: pager_commit ID
157**
158** Commit all changes
159*/
160static int pager_commit(
161 void *NotUsed,
162 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
163 int argc, /* Number of arguments */
drhc2eef3b2002-08-31 18:53:06 +0000164 const char **argv /* Text of each argument */
drh5c4d9702001-08-20 00:33:58 +0000165){
166 Pager *pPager;
167 int rc;
168 if( argc!=2 ){
169 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
170 " ID\"", 0);
171 return TCL_ERROR;
172 }
drhe8f52c52008-07-12 14:52:20 +0000173 pPager = sqlite3TestTextToPtr(argv[1]);
drh49b9d332009-01-02 18:10:42 +0000174 rc = sqlite3PagerCommitPhaseOne(pPager, 0, 0);
drh80e35f42007-03-30 14:06:34 +0000175 if( rc!=SQLITE_OK ){
176 Tcl_AppendResult(interp, errorName(rc), 0);
177 return TCL_ERROR;
178 }
179 rc = sqlite3PagerCommitPhaseTwo(pPager);
drh5c4d9702001-08-20 00:33:58 +0000180 if( rc!=SQLITE_OK ){
181 Tcl_AppendResult(interp, errorName(rc), 0);
182 return TCL_ERROR;
183 }
184 return TCL_OK;
185}
186
187/*
drh3aac2dd2004-04-26 14:10:20 +0000188** Usage: pager_stmt_begin ID
drhfa86c412002-02-02 15:01:15 +0000189**
190** Start a new checkpoint.
191*/
drh3aac2dd2004-04-26 14:10:20 +0000192static int pager_stmt_begin(
drhfa86c412002-02-02 15:01:15 +0000193 void *NotUsed,
194 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
195 int argc, /* Number of arguments */
drhc2eef3b2002-08-31 18:53:06 +0000196 const char **argv /* Text of each argument */
drhfa86c412002-02-02 15:01:15 +0000197){
198 Pager *pPager;
199 int rc;
200 if( argc!=2 ){
201 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
202 " ID\"", 0);
203 return TCL_ERROR;
204 }
drhe8f52c52008-07-12 14:52:20 +0000205 pPager = sqlite3TestTextToPtr(argv[1]);
danielk1977fd7f0452008-12-17 17:30:26 +0000206 rc = sqlite3PagerOpenSavepoint(pPager, 1);
drhfa86c412002-02-02 15:01:15 +0000207 if( rc!=SQLITE_OK ){
208 Tcl_AppendResult(interp, errorName(rc), 0);
209 return TCL_ERROR;
210 }
211 return TCL_OK;
212}
213
214/*
drh3aac2dd2004-04-26 14:10:20 +0000215** Usage: pager_stmt_rollback ID
drhfa86c412002-02-02 15:01:15 +0000216**
217** Rollback changes to a checkpoint
218*/
drh3aac2dd2004-04-26 14:10:20 +0000219static int pager_stmt_rollback(
drhfa86c412002-02-02 15:01:15 +0000220 void *NotUsed,
221 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
222 int argc, /* Number of arguments */
drhc2eef3b2002-08-31 18:53:06 +0000223 const char **argv /* Text of each argument */
drhfa86c412002-02-02 15:01:15 +0000224){
225 Pager *pPager;
226 int rc;
227 if( argc!=2 ){
228 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
229 " ID\"", 0);
230 return TCL_ERROR;
231 }
drhe8f52c52008-07-12 14:52:20 +0000232 pPager = sqlite3TestTextToPtr(argv[1]);
danielk1977fd7f0452008-12-17 17:30:26 +0000233 rc = sqlite3PagerSavepoint(pPager, SAVEPOINT_ROLLBACK, 0);
234 sqlite3PagerSavepoint(pPager, SAVEPOINT_RELEASE, 0);
drhfa86c412002-02-02 15:01:15 +0000235 if( rc!=SQLITE_OK ){
236 Tcl_AppendResult(interp, errorName(rc), 0);
237 return TCL_ERROR;
238 }
239 return TCL_OK;
240}
241
242/*
drh3aac2dd2004-04-26 14:10:20 +0000243** Usage: pager_stmt_commit ID
drhfa86c412002-02-02 15:01:15 +0000244**
245** Commit changes to a checkpoint
246*/
drh3aac2dd2004-04-26 14:10:20 +0000247static int pager_stmt_commit(
drhfa86c412002-02-02 15:01:15 +0000248 void *NotUsed,
249 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
250 int argc, /* Number of arguments */
drhc2eef3b2002-08-31 18:53:06 +0000251 const char **argv /* Text of each argument */
drhfa86c412002-02-02 15:01:15 +0000252){
253 Pager *pPager;
254 int rc;
255 if( argc!=2 ){
256 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
257 " ID\"", 0);
258 return TCL_ERROR;
259 }
drhe8f52c52008-07-12 14:52:20 +0000260 pPager = sqlite3TestTextToPtr(argv[1]);
danielk1977fd7f0452008-12-17 17:30:26 +0000261 rc = sqlite3PagerSavepoint(pPager, SAVEPOINT_RELEASE, 0);
drhfa86c412002-02-02 15:01:15 +0000262 if( rc!=SQLITE_OK ){
263 Tcl_AppendResult(interp, errorName(rc), 0);
264 return TCL_ERROR;
265 }
266 return TCL_OK;
267}
268
269/*
drh5c4d9702001-08-20 00:33:58 +0000270** Usage: pager_stats ID
271**
272** Return pager statistics.
273*/
274static int pager_stats(
275 void *NotUsed,
276 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
277 int argc, /* Number of arguments */
drhc2eef3b2002-08-31 18:53:06 +0000278 const char **argv /* Text of each argument */
drh5c4d9702001-08-20 00:33:58 +0000279){
280 Pager *pPager;
281 int i, *a;
282 if( argc!=2 ){
283 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
284 " ID\"", 0);
285 return TCL_ERROR;
286 }
drhe8f52c52008-07-12 14:52:20 +0000287 pPager = sqlite3TestTextToPtr(argv[1]);
danielk19773b8a05f2007-03-19 17:44:26 +0000288 a = sqlite3PagerStats(pPager);
drh5c4d9702001-08-20 00:33:58 +0000289 for(i=0; i<9; i++){
290 static char *zName[] = {
291 "ref", "page", "max", "size", "state", "err",
292 "hit", "miss", "ovfl",
293 };
294 char zBuf[100];
295 Tcl_AppendElement(interp, zName[i]);
drhfe63d1c2004-09-08 20:13:04 +0000296 sqlite3_snprintf(sizeof(zBuf),zBuf,"%d",a[i]);
drh5c4d9702001-08-20 00:33:58 +0000297 Tcl_AppendElement(interp, zBuf);
298 }
299 return TCL_OK;
300}
301
302/*
303** Usage: pager_pagecount ID
304**
305** Return the size of the database file.
306*/
307static int pager_pagecount(
308 void *NotUsed,
309 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
310 int argc, /* Number of arguments */
drhc2eef3b2002-08-31 18:53:06 +0000311 const char **argv /* Text of each argument */
drh5c4d9702001-08-20 00:33:58 +0000312){
313 Pager *pPager;
314 char zBuf[100];
danielk1977ad0132d2008-06-07 08:58:22 +0000315 int nPage;
drh5c4d9702001-08-20 00:33:58 +0000316 if( argc!=2 ){
317 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
318 " ID\"", 0);
319 return TCL_ERROR;
320 }
drhe8f52c52008-07-12 14:52:20 +0000321 pPager = sqlite3TestTextToPtr(argv[1]);
danielk1977ad0132d2008-06-07 08:58:22 +0000322 sqlite3PagerPagecount(pPager, &nPage);
323 sqlite3_snprintf(sizeof(zBuf), zBuf, "%d", nPage);
drh5c4d9702001-08-20 00:33:58 +0000324 Tcl_AppendResult(interp, zBuf, 0);
325 return TCL_OK;
326}
327
328/*
329** Usage: page_get ID PGNO
330**
331** Return a pointer to a page from the database.
332*/
333static int page_get(
334 void *NotUsed,
335 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
336 int argc, /* Number of arguments */
drhc2eef3b2002-08-31 18:53:06 +0000337 const char **argv /* Text of each argument */
drh5c4d9702001-08-20 00:33:58 +0000338){
339 Pager *pPager;
340 char zBuf[100];
danielk19773b8a05f2007-03-19 17:44:26 +0000341 DbPage *pPage;
drh5c4d9702001-08-20 00:33:58 +0000342 int pgno;
343 int rc;
344 if( argc!=3 ){
345 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
346 " ID PGNO\"", 0);
347 return TCL_ERROR;
348 }
drhe8f52c52008-07-12 14:52:20 +0000349 pPager = sqlite3TestTextToPtr(argv[1]);
drh5c4d9702001-08-20 00:33:58 +0000350 if( Tcl_GetInt(interp, argv[2], &pgno) ) return TCL_ERROR;
danielk197789bc4bc2009-07-21 19:25:24 +0000351 rc = sqlite3PagerSharedLock(pPager);
352 if( rc==SQLITE_OK ){
353 rc = sqlite3PagerGet(pPager, pgno, &pPage);
354 }
drh5c4d9702001-08-20 00:33:58 +0000355 if( rc!=SQLITE_OK ){
356 Tcl_AppendResult(interp, errorName(rc), 0);
357 return TCL_ERROR;
358 }
drhfe63d1c2004-09-08 20:13:04 +0000359 sqlite3_snprintf(sizeof(zBuf),zBuf,"%p",pPage);
drh5c4d9702001-08-20 00:33:58 +0000360 Tcl_AppendResult(interp, zBuf, 0);
361 return TCL_OK;
362}
363
364/*
365** Usage: page_lookup ID PGNO
366**
367** Return a pointer to a page if the page is already in cache.
368** If not in cache, return an empty string.
369*/
370static int page_lookup(
371 void *NotUsed,
372 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
373 int argc, /* Number of arguments */
drhc2eef3b2002-08-31 18:53:06 +0000374 const char **argv /* Text of each argument */
drh5c4d9702001-08-20 00:33:58 +0000375){
376 Pager *pPager;
377 char zBuf[100];
danielk19773b8a05f2007-03-19 17:44:26 +0000378 DbPage *pPage;
drh5c4d9702001-08-20 00:33:58 +0000379 int pgno;
380 if( argc!=3 ){
381 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
382 " ID PGNO\"", 0);
383 return TCL_ERROR;
384 }
drhe8f52c52008-07-12 14:52:20 +0000385 pPager = sqlite3TestTextToPtr(argv[1]);
drh5c4d9702001-08-20 00:33:58 +0000386 if( Tcl_GetInt(interp, argv[2], &pgno) ) return TCL_ERROR;
danielk19773b8a05f2007-03-19 17:44:26 +0000387 pPage = sqlite3PagerLookup(pPager, pgno);
drh5c4d9702001-08-20 00:33:58 +0000388 if( pPage ){
drhfe63d1c2004-09-08 20:13:04 +0000389 sqlite3_snprintf(sizeof(zBuf),zBuf,"%p",pPage);
drh5c4d9702001-08-20 00:33:58 +0000390 Tcl_AppendResult(interp, zBuf, 0);
391 }
392 return TCL_OK;
393}
394
395/*
danielk1977aca790a2005-01-13 11:07:52 +0000396** Usage: pager_truncate ID PGNO
397*/
398static int pager_truncate(
399 void *NotUsed,
400 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
401 int argc, /* Number of arguments */
402 const char **argv /* Text of each argument */
403){
404 Pager *pPager;
danielk1977aca790a2005-01-13 11:07:52 +0000405 int pgno;
406 if( argc!=3 ){
407 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
408 " ID PGNO\"", 0);
409 return TCL_ERROR;
410 }
drhe8f52c52008-07-12 14:52:20 +0000411 pPager = sqlite3TestTextToPtr(argv[1]);
danielk1977aca790a2005-01-13 11:07:52 +0000412 if( Tcl_GetInt(interp, argv[2], &pgno) ) return TCL_ERROR;
danielk1977f90b7262009-01-07 15:18:20 +0000413 sqlite3PagerTruncateImage(pPager, pgno);
danielk1977aca790a2005-01-13 11:07:52 +0000414 return TCL_OK;
415}
416
417
418/*
drh5c4d9702001-08-20 00:33:58 +0000419** Usage: page_unref PAGE
420**
421** Drop a pointer to a page.
422*/
423static int page_unref(
424 void *NotUsed,
425 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
426 int argc, /* Number of arguments */
drhc2eef3b2002-08-31 18:53:06 +0000427 const char **argv /* Text of each argument */
drh5c4d9702001-08-20 00:33:58 +0000428){
danielk19773b8a05f2007-03-19 17:44:26 +0000429 DbPage *pPage;
drh5c4d9702001-08-20 00:33:58 +0000430 if( argc!=2 ){
431 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
432 " PAGE\"", 0);
433 return TCL_ERROR;
434 }
drhe8f52c52008-07-12 14:52:20 +0000435 pPage = (DbPage *)sqlite3TestTextToPtr(argv[1]);
danielk1977bea2a942009-01-20 17:06:27 +0000436 sqlite3PagerUnref(pPage);
drh5c4d9702001-08-20 00:33:58 +0000437 return TCL_OK;
438}
439
440/*
441** Usage: page_read PAGE
442**
443** Return the content of a page
444*/
445static int page_read(
446 void *NotUsed,
447 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
448 int argc, /* Number of arguments */
drhc2eef3b2002-08-31 18:53:06 +0000449 const char **argv /* Text of each argument */
drh5c4d9702001-08-20 00:33:58 +0000450){
451 char zBuf[100];
danielk19773b8a05f2007-03-19 17:44:26 +0000452 DbPage *pPage;
drh5c4d9702001-08-20 00:33:58 +0000453 if( argc!=2 ){
454 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
455 " PAGE\"", 0);
456 return TCL_ERROR;
457 }
drhe8f52c52008-07-12 14:52:20 +0000458 pPage = sqlite3TestTextToPtr(argv[1]);
danielk19773b8a05f2007-03-19 17:44:26 +0000459 memcpy(zBuf, sqlite3PagerGetData(pPage), sizeof(zBuf));
drh5c4d9702001-08-20 00:33:58 +0000460 Tcl_AppendResult(interp, zBuf, 0);
461 return TCL_OK;
462}
463
464/*
465** Usage: page_number PAGE
466**
467** Return the page number for a page.
468*/
469static int page_number(
470 void *NotUsed,
471 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
472 int argc, /* Number of arguments */
drhc2eef3b2002-08-31 18:53:06 +0000473 const char **argv /* Text of each argument */
drh5c4d9702001-08-20 00:33:58 +0000474){
475 char zBuf[100];
danielk19773b8a05f2007-03-19 17:44:26 +0000476 DbPage *pPage;
drh5c4d9702001-08-20 00:33:58 +0000477 if( argc!=2 ){
478 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
479 " PAGE\"", 0);
480 return TCL_ERROR;
481 }
drhe8f52c52008-07-12 14:52:20 +0000482 pPage = (DbPage *)sqlite3TestTextToPtr(argv[1]);
danielk19773b8a05f2007-03-19 17:44:26 +0000483 sqlite3_snprintf(sizeof(zBuf), zBuf, "%d", sqlite3PagerPagenumber(pPage));
drh5c4d9702001-08-20 00:33:58 +0000484 Tcl_AppendResult(interp, zBuf, 0);
485 return TCL_OK;
486}
487
488/*
489** Usage: page_write PAGE DATA
490**
491** Write something into a page.
492*/
493static int page_write(
494 void *NotUsed,
495 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
496 int argc, /* Number of arguments */
drhc2eef3b2002-08-31 18:53:06 +0000497 const char **argv /* Text of each argument */
drh5c4d9702001-08-20 00:33:58 +0000498){
danielk19773b8a05f2007-03-19 17:44:26 +0000499 DbPage *pPage;
500 char *pData;
drh5c4d9702001-08-20 00:33:58 +0000501 int rc;
502 if( argc!=3 ){
503 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
504 " PAGE DATA\"", 0);
505 return TCL_ERROR;
506 }
drhe8f52c52008-07-12 14:52:20 +0000507 pPage = (DbPage *)sqlite3TestTextToPtr(argv[1]);
danielk19773b8a05f2007-03-19 17:44:26 +0000508 rc = sqlite3PagerWrite(pPage);
drh5c4d9702001-08-20 00:33:58 +0000509 if( rc!=SQLITE_OK ){
510 Tcl_AppendResult(interp, errorName(rc), 0);
511 return TCL_ERROR;
512 }
danielk19773b8a05f2007-03-19 17:44:26 +0000513 pData = sqlite3PagerGetData(pPage);
514 strncpy(pData, argv[2], test_pagesize-1);
515 pData[test_pagesize-1] = 0;
drh5c4d9702001-08-20 00:33:58 +0000516 return TCL_OK;
517}
518
danielk197744ee5bf2005-05-27 09:41:12 +0000519#ifndef SQLITE_OMIT_DISKIO
drh5c4d9702001-08-20 00:33:58 +0000520/*
drhd0d006e2002-12-01 02:00:57 +0000521** Usage: fake_big_file N FILENAME
522**
523** Write a few bytes at the N megabyte point of FILENAME. This will
524** create a large file. If the file was a valid SQLite database, then
525** the next time the database is opened, SQLite will begin allocating
526** new pages after N. If N is 2096 or bigger, this will test the
527** ability of SQLite to write to large files.
528*/
529static int fake_big_file(
530 void *NotUsed,
531 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
532 int argc, /* Number of arguments */
533 const char **argv /* Text of each argument */
534){
danielk1977b4b47412007-08-17 15:53:36 +0000535 sqlite3_vfs *pVfs;
536 sqlite3_file *fd = 0;
drhd0d006e2002-12-01 02:00:57 +0000537 int rc;
538 int n;
drheb206252004-10-01 02:00:31 +0000539 i64 offset;
drh69578ac2012-01-11 00:38:51 +0000540 char *zFile;
541 int nFile;
drhd0d006e2002-12-01 02:00:57 +0000542 if( argc!=3 ){
543 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
544 " N-MEGABYTES FILE\"", 0);
545 return TCL_ERROR;
546 }
547 if( Tcl_GetInt(interp, argv[1], &n) ) return TCL_ERROR;
danielk1977b4b47412007-08-17 15:53:36 +0000548
drhd677b3d2007-08-20 22:48:41 +0000549 pVfs = sqlite3_vfs_find(0);
drh83cc1392012-04-19 18:04:28 +0000550 nFile = (int)strlen(argv[2]);
drh69578ac2012-01-11 00:38:51 +0000551 zFile = sqlite3_malloc( nFile+2 );
552 if( zFile==0 ) return TCL_ERROR;
553 memcpy(zFile, argv[2], nFile+1);
554 zFile[nFile+1] = 0;
555 rc = sqlite3OsOpenMalloc(pVfs, zFile, &fd,
danielk1977967a4a12007-08-20 14:23:44 +0000556 (SQLITE_OPEN_CREATE|SQLITE_OPEN_READWRITE|SQLITE_OPEN_MAIN_DB), 0
danielk1977fee2d252007-08-18 10:59:19 +0000557 );
drhd0d006e2002-12-01 02:00:57 +0000558 if( rc ){
559 Tcl_AppendResult(interp, "open failed: ", errorName(rc), 0);
drh69578ac2012-01-11 00:38:51 +0000560 sqlite3_free(zFile);
drhd0d006e2002-12-01 02:00:57 +0000561 return TCL_ERROR;
562 }
563 offset = n;
564 offset *= 1024*1024;
danielk197762079062007-08-15 17:08:46 +0000565 rc = sqlite3OsWrite(fd, "Hello, World!", 14, offset);
danielk1977b4b47412007-08-17 15:53:36 +0000566 sqlite3OsCloseFree(fd);
drh69578ac2012-01-11 00:38:51 +0000567 sqlite3_free(zFile);
drhd0d006e2002-12-01 02:00:57 +0000568 if( rc ){
569 Tcl_AppendResult(interp, "write failed: ", errorName(rc), 0);
570 return TCL_ERROR;
571 }
drhd0d006e2002-12-01 02:00:57 +0000572 return TCL_OK;
573}
danielk197744ee5bf2005-05-27 09:41:12 +0000574#endif
drhd0d006e2002-12-01 02:00:57 +0000575
drh3088d592008-03-21 16:45:47 +0000576
drhd0d006e2002-12-01 02:00:57 +0000577/*
drhc7a3bb92009-02-05 16:31:45 +0000578** test_control_pending_byte PENDING_BYTE
579**
580** Set the PENDING_BYTE using the sqlite3_test_control() interface.
581*/
582static int testPendingByte(
583 void *NotUsed,
584 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
585 int argc, /* Number of arguments */
586 const char **argv /* Text of each argument */
587){
588 int pbyte;
589 int rc;
590 if( argc!=2 ){
591 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
592 " PENDING-BYTE\"", (void*)0);
dan8d6ad1c2010-05-04 10:36:20 +0000593 return TCL_ERROR;
drhc7a3bb92009-02-05 16:31:45 +0000594 }
595 if( Tcl_GetInt(interp, argv[1], &pbyte) ) return TCL_ERROR;
596 rc = sqlite3_test_control(SQLITE_TESTCTRL_PENDING_BYTE, pbyte);
597 Tcl_SetObjResult(interp, Tcl_NewIntObj(rc));
598 return TCL_OK;
599}
600
601/*
drh3088d592008-03-21 16:45:47 +0000602** sqlite3BitvecBuiltinTest SIZE PROGRAM
603**
604** Invoke the SQLITE_TESTCTRL_BITVEC_TEST operator on test_control.
605** See comments on sqlite3BitvecBuiltinTest() for additional information.
drhf5e7bb52008-02-18 14:47:33 +0000606*/
drh3088d592008-03-21 16:45:47 +0000607static int testBitvecBuiltinTest(
drhf5e7bb52008-02-18 14:47:33 +0000608 void *NotUsed,
609 Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
610 int argc, /* Number of arguments */
611 const char **argv /* Text of each argument */
612){
drh3088d592008-03-21 16:45:47 +0000613 int sz, rc;
614 int nProg = 0;
615 int aProg[100];
616 const char *z;
drhf5e7bb52008-02-18 14:47:33 +0000617 if( argc!=3 ){
drh3088d592008-03-21 16:45:47 +0000618 Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
619 " SIZE PROGRAM\"", (void*)0);
drhf5e7bb52008-02-18 14:47:33 +0000620 }
drh3088d592008-03-21 16:45:47 +0000621 if( Tcl_GetInt(interp, argv[1], &sz) ) return TCL_ERROR;
622 z = argv[2];
623 while( nProg<99 && *z ){
danielk197778ca0e72009-01-20 16:53:39 +0000624 while( *z && !sqlite3Isdigit(*z) ){ z++; }
drh3088d592008-03-21 16:45:47 +0000625 if( *z==0 ) break;
626 aProg[nProg++] = atoi(z);
danielk197778ca0e72009-01-20 16:53:39 +0000627 while( sqlite3Isdigit(*z) ){ z++; }
drh3088d592008-03-21 16:45:47 +0000628 }
629 aProg[nProg] = 0;
630 rc = sqlite3_test_control(SQLITE_TESTCTRL_BITVEC_TEST, sz, aProg);
631 Tcl_SetObjResult(interp, Tcl_NewIntObj(rc));
drhf5e7bb52008-02-18 14:47:33 +0000632 return TCL_OK;
633}
drhf5e7bb52008-02-18 14:47:33 +0000634
635/*
drh5c4d9702001-08-20 00:33:58 +0000636** Register commands with the TCL interpreter.
637*/
638int Sqlitetest2_Init(Tcl_Interp *interp){
drhd5eb79e2007-03-15 12:17:42 +0000639 extern int sqlite3_io_error_persist;
danielk19776f8a5032004-05-10 10:34:51 +0000640 extern int sqlite3_io_error_pending;
drhc9ac5ca2005-11-04 22:03:30 +0000641 extern int sqlite3_io_error_hit;
drh1aa5af12008-03-07 19:51:14 +0000642 extern int sqlite3_io_error_hardhit;
drh047d4832004-10-01 14:38:02 +0000643 extern int sqlite3_diskfull_pending;
drhf307a4a2005-09-09 10:46:19 +0000644 extern int sqlite3_diskfull;
drhc2eef3b2002-08-31 18:53:06 +0000645 static struct {
646 char *zName;
647 Tcl_CmdProc *xProc;
648 } aCmd[] = {
649 { "pager_open", (Tcl_CmdProc*)pager_open },
650 { "pager_close", (Tcl_CmdProc*)pager_close },
651 { "pager_commit", (Tcl_CmdProc*)pager_commit },
652 { "pager_rollback", (Tcl_CmdProc*)pager_rollback },
drh3aac2dd2004-04-26 14:10:20 +0000653 { "pager_stmt_begin", (Tcl_CmdProc*)pager_stmt_begin },
654 { "pager_stmt_commit", (Tcl_CmdProc*)pager_stmt_commit },
655 { "pager_stmt_rollback", (Tcl_CmdProc*)pager_stmt_rollback },
drhc2eef3b2002-08-31 18:53:06 +0000656 { "pager_stats", (Tcl_CmdProc*)pager_stats },
657 { "pager_pagecount", (Tcl_CmdProc*)pager_pagecount },
658 { "page_get", (Tcl_CmdProc*)page_get },
659 { "page_lookup", (Tcl_CmdProc*)page_lookup },
660 { "page_unref", (Tcl_CmdProc*)page_unref },
661 { "page_read", (Tcl_CmdProc*)page_read },
662 { "page_write", (Tcl_CmdProc*)page_write },
663 { "page_number", (Tcl_CmdProc*)page_number },
danielk1977aca790a2005-01-13 11:07:52 +0000664 { "pager_truncate", (Tcl_CmdProc*)pager_truncate },
danielk197744ee5bf2005-05-27 09:41:12 +0000665#ifndef SQLITE_OMIT_DISKIO
drhd0d006e2002-12-01 02:00:57 +0000666 { "fake_big_file", (Tcl_CmdProc*)fake_big_file },
danielk197744ee5bf2005-05-27 09:41:12 +0000667#endif
drhc7a3bb92009-02-05 16:31:45 +0000668 { "sqlite3BitvecBuiltinTest",(Tcl_CmdProc*)testBitvecBuiltinTest },
669 { "sqlite3_test_control_pending_byte", (Tcl_CmdProc*)testPendingByte },
drhc2eef3b2002-08-31 18:53:06 +0000670 };
671 int i;
672 for(i=0; i<sizeof(aCmd)/sizeof(aCmd[0]); i++){
673 Tcl_CreateCommand(interp, aCmd[i].zName, aCmd[i].xProc, 0, 0);
674 }
danielk1977369f27e2004-06-15 11:40:04 +0000675 Tcl_LinkVar(interp, "sqlite_io_error_pending",
danielk19776f8a5032004-05-10 10:34:51 +0000676 (char*)&sqlite3_io_error_pending, TCL_LINK_INT);
drhd5eb79e2007-03-15 12:17:42 +0000677 Tcl_LinkVar(interp, "sqlite_io_error_persist",
678 (char*)&sqlite3_io_error_persist, TCL_LINK_INT);
drhc9ac5ca2005-11-04 22:03:30 +0000679 Tcl_LinkVar(interp, "sqlite_io_error_hit",
680 (char*)&sqlite3_io_error_hit, TCL_LINK_INT);
drh1aa5af12008-03-07 19:51:14 +0000681 Tcl_LinkVar(interp, "sqlite_io_error_hardhit",
682 (char*)&sqlite3_io_error_hardhit, TCL_LINK_INT);
drh047d4832004-10-01 14:38:02 +0000683 Tcl_LinkVar(interp, "sqlite_diskfull_pending",
684 (char*)&sqlite3_diskfull_pending, TCL_LINK_INT);
drhf307a4a2005-09-09 10:46:19 +0000685 Tcl_LinkVar(interp, "sqlite_diskfull",
686 (char*)&sqlite3_diskfull, TCL_LINK_INT);
drhf83dc1e2010-06-03 12:09:52 +0000687#ifndef SQLITE_OMIT_WSD
danielk1977fd5f5b62005-09-16 09:52:29 +0000688 Tcl_LinkVar(interp, "sqlite_pending_byte",
drhc7a3bb92009-02-05 16:31:45 +0000689 (char*)&sqlite3PendingByte, TCL_LINK_INT | TCL_LINK_READ_ONLY);
drhf83dc1e2010-06-03 12:09:52 +0000690#endif
drh5c4d9702001-08-20 00:33:58 +0000691 return TCL_OK;
692}