summaryrefslogtreecommitdiffstats
path: root/lib/libsqlite3/tool/rollback-test.c
diff options
context:
space:
mode:
Diffstat (limited to 'lib/libsqlite3/tool/rollback-test.c')
-rw-r--r--lib/libsqlite3/tool/rollback-test.c155
1 files changed, 0 insertions, 155 deletions
diff --git a/lib/libsqlite3/tool/rollback-test.c b/lib/libsqlite3/tool/rollback-test.c
deleted file mode 100644
index 915d9d203da..00000000000
--- a/lib/libsqlite3/tool/rollback-test.c
+++ /dev/null
@@ -1,155 +0,0 @@
-/*
-** This program is used to generate and verify databases with hot journals.
-** Use this program to generate a hot journal on one machine and verify
-** that it rolls back correctly on another machine with a different
-** architecture.
-**
-** Usage:
-**
-** rollback-test new [-utf8] [-utf16le] [-utf16be] [-pagesize=N] DATABASE
-** rollback-test check DATABASE
-** rollback-test crash [-wal] [-rollback] DATABASE
-*/
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include "sqlite3.h"
-
-static void usage(char *argv0){
- fprintf(stderr,
- "Usage: %s new [-utf8] [-utf16le] [-utf16be] [-pagesize=N] DATABASE\n"
- " %s check DATABASE\n"
- " %s crash [-wal] DATABASE\n",
- argv0, argv0, argv0
- );
- exit(1);
-}
-
-static sqlite3 *openDb(const char *zFilename){
- int rc;
- sqlite3 *db;
- rc = sqlite3_open(zFilename, &db);
- if( rc ){
- fprintf(stderr, "Cannot open \"%s\": %s\n",
- zFilename, sqlite3_errmsg(db));
- sqlite3_close(db);
- exit(1);
- }
- return db;
-}
-
-static int nReply = 0;
-static char zReply[1000];
-
-static int execCallback(void *NotUsed, int nArg, char **azArg, char **azCol){
- int i, n;
- char *z;
- for(i=0; i<nArg; i++){
- z = azArg[i];
- if( z==0 ) z = "NULL";
- if( nReply>0 && nReply<sizeof(zReply)-1 ) zReply[nReply++] = ' ';
- n = strlen(z);
- if( nReply+n>=sizeof(zReply)-1 ) n = sizeof(zReply) - nReply - 1;
- memcpy(&zReply[nReply], z, n);
- nReply += n;
- zReply[nReply] = 0;
- }
- return 0;
-}
-
-static void runSql(sqlite3 *db, const char *zSql){
- char *zErr = 0;
- int rc;
- nReply = 0;
- rc = sqlite3_exec(db, zSql, execCallback, 0, &zErr);
- if( zErr ){
- fprintf(stderr, "SQL error: %s\n", zErr);
- exit(1);
- }
- if( rc ){
- fprintf(stderr, "SQL error: %s\n", sqlite3_errmsg(db));
- exit(1);
- }
-}
-
-int main(int argc, char **argv){
- sqlite3 *db;
- int i;
-
- if( argc<3 ) usage(argv[0]);
- if( strcmp(argv[1], "new")==0 ){
- db = openDb(argv[argc-1]);
- for(i=2; i<argc-1; i++){
- if( strcmp(argv[i],"-utf8")==0 ){
- runSql(db, "PRAGMA encoding=UTF8");
- }else if( strcmp(argv[i], "-utf16le")==0 ){
- runSql(db, "PRAGMA encoding=UTF16LE");
- }else if( strcmp(argv[i], "-utf16be")==0 ){
- runSql(db, "PRAGMA encoding=UTF16BE");
- }else if( strncmp(argv[i], "-pagesize=", 10)==0 ){
- int szPg = atoi(&argv[i][10]);
- char zBuf[100];
- sprintf(zBuf, "PRAGMA pagesize=%d", szPg);
- runSql(db, zBuf);
- }else{
- fprintf(stderr, "unknown option %s\n", argv[i]);
- usage(argv[0]);
- }
- }
- runSql(db,
- "BEGIN;"
- "CREATE TABLE t1(x INTEGER PRIMARY KEY, y);"
- "INSERT INTO t1(y) VALUES('abcdefghijklmnopqrstuvwxyz');"
- "INSERT INTO t1(y) VALUES('abcdefghijklmnopqrstuvwxyz');"
- "INSERT INTO t1(y) SELECT y FROM t1;" /* 4 */
- "INSERT INTO t1(y) SELECT y FROM t1;" /* 8 */
- "INSERT INTO t1(y) SELECT y FROM t1;" /* 16 */
- "INSERT INTO t1(y) SELECT y FROM t1;" /* 32 */
- "INSERT INTO t1(y) SELECT y FROM t1;" /* 64 */
- "INSERT INTO t1(y) SELECT y FROM t1;" /* 128 */
- "INSERT INTO t1(y) SELECT y FROM t1;" /* 256 */
- "INSERT INTO t1(y) SELECT y FROM t1;" /* 512 */
- "INSERT INTO t1(y) SELECT y FROM t1;" /* 1024 */
- "UPDATE t1 SET y=(y || x);"
- "CREATE INDEX t1y ON t1(y);"
- "COMMIT;"
- );
- sqlite3_close(db);
- }else if( strcmp(argv[1], "check")==0 ){
- db = openDb(argv[argc-1]);
- runSql(db, "PRAGMA integrity_check");
- if( strcmp(zReply, "ok")!=0 ){
- fprintf(stderr, "Integrity check: %s\n", zReply);
- exit(1);
- }
- runSql(db,
- "SELECT count(*) FROM t1 WHERE y<>('abcdefghijklmnopqrstuvwxyz' || x)"
- );
- if( strcmp(zReply, "0")!=0 ){
- fprintf(stderr, "Wrong content\n");
- exit(1);
- }
- printf("Ok\n");
- }else if( strcmp(argv[1], "crash")==0 ){
- db = openDb(argv[argc-1]);
- for(i=2; i<argc-1; i++){
- if( strcmp(argv[i],"-wal")==0 ){
- runSql(db, "PRAGMA journal_mode=WAL");
- }else if( strcmp(argv[i], "-rollback")==0 ){
- runSql(db, "PRAGMA journal_mode=DELETE");
- }else{
- fprintf(stderr, "unknown option %s\n", argv[i]);
- usage(argv[0]);
- }
- }
- runSql(db,
- "PRAGMA cache_size=10;"
- "BEGIN;"
- "UPDATE t1 SET y=(y || -x)"
- );
- exit(0);
- }else{
- usage(argv[0]);
- }
- return 0;
-}