| Index: third_party/sqlite/sqlite-src-3100200/test/tt3_vacuum.c
|
| diff --git a/third_party/sqlite/sqlite-src-3100200/test/tt3_vacuum.c b/third_party/sqlite/sqlite-src-3100200/test/tt3_vacuum.c
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..023fdfd74d1591670665ad64dbe5ac057f4fa4a5
|
| --- /dev/null
|
| +++ b/third_party/sqlite/sqlite-src-3100200/test/tt3_vacuum.c
|
| @@ -0,0 +1,90 @@
|
| +/*
|
| +** 2014 December 9
|
| +**
|
| +** The author disclaims copyright to this source code. In place of
|
| +** a legal notice, here is a blessing:
|
| +**
|
| +** May you do good and not evil.
|
| +** May you find forgiveness for yourself and forgive others.
|
| +** May you share freely, never taking more than you give.
|
| +**
|
| +*************************************************************************
|
| +**
|
| +** This file contains multi-threaded tests that use shared-cache and
|
| +** the VACUUM command.
|
| +**
|
| +** Tests:
|
| +**
|
| +** vacuum1
|
| +**
|
| +*/
|
| +
|
| +
|
| +static char *vacuum1_thread_writer(int iTid, void *pArg){
|
| + Error err = {0}; /* Error code and message */
|
| + Sqlite db = {0}; /* SQLite database connection */
|
| + opendb(&err, &db, "test.db", 0);
|
| + i64 i = 0;
|
| +
|
| + while( !timetostop(&err) ){
|
| + i++;
|
| +
|
| + /* Insert lots of rows. Then delete some. */
|
| + execsql(&err, &db,
|
| + "WITH loop(i) AS (SELECT 1 UNION ALL SELECT i+1 FROM loop WHERE i<100) "
|
| + "INSERT INTO t1 SELECT randomblob(50), randomblob(2500) FROM loop"
|
| + );
|
| +
|
| + /* Delete lots of rows */
|
| + execsql(&err, &db, "DELETE FROM t1 WHERE rowid = :i", &i);
|
| + clear_error(&err, SQLITE_LOCKED);
|
| +
|
| + /* Select the rows */
|
| + execsql(&err, &db, "SELECT * FROM t1 ORDER BY x");
|
| + clear_error(&err, SQLITE_LOCKED);
|
| + }
|
| +
|
| + closedb(&err, &db);
|
| + print_and_free_err(&err);
|
| + return sqlite3_mprintf("ok");
|
| +}
|
| +
|
| +static char *vacuum1_thread_vacuumer(int iTid, void *pArg){
|
| + Error err = {0}; /* Error code and message */
|
| + Sqlite db = {0}; /* SQLite database connection */
|
| + opendb(&err, &db, "test.db", 0);
|
| +
|
| + do{
|
| + sql_script(&err, &db, "VACUUM");
|
| + clear_error(&err, SQLITE_LOCKED);
|
| + }while( !timetostop(&err) );
|
| +
|
| + closedb(&err, &db);
|
| + print_and_free_err(&err);
|
| + return sqlite3_mprintf("ok");
|
| +}
|
| +
|
| +static void vacuum1(int nMs){
|
| + Error err = {0};
|
| + Sqlite db = {0};
|
| + Threadset threads = {0};
|
| +
|
| + opendb(&err, &db, "test.db", 1);
|
| + sql_script(&err, &db,
|
| + "CREATE TABLE t1(x PRIMARY KEY, y BLOB);"
|
| + "CREATE INDEX i1 ON t1(y);"
|
| + );
|
| + closedb(&err, &db);
|
| +
|
| + setstoptime(&err, nMs);
|
| +
|
| + sqlite3_enable_shared_cache(1);
|
| + launch_thread(&err, &threads, vacuum1_thread_writer, 0);
|
| + launch_thread(&err, &threads, vacuum1_thread_writer, 0);
|
| + launch_thread(&err, &threads, vacuum1_thread_writer, 0);
|
| + launch_thread(&err, &threads, vacuum1_thread_vacuumer, 0);
|
| + join_all_threads(&err, &threads);
|
| + sqlite3_enable_shared_cache(0);
|
| +
|
| + print_and_free_err(&err);
|
| +}
|
|
|