Many improvements to the mptest program. Added a simple test script.
FossilOrigin-Name: 07b0401a9b61b1664fc6dcddac3b5969fc0f481a
This commit is contained in:
drh
parent
27338e6ed7
commit
3f5bc38037
17
manifest
17
manifest
@ -1,5 +1,5 @@
|
||||
C Add\sa\sprototype\sTH3-script-style\stest\sharness\sthat\sstarts\smultiple\sprocesses\noperating\son\sthe\ssame\sdatabase\sfile\sat\sthe\ssame\stime.
|
||||
D 2013-04-06T00:19:37.887
|
||||
C Many\simprovements\sto\sthe\smptest\sprogram.\s\sAdded\sa\ssimple\stest\sscript.
|
||||
D 2013-04-06T13:09:11.141
|
||||
F Makefile.arm-wince-mingw32ce-gcc d6df77f1f48d690bd73162294bbba7f59507c72f
|
||||
F Makefile.in aafa71d66bab7e87fb2f348152340645f79f0244
|
||||
F Makefile.linux-gcc 91d710bdc4998cb015f39edf3cb314ec4f4d7e23
|
||||
@ -110,7 +110,9 @@ F mkextw.sh 4123480947681d9b434a5e7b1ee08135abe409ac
|
||||
F mkopcodec.awk f6fccee29e68493bfd90a2e0466ede5fa94dd2fc
|
||||
F mkopcodeh.awk 29b84656502eee5f444c3147f331ee686956ab0e
|
||||
F mkso.sh fd21c06b063bb16a5d25deea1752c2da6ac3ed83
|
||||
F mptest/mptest.c 04110c35f415218e54e030b2e37215ad4adf01f3
|
||||
F mptest/config01.test 058a9bc2b0db710d36003ab06dc1618566f27b52
|
||||
F mptest/mptest.c d73b294c354719f33086d8d3ebc273553b26073c
|
||||
F mptest/multiwrite01.test aef0af17f1ce1beacd158e403a45a21008d7a70c
|
||||
F spec.template 86a4a43b99ebb3e75e6b9a735d5fd293a24e90ca
|
||||
F sqlite.pc.in 42b7bf0d02e08b9e77734a47798d1a55a9e0716b
|
||||
F sqlite3.1 6be1ad09113570e1fc8dcaff84c9b0b337db5ffc
|
||||
@ -1045,10 +1047,7 @@ F tool/vdbe-compress.tcl f12c884766bd14277f4fcedcae07078011717381
|
||||
F tool/warnings-clang.sh f6aa929dc20ef1f856af04a730772f59283631d4
|
||||
F tool/warnings.sh fbc018d67fd7395f440c28f33ef0f94420226381
|
||||
F tool/win/sqlite.vsix 97894c2790eda7b5bce3cc79cb2a8ec2fde9b3ac
|
||||
P b095e2cdb61ca8487255687f58fb1024d40f3986
|
||||
R c143d7671ed86699bfdf0a0519618d31
|
||||
T *branch * mptest
|
||||
T *sym-mptest *
|
||||
T -sym-trunk *
|
||||
P c318fafe686120d7fb8e487eb3bb4942d497665c
|
||||
R e5c361902695f1e216fb1ed024ee2204
|
||||
U drh
|
||||
Z f0aabffa9579562b9fff6a9c66b5a272
|
||||
Z 1a794dfe7c097a8f7d97d3bcdba2a731
|
||||
|
||||
@ -1 +1 @@
|
||||
c318fafe686120d7fb8e487eb3bb4942d497665c
|
||||
07b0401a9b61b1664fc6dcddac3b5969fc0f481a
|
||||
19
mptest/config01.test
Normal file
19
mptest/config01.test
Normal file
@ -0,0 +1,19 @@
|
||||
/*
|
||||
** Configure five tasks in different ways, then run tests.
|
||||
*/
|
||||
PRAGMA page_size=8192;
|
||||
--task 1
|
||||
PRAGMA journal_mode=PERSIST;
|
||||
PRAGMA mmap_limit=0;
|
||||
--end
|
||||
--task 2
|
||||
PRAGMA journal_mode=TRUNCATE;
|
||||
PRAGMA mmap_limit=28672;
|
||||
--end
|
||||
--task 3
|
||||
PRAGMA journal_mode=MEMORY;
|
||||
--end
|
||||
--task 4
|
||||
PRAGMA journal_mode=OFF;
|
||||
--end
|
||||
--source multiwrite01.test
|
||||
194
mptest/mptest.c
194
mptest/mptest.c
@ -57,8 +57,13 @@ static struct Global {
|
||||
int iTrace; /* Tracing level */
|
||||
int bSqlTrace; /* True to trace SQL commands */
|
||||
int nError; /* Number of errors */
|
||||
int nTest; /* Number of --match operators */
|
||||
int iTimeout; /* Milliseconds until a busy timeout */
|
||||
} g;
|
||||
|
||||
/* Default timeout */
|
||||
#define DEFAULT_TIMEOUT 10000
|
||||
|
||||
/*
|
||||
** Print a message adding zPrefix[] to the beginning of every line.
|
||||
*/
|
||||
@ -226,7 +231,9 @@ static void fatalError(const char *zFormat, ...){
|
||||
sqlite3_free(zMsg);
|
||||
if( g.db ){
|
||||
int nTry = 0;
|
||||
while( trySql("CREATE TABLE halt(x);")==SQLITE_BUSY && (nTry++)<100 ){
|
||||
g.iTimeout = 0;
|
||||
while( trySql("UPDATE client SET wantHalt=1;")==SQLITE_BUSY
|
||||
&& (nTry++)<100 ){
|
||||
sqlite3_sleep(10);
|
||||
}
|
||||
}
|
||||
@ -262,6 +269,18 @@ static int clipLength(const char *z){
|
||||
return n;
|
||||
}
|
||||
|
||||
/*
|
||||
** Busy handler with a g.iTimeout-millisecond timeout
|
||||
*/
|
||||
static int busyHandler(void *pCD, int count){
|
||||
if( count*10>g.iTimeout ){
|
||||
if( g.iTimeout>0 ) errorMessage("timeout after %dms", g.iTimeout);
|
||||
return 0;
|
||||
}
|
||||
sqlite3_sleep(10);
|
||||
return 1;
|
||||
}
|
||||
|
||||
/*
|
||||
** SQL Trace callback
|
||||
*/
|
||||
@ -408,6 +427,7 @@ static int evalSql(String *p, const char *zFormat, ...){
|
||||
va_start(ap, zFormat);
|
||||
zSql = sqlite3_vmprintf(zFormat, ap);
|
||||
va_end(ap);
|
||||
assert( g.iTimeout>0 );
|
||||
rc = sqlite3_exec(g.db, zSql, evalCallback, p, &zErrMsg);
|
||||
sqlite3_free(zSql);
|
||||
if( rc ){
|
||||
@ -435,21 +455,34 @@ static int startScript(
|
||||
sqlite3_stmt *pStmt = 0;
|
||||
int taskId;
|
||||
int rc;
|
||||
int totalTime = 0;
|
||||
|
||||
*pzScript = 0;
|
||||
g.iTimeout = 0;
|
||||
while(1){
|
||||
if( trySql("SELECT * FROM halt")==SQLITE_OK ) return SQLITE_DONE;
|
||||
rc = trySql("BEGIN IMMEDIATE");
|
||||
if( rc==SQLITE_BUSY ){
|
||||
sqlite3_sleep(10);
|
||||
totalTime += 10;
|
||||
continue;
|
||||
}
|
||||
if( rc!=SQLITE_OK ){
|
||||
fatalError("%s\nBEGIN IMMEDIATE", sqlite3_errmsg(g.db));
|
||||
}
|
||||
if( g.nError ){
|
||||
runSql("UPDATE clienterror SET cnt=cnt+%d", g.nError);
|
||||
if( g.nError || g.nTest ){
|
||||
runSql("UPDATE counters SET nError=nError+%d, nTest=nTest+%d",
|
||||
g.nError, g.nTest);
|
||||
g.nError = 0;
|
||||
g.nTest = 0;
|
||||
}
|
||||
pStmt = prepareSql("SELECT 1 FROM client WHERE id=%d AND wantHalt",iClient);
|
||||
rc = sqlite3_step(pStmt);
|
||||
sqlite3_finalize(pStmt);
|
||||
if( rc==SQLITE_ROW ){
|
||||
runSql("DELETE FROM client WHERE id=%d", iClient);
|
||||
runSql("COMMIT");
|
||||
g.iTimeout = DEFAULT_TIMEOUT;
|
||||
return SQLITE_DONE;
|
||||
}
|
||||
pStmt = prepareSql(
|
||||
"SELECT script, id FROM task"
|
||||
@ -466,37 +499,58 @@ static int startScript(
|
||||
" SET starttime=strftime('%%Y-%%m-%%d %%H:%%M:%%f','now')"
|
||||
" WHERE id=%d;", taskId);
|
||||
runSql("COMMIT;");
|
||||
g.iTimeout = DEFAULT_TIMEOUT;
|
||||
return SQLITE_OK;
|
||||
}
|
||||
sqlite3_finalize(pStmt);
|
||||
if( rc==SQLITE_DONE ){
|
||||
if( totalTime>30000 ){
|
||||
errorMessage("Waited over 30 seconds with no work. Giving up.");
|
||||
runSql("DELETE FROM client WHERE id=%d; COMMIT;", iClient);
|
||||
sqlite3_close(g.db);
|
||||
exit(1);
|
||||
}
|
||||
runSql("COMMIT;");
|
||||
sqlite3_sleep(100);
|
||||
totalTime += 100;
|
||||
continue;
|
||||
}
|
||||
fatalError("%s", sqlite3_errmsg(g.db));
|
||||
}
|
||||
g.iTimeout = DEFAULT_TIMEOUT;
|
||||
}
|
||||
|
||||
/*
|
||||
** Mark a script as having finished.
|
||||
** Mark a script as having finished. Remove the CLIENT table entry
|
||||
** if bShutdown is true.
|
||||
*/
|
||||
static int finishScript(int taskId){
|
||||
sqlite3_stmt *pStmt;
|
||||
int rc;
|
||||
pStmt = prepareSql(
|
||||
"UPDATE task"
|
||||
" SET endtime=strftime('%%Y-%%m-%%d %%H:%%M:%%f','now')"
|
||||
" WHERE id=%d;", taskId);
|
||||
do{
|
||||
rc = sqlite3_step(pStmt);
|
||||
sqlite3_reset(pStmt);
|
||||
}while( rc==SQLITE_BUSY );
|
||||
sqlite3_finalize(pStmt);
|
||||
if( rc!=SQLITE_DONE ){
|
||||
fatalError("%s\n", sqlite3_errmsg(g.db));
|
||||
static int finishScript(int iClient, int taskId, int bShutdown){
|
||||
runSql("UPDATE task"
|
||||
" SET endtime=strftime('%%Y-%%m-%%d %%H:%%M:%%f','now')"
|
||||
" WHERE id=%d;", taskId);
|
||||
if( bShutdown ){
|
||||
runSql("DELETE FROM client WHERE id=%d", iClient);
|
||||
}
|
||||
return SQLITE_OK;
|
||||
}
|
||||
|
||||
/*
|
||||
** Start up a client process for iClient, if it is not already
|
||||
** running. If the client is already running, then this routine
|
||||
** is a no-op.
|
||||
*/
|
||||
static void startClient(int iClient){
|
||||
runSql("INSERT OR IGNORE INTO client VALUES(%d,0)", iClient);
|
||||
if( sqlite3_changes(g.db) ){
|
||||
char *zSys;
|
||||
zSys = sqlite3_mprintf(
|
||||
"%s \"%s\" --client %d --trace %d %s&",
|
||||
g.argv0, g.zDbFile, iClient, g.iTrace,
|
||||
g.bSqlTrace ? "--sqltrace " : "");
|
||||
|
||||
system(zSys);
|
||||
sqlite3_free(zSys);
|
||||
}
|
||||
return rc;
|
||||
}
|
||||
|
||||
/*
|
||||
@ -597,13 +651,18 @@ static void waitForClient(int iClient, int iTimeout, char *zErrPrefix){
|
||||
int rc;
|
||||
if( iClient>0 ){
|
||||
pStmt = prepareSql(
|
||||
"SELECT 1 FROM task WHERE client=%d AND endtime IS NULL",
|
||||
"SELECT 1 FROM task"
|
||||
" WHERE client=%d"
|
||||
" AND client IN (SELECT id FROM client)"
|
||||
" AND endtime IS NULL",
|
||||
iClient);
|
||||
}else{
|
||||
pStmt = prepareSql(
|
||||
"SELECT 1 FROM task WHERE client=%d AND endtime IS NULL",
|
||||
iClient);
|
||||
"SELECT 1 FROM task"
|
||||
" WHERE client IN (SELECT id FROM client)"
|
||||
" AND endtime IS NULL");
|
||||
}
|
||||
g.iTimeout = 0;
|
||||
while( ((rc = sqlite3_step(pStmt))==SQLITE_BUSY || rc==SQLITE_ROW)
|
||||
&& iTimeout>0
|
||||
){
|
||||
@ -612,6 +671,7 @@ static void waitForClient(int iClient, int iTimeout, char *zErrPrefix){
|
||||
iTimeout -= 50;
|
||||
}
|
||||
sqlite3_finalize(pStmt);
|
||||
g.iTimeout = DEFAULT_TIMEOUT;
|
||||
if( rc!=SQLITE_DONE ){
|
||||
if( zErrPrefix==0 ) zErrPrefix = "";
|
||||
if( iClient>0 ){
|
||||
@ -639,16 +699,13 @@ static void runScript(
|
||||
int ii = 0;
|
||||
int iBegin = 0;
|
||||
int n, c, j;
|
||||
int rc;
|
||||
int len;
|
||||
int nArg;
|
||||
String sResult;
|
||||
char zCmd[30];
|
||||
char zError[1000];
|
||||
char azArg[MX_ARG][100];
|
||||
unsigned char isRunning[100];
|
||||
|
||||
memset(isRunning, 0, sizeof(isRunning));
|
||||
memset(&sResult, 0, sizeof(sResult));
|
||||
stringReset(&sResult);
|
||||
while( (c = zScript[ii])!=0 ){
|
||||
@ -699,7 +756,7 @@ static void runScript(
|
||||
*/
|
||||
if( strcmp(zCmd, "exit")==0 ){
|
||||
int rc = atoi(azArg[0]);
|
||||
finishScript(taskId);
|
||||
finishScript(iClient, taskId, 1);
|
||||
if( rc==0 ) sqlite3_close(g.db);
|
||||
exit(rc);
|
||||
}else
|
||||
@ -727,6 +784,7 @@ static void runScript(
|
||||
errorMessage("line %d of %s:\nExpected [%.*s]\n Got [%s]",
|
||||
prevLine, zFilename, len-jj-1, zAns, sResult.z);
|
||||
}
|
||||
g.nTest++;
|
||||
stringReset(&sResult);
|
||||
}else
|
||||
|
||||
@ -736,7 +794,7 @@ static void runScript(
|
||||
** Run a subscript from a separate file.
|
||||
*/
|
||||
if( strcmp(zCmd, "source")==0 ){
|
||||
char *zNewFile = azArg[1];
|
||||
char *zNewFile = azArg[0];
|
||||
char *zNewScript = readFile(zNewFile);
|
||||
if( g.iTrace ) logMessage("begin script [%s]\n", zNewFile);
|
||||
runScript(0, 0, zNewScript, zNewFile);
|
||||
@ -762,26 +820,9 @@ static void runScript(
|
||||
*/
|
||||
if( strcmp(zCmd, "start")==0 ){
|
||||
int iNewClient = atoi(azArg[0]);
|
||||
char *zSys;
|
||||
if( iNewClient<1 || iNewClient>=sizeof(isRunning) ){
|
||||
errorMessage("line %d of %s: bad client number: %d",
|
||||
prevLine, zFilename, iNewClient);
|
||||
goto start_error;
|
||||
if( iNewClient>0 ){
|
||||
startClient(iNewClient);
|
||||
}
|
||||
if( isRunning[iNewClient] ){
|
||||
errorMessage("line %d of %s: client already running: %d",
|
||||
prevLine, zFilename, iNewClient);
|
||||
goto start_error;
|
||||
}
|
||||
zSys = sqlite3_mprintf(
|
||||
"%s \"%s\" --client %d --trace %d %s&",
|
||||
g.argv0, g.zDbFile, iNewClient, g.iTrace,
|
||||
g.bSqlTrace ? "--sqltrace " : "");
|
||||
|
||||
system(zSys);
|
||||
sqlite3_free(zSys);
|
||||
isRunning[iNewClient] = 1;
|
||||
start_error: {/* no-op */}
|
||||
}else
|
||||
|
||||
/*
|
||||
@ -803,30 +844,24 @@ static void runScript(
|
||||
** <task-content-here>
|
||||
** --end
|
||||
**
|
||||
** Assign work to a client.
|
||||
** Assign work to a client. Start the client if it is not running
|
||||
** already.
|
||||
*/
|
||||
if( strcmp(zCmd, "task")==0 ){
|
||||
int iTarget = atoi(azArg[0]);
|
||||
int iEnd;
|
||||
char *zTask;
|
||||
sqlite3_stmt *pStmt;
|
||||
iEnd = findEnd(zScript+ii+len, &lineno);
|
||||
if( iTarget<0 || iTarget>=sizeof(isRunning)
|
||||
|| !isRunning[iTarget] ){
|
||||
errorMessage("line %d of %s: client %d is not running",
|
||||
if( iTarget<0 ){
|
||||
errorMessage("line %d of %s: bad client number: %d",
|
||||
prevLine, zFilename, iTarget);
|
||||
goto task_error;
|
||||
}else{
|
||||
zTask = sqlite3_mprintf("%.*s", iEnd, zScript+ii+len);
|
||||
startClient(iTarget);
|
||||
runSql("INSERT INTO task(client,script)"
|
||||
" VALUES(%d,'%q')", iTarget, zTask);
|
||||
sqlite3_free(zTask);
|
||||
}
|
||||
zTask = sqlite3_mprintf("%.*s", iEnd, zScript+ii+len);
|
||||
pStmt = prepareSql("INSERT INTO task(client,script)"
|
||||
" VALUES(%d,'%q')", iTarget, zTask);
|
||||
sqlite3_free(zTask);
|
||||
while( (rc = sqlite3_step(pStmt))==SQLITE_BUSY ){
|
||||
sqlite3_reset(pStmt);
|
||||
sqlite3_sleep(10);
|
||||
}
|
||||
sqlite3_finalize(pStmt);
|
||||
task_error:
|
||||
iEnd += tokenLength(zScript+ii+len+iEnd, &lineno);
|
||||
len += iEnd;
|
||||
iBegin = ii+len;
|
||||
@ -964,6 +999,8 @@ int main(int argc, char **argv){
|
||||
}
|
||||
rc = sqlite3_open_v2(g.zDbFile, &g.db, openFlags, g.zVfs);
|
||||
if( rc ) fatalError("cannot open [%s]", g.zDbFile);
|
||||
sqlite3_busy_handler(g.db, busyHandler, 0);
|
||||
g.iTimeout = DEFAULT_TIMEOUT;
|
||||
if( g.bSqlTrace ) sqlite3_trace(g.db, sqlTraceCallback, 0);
|
||||
if( iClient>0 ){
|
||||
if( n>0 ) unrecognizedArguments(argv[0], n, argv+2);
|
||||
@ -977,12 +1014,13 @@ int main(int argc, char **argv){
|
||||
iClient, taskId);
|
||||
runScript(iClient, taskId, zScript, zTaskName);
|
||||
if( g.iTrace ) logMessage("end task %d", taskId);
|
||||
finishScript(taskId);
|
||||
finishScript(iClient, taskId, 0);
|
||||
sqlite3_sleep(10);
|
||||
}
|
||||
if( g.iTrace ) logMessage("end-client");
|
||||
}else{
|
||||
sqlite3_stmt *pStmt;
|
||||
int iTimeout;
|
||||
if( n==0 ){
|
||||
fatalError("missing script filename");
|
||||
}
|
||||
@ -995,8 +1033,11 @@ int main(int argc, char **argv){
|
||||
" endtime DATE,\n"
|
||||
" script TEXT\n"
|
||||
");"
|
||||
"CREATE TABLE clienterror(cnt);\n"
|
||||
"INSERT INTO clienterror VALUES(0);\n"
|
||||
"CREATE INDEX task_i1 ON task(client, starttime);\n"
|
||||
"CREATE INDEX task_i2 ON task(client, endtime);\n"
|
||||
"CREATE TABLE counters(nError,nTest);\n"
|
||||
"INSERT INTO counters VALUES(0,0);\n"
|
||||
"CREATE TABLE client(id INTEGER PRIMARY KEY, wantHalt);\n"
|
||||
);
|
||||
zScript = readFile(argv[2]);
|
||||
if( g.iTrace ) logMessage("begin script [%s]\n", argv[2]);
|
||||
@ -1004,16 +1045,25 @@ int main(int argc, char **argv){
|
||||
sqlite3_free(zScript);
|
||||
if( g.iTrace ) logMessage("end script [%s]\n", argv[2]);
|
||||
waitForClient(0, 2000, "during shutdown...\n");
|
||||
while( trySql("CREATE TABLE halt(x);")==SQLITE_BUSY ){
|
||||
trySql("UPDATE client SET wantHalt=1");
|
||||
sqlite3_sleep(10);
|
||||
g.iTimeout = 0;
|
||||
iTimeout = 1000;
|
||||
while( ((rc = trySql("SELECT 1 FROM client"))==SQLITE_BUSY
|
||||
|| rc==SQLITE_ROW) && iTimeout>0 ){
|
||||
sqlite3_sleep(10);
|
||||
iTimeout -= 10;
|
||||
}
|
||||
sqlite3_sleep(100);
|
||||
pStmt = prepareSql("SELECT cnt FROM clienterror");
|
||||
while( (rc = sqlite3_step(pStmt))==SQLITE_BUSY ){
|
||||
pStmt = prepareSql("SELECT nError, nTest FROM counters");
|
||||
iTimeout = 1000;
|
||||
while( (rc = sqlite3_step(pStmt))==SQLITE_BUSY && iTimeout>0 ){
|
||||
sqlite3_sleep(10);
|
||||
iTimeout -= 10;
|
||||
}
|
||||
if( rc==SQLITE_ROW ){
|
||||
g.nError += sqlite3_column_int(pStmt, 0);
|
||||
g.nTest += sqlite3_column_int(pStmt, 1);
|
||||
}
|
||||
sqlite3_finalize(pStmt);
|
||||
}
|
||||
@ -1021,11 +1071,7 @@ int main(int argc, char **argv){
|
||||
maybeClose(g.pLog);
|
||||
maybeClose(g.pErrLog);
|
||||
if( iClient==0 ){
|
||||
if( g.nError ){
|
||||
printf("ERRORS: %d\n", g.nError);
|
||||
}else if( g.iTrace ){
|
||||
printf("All OK\n");
|
||||
}
|
||||
printf("Summary: %d errors in %d tests\n", g.nError, g.nTest);
|
||||
}
|
||||
return g.nError>0;
|
||||
}
|
||||
|
||||
141
mptest/multiwrite01.test
Normal file
141
mptest/multiwrite01.test
Normal file
@ -0,0 +1,141 @@
|
||||
/*
|
||||
** This script sets up five different tasks all writing and updating
|
||||
** the database at the same time, but each in its own table.
|
||||
*/
|
||||
--task 1
|
||||
DROP TABLE IF EXISTS t1;
|
||||
CREATE TABLE t1(a INTEGER PRIMARY KEY, b);
|
||||
--sleep 1
|
||||
INSERT INTO t1 VALUES(1, randomblob(2000));
|
||||
INSERT INTO t1 VALUES(2, randomblob(1000));
|
||||
--sleep 1
|
||||
INSERT INTO t1 SELECT a+2, randomblob(1500) FROM t1;
|
||||
INSERT INTO t1 SELECT a+4, randomblob(1500) FROM t1;
|
||||
INSERT INTO t1 SELECT a+8, randomblob(1500) FROM t1;
|
||||
--sleep 1
|
||||
INSERT INTO t1 SELECT a+16, randomblob(1500) FROM t1;
|
||||
--sleep 1
|
||||
INSERT INTO t1 SELECT a+32, randomblob(1500) FROM t1;
|
||||
SELECT count(*) FROM t1;
|
||||
--match 64
|
||||
SELECT avg(length(b)) FROM t1;
|
||||
--match 1500.0
|
||||
--sleep 2
|
||||
UPDATE t1 SET b='x'||a||'y';
|
||||
SELECT total(length(b)) FROM t1;
|
||||
--match 247
|
||||
--end
|
||||
|
||||
|
||||
--task 2
|
||||
DROP TABLE IF EXISTS t2;
|
||||
CREATE TABLE t2(a INTEGER PRIMARY KEY, b);
|
||||
--sleep 1
|
||||
INSERT INTO t2 VALUES(1, randomblob(2000));
|
||||
INSERT INTO t2 VALUES(2, randomblob(1000));
|
||||
--sleep 1
|
||||
INSERT INTO t2 SELECT a+2, randomblob(1500) FROM t2;
|
||||
INSERT INTO t2 SELECT a+4, randomblob(1500) FROM t2;
|
||||
INSERT INTO t2 SELECT a+8, randomblob(1500) FROM t2;
|
||||
--sleep 1
|
||||
INSERT INTO t2 SELECT a+16, randomblob(1500) FROM t2;
|
||||
--sleep 1
|
||||
INSERT INTO t2 SELECT a+32, randomblob(1500) FROM t2;
|
||||
SELECT count(*) FROM t2;
|
||||
--match 64
|
||||
SELECT avg(length(b)) FROM t2;
|
||||
--match 1500.0
|
||||
--sleep 2
|
||||
UPDATE t2 SET b='x'||a||'y';
|
||||
SELECT total(length(b)) FROM t2;
|
||||
--match 247
|
||||
--end
|
||||
|
||||
--task 3
|
||||
DROP TABLE IF EXISTS t3;
|
||||
CREATE TABLE t3(a INTEGER PRIMARY KEY, b);
|
||||
--sleep 1
|
||||
INSERT INTO t3 VALUES(1, randomblob(2000));
|
||||
INSERT INTO t3 VALUES(2, randomblob(1000));
|
||||
--sleep 1
|
||||
INSERT INTO t3 SELECT a+2, randomblob(1500) FROM t3;
|
||||
INSERT INTO t3 SELECT a+4, randomblob(1500) FROM t3;
|
||||
INSERT INTO t3 SELECT a+8, randomblob(1500) FROM t3;
|
||||
--sleep 1
|
||||
INSERT INTO t3 SELECT a+16, randomblob(1500) FROM t3;
|
||||
--sleep 1
|
||||
INSERT INTO t3 SELECT a+32, randomblob(1500) FROM t3;
|
||||
SELECT count(*) FROM t3;
|
||||
--match 64
|
||||
SELECT avg(length(b)) FROM t3;
|
||||
--match 1500.0
|
||||
--sleep 2
|
||||
UPDATE t3 SET b='x'||a||'y';
|
||||
SELECT total(length(b)) FROM t3;
|
||||
--match 247
|
||||
--end
|
||||
|
||||
--task 4
|
||||
DROP TABLE IF EXISTS t4;
|
||||
CREATE TABLE t4(a INTEGER PRIMARY KEY, b);
|
||||
--sleep 1
|
||||
INSERT INTO t4 VALUES(1, randomblob(2000));
|
||||
INSERT INTO t4 VALUES(2, randomblob(1000));
|
||||
--sleep 1
|
||||
INSERT INTO t4 SELECT a+2, randomblob(1500) FROM t4;
|
||||
INSERT INTO t4 SELECT a+4, randomblob(1500) FROM t4;
|
||||
INSERT INTO t4 SELECT a+8, randomblob(1500) FROM t4;
|
||||
--sleep 1
|
||||
INSERT INTO t4 SELECT a+16, randomblob(1500) FROM t4;
|
||||
--sleep 1
|
||||
INSERT INTO t4 SELECT a+32, randomblob(1500) FROM t4;
|
||||
SELECT count(*) FROM t4;
|
||||
--match 64
|
||||
SELECT avg(length(b)) FROM t4;
|
||||
--match 1500.0
|
||||
--sleep 2
|
||||
UPDATE t4 SET b='x'||a||'y';
|
||||
SELECT total(length(b)) FROM t4;
|
||||
--match 247
|
||||
--end
|
||||
|
||||
--task 5
|
||||
DROP TABLE IF EXISTS t5;
|
||||
CREATE TABLE t5(a INTEGER PRIMARY KEY, b);
|
||||
--sleep 1
|
||||
INSERT INTO t5 VALUES(1, randomblob(2000));
|
||||
INSERT INTO t5 VALUES(2, randomblob(1000));
|
||||
--sleep 1
|
||||
INSERT INTO t5 SELECT a+2, randomblob(1500) FROM t5;
|
||||
INSERT INTO t5 SELECT a+4, randomblob(1500) FROM t5;
|
||||
INSERT INTO t5 SELECT a+8, randomblob(1500) FROM t5;
|
||||
--sleep 1
|
||||
INSERT INTO t5 SELECT a+16, randomblob(1500) FROM t5;
|
||||
--sleep 1
|
||||
INSERT INTO t5 SELECT a+32, randomblob(1500) FROM t5;
|
||||
SELECT count(*) FROM t5;
|
||||
--match 64
|
||||
SELECT avg(length(b)) FROM t5;
|
||||
--match 1500.0
|
||||
--sleep 2
|
||||
UPDATE t5 SET b='x'||a||'y';
|
||||
SELECT total(length(b)) FROM t5;
|
||||
--match 247
|
||||
--end
|
||||
|
||||
--wait all
|
||||
SELECT count(*), total(length(b)) FROM t1;
|
||||
--match 64 247
|
||||
SELECT count(*), total(length(b)) FROM t2;
|
||||
--match 64 247
|
||||
SELECT count(*), total(length(b)) FROM t3;
|
||||
--match 64 247
|
||||
SELECT count(*), total(length(b)) FROM t4;
|
||||
--match 64 247
|
||||
SELECT count(*), total(length(b)) FROM t5;
|
||||
--match 64 247
|
||||
DROP TABLE t1;
|
||||
DROP TABLE t2;
|
||||
DROP TABLE t3;
|
||||
DROP TABLE t4;
|
||||
DROP TABLE t5;
|
||||
Loading…
Reference in New Issue
Block a user