mirror of
https://github.com/tursodatabase/libsql.git
synced 2024-12-15 06:19:42 +00:00
91 lines
2.4 KiB
C
91 lines
2.4 KiB
C
/*
|
|
** 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);
|
|
}
|