Index: third_party/sqlite/sqlite-src-3170000/test/tt3_vacuum.c |
diff --git a/third_party/sqlite/sqlite-src-3170000/test/tt3_vacuum.c b/third_party/sqlite/sqlite-src-3170000/test/tt3_vacuum.c |
new file mode 100644 |
index 0000000000000000000000000000000000000000..023fdfd74d1591670665ad64dbe5ac057f4fa4a5 |
--- /dev/null |
+++ b/third_party/sqlite/sqlite-src-3170000/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); |
+} |