OLD | NEW |
| (Empty) |
1 /* | |
2 ** 2014 December 9 | |
3 ** | |
4 ** The author disclaims copyright to this source code. In place of | |
5 ** a legal notice, here is a blessing: | |
6 ** | |
7 ** May you do good and not evil. | |
8 ** May you find forgiveness for yourself and forgive others. | |
9 ** May you share freely, never taking more than you give. | |
10 ** | |
11 ************************************************************************* | |
12 ** | |
13 ** This file contains multi-threaded tests that use shared-cache and | |
14 ** the VACUUM command. | |
15 ** | |
16 ** Tests: | |
17 ** | |
18 ** vacuum1 | |
19 ** | |
20 */ | |
21 | |
22 | |
23 static char *vacuum1_thread_writer(int iTid, void *pArg){ | |
24 Error err = {0}; /* Error code and message */ | |
25 Sqlite db = {0}; /* SQLite database connection */ | |
26 opendb(&err, &db, "test.db", 0); | |
27 i64 i = 0; | |
28 | |
29 while( !timetostop(&err) ){ | |
30 i++; | |
31 | |
32 /* Insert lots of rows. Then delete some. */ | |
33 execsql(&err, &db, | |
34 "WITH loop(i) AS (SELECT 1 UNION ALL SELECT i+1 FROM loop WHERE i<100) " | |
35 "INSERT INTO t1 SELECT randomblob(50), randomblob(2500) FROM loop" | |
36 ); | |
37 | |
38 /* Delete lots of rows */ | |
39 execsql(&err, &db, "DELETE FROM t1 WHERE rowid = :i", &i); | |
40 clear_error(&err, SQLITE_LOCKED); | |
41 | |
42 /* Select the rows */ | |
43 execsql(&err, &db, "SELECT * FROM t1 ORDER BY x"); | |
44 clear_error(&err, SQLITE_LOCKED); | |
45 } | |
46 | |
47 closedb(&err, &db); | |
48 print_and_free_err(&err); | |
49 return sqlite3_mprintf("ok"); | |
50 } | |
51 | |
52 static char *vacuum1_thread_vacuumer(int iTid, void *pArg){ | |
53 Error err = {0}; /* Error code and message */ | |
54 Sqlite db = {0}; /* SQLite database connection */ | |
55 opendb(&err, &db, "test.db", 0); | |
56 | |
57 do{ | |
58 sql_script(&err, &db, "VACUUM"); | |
59 clear_error(&err, SQLITE_LOCKED); | |
60 }while( !timetostop(&err) ); | |
61 | |
62 closedb(&err, &db); | |
63 print_and_free_err(&err); | |
64 return sqlite3_mprintf("ok"); | |
65 } | |
66 | |
67 static void vacuum1(int nMs){ | |
68 Error err = {0}; | |
69 Sqlite db = {0}; | |
70 Threadset threads = {0}; | |
71 | |
72 opendb(&err, &db, "test.db", 1); | |
73 sql_script(&err, &db, | |
74 "CREATE TABLE t1(x PRIMARY KEY, y BLOB);" | |
75 "CREATE INDEX i1 ON t1(y);" | |
76 ); | |
77 closedb(&err, &db); | |
78 | |
79 setstoptime(&err, nMs); | |
80 | |
81 sqlite3_enable_shared_cache(1); | |
82 launch_thread(&err, &threads, vacuum1_thread_writer, 0); | |
83 launch_thread(&err, &threads, vacuum1_thread_writer, 0); | |
84 launch_thread(&err, &threads, vacuum1_thread_writer, 0); | |
85 launch_thread(&err, &threads, vacuum1_thread_vacuumer, 0); | |
86 join_all_threads(&err, &threads); | |
87 sqlite3_enable_shared_cache(0); | |
88 | |
89 print_and_free_err(&err); | |
90 } | |
OLD | NEW |