0000: 2f 2a 0a 2a 2a 20 32 30 31 34 20 44 65 63 65 6d /*.** 2014 Decem
0010: 62 65 72 20 39 0a 2a 2a 0a 2a 2a 20 54 68 65 20 ber 9.**.** The
0020: 61 75 74 68 6f 72 20 64 69 73 63 6c 61 69 6d 73 author disclaims
0030: 20 63 6f 70 79 72 69 67 68 74 20 74 6f 20 74 68 copyright to th
0040: 69 73 20 73 6f 75 72 63 65 20 63 6f 64 65 2e 20 is source code.
0050: 20 49 6e 20 70 6c 61 63 65 20 6f 66 0a 2a 2a 20 In place of.**
0060: 61 20 6c 65 67 61 6c 20 6e 6f 74 69 63 65 2c 20 a legal notice,
0070: 68 65 72 65 20 69 73 20 61 20 62 6c 65 73 73 69 here is a blessi
0080: 6e 67 3a 0a 2a 2a 0a 2a 2a 20 20 20 20 4d 61 79 ng:.**.** May
0090: 20 79 6f 75 20 64 6f 20 67 6f 6f 64 20 61 6e 64 you do good and
00a0: 20 6e 6f 74 20 65 76 69 6c 2e 0a 2a 2a 20 20 20 not evil..**
00b0: 20 4d 61 79 20 79 6f 75 20 66 69 6e 64 20 66 6f May you find fo
00c0: 72 67 69 76 65 6e 65 73 73 20 66 6f 72 20 79 6f rgiveness for yo
00d0: 75 72 73 65 6c 66 20 61 6e 64 20 66 6f 72 67 69 urself and forgi
00e0: 76 65 20 6f 74 68 65 72 73 2e 0a 2a 2a 20 20 20 ve others..**
00f0: 20 4d 61 79 20 79 6f 75 20 73 68 61 72 65 20 66 May you share f
0100: 72 65 65 6c 79 2c 20 6e 65 76 65 72 20 74 61 6b reely, never tak
0110: 69 6e 67 20 6d 6f 72 65 20 74 68 61 6e 20 79 6f ing more than yo
0120: 75 20 67 69 76 65 2e 0a 2a 2a 0a 2a 2a 2a 2a 2a u give..**.*****
0130: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
0140: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
0150: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
0160: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
0170: 2a 2a 2a 2a 0a 2a 2a 0a 2a 2a 0a 2a 2f 0a 0a 0a ****.**.**.*/...
0180: 2f 2a 0a 2a 2a 20 54 68 72 65 61 64 20 31 2e 20 /*.** Thread 1.
0190: 43 52 45 41 54 45 20 61 6e 64 20 44 52 4f 50 20 CREATE and DROP
01a0: 61 20 74 61 62 6c 65 2e 0a 2a 2f 0a 73 74 61 74 a table..*/.stat
01b0: 69 63 20 63 68 61 72 20 2a 73 74 72 65 73 73 5f ic char *stress_
01c0: 74 68 72 65 61 64 5f 31 28 69 6e 74 20 69 54 69 thread_1(int iTi
01d0: 64 2c 20 76 6f 69 64 20 2a 70 41 72 67 29 7b 0a d, void *pArg){.
01e0: 20 20 45 72 72 6f 72 20 65 72 72 20 3d 20 7b 30 Error err = {0
01f0: 7d 3b 20 20 20 20 20 20 20 20 20 20 20 20 20 20 };
0200: 20 20 2f 2a 20 45 72 72 6f 72 20 63 6f 64 65 20 /* Error code
0210: 61 6e 64 20 6d 65 73 73 61 67 65 20 2a 2f 0a 20 and message */.
0220: 20 53 71 6c 69 74 65 20 64 62 20 3d 20 7b 30 7d Sqlite db = {0}
0230: 3b 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 ;
0240: 20 2f 2a 20 53 51 4c 69 74 65 20 64 61 74 61 62 /* SQLite datab
0250: 61 73 65 20 63 6f 6e 6e 65 63 74 69 6f 6e 20 2a ase connection *
0260: 2f 0a 0a 20 20 6f 70 65 6e 64 62 28 26 65 72 72 /.. opendb(&err
0270: 2c 20 26 64 62 2c 20 22 74 65 73 74 2e 64 62 22 , &db, "test.db"
0280: 2c 20 30 2c 20 30 29 3b 0a 20 20 77 68 69 6c 65 , 0, 0);. while
0290: 28 20 21 74 69 6d 65 74 6f 73 74 6f 70 28 26 65 ( !timetostop(&e
02a0: 72 72 29 20 29 7b 0a 20 20 20 20 73 71 6c 5f 73 rr) ){. sql_s
02b0: 63 72 69 70 74 28 26 65 72 72 2c 20 26 64 62 2c cript(&err, &db,
02c0: 20 22 43 52 45 41 54 45 20 54 41 42 4c 45 20 49 "CREATE TABLE I
02d0: 46 20 4e 4f 54 20 45 58 49 53 54 53 20 74 31 28 F NOT EXISTS t1(
02e0: 61 20 50 52 49 4d 41 52 59 20 4b 45 59 2c 20 62 a PRIMARY KEY, b
02f0: 29 22 29 3b 0a 20 20 20 20 63 6c 65 61 72 5f 65 )");. clear_e
0300: 72 72 6f 72 28 26 65 72 72 2c 20 53 51 4c 49 54 rror(&err, SQLIT
0310: 45 5f 4c 4f 43 4b 45 44 29 3b 0a 20 20 20 20 73 E_LOCKED);. s
0320: 71 6c 5f 73 63 72 69 70 74 28 26 65 72 72 2c 20 ql_script(&err,
0330: 26 64 62 2c 20 22 44 52 4f 50 20 54 41 42 4c 45 &db, "DROP TABLE
0340: 20 49 46 20 45 58 49 53 54 53 20 74 31 22 29 3b IF EXISTS t1");
0350: 0a 20 20 20 20 63 6c 65 61 72 5f 65 72 72 6f 72 . clear_error
0360: 28 26 65 72 72 2c 20 53 51 4c 49 54 45 5f 4c 4f (&err, SQLITE_LO
0370: 43 4b 45 44 29 3b 0a 20 20 7d 0a 20 20 63 6c 6f CKED);. }. clo
0380: 73 65 64 62 28 26 65 72 72 2c 20 26 64 62 29 3b sedb(&err, &db);
0390: 0a 20 20 70 72 69 6e 74 5f 61 6e 64 5f 66 72 65 . print_and_fre
03a0: 65 5f 65 72 72 28 26 65 72 72 29 3b 0a 20 20 72 e_err(&err);. r
03b0: 65 74 75 72 6e 20 73 71 6c 69 74 65 33 5f 6d 70 eturn sqlite3_mp
03c0: 72 69 6e 74 66 28 22 6f 6b 22 29 3b 0a 7d 0a 0a rintf("ok");.}..
03d0: 2f 2a 0a 2a 2a 20 54 68 72 65 61 64 20 32 2e 20 /*.** Thread 2.
03e0: 4f 70 65 6e 20 61 6e 64 20 63 6c 6f 73 65 20 64 Open and close d
03f0: 61 74 61 62 61 73 65 20 63 6f 6e 6e 65 63 74 69 atabase connecti
0400: 6f 6e 73 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 63 ons..*/.static c
0410: 68 61 72 20 2a 73 74 72 65 73 73 5f 74 68 72 65 har *stress_thre
0420: 61 64 5f 32 28 69 6e 74 20 69 54 69 64 2c 20 76 ad_2(int iTid, v
0430: 6f 69 64 20 2a 70 41 72 67 29 7b 0a 20 20 45 72 oid *pArg){. Er
0440: 72 6f 72 20 65 72 72 20 3d 20 7b 30 7d 3b 20 20 ror err = {0};
0450: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a /*
0460: 20 45 72 72 6f 72 20 63 6f 64 65 20 61 6e 64 20 Error code and
0470: 6d 65 73 73 61 67 65 20 2a 2f 0a 20 20 53 71 6c message */. Sql
0480: 69 74 65 20 64 62 20 3d 20 7b 30 7d 3b 20 20 20 ite db = {0};
0490: 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 /*
04a0: 53 51 4c 69 74 65 20 64 61 74 61 62 61 73 65 20 SQLite database
04b0: 63 6f 6e 6e 65 63 74 69 6f 6e 20 2a 2f 0a 20 20 connection */.
04c0: 77 68 69 6c 65 28 20 21 74 69 6d 65 74 6f 73 74 while( !timetost
04d0: 6f 70 28 26 65 72 72 29 20 29 7b 0a 20 20 20 20 op(&err) ){.
04e0: 6f 70 65 6e 64 62 28 26 65 72 72 2c 20 26 64 62 opendb(&err, &db
04f0: 2c 20 22 74 65 73 74 2e 64 62 22 2c 20 30 2c 20 , "test.db", 0,
0500: 30 29 3b 0a 20 20 20 20 73 71 6c 5f 73 63 72 69 0);. sql_scri
0510: 70 74 28 26 65 72 72 2c 20 26 64 62 2c 20 22 53 pt(&err, &db, "S
0520: 45 4c 45 43 54 20 2a 20 46 52 4f 4d 20 73 71 6c ELECT * FROM sql
0530: 69 74 65 5f 6d 61 73 74 65 72 3b 22 29 3b 0a 20 ite_master;");.
0540: 20 20 20 63 6c 65 61 72 5f 65 72 72 6f 72 28 26 clear_error(&
0550: 65 72 72 2c 20 53 51 4c 49 54 45 5f 4c 4f 43 4b err, SQLITE_LOCK
0560: 45 44 29 3b 0a 20 20 20 20 63 6c 6f 73 65 64 62 ED);. closedb
0570: 28 26 65 72 72 2c 20 26 64 62 29 3b 0a 20 20 7d (&err, &db);. }
0580: 0a 20 20 70 72 69 6e 74 5f 61 6e 64 5f 66 72 65 . print_and_fre
0590: 65 5f 65 72 72 28 26 65 72 72 29 3b 0a 20 20 72 e_err(&err);. r
05a0: 65 74 75 72 6e 20 73 71 6c 69 74 65 33 5f 6d 70 eturn sqlite3_mp
05b0: 72 69 6e 74 66 28 22 6f 6b 22 29 3b 0a 7d 0a 0a rintf("ok");.}..
05c0: 2f 2a 0a 2a 2a 20 54 68 72 65 61 64 20 33 2e 20 /*.** Thread 3.
05d0: 41 74 74 65 6d 70 74 20 6d 61 6e 79 20 73 6d 61 Attempt many sma
05e0: 6c 6c 20 53 45 4c 45 43 54 20 73 74 61 74 65 6d ll SELECT statem
05f0: 65 6e 74 73 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 ents..*/.static
0600: 63 68 61 72 20 2a 73 74 72 65 73 73 5f 74 68 72 char *stress_thr
0610: 65 61 64 5f 33 28 69 6e 74 20 69 54 69 64 2c 20 ead_3(int iTid,
0620: 76 6f 69 64 20 2a 70 41 72 67 29 7b 0a 20 20 45 void *pArg){. E
0630: 72 72 6f 72 20 65 72 72 20 3d 20 7b 30 7d 3b 20 rror err = {0};
0640: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 2f /
0650: 2a 20 45 72 72 6f 72 20 63 6f 64 65 20 61 6e 64 * Error code and
0660: 20 6d 65 73 73 61 67 65 20 2a 2f 0a 20 20 53 71 message */. Sq
0670: 6c 69 74 65 20 64 62 20 3d 20 7b 30 7d 3b 20 20 lite db = {0};
0680: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a /*
0690: 20 53 51 4c 69 74 65 20 64 61 74 61 62 61 73 65 SQLite database
06a0: 20 63 6f 6e 6e 65 63 74 69 6f 6e 20 2a 2f 0a 0a connection */..
06b0: 20 20 69 6e 74 20 69 31 20 3d 20 30 3b 0a 20 20 int i1 = 0;.
06c0: 69 6e 74 20 69 32 20 3d 20 30 3b 0a 0a 20 20 6f int i2 = 0;.. o
06d0: 70 65 6e 64 62 28 26 65 72 72 2c 20 26 64 62 2c pendb(&err, &db,
06e0: 20 22 74 65 73 74 2e 64 62 22 2c 20 30 2c 20 30 "test.db", 0, 0
06f0: 29 3b 0a 20 20 77 68 69 6c 65 28 20 21 74 69 6d );. while( !tim
0700: 65 74 6f 73 74 6f 70 28 26 65 72 72 29 20 29 7b etostop(&err) ){
0710: 0a 20 20 20 20 73 71 6c 5f 73 63 72 69 70 74 28 . sql_script(
0720: 26 65 72 72 2c 20 26 64 62 2c 20 22 53 45 4c 45 &err, &db, "SELE
0730: 43 54 20 2a 20 46 52 4f 4d 20 74 31 20 4f 52 44 CT * FROM t1 ORD
0740: 45 52 20 42 59 20 61 3b 22 29 3b 0a 20 20 20 20 ER BY a;");.
0750: 69 31 2b 2b 3b 0a 20 20 20 20 69 66 28 20 65 72 i1++;. if( er
0760: 72 2e 72 63 20 29 20 69 32 2b 2b 3b 0a 20 20 20 r.rc ) i2++;.
0770: 20 63 6c 65 61 72 5f 65 72 72 6f 72 28 26 65 72 clear_error(&er
0780: 72 2c 20 53 51 4c 49 54 45 5f 4c 4f 43 4b 45 44 r, SQLITE_LOCKED
0790: 29 3b 0a 20 20 20 20 63 6c 65 61 72 5f 65 72 72 );. clear_err
07a0: 6f 72 28 26 65 72 72 2c 20 53 51 4c 49 54 45 5f or(&err, SQLITE_
07b0: 45 52 52 4f 52 29 3b 0a 20 20 7d 0a 20 20 63 6c ERROR);. }. cl
07c0: 6f 73 65 64 62 28 26 65 72 72 2c 20 26 64 62 29 osedb(&err, &db)
07d0: 3b 0a 20 20 70 72 69 6e 74 5f 61 6e 64 5f 66 72 ;. print_and_fr
07e0: 65 65 5f 65 72 72 28 26 65 72 72 29 3b 0a 20 20 ee_err(&err);.
07f0: 72 65 74 75 72 6e 20 73 71 6c 69 74 65 33 5f 6d return sqlite3_m
0800: 70 72 69 6e 74 66 28 22 72 65 61 64 20 74 31 20 printf("read t1
0810: 25 64 2f 25 64 20 61 74 74 65 6d 70 74 73 22 2c %d/%d attempts",
0820: 20 69 32 2c 20 69 31 29 3b 0a 7d 0a 0a 2f 2a 0a i2, i1);.}../*.
0830: 2a 2a 20 54 68 72 65 61 64 20 35 2e 20 41 74 74 ** Thread 5. Att
0840: 65 6d 70 74 20 49 4e 53 45 52 54 20 73 74 61 74 empt INSERT stat
0850: 65 6d 65 6e 74 73 2e 0a 2a 2f 0a 73 74 61 74 69 ements..*/.stati
0860: 63 20 63 68 61 72 20 2a 73 74 72 65 73 73 5f 74 c char *stress_t
0870: 68 72 65 61 64 5f 34 28 69 6e 74 20 69 54 69 64 hread_4(int iTid
0880: 2c 20 76 6f 69 64 20 2a 70 41 72 67 29 7b 0a 20 , void *pArg){.
0890: 20 45 72 72 6f 72 20 65 72 72 20 3d 20 7b 30 7d Error err = {0}
08a0: 3b 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 ;
08b0: 20 2f 2a 20 45 72 72 6f 72 20 63 6f 64 65 20 61 /* Error code a
08c0: 6e 64 20 6d 65 73 73 61 67 65 20 2a 2f 0a 20 20 nd message */.
08d0: 53 71 6c 69 74 65 20 64 62 20 3d 20 7b 30 7d 3b Sqlite db = {0};
08e0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
08f0: 2f 2a 20 53 51 4c 69 74 65 20 64 61 74 61 62 61 /* SQLite databa
0900: 73 65 20 63 6f 6e 6e 65 63 74 69 6f 6e 20 2a 2f se connection */
0910: 0a 20 20 69 6e 74 20 69 31 20 3d 20 30 3b 0a 20 . int i1 = 0;.
0920: 20 69 6e 74 20 69 32 20 3d 20 30 3b 0a 20 20 69 int i2 = 0;. i
0930: 6e 74 20 69 41 72 67 20 3d 20 50 54 52 32 49 4e nt iArg = PTR2IN
0940: 54 28 70 41 72 67 29 3b 0a 0a 20 20 6f 70 65 6e T(pArg);.. open
0950: 64 62 28 26 65 72 72 2c 20 26 64 62 2c 20 22 74 db(&err, &db, "t
0960: 65 73 74 2e 64 62 22 2c 20 30 2c 20 30 29 3b 0a est.db", 0, 0);.
0970: 20 20 77 68 69 6c 65 28 20 21 74 69 6d 65 74 6f while( !timeto
0980: 73 74 6f 70 28 26 65 72 72 29 20 29 7b 0a 20 20 stop(&err) ){.
0990: 20 20 69 66 28 20 69 41 72 67 20 29 7b 0a 20 20 if( iArg ){.
09a0: 20 20 20 20 63 6c 6f 73 65 64 62 28 26 65 72 72 closedb(&err
09b0: 2c 20 26 64 62 29 3b 0a 20 20 20 20 20 20 6f 70 , &db);. op
09c0: 65 6e 64 62 28 26 65 72 72 2c 20 26 64 62 2c 20 endb(&err, &db,
09d0: 22 74 65 73 74 2e 64 62 22 2c 20 30 2c 20 30 29 "test.db", 0, 0)
09e0: 3b 0a 20 20 20 20 7d 0a 20 20 20 20 73 71 6c 5f ;. }. sql_
09f0: 73 63 72 69 70 74 28 26 65 72 72 2c 20 26 64 62 script(&err, &db
0a00: 2c 20 0a 20 20 20 20 20 20 20 20 22 57 49 54 48 , . "WITH
0a10: 20 6c 6f 6f 70 28 69 29 20 41 53 20 28 53 45 4c loop(i) AS (SEL
0a20: 45 43 54 20 31 20 55 4e 49 4f 4e 20 41 4c 4c 20 ECT 1 UNION ALL
0a30: 53 45 4c 45 43 54 20 69 2b 31 20 46 52 4f 4d 20 SELECT i+1 FROM
0a40: 6c 6f 6f 70 20 4c 49 4d 49 54 20 32 30 30 29 20 loop LIMIT 200)
0a50: 22 0a 20 20 20 20 20 20 20 20 22 49 4e 53 45 52 ". "INSER
0a60: 54 20 49 4e 54 4f 20 74 31 20 56 41 4c 55 45 53 T INTO t1 VALUES
0a70: 28 72 61 6e 64 6f 6d 62 6c 6f 62 28 36 30 29 2c (randomblob(60),
0a80: 20 72 61 6e 64 6f 6d 62 6c 6f 62 28 36 30 29 29 randomblob(60))
0a90: 3b 22 0a 20 20 20 20 29 3b 0a 20 20 20 20 69 31 ;". );. i1
0aa0: 2b 2b 3b 0a 20 20 20 20 69 66 28 20 65 72 72 2e ++;. if( err.
0ab0: 72 63 20 29 20 69 32 2b 2b 3b 0a 20 20 20 20 63 rc ) i2++;. c
0ac0: 6c 65 61 72 5f 65 72 72 6f 72 28 26 65 72 72 2c lear_error(&err,
0ad0: 20 53 51 4c 49 54 45 5f 4c 4f 43 4b 45 44 29 3b SQLITE_LOCKED);
0ae0: 0a 20 20 20 20 63 6c 65 61 72 5f 65 72 72 6f 72 . clear_error
0af0: 28 26 65 72 72 2c 20 53 51 4c 49 54 45 5f 45 52 (&err, SQLITE_ER
0b00: 52 4f 52 29 3b 0a 20 20 7d 0a 20 20 63 6c 6f 73 ROR);. }. clos
0b10: 65 64 62 28 26 65 72 72 2c 20 26 64 62 29 3b 0a edb(&err, &db);.
0b20: 20 20 70 72 69 6e 74 5f 61 6e 64 5f 66 72 65 65 print_and_free
0b30: 5f 65 72 72 28 26 65 72 72 29 3b 0a 20 20 72 65 _err(&err);. re
0b40: 74 75 72 6e 20 73 71 6c 69 74 65 33 5f 6d 70 72 turn sqlite3_mpr
0b50: 69 6e 74 66 28 22 77 72 6f 74 65 20 74 31 20 25 intf("wrote t1 %
0b60: 64 2f 25 64 20 61 74 74 65 6d 70 74 73 22 2c 20 d/%d attempts",
0b70: 69 32 2c 20 69 31 29 3b 0a 7d 0a 0a 2f 2a 0a 2a i2, i1);.}../*.*
0b80: 2a 20 54 68 72 65 61 64 20 36 2e 20 41 74 74 65 * Thread 6. Atte
0b90: 6d 70 74 20 44 45 4c 45 54 45 20 6f 70 65 72 61 mpt DELETE opera
0ba0: 74 69 6f 6e 73 2e 0a 2a 2f 0a 73 74 61 74 69 63 tions..*/.static
0bb0: 20 63 68 61 72 20 2a 73 74 72 65 73 73 5f 74 68 char *stress_th
0bc0: 72 65 61 64 5f 35 28 69 6e 74 20 69 54 69 64 2c read_5(int iTid,
0bd0: 20 76 6f 69 64 20 2a 70 41 72 67 29 7b 0a 20 20 void *pArg){.
0be0: 45 72 72 6f 72 20 65 72 72 20 3d 20 7b 30 7d 3b Error err = {0};
0bf0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
0c00: 2f 2a 20 45 72 72 6f 72 20 63 6f 64 65 20 61 6e /* Error code an
0c10: 64 20 6d 65 73 73 61 67 65 20 2a 2f 0a 20 20 53 d message */. S
0c20: 71 6c 69 74 65 20 64 62 20 3d 20 7b 30 7d 3b 20 qlite db = {0};
0c30: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 2f /
0c40: 2a 20 53 51 4c 69 74 65 20 64 61 74 61 62 61 73 * SQLite databas
0c50: 65 20 63 6f 6e 6e 65 63 74 69 6f 6e 20 2a 2f 0a e connection */.
0c60: 20 20 69 6e 74 20 69 41 72 67 20 3d 20 50 54 52 int iArg = PTR
0c70: 32 49 4e 54 28 70 41 72 67 29 3b 0a 0a 20 20 69 2INT(pArg);.. i
0c80: 6e 74 20 69 31 20 3d 20 30 3b 0a 20 20 69 6e 74 nt i1 = 0;. int
0c90: 20 69 32 20 3d 20 30 3b 0a 0a 20 20 6f 70 65 6e i2 = 0;.. open
0ca0: 64 62 28 26 65 72 72 2c 20 26 64 62 2c 20 22 74 db(&err, &db, "t
0cb0: 65 73 74 2e 64 62 22 2c 20 30 2c 20 30 29 3b 0a est.db", 0, 0);.
0cc0: 20 20 77 68 69 6c 65 28 20 21 74 69 6d 65 74 6f while( !timeto
0cd0: 73 74 6f 70 28 26 65 72 72 29 20 29 7b 0a 20 20 stop(&err) ){.
0ce0: 20 20 69 36 34 20 69 20 3d 20 28 69 31 20 25 20 i64 i = (i1 %
0cf0: 34 29 3b 0a 20 20 20 20 69 66 28 20 69 41 72 67 4);. if( iArg
0d00: 20 29 7b 0a 20 20 20 20 20 20 63 6c 6f 73 65 64 ){. closed
0d10: 62 28 26 65 72 72 2c 20 26 64 62 29 3b 0a 20 20 b(&err, &db);.
0d20: 20 20 20 20 6f 70 65 6e 64 62 28 26 65 72 72 2c opendb(&err,
0d30: 20 26 64 62 2c 20 22 74 65 73 74 2e 64 62 22 2c &db, "test.db",
0d40: 20 30 2c 20 30 29 3b 0a 20 20 20 20 7d 0a 20 20 0, 0);. }.
0d50: 20 20 65 78 65 63 73 71 6c 28 26 65 72 72 2c 20 execsql(&err,
0d60: 26 64 62 2c 20 22 44 45 4c 45 54 45 20 46 52 4f &db, "DELETE FRO
0d70: 4d 20 74 31 20 57 48 45 52 45 20 28 72 6f 77 69 M t1 WHERE (rowi
0d80: 64 20 25 20 34 29 3d 3d 3a 69 22 2c 20 26 69 29 d % 4)==:i", &i)
0d90: 3b 0a 20 20 20 20 69 31 2b 2b 3b 0a 20 20 20 20 ;. i1++;.
0da0: 69 66 28 20 65 72 72 2e 72 63 20 29 20 69 32 2b if( err.rc ) i2+
0db0: 2b 3b 0a 20 20 20 20 63 6c 65 61 72 5f 65 72 72 +;. clear_err
0dc0: 6f 72 28 26 65 72 72 2c 20 53 51 4c 49 54 45 5f or(&err, SQLITE_
0dd0: 4c 4f 43 4b 45 44 29 3b 0a 20 20 7d 0a 20 20 63 LOCKED);. }. c
0de0: 6c 6f 73 65 64 62 28 26 65 72 72 2c 20 26 64 62 losedb(&err, &db
0df0: 29 3b 0a 20 20 70 72 69 6e 74 5f 61 6e 64 5f 66 );. print_and_f
0e00: 72 65 65 5f 65 72 72 28 26 65 72 72 29 3b 0a 20 ree_err(&err);.
0e10: 20 72 65 74 75 72 6e 20 73 71 6c 69 74 65 33 5f return sqlite3_
0e20: 6d 70 72 69 6e 74 66 28 22 64 65 6c 65 74 65 64 mprintf("deleted
0e30: 20 66 72 6f 6d 20 74 31 20 25 64 2f 25 64 20 61 from t1 %d/%d a
0e40: 74 74 65 6d 70 74 73 22 2c 20 69 32 2c 20 69 31 ttempts", i2, i1
0e50: 29 3b 0a 7d 0a 0a 0a 73 74 61 74 69 63 20 76 6f );.}...static vo
0e60: 69 64 20 73 74 72 65 73 73 31 28 69 6e 74 20 6e id stress1(int n
0e70: 4d 73 29 7b 0a 20 20 45 72 72 6f 72 20 65 72 72 Ms){. Error err
0e80: 20 3d 20 7b 30 7d 3b 0a 20 20 54 68 72 65 61 64 = {0};. Thread
0e90: 73 65 74 20 74 68 72 65 61 64 73 20 3d 20 7b 30 set threads = {0
0ea0: 7d 3b 0a 0a 20 20 73 65 74 73 74 6f 70 74 69 6d };.. setstoptim
0eb0: 65 28 26 65 72 72 2c 20 6e 4d 73 29 3b 0a 20 20 e(&err, nMs);.
0ec0: 73 71 6c 69 74 65 33 5f 65 6e 61 62 6c 65 5f 73 sqlite3_enable_s
0ed0: 68 61 72 65 64 5f 63 61 63 68 65 28 31 29 3b 0a hared_cache(1);.
0ee0: 0a 20 20 6c 61 75 6e 63 68 5f 74 68 72 65 61 64 . launch_thread
0ef0: 28 26 65 72 72 2c 20 26 74 68 72 65 61 64 73 2c (&err, &threads,
0f00: 20 73 74 72 65 73 73 5f 74 68 72 65 61 64 5f 31 stress_thread_1
0f10: 2c 20 30 29 3b 0a 20 20 6c 61 75 6e 63 68 5f 74 , 0);. launch_t
0f20: 68 72 65 61 64 28 26 65 72 72 2c 20 26 74 68 72 hread(&err, &thr
0f30: 65 61 64 73 2c 20 73 74 72 65 73 73 5f 74 68 72 eads, stress_thr
0f40: 65 61 64 5f 31 2c 20 30 29 3b 0a 0a 20 20 6c 61 ead_1, 0);.. la
0f50: 75 6e 63 68 5f 74 68 72 65 61 64 28 26 65 72 72 unch_thread(&err
0f60: 2c 20 26 74 68 72 65 61 64 73 2c 20 73 74 72 65 , &threads, stre
0f70: 73 73 5f 74 68 72 65 61 64 5f 32 2c 20 30 29 3b ss_thread_2, 0);
0f80: 0a 20 20 6c 61 75 6e 63 68 5f 74 68 72 65 61 64 . launch_thread
0f90: 28 26 65 72 72 2c 20 26 74 68 72 65 61 64 73 2c (&err, &threads,
0fa0: 20 73 74 72 65 73 73 5f 74 68 72 65 61 64 5f 32 stress_thread_2
0fb0: 2c 20 30 29 3b 0a 0a 20 20 6c 61 75 6e 63 68 5f , 0);.. launch_
0fc0: 74 68 72 65 61 64 28 26 65 72 72 2c 20 26 74 68 thread(&err, &th
0fd0: 72 65 61 64 73 2c 20 73 74 72 65 73 73 5f 74 68 reads, stress_th
0fe0: 72 65 61 64 5f 33 2c 20 30 29 3b 0a 20 20 6c 61 read_3, 0);. la
0ff0: 75 6e 63 68 5f 74 68 72 65 61 64 28 26 65 72 72 unch_thread(&err
1000: 2c 20 26 74 68 72 65 61 64 73 2c 20 73 74 72 65 , &threads, stre
1010: 73 73 5f 74 68 72 65 61 64 5f 33 2c 20 30 29 3b ss_thread_3, 0);
1020: 0a 0a 20 20 6c 61 75 6e 63 68 5f 74 68 72 65 61 .. launch_threa
1030: 64 28 26 65 72 72 2c 20 26 74 68 72 65 61 64 73 d(&err, &threads
1040: 2c 20 73 74 72 65 73 73 5f 74 68 72 65 61 64 5f , stress_thread_
1050: 34 2c 20 30 29 3b 0a 20 20 6c 61 75 6e 63 68 5f 4, 0);. launch_
1060: 74 68 72 65 61 64 28 26 65 72 72 2c 20 26 74 68 thread(&err, &th
1070: 72 65 61 64 73 2c 20 73 74 72 65 73 73 5f 74 68 reads, stress_th
1080: 72 65 61 64 5f 34 2c 20 30 29 3b 0a 0a 20 20 6c read_4, 0);.. l
1090: 61 75 6e 63 68 5f 74 68 72 65 61 64 28 26 65 72 aunch_thread(&er
10a0: 72 2c 20 26 74 68 72 65 61 64 73 2c 20 73 74 72 r, &threads, str
10b0: 65 73 73 5f 74 68 72 65 61 64 5f 35 2c 20 30 29 ess_thread_5, 0)
10c0: 3b 0a 20 20 6c 61 75 6e 63 68 5f 74 68 72 65 61 ;. launch_threa
10d0: 64 28 26 65 72 72 2c 20 26 74 68 72 65 61 64 73 d(&err, &threads
10e0: 2c 20 73 74 72 65 73 73 5f 74 68 72 65 61 64 5f , stress_thread_
10f0: 35 2c 20 28 76 6f 69 64 2a 29 31 29 3b 0a 0a 20 5, (void*)1);..
1100: 20 6a 6f 69 6e 5f 61 6c 6c 5f 74 68 72 65 61 64 join_all_thread
1110: 73 28 26 65 72 72 2c 20 26 74 68 72 65 61 64 73 s(&err, &threads
1120: 29 3b 0a 20 20 73 71 6c 69 74 65 33 5f 65 6e 61 );. sqlite3_ena
1130: 62 6c 65 5f 73 68 61 72 65 64 5f 63 61 63 68 65 ble_shared_cache
1140: 28 30 29 3b 0a 0a 20 20 70 72 69 6e 74 5f 61 6e (0);.. print_an
1150: 64 5f 66 72 65 65 5f 65 72 72 28 26 65 72 72 29 d_free_err(&err)
1160: 3b 0a 7d 0a 0a 2f 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ;.}../**********
1170: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
1180: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
1190: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
11a0: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
11b0: 0a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a .***************
11c0: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
11d0: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
11e0: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
11f0: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 0a 2a 2a 20 ************.**
1200: 53 74 61 72 74 20 6f 66 20 74 65 73 74 20 63 61 Start of test ca
1210: 73 65 20 22 73 74 72 65 73 73 32 22 0a 2a 2f 0a se "stress2".*/.
1220: 0a 0a 0a 2f 2a 0a 2a 2a 20 31 2e 20 20 43 52 45 .../*.** 1. CRE
1230: 41 54 45 20 54 41 42 4c 45 20 73 74 61 74 65 6d ATE TABLE statem
1240: 65 6e 74 73 2e 0a 2a 2a 20 32 2e 20 20 44 52 4f ents..** 2. DRO
1250: 50 20 54 41 42 4c 45 20 73 74 61 74 65 6d 65 6e P TABLE statemen
1260: 74 73 2e 0a 2a 2a 20 33 2e 20 20 53 6d 61 6c 6c ts..** 3. Small
1270: 20 53 45 4c 45 43 54 20 73 74 61 74 65 6d 65 6e SELECT statemen
1280: 74 73 2e 0a 2a 2a 20 34 2e 20 20 42 69 67 20 53 ts..** 4. Big S
1290: 45 4c 45 43 54 20 73 74 61 74 65 6d 65 6e 74 73 ELECT statements
12a0: 2e 0a 2a 2a 20 35 2e 20 20 53 6d 61 6c 6c 20 49 ..** 5. Small I
12b0: 4e 53 45 52 54 20 73 74 61 74 65 6d 65 6e 74 73 NSERT statements
12c0: 2e 0a 2a 2a 20 36 2e 20 20 42 69 67 20 49 4e 53 ..** 6. Big INS
12d0: 45 52 54 20 73 74 61 74 65 6d 65 6e 74 73 2e 0a ERT statements..
12e0: 2a 2a 20 37 2e 20 20 53 6d 61 6c 6c 20 55 50 44 ** 7. Small UPD
12f0: 41 54 45 20 73 74 61 74 65 6d 65 6e 74 73 2e 0a ATE statements..
1300: 2a 2a 20 38 2e 20 20 42 69 67 20 55 50 44 41 54 ** 8. Big UPDAT
1310: 45 20 73 74 61 74 65 6d 65 6e 74 73 2e 0a 2a 2a E statements..**
1320: 20 39 2e 20 20 53 6d 61 6c 6c 20 44 45 4c 45 54 9. Small DELET
1330: 45 20 73 74 61 74 65 6d 65 6e 74 73 2e 0a 2a 2a E statements..**
1340: 20 31 30 2e 20 42 69 67 20 44 45 4c 45 54 45 20 10. Big DELETE
1350: 73 74 61 74 65 6d 65 6e 74 73 2e 0a 2a 2a 20 31 statements..** 1
1360: 31 2e 20 56 41 43 55 55 4d 2e 0a 2a 2a 20 31 34 1. VACUUM..** 14
1370: 2e 20 49 6e 74 65 67 72 69 74 79 2d 63 68 65 63 . Integrity-chec
1380: 6b 2e 0a 2a 2a 20 31 37 2e 20 53 77 69 74 63 68 k..** 17. Switch
1390: 20 74 68 65 20 6a 6f 75 72 6e 61 6c 20 6d 6f 64 the journal mod
13a0: 65 20 66 72 6f 6d 20 64 65 6c 65 74 65 20 74 6f e from delete to
13b0: 20 77 61 6c 20 61 6e 64 20 62 61 63 6b 20 61 67 wal and back ag
13c0: 61 69 6e 2e 0a 2a 2a 20 31 39 2e 20 4f 70 65 6e ain..** 19. Open
13d0: 20 61 6e 64 20 63 6c 6f 73 65 20 64 61 74 61 62 and close datab
13e0: 61 73 65 20 63 6f 6e 6e 65 63 74 69 6f 6e 73 20 ase connections
13f0: 72 61 70 69 64 6c 79 2e 0a 2a 2f 0a 0a 23 64 65 rapidly..*/..#de
1400: 66 69 6e 65 20 53 54 52 45 53 53 32 5f 54 41 42 fine STRESS2_TAB
1410: 43 4e 54 20 35 20 20 20 20 20 20 20 20 20 20 2f CNT 5 /
1420: 2a 20 63 6f 75 6e 74 31 20 69 6e 20 53 44 53 20 * count1 in SDS
1430: 74 65 73 74 20 2a 2f 0a 0a 23 64 65 66 69 6e 65 test */..#define
1440: 20 53 54 52 45 53 53 32 5f 43 4f 55 4e 54 32 20 STRESS2_COUNT2
1450: 32 30 30 20 20 20 20 20 20 20 20 2f 2a 20 63 6f 200 /* co
1460: 75 6e 74 32 20 69 6e 20 53 44 53 20 74 65 73 74 unt2 in SDS test
1470: 20 2a 2f 0a 23 64 65 66 69 6e 65 20 53 54 52 45 */.#define STRE
1480: 53 53 32 5f 43 4f 55 4e 54 33 20 20 35 37 20 20 SS2_COUNT3 57
1490: 20 20 20 20 20 20 2f 2a 20 63 6f 75 6e 74 32 20 /* count2
14a0: 69 6e 20 53 44 53 20 74 65 73 74 20 2a 2f 0a 0a in SDS test */..
14b0: 73 74 61 74 69 63 20 76 6f 69 64 20 73 74 72 65 static void stre
14c0: 73 73 32 5f 77 6f 72 6b 6c 6f 61 64 31 28 45 72 ss2_workload1(Er
14d0: 72 6f 72 20 2a 70 45 72 72 2c 20 53 71 6c 69 74 ror *pErr, Sqlit
14e0: 65 20 2a 70 44 62 2c 20 69 6e 74 20 69 29 7b 0a e *pDb, int i){.
14f0: 20 20 69 6e 74 20 69 54 61 62 20 3d 20 28 69 20 int iTab = (i
1500: 25 20 28 53 54 52 45 53 53 32 5f 54 41 42 43 4e % (STRESS2_TABCN
1510: 54 2d 31 29 29 20 2b 20 31 3b 0a 20 20 73 71 6c T-1)) + 1;. sql
1520: 5f 73 63 72 69 70 74 5f 70 72 69 6e 74 66 28 70 _script_printf(p
1530: 45 72 72 2c 20 70 44 62 2c 20 0a 20 20 20 20 20 Err, pDb, .
1540: 20 22 43 52 45 41 54 45 20 54 41 42 4c 45 20 49 "CREATE TABLE I
1550: 46 20 4e 4f 54 20 45 58 49 53 54 53 20 74 25 64 F NOT EXISTS t%d
1560: 28 78 20 50 52 49 4d 41 52 59 20 4b 45 59 2c 20 (x PRIMARY KEY,
1570: 79 2c 20 7a 29 3b 22 2c 20 69 54 61 62 0a 20 20 y, z);", iTab.
1580: 29 3b 0a 7d 0a 0a 73 74 61 74 69 63 20 76 6f 69 );.}..static voi
1590: 64 20 73 74 72 65 73 73 32 5f 77 6f 72 6b 6c 6f d stress2_worklo
15a0: 61 64 32 28 45 72 72 6f 72 20 2a 70 45 72 72 2c ad2(Error *pErr,
15b0: 20 53 71 6c 69 74 65 20 2a 70 44 62 2c 20 69 6e Sqlite *pDb, in
15c0: 74 20 69 29 7b 0a 20 20 69 6e 74 20 69 54 61 62 t i){. int iTab
15d0: 20 3d 20 28 69 20 25 20 28 53 54 52 45 53 53 32 = (i % (STRESS2
15e0: 5f 54 41 42 43 4e 54 2d 31 29 29 20 2b 20 31 3b _TABCNT-1)) + 1;
15f0: 0a 20 20 73 71 6c 5f 73 63 72 69 70 74 5f 70 72 . sql_script_pr
1600: 69 6e 74 66 28 70 45 72 72 2c 20 70 44 62 2c 20 intf(pErr, pDb,
1610: 22 44 52 4f 50 20 54 41 42 4c 45 20 49 46 20 45 "DROP TABLE IF E
1620: 58 49 53 54 53 20 74 25 64 3b 22 2c 20 69 54 61 XISTS t%d;", iTa
1630: 62 29 3b 0a 7d 0a 0a 73 74 61 74 69 63 20 76 6f b);.}..static vo
1640: 69 64 20 73 74 72 65 73 73 32 5f 77 6f 72 6b 6c id stress2_workl
1650: 6f 61 64 33 28 45 72 72 6f 72 20 2a 70 45 72 72 oad3(Error *pErr
1660: 2c 20 53 71 6c 69 74 65 20 2a 70 44 62 2c 20 69 , Sqlite *pDb, i
1670: 6e 74 20 69 29 7b 0a 20 20 73 71 6c 5f 73 63 72 nt i){. sql_scr
1680: 69 70 74 28 70 45 72 72 2c 20 70 44 62 2c 20 22 ipt(pErr, pDb, "
1690: 53 45 4c 45 43 54 20 2a 20 46 52 4f 4d 20 74 30 SELECT * FROM t0
16a0: 20 57 48 45 52 45 20 7a 20 3d 20 27 73 6d 61 6c WHERE z = 'smal
16b0: 6c 27 22 29 3b 0a 7d 0a 0a 73 74 61 74 69 63 20 l'");.}..static
16c0: 76 6f 69 64 20 73 74 72 65 73 73 32 5f 77 6f 72 void stress2_wor
16d0: 6b 6c 6f 61 64 34 28 45 72 72 6f 72 20 2a 70 45 kload4(Error *pE
16e0: 72 72 2c 20 53 71 6c 69 74 65 20 2a 70 44 62 2c rr, Sqlite *pDb,
16f0: 20 69 6e 74 20 69 29 7b 0a 20 20 73 71 6c 5f 73 int i){. sql_s
1700: 63 72 69 70 74 28 70 45 72 72 2c 20 70 44 62 2c cript(pErr, pDb,
1710: 20 22 53 45 4c 45 43 54 20 2a 20 46 52 4f 4d 20 "SELECT * FROM
1720: 74 30 20 57 48 45 52 45 20 7a 20 3d 20 27 62 69 t0 WHERE z = 'bi
1730: 67 27 22 29 3b 0a 7d 0a 0a 73 74 61 74 69 63 20 g'");.}..static
1740: 76 6f 69 64 20 73 74 72 65 73 73 32 5f 77 6f 72 void stress2_wor
1750: 6b 6c 6f 61 64 35 28 45 72 72 6f 72 20 2a 70 45 kload5(Error *pE
1760: 72 72 2c 20 53 71 6c 69 74 65 20 2a 70 44 62 2c rr, Sqlite *pDb,
1770: 20 69 6e 74 20 69 29 7b 0a 20 20 73 71 6c 5f 73 int i){. sql_s
1780: 63 72 69 70 74 28 70 45 72 72 2c 20 70 44 62 2c cript(pErr, pDb,
1790: 0a 20 20 20 20 20 20 22 49 4e 53 45 52 54 20 49 . "INSERT I
17a0: 4e 54 4f 20 74 30 20 56 41 4c 55 45 53 28 68 65 NTO t0 VALUES(he
17b0: 78 28 72 61 6e 64 6f 6d 28 29 29 2c 20 68 65 78 x(random()), hex
17c0: 28 72 61 6e 64 6f 6d 62 6c 6f 62 28 32 30 30 29 (randomblob(200)
17d0: 29 2c 20 27 73 6d 61 6c 6c 27 29 3b 22 0a 20 20 ), 'small');".
17e0: 29 3b 0a 7d 0a 0a 73 74 61 74 69 63 20 76 6f 69 );.}..static voi
17f0: 64 20 73 74 72 65 73 73 32 5f 77 6f 72 6b 6c 6f d stress2_worklo
1800: 61 64 36 28 45 72 72 6f 72 20 2a 70 45 72 72 2c ad6(Error *pErr,
1810: 20 53 71 6c 69 74 65 20 2a 70 44 62 2c 20 69 6e Sqlite *pDb, in
1820: 74 20 69 29 7b 0a 20 20 73 71 6c 5f 73 63 72 69 t i){. sql_scri
1830: 70 74 28 70 45 72 72 2c 20 70 44 62 2c 0a 20 20 pt(pErr, pDb,.
1840: 20 20 20 20 22 49 4e 53 45 52 54 20 49 4e 54 4f "INSERT INTO
1850: 20 74 30 20 56 41 4c 55 45 53 28 68 65 78 28 72 t0 VALUES(hex(r
1860: 61 6e 64 6f 6d 28 29 29 2c 20 68 65 78 28 72 61 andom()), hex(ra
1870: 6e 64 6f 6d 62 6c 6f 62 28 35 37 29 29 2c 20 27 ndomblob(57)), '
1880: 62 69 67 27 29 3b 22 0a 20 20 29 3b 0a 7d 0a 0a big');". );.}..
1890: 73 74 61 74 69 63 20 76 6f 69 64 20 73 74 72 65 static void stre
18a0: 73 73 32 5f 77 6f 72 6b 6c 6f 61 64 37 28 45 72 ss2_workload7(Er
18b0: 72 6f 72 20 2a 70 45 72 72 2c 20 53 71 6c 69 74 ror *pErr, Sqlit
18c0: 65 20 2a 70 44 62 2c 20 69 6e 74 20 69 29 7b 0a e *pDb, int i){.
18d0: 20 20 73 71 6c 5f 73 63 72 69 70 74 5f 70 72 69 sql_script_pri
18e0: 6e 74 66 28 70 45 72 72 2c 20 70 44 62 2c 0a 20 ntf(pErr, pDb,.
18f0: 20 20 20 20 20 22 55 50 44 41 54 45 20 74 30 20 "UPDATE t0
1900: 53 45 54 20 79 20 3d 20 68 65 78 28 72 61 6e 64 SET y = hex(rand
1910: 6f 6d 62 6c 6f 62 28 32 30 30 29 29 20 22 0a 20 omblob(200)) ".
1920: 20 20 20 20 20 22 57 48 45 52 45 20 78 20 4c 49 "WHERE x LI
1930: 4b 45 20 68 65 78 28 28 25 64 20 25 25 20 35 29 KE hex((%d %% 5)
1940: 29 20 41 4e 44 20 7a 3d 27 73 6d 61 6c 6c 27 3b ) AND z='small';
1950: 22 0a 20 20 20 20 20 20 2c 69 0a 20 20 29 3b 0a ". ,i. );.
1960: 7d 0a 73 74 61 74 69 63 20 76 6f 69 64 20 73 74 }.static void st
1970: 72 65 73 73 32 5f 77 6f 72 6b 6c 6f 61 64 38 28 ress2_workload8(
1980: 45 72 72 6f 72 20 2a 70 45 72 72 2c 20 53 71 6c Error *pErr, Sql
1990: 69 74 65 20 2a 70 44 62 2c 20 69 6e 74 20 69 29 ite *pDb, int i)
19a0: 7b 0a 20 20 73 71 6c 5f 73 63 72 69 70 74 5f 70 {. sql_script_p
19b0: 72 69 6e 74 66 28 70 45 72 72 2c 20 70 44 62 2c rintf(pErr, pDb,
19c0: 0a 20 20 20 20 20 20 22 55 50 44 41 54 45 20 74 . "UPDATE t
19d0: 30 20 53 45 54 20 79 20 3d 20 68 65 78 28 72 61 0 SET y = hex(ra
19e0: 6e 64 6f 6d 62 6c 6f 62 28 35 37 29 29 20 22 0a ndomblob(57)) ".
19f0: 20 20 20 20 20 20 22 57 48 45 52 45 20 78 20 4c "WHERE x L
1a00: 49 4b 45 20 68 65 78 28 25 64 20 25 25 20 35 29 IKE hex(%d %% 5)
1a10: 20 41 4e 44 20 7a 3d 27 62 69 67 27 3b 22 0a 20 AND z='big';".
1a20: 20 20 20 20 20 2c 69 0a 20 20 29 3b 0a 7d 0a 0a ,i. );.}..
1a30: 73 74 61 74 69 63 20 76 6f 69 64 20 73 74 72 65 static void stre
1a40: 73 73 32 5f 77 6f 72 6b 6c 6f 61 64 39 28 45 72 ss2_workload9(Er
1a50: 72 6f 72 20 2a 70 45 72 72 2c 20 53 71 6c 69 74 ror *pErr, Sqlit
1a60: 65 20 2a 70 44 62 2c 20 69 6e 74 20 69 29 7b 0a e *pDb, int i){.
1a70: 20 20 73 71 6c 5f 73 63 72 69 70 74 5f 70 72 69 sql_script_pri
1a80: 6e 74 66 28 70 45 72 72 2c 20 70 44 62 2c 0a 20 ntf(pErr, pDb,.
1a90: 20 20 20 20 20 22 44 45 4c 45 54 45 20 46 52 4f "DELETE FRO
1aa0: 4d 20 74 30 20 57 48 45 52 45 20 78 20 4c 49 4b M t0 WHERE x LIK
1ab0: 45 20 68 65 78 28 25 64 20 25 25 20 35 29 20 41 E hex(%d %% 5) A
1ac0: 4e 44 20 7a 3d 27 73 6d 61 6c 6c 27 3b 22 2c 20 ND z='small';",
1ad0: 69 0a 20 20 29 3b 0a 7d 0a 73 74 61 74 69 63 20 i. );.}.static
1ae0: 76 6f 69 64 20 73 74 72 65 73 73 32 5f 77 6f 72 void stress2_wor
1af0: 6b 6c 6f 61 64 31 30 28 45 72 72 6f 72 20 2a 70 kload10(Error *p
1b00: 45 72 72 2c 20 53 71 6c 69 74 65 20 2a 70 44 62 Err, Sqlite *pDb
1b10: 2c 20 69 6e 74 20 69 29 7b 0a 20 20 73 71 6c 5f , int i){. sql_
1b20: 73 63 72 69 70 74 5f 70 72 69 6e 74 66 28 70 45 script_printf(pE
1b30: 72 72 2c 20 70 44 62 2c 0a 20 20 20 20 20 20 22 rr, pDb,. "
1b40: 44 45 4c 45 54 45 20 46 52 4f 4d 20 74 30 20 57 DELETE FROM t0 W
1b50: 48 45 52 45 20 78 20 4c 49 4b 45 20 68 65 78 28 HERE x LIKE hex(
1b60: 25 64 20 25 25 20 35 29 20 41 4e 44 20 7a 3d 27 %d %% 5) AND z='
1b70: 62 69 67 27 3b 22 2c 20 69 0a 20 20 29 3b 0a 7d big';", i. );.}
1b80: 0a 0a 73 74 61 74 69 63 20 76 6f 69 64 20 73 74 ..static void st
1b90: 72 65 73 73 32 5f 77 6f 72 6b 6c 6f 61 64 31 31 ress2_workload11
1ba0: 28 45 72 72 6f 72 20 2a 70 45 72 72 2c 20 53 71 (Error *pErr, Sq
1bb0: 6c 69 74 65 20 2a 70 44 62 2c 20 69 6e 74 20 69 lite *pDb, int i
1bc0: 29 7b 0a 20 20 73 71 6c 5f 73 63 72 69 70 74 28 ){. sql_script(
1bd0: 70 45 72 72 2c 20 70 44 62 2c 20 22 56 41 43 55 pErr, pDb, "VACU
1be0: 55 4d 22 29 3b 0a 7d 0a 0a 73 74 61 74 69 63 20 UM");.}..static
1bf0: 76 6f 69 64 20 73 74 72 65 73 73 32 5f 77 6f 72 void stress2_wor
1c00: 6b 6c 6f 61 64 31 34 28 45 72 72 6f 72 20 2a 70 kload14(Error *p
1c10: 45 72 72 2c 20 53 71 6c 69 74 65 20 2a 70 44 62 Err, Sqlite *pDb
1c20: 2c 20 69 6e 74 20 69 29 7b 0a 20 20 73 71 6c 5f , int i){. sql_
1c30: 73 63 72 69 70 74 28 70 45 72 72 2c 20 70 44 62 script(pErr, pDb
1c40: 2c 20 22 50 52 41 47 4d 41 20 69 6e 74 65 67 72 , "PRAGMA integr
1c50: 69 74 79 5f 63 68 65 63 6b 22 29 3b 0a 7d 0a 0a ity_check");.}..
1c60: 73 74 61 74 69 63 20 76 6f 69 64 20 73 74 72 65 static void stre
1c70: 73 73 32 5f 77 6f 72 6b 6c 6f 61 64 31 37 28 45 ss2_workload17(E
1c80: 72 72 6f 72 20 2a 70 45 72 72 2c 20 53 71 6c 69 rror *pErr, Sqli
1c90: 74 65 20 2a 70 44 62 2c 20 69 6e 74 20 69 29 7b te *pDb, int i){
1ca0: 0a 20 20 73 71 6c 5f 73 63 72 69 70 74 5f 70 72 . sql_script_pr
1cb0: 69 6e 74 66 28 70 45 72 72 2c 20 70 44 62 2c 20 intf(pErr, pDb,
1cc0: 0a 20 20 20 20 20 20 22 50 52 41 47 4d 41 20 6a . "PRAGMA j
1cd0: 6f 75 72 6e 61 6c 5f 6d 6f 64 65 20 3d 20 25 71 ournal_mode = %q
1ce0: 22 2c 20 28 69 25 32 29 20 3f 20 22 64 65 6c 65 ", (i%2) ? "dele
1cf0: 74 65 22 20 3a 20 22 77 61 6c 22 0a 20 20 29 3b te" : "wal". );
1d00: 0a 7d 0a 0a 73 74 61 74 69 63 20 63 68 61 72 20 .}..static char
1d10: 2a 73 74 72 65 73 73 32 5f 77 6f 72 6b 6c 6f 61 *stress2_workloa
1d20: 64 31 39 28 69 6e 74 20 69 54 69 64 2c 20 76 6f d19(int iTid, vo
1d30: 69 64 20 2a 70 41 72 67 29 7b 0a 20 20 45 72 72 id *pArg){. Err
1d40: 6f 72 20 65 72 72 20 3d 20 7b 30 7d 3b 20 20 20 or err = {0};
1d50: 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 /*
1d60: 45 72 72 6f 72 20 63 6f 64 65 20 61 6e 64 20 6d Error code and m
1d70: 65 73 73 61 67 65 20 2a 2f 0a 20 20 53 71 6c 69 essage */. Sqli
1d80: 74 65 20 64 62 20 3d 20 7b 30 7d 3b 20 20 20 20 te db = {0};
1d90: 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 53 /* S
1da0: 51 4c 69 74 65 20 64 61 74 61 62 61 73 65 20 63 QLite database c
1db0: 6f 6e 6e 65 63 74 69 6f 6e 20 2a 2f 0a 20 20 63 onnection */. c
1dc0: 6f 6e 73 74 20 63 68 61 72 20 2a 7a 44 62 20 3d onst char *zDb =
1dd0: 20 28 63 6f 6e 73 74 20 63 68 61 72 2a 29 70 41 (const char*)pA
1de0: 72 67 3b 0a 20 20 77 68 69 6c 65 28 20 21 74 69 rg;. while( !ti
1df0: 6d 65 74 6f 73 74 6f 70 28 26 65 72 72 29 20 29 metostop(&err) )
1e00: 7b 0a 20 20 20 20 6f 70 65 6e 64 62 28 26 65 72 {. opendb(&er
1e10: 72 2c 20 26 64 62 2c 20 7a 44 62 2c 20 30 2c 20 r, &db, zDb, 0,
1e20: 30 29 3b 0a 20 20 20 20 73 71 6c 5f 73 63 72 69 0);. sql_scri
1e30: 70 74 28 26 65 72 72 2c 20 26 64 62 2c 20 22 53 pt(&err, &db, "S
1e40: 45 4c 45 43 54 20 2a 20 46 52 4f 4d 20 73 71 6c ELECT * FROM sql
1e50: 69 74 65 5f 6d 61 73 74 65 72 3b 22 29 3b 0a 20 ite_master;");.
1e60: 20 20 20 63 6c 65 61 72 5f 65 72 72 6f 72 28 26 clear_error(&
1e70: 65 72 72 2c 20 53 51 4c 49 54 45 5f 4c 4f 43 4b err, SQLITE_LOCK
1e80: 45 44 29 3b 0a 20 20 20 20 63 6c 6f 73 65 64 62 ED);. closedb
1e90: 28 26 65 72 72 2c 20 26 64 62 29 3b 0a 20 20 7d (&err, &db);. }
1ea0: 0a 20 20 70 72 69 6e 74 5f 61 6e 64 5f 66 72 65 . print_and_fre
1eb0: 65 5f 65 72 72 28 26 65 72 72 29 3b 0a 20 20 72 e_err(&err);. r
1ec0: 65 74 75 72 6e 20 73 71 6c 69 74 65 33 5f 6d 70 eturn sqlite3_mp
1ed0: 72 69 6e 74 66 28 22 6f 6b 22 29 3b 0a 7d 0a 0a rintf("ok");.}..
1ee0: 0a 74 79 70 65 64 65 66 20 73 74 72 75 63 74 20 .typedef struct
1ef0: 53 74 72 65 73 73 32 43 74 78 20 53 74 72 65 73 Stress2Ctx Stres
1f00: 73 32 43 74 78 3b 0a 73 74 72 75 63 74 20 53 74 s2Ctx;.struct St
1f10: 72 65 73 73 32 43 74 78 20 7b 0a 20 20 63 6f 6e ress2Ctx {. con
1f20: 73 74 20 63 68 61 72 20 2a 7a 44 62 3b 0a 20 20 st char *zDb;.
1f30: 76 6f 69 64 20 28 2a 78 50 72 6f 63 29 28 45 72 void (*xProc)(Er
1f40: 72 6f 72 2a 2c 20 53 71 6c 69 74 65 2a 2c 20 69 ror*, Sqlite*, i
1f50: 6e 74 29 3b 0a 7d 3b 0a 0a 73 74 61 74 69 63 20 nt);.};..static
1f60: 63 68 61 72 20 2a 73 74 72 65 73 73 32 5f 74 68 char *stress2_th
1f70: 72 65 61 64 5f 77 72 61 70 70 65 72 28 69 6e 74 read_wrapper(int
1f80: 20 69 54 69 64 2c 20 76 6f 69 64 20 2a 70 41 72 iTid, void *pAr
1f90: 67 29 7b 0a 20 20 53 74 72 65 73 73 32 43 74 78 g){. Stress2Ctx
1fa0: 20 2a 70 43 74 78 20 3d 20 28 53 74 72 65 73 73 *pCtx = (Stress
1fb0: 32 43 74 78 2a 29 70 41 72 67 3b 0a 20 20 45 72 2Ctx*)pArg;. Er
1fc0: 72 6f 72 20 65 72 72 20 3d 20 7b 30 7d 3b 20 20 ror err = {0};
1fd0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a /*
1fe0: 20 45 72 72 6f 72 20 63 6f 64 65 20 61 6e 64 20 Error code and
1ff0: 6d 65 73 73 61 67 65 20 2a 2f 0a 20 20 53 71 6c message */. Sql
2000: 69 74 65 20 64 62 20 3d 20 7b 30 7d 3b 20 20 20 ite db = {0};
2010: 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 /*
2020: 53 51 4c 69 74 65 20 64 61 74 61 62 61 73 65 20 SQLite database
2030: 63 6f 6e 6e 65 63 74 69 6f 6e 20 2a 2f 0a 20 20 connection */.
2040: 69 6e 74 20 69 31 20 3d 20 30 3b 0a 20 20 69 6e int i1 = 0;. in
2050: 74 20 69 32 20 3d 20 30 3b 0a 0a 20 20 77 68 69 t i2 = 0;.. whi
2060: 6c 65 28 20 21 74 69 6d 65 74 6f 73 74 6f 70 28 le( !timetostop(
2070: 26 65 72 72 29 20 29 7b 0a 20 20 20 20 69 6e 74 &err) ){. int
2080: 20 63 6e 74 3b 0a 20 20 20 20 6f 70 65 6e 64 62 cnt;. opendb
2090: 28 26 65 72 72 2c 20 26 64 62 2c 20 70 43 74 78 (&err, &db, pCtx
20a0: 2d 3e 7a 44 62 2c 20 30 2c 20 30 29 3b 0a 20 20 ->zDb, 0, 0);.
20b0: 20 20 66 6f 72 28 63 6e 74 3d 30 3b 20 65 72 72 for(cnt=0; err
20c0: 2e 72 63 3d 3d 53 51 4c 49 54 45 5f 4f 4b 20 26 .rc==SQLITE_OK &
20d0: 26 20 63 6e 74 3c 53 54 52 45 53 53 32 5f 54 41 & cnt<STRESS2_TA
20e0: 42 43 4e 54 3b 20 63 6e 74 2b 2b 29 7b 0a 20 20 BCNT; cnt++){.
20f0: 20 20 20 20 70 43 74 78 2d 3e 78 50 72 6f 63 28 pCtx->xProc(
2100: 26 65 72 72 2c 20 26 64 62 2c 20 69 31 29 3b 0a &err, &db, i1);.
2110: 20 20 20 20 20 20 69 32 20 2b 3d 20 28 65 72 72 i2 += (err
2120: 2e 72 63 3d 3d 53 51 4c 49 54 45 5f 4f 4b 29 3b .rc==SQLITE_OK);
2130: 0a 20 20 20 20 20 20 63 6c 65 61 72 5f 65 72 72 . clear_err
2140: 6f 72 28 26 65 72 72 2c 20 53 51 4c 49 54 45 5f or(&err, SQLITE_
2150: 4c 4f 43 4b 45 44 29 3b 0a 20 20 20 20 20 20 69 LOCKED);. i
2160: 31 2b 2b 3b 0a 20 20 20 20 7d 0a 20 20 20 20 63 1++;. }. c
2170: 6c 6f 73 65 64 62 28 26 65 72 72 2c 20 26 64 62 losedb(&err, &db
2180: 29 3b 0a 20 20 7d 0a 0a 20 20 70 72 69 6e 74 5f );. }.. print_
2190: 61 6e 64 5f 66 72 65 65 5f 65 72 72 28 26 65 72 and_free_err(&er
21a0: 72 29 3b 0a 20 20 72 65 74 75 72 6e 20 73 71 6c r);. return sql
21b0: 69 74 65 33 5f 6d 70 72 69 6e 74 66 28 22 6f 6b ite3_mprintf("ok
21c0: 20 25 64 2f 25 64 22 2c 20 69 32 2c 20 69 31 29 %d/%d", i2, i1)
21d0: 3b 0a 7d 0a 0a 73 74 61 74 69 63 20 76 6f 69 64 ;.}..static void
21e0: 20 73 74 72 65 73 73 32 5f 6c 61 75 6e 63 68 5f stress2_launch_
21f0: 74 68 72 65 61 64 5f 6c 6f 6f 70 28 0a 20 20 45 thread_loop(. E
2200: 72 72 6f 72 20 2a 70 45 72 72 2c 20 20 20 20 20 rror *pErr,
2210: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 2f /
2220: 2a 20 49 4e 2f 4f 55 54 3a 20 45 72 72 6f 72 20 * IN/OUT: Error
2230: 63 6f 64 65 20 2a 2f 0a 20 20 54 68 72 65 61 64 code */. Thread
2240: 73 65 74 20 2a 70 54 68 72 65 61 64 73 2c 20 20 set *pThreads,
2250: 20 20 20 20 20 20 20 20 20 20 2f 2a 20 54 68 72 /* Thr
2260: 65 61 64 20 73 65 74 20 2a 2f 0a 20 20 63 6f 6e ead set */. con
2270: 73 74 20 63 68 61 72 20 2a 7a 44 62 2c 20 20 20 st char *zDb,
2280: 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 /*
2290: 44 61 74 61 62 61 73 65 20 6e 61 6d 65 20 2a 2f Database name */
22a0: 0a 20 20 76 6f 69 64 20 28 2a 78 29 28 45 72 72 . void (*x)(Err
22b0: 6f 72 2a 2c 53 71 6c 69 74 65 2a 2c 69 6e 74 29 or*,Sqlite*,int)
22c0: 20 20 20 2f 2a 20 52 75 6e 20 74 68 69 73 20 75 /* Run this u
22d0: 6e 74 69 6c 20 65 72 72 6f 72 20 6f 72 20 74 69 ntil error or ti
22e0: 6d 65 6f 75 74 20 2a 2f 0a 29 7b 0a 20 20 53 74 meout */.){. St
22f0: 72 65 73 73 32 43 74 78 20 2a 70 43 74 78 20 3d ress2Ctx *pCtx =
2300: 20 73 71 6c 69 74 65 33 5f 6d 61 6c 6c 6f 63 28 sqlite3_malloc(
2310: 73 69 7a 65 6f 66 28 53 74 72 65 73 73 32 43 74 sizeof(Stress2Ct
2320: 78 29 29 3b 0a 20 20 70 43 74 78 2d 3e 7a 44 62 x));. pCtx->zDb
2330: 20 3d 20 7a 44 62 3b 0a 20 20 70 43 74 78 2d 3e = zDb;. pCtx->
2340: 78 50 72 6f 63 20 3d 20 78 3b 0a 20 20 6c 61 75 xProc = x;. lau
2350: 6e 63 68 5f 74 68 72 65 61 64 28 70 45 72 72 2c nch_thread(pErr,
2360: 20 70 54 68 72 65 61 64 73 2c 20 73 74 72 65 73 pThreads, stres
2370: 73 32 5f 74 68 72 65 61 64 5f 77 72 61 70 70 65 s2_thread_wrappe
2380: 72 2c 20 28 76 6f 69 64 2a 29 70 43 74 78 29 3b r, (void*)pCtx);
2390: 0a 7d 0a 0a 73 74 61 74 69 63 20 76 6f 69 64 20 .}..static void
23a0: 73 74 72 65 73 73 32 28 69 6e 74 20 6e 4d 73 29 stress2(int nMs)
23b0: 7b 0a 20 20 73 74 72 75 63 74 20 53 74 72 65 73 {. struct Stres
23c0: 73 32 54 61 73 6b 20 7b 0a 20 20 20 20 76 6f 69 s2Task {. voi
23d0: 64 20 28 2a 78 29 28 45 72 72 6f 72 2a 2c 53 71 d (*x)(Error*,Sq
23e0: 6c 69 74 65 2a 2c 69 6e 74 29 3b 0a 20 20 7d 20 lite*,int);. }
23f0: 61 54 61 73 6b 5b 5d 20 3d 20 7b 0a 20 20 20 20 aTask[] = {.
2400: 7b 20 73 74 72 65 73 73 32 5f 77 6f 72 6b 6c 6f { stress2_worklo
2410: 61 64 31 20 7d 2c 0a 20 20 20 20 7b 20 73 74 72 ad1 },. { str
2420: 65 73 73 32 5f 77 6f 72 6b 6c 6f 61 64 32 20 7d ess2_workload2 }
2430: 2c 0a 20 20 20 20 7b 20 73 74 72 65 73 73 32 5f ,. { stress2_
2440: 77 6f 72 6b 6c 6f 61 64 33 20 7d 2c 0a 20 20 20 workload3 },.
2450: 20 7b 20 73 74 72 65 73 73 32 5f 77 6f 72 6b 6c { stress2_workl
2460: 6f 61 64 34 20 7d 2c 0a 20 20 20 20 7b 20 73 74 oad4 },. { st
2470: 72 65 73 73 32 5f 77 6f 72 6b 6c 6f 61 64 35 20 ress2_workload5
2480: 7d 2c 0a 20 20 20 20 7b 20 73 74 72 65 73 73 32 },. { stress2
2490: 5f 77 6f 72 6b 6c 6f 61 64 36 20 7d 2c 0a 20 20 _workload6 },.
24a0: 20 20 7b 20 73 74 72 65 73 73 32 5f 77 6f 72 6b { stress2_work
24b0: 6c 6f 61 64 37 20 7d 2c 0a 20 20 20 20 7b 20 73 load7 },. { s
24c0: 74 72 65 73 73 32 5f 77 6f 72 6b 6c 6f 61 64 38 tress2_workload8
24d0: 20 7d 2c 0a 20 20 20 20 7b 20 73 74 72 65 73 73 },. { stress
24e0: 32 5f 77 6f 72 6b 6c 6f 61 64 39 20 7d 2c 0a 20 2_workload9 },.
24f0: 20 20 20 7b 20 73 74 72 65 73 73 32 5f 77 6f 72 { stress2_wor
2500: 6b 6c 6f 61 64 31 30 20 7d 2c 0a 20 20 20 20 7b kload10 },. {
2510: 20 73 74 72 65 73 73 32 5f 77 6f 72 6b 6c 6f 61 stress2_workloa
2520: 64 31 31 20 7d 2c 0a 20 20 20 20 7b 20 73 74 72 d11 },. { str
2530: 65 73 73 32 5f 77 6f 72 6b 6c 6f 61 64 31 34 20 ess2_workload14
2540: 7d 2c 0a 20 20 20 20 7b 20 73 74 72 65 73 73 32 },. { stress2
2550: 5f 77 6f 72 6b 6c 6f 61 64 31 37 20 7d 2c 0a 20 _workload17 },.
2560: 20 7d 3b 0a 20 20 63 6f 6e 73 74 20 63 68 61 72 };. const char
2570: 20 2a 7a 44 62 20 3d 20 22 74 65 73 74 2e 64 62 *zDb = "test.db
2580: 22 3b 0a 0a 20 20 69 6e 74 20 69 3b 0a 20 20 45 ";.. int i;. E
2590: 72 72 6f 72 20 65 72 72 20 3d 20 7b 30 7d 3b 0a rror err = {0};.
25a0: 20 20 53 71 6c 69 74 65 20 64 62 20 3d 20 7b 30 Sqlite db = {0
25b0: 7d 3b 0a 20 20 54 68 72 65 61 64 73 65 74 20 74 };. Threadset t
25c0: 68 72 65 61 64 73 20 3d 20 7b 30 7d 3b 0a 0a 20 hreads = {0};..
25d0: 20 2f 2a 20 54 6f 20 6d 61 6b 65 20 73 75 72 65 /* To make sure
25e0: 20 74 68 65 20 64 62 20 66 69 6c 65 20 69 73 20 the db file is
25f0: 65 6d 70 74 79 20 62 65 66 6f 72 65 20 63 6f 6d empty before com
2600: 6d 65 6e 63 69 6e 67 20 2a 2f 0a 20 20 6f 70 65 mencing */. ope
2610: 6e 64 62 28 26 65 72 72 2c 20 26 64 62 2c 20 7a ndb(&err, &db, z
2620: 44 62 2c 20 31 2c 20 30 29 3b 0a 20 20 73 71 6c Db, 1, 0);. sql
2630: 5f 73 63 72 69 70 74 28 26 65 72 72 2c 20 26 64 _script(&err, &d
2640: 62 2c 20 0a 20 20 20 20 20 20 22 43 52 45 41 54 b, . "CREAT
2650: 45 20 54 41 42 4c 45 20 49 46 20 4e 4f 54 20 45 E TABLE IF NOT E
2660: 58 49 53 54 53 20 74 30 28 78 20 50 52 49 4d 41 XISTS t0(x PRIMA
2670: 52 59 20 4b 45 59 2c 20 79 2c 20 7a 29 3b 22 0a RY KEY, y, z);".
2680: 20 20 20 20 20 20 22 43 52 45 41 54 45 20 49 4e "CREATE IN
2690: 44 45 58 20 49 46 20 4e 4f 54 20 45 58 49 53 54 DEX IF NOT EXIST
26a0: 53 20 69 30 20 4f 4e 20 74 30 28 79 29 3b 22 0a S i0 ON t0(y);".
26b0: 20 20 29 3b 0a 20 20 63 6c 6f 73 65 64 62 28 26 );. closedb(&
26c0: 65 72 72 2c 20 26 64 62 29 3b 0a 0a 20 20 73 65 err, &db);.. se
26d0: 74 73 74 6f 70 74 69 6d 65 28 26 65 72 72 2c 20 tstoptime(&err,
26e0: 6e 4d 73 29 3b 0a 20 20 73 71 6c 69 74 65 33 5f nMs);. sqlite3_
26f0: 65 6e 61 62 6c 65 5f 73 68 61 72 65 64 5f 63 61 enable_shared_ca
2700: 63 68 65 28 31 29 3b 0a 0a 20 20 66 6f 72 28 69 che(1);.. for(i
2710: 3d 30 3b 20 69 3c 73 69 7a 65 6f 66 28 61 54 61 =0; i<sizeof(aTa
2720: 73 6b 29 2f 73 69 7a 65 6f 66 28 61 54 61 73 6b sk)/sizeof(aTask
2730: 5b 30 5d 29 3b 20 69 2b 2b 29 7b 0a 20 20 20 20 [0]); i++){.
2740: 73 74 72 65 73 73 32 5f 6c 61 75 6e 63 68 5f 74 stress2_launch_t
2750: 68 72 65 61 64 5f 6c 6f 6f 70 28 26 65 72 72 2c hread_loop(&err,
2760: 20 26 74 68 72 65 61 64 73 2c 20 7a 44 62 2c 20 &threads, zDb,
2770: 61 54 61 73 6b 5b 69 5d 2e 78 29 3b 0a 20 20 7d aTask[i].x);. }
2780: 0a 20 20 6c 61 75 6e 63 68 5f 74 68 72 65 61 64 . launch_thread
2790: 28 26 65 72 72 2c 20 26 74 68 72 65 61 64 73 2c (&err, &threads,
27a0: 20 73 74 72 65 73 73 32 5f 77 6f 72 6b 6c 6f 61 stress2_workloa
27b0: 64 31 39 2c 20 28 76 6f 69 64 2a 29 7a 44 62 29 d19, (void*)zDb)
27c0: 3b 0a 20 20 6c 61 75 6e 63 68 5f 74 68 72 65 61 ;. launch_threa
27d0: 64 28 26 65 72 72 2c 20 26 74 68 72 65 61 64 73 d(&err, &threads
27e0: 2c 20 73 74 72 65 73 73 32 5f 77 6f 72 6b 6c 6f , stress2_worklo
27f0: 61 64 31 39 2c 20 28 76 6f 69 64 2a 29 7a 44 62 ad19, (void*)zDb
2800: 29 3b 0a 0a 20 20 6a 6f 69 6e 5f 61 6c 6c 5f 74 );.. join_all_t
2810: 68 72 65 61 64 73 28 26 65 72 72 2c 20 26 74 68 hreads(&err, &th
2820: 72 65 61 64 73 29 3b 0a 20 20 73 71 6c 69 74 65 reads);. sqlite
2830: 33 5f 65 6e 61 62 6c 65 5f 73 68 61 72 65 64 5f 3_enable_shared_
2840: 63 61 63 68 65 28 30 29 3b 0a 20 20 70 72 69 6e cache(0);. prin
2850: 74 5f 61 6e 64 5f 66 72 65 65 5f 65 72 72 28 26 t_and_free_err(&
2860: 65 72 72 29 3b 0a 7d 0a 0a 0a 0a 0a err);.}.....