Adding upstream version 3.40.1.upstream/3.40.1upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 90 insertions, 0 deletions

diff --git a/test/tt3_vacuum.c b/test/tt3_vacuum.c
new file mode 100644
index 0000000..c41a6b4
--- /dev/null
+++ b/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 */
+  i64 i = 0;
+
+  opendb(&err, &db, "test.db", 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);
+}