| OLD | NEW |
| 1 /* | 1 /* |
| 2 ** 2014 December 9 | 2 ** 2014 December 9 |
| 3 ** | 3 ** |
| 4 ** The author disclaims copyright to this source code. In place of | 4 ** The author disclaims copyright to this source code. In place of |
| 5 ** a legal notice, here is a blessing: | 5 ** a legal notice, here is a blessing: |
| 6 ** | 6 ** |
| 7 ** May you do good and not evil. | 7 ** May you do good and not evil. |
| 8 ** May you find forgiveness for yourself and forgive others. | 8 ** May you find forgiveness for yourself and forgive others. |
| 9 ** May you share freely, never taking more than you give. | 9 ** May you share freely, never taking more than you give. |
| 10 ** | 10 ** |
| 11 ************************************************************************* | 11 ************************************************************************* |
| 12 ** | 12 ** |
| 13 ** create_drop_index_1 | 13 ** create_drop_index_1 |
| 14 */ | 14 */ |
| 15 | 15 |
| 16 | 16 |
| 17 static char *create_drop_index_thread(int iTid, int iArg){ | 17 static char *create_drop_index_thread(int iTid, void *pArg){ |
| 18 Error err = {0}; /* Error code and message */ | 18 Error err = {0}; /* Error code and message */ |
| 19 Sqlite db = {0}; /* SQLite database connection */ | 19 Sqlite db = {0}; /* SQLite database connection */ |
| 20 | 20 |
| 21 while( !timetostop(&err) ){ | 21 while( !timetostop(&err) ){ |
| 22 opendb(&err, &db, "test.db", 0); | 22 opendb(&err, &db, "test.db", 0); |
| 23 | 23 |
| 24 sql_script(&err, &db, | 24 sql_script(&err, &db, |
| 25 | |
| 26 "DROP INDEX IF EXISTS i1;" | 25 "DROP INDEX IF EXISTS i1;" |
| 27 "DROP INDEX IF EXISTS i2;" | 26 "DROP INDEX IF EXISTS i2;" |
| 28 "DROP INDEX IF EXISTS i3;" | 27 "DROP INDEX IF EXISTS i3;" |
| 29 "DROP INDEX IF EXISTS i4;" | 28 "DROP INDEX IF EXISTS i4;" |
| 30 | 29 |
| 31 "CREATE INDEX IF NOT EXISTS i1 ON t1(a);" | 30 "CREATE INDEX IF NOT EXISTS i1 ON t11(a);" |
| 32 "CREATE INDEX IF NOT EXISTS i2 ON t1(b);" | 31 "CREATE INDEX IF NOT EXISTS i2 ON t11(b);" |
| 33 "CREATE INDEX IF NOT EXISTS i3 ON t1(c);" | 32 "CREATE INDEX IF NOT EXISTS i3 ON t11(c);" |
| 34 "CREATE INDEX IF NOT EXISTS i4 ON t1(d);" | 33 "CREATE INDEX IF NOT EXISTS i4 ON t11(d);" |
| 35 | 34 |
| 36 "SELECT * FROM t1 ORDER BY a;" | 35 "SELECT * FROM t11 ORDER BY a;" |
| 37 "SELECT * FROM t1 ORDER BY b;" | 36 "SELECT * FROM t11 ORDER BY b;" |
| 38 "SELECT * FROM t1 ORDER BY c;" | 37 "SELECT * FROM t11 ORDER BY c;" |
| 39 "SELECT * FROM t1 ORDER BY d;" | 38 "SELECT * FROM t11 ORDER BY d;" |
| 40 ); | 39 ); |
| 40 clear_error(&err, SQLITE_LOCKED); |
| 41 | 41 |
| 42 closedb(&err, &db); | 42 closedb(&err, &db); |
| 43 } | 43 } |
| 44 | 44 |
| 45 print_and_free_err(&err); | 45 print_and_free_err(&err); |
| 46 return sqlite3_mprintf("ok"); | 46 return sqlite3_mprintf("ok"); |
| 47 } | 47 } |
| 48 | 48 |
| 49 static void create_drop_index_1(int nMs){ | 49 static void create_drop_index_1(int nMs){ |
| 50 Error err = {0}; | 50 Error err = {0}; |
| 51 Sqlite db = {0}; | 51 Sqlite db = {0}; |
| 52 Threadset threads = {0}; | 52 Threadset threads = {0}; |
| 53 | 53 |
| 54 opendb(&err, &db, "test.db", 1); | 54 opendb(&err, &db, "test.db", 1); |
| 55 sql_script(&err, &db, | 55 sql_script(&err, &db, |
| 56 "CREATE TABLE t1(a, b, c, d);" | 56 "CREATE TABLE t11(a, b, c, d);" |
| 57 "WITH data(x) AS (SELECT 1 UNION ALL SELECT x+1 FROM data WHERE x<100) " | 57 "WITH data(x) AS (SELECT 1 UNION ALL SELECT x+1 FROM data WHERE x<100) " |
| 58 "INSERT INTO t1 SELECT x,x,x,x FROM data;" | 58 "INSERT INTO t11 SELECT x,x,x,x FROM data;" |
| 59 ); | 59 ); |
| 60 closedb(&err, &db); | 60 closedb(&err, &db); |
| 61 | 61 |
| 62 setstoptime(&err, nMs); | 62 setstoptime(&err, nMs); |
| 63 | 63 |
| 64 sqlite3_enable_shared_cache(1); | 64 sqlite3_enable_shared_cache(1); |
| 65 launch_thread(&err, &threads, create_drop_index_thread, 0); | 65 launch_thread(&err, &threads, create_drop_index_thread, 0); |
| 66 launch_thread(&err, &threads, create_drop_index_thread, 0); | 66 launch_thread(&err, &threads, create_drop_index_thread, 0); |
| 67 launch_thread(&err, &threads, create_drop_index_thread, 0); | 67 launch_thread(&err, &threads, create_drop_index_thread, 0); |
| 68 launch_thread(&err, &threads, create_drop_index_thread, 0); | 68 launch_thread(&err, &threads, create_drop_index_thread, 0); |
| 69 launch_thread(&err, &threads, create_drop_index_thread, 0); | 69 launch_thread(&err, &threads, create_drop_index_thread, 0); |
| 70 sqlite3_enable_shared_cache(0); | |
| 71 | 70 |
| 72 join_all_threads(&err, &threads); | 71 join_all_threads(&err, &threads); |
| 72 sqlite3_enable_shared_cache(0); |
| 73 print_and_free_err(&err); | 73 print_and_free_err(&err); |
| 74 } | 74 } |
| OLD | NEW |