blob: 6e5e5771a7f7f6577ad99f0a4d7a6343f14a79cf [file] [log] [blame]
drh75897232000-05-29 14:26:00 +00001/*
drhb19a2bc2001-09-16 00:13:26 +00002** 2001 September 15
drh75897232000-05-29 14:26:00 +00003**
drhb19a2bc2001-09-16 00:13:26 +00004** The author disclaims copyright to this source code. In place of
5** a legal notice, here is a blessing:
drh75897232000-05-29 14:26:00 +00006**
drhb19a2bc2001-09-16 00:13:26 +00007** 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.
drh75897232000-05-29 14:26:00 +000010**
11*************************************************************************
12** Main file for the SQLite library. The routines in this file
13** implement the programmer interface to the library. Routines in
14** other files are for internal use by SQLite and should not be
15** accessed by users of the library.
16**
drhc2311722002-07-19 17:46:38 +000017** $Id: main.c,v 1.89 2002/07/19 17:46:39 drh Exp $
drh75897232000-05-29 14:26:00 +000018*/
19#include "sqliteInt.h"
drh8cfbf082001-09-19 13:22:39 +000020#include "os.h"
drhce9079c2002-05-15 14:17:44 +000021#include <ctype.h>
drh75897232000-05-29 14:26:00 +000022
23/*
drhc2311722002-07-19 17:46:38 +000024** A pointer to this structure is used to communicate information
25** from sqliteInit into the sqliteInitCallback.
26*/
27typedef struct {
28 sqlite *db; /* The database being initialized */
29 char **pzErrMsg; /* Error message stored here */
30} InitData;
31
32
33/*
drh75897232000-05-29 14:26:00 +000034** This is the callback routine for the code that initializes the
drh382c0242001-10-06 16:33:02 +000035** database. See sqliteInit() below for additional information.
36**
37** Each callback contains the following information:
drh28037572000-08-02 13:47:41 +000038**
drh4a324312001-12-21 14:30:42 +000039** argv[0] = "file-format" or "schema-cookie" or "table" or "index"
drhe3c41372001-09-17 20:25:58 +000040** argv[1] = table or index name or meta statement type.
41** argv[2] = root page number for table or index. NULL for meta.
drhadbca9c2001-09-27 15:11:53 +000042** argv[3] = SQL create statement for the table or index
drhe0bc4042002-06-25 01:09:11 +000043** argv[4] = "1" for temporary files, "0" for main database
drhd78eeee2001-09-13 16:18:53 +000044**
drh75897232000-05-29 14:26:00 +000045*/
drhc2311722002-07-19 17:46:38 +000046static
47int sqliteInitCallback(void *pInit, int argc, char **argv, char **azColName){
48 InitData *pData = (InitData*)pInit;
drh75897232000-05-29 14:26:00 +000049 Parse sParse;
drhd78eeee2001-09-13 16:18:53 +000050 int nErr = 0;
drh75897232000-05-29 14:26:00 +000051
drh382c0242001-10-06 16:33:02 +000052 /* TODO: Do some validity checks on all fields. In particular,
53 ** make sure fields do not contain NULLs. Otherwise we might core
54 ** when attempting to initialize from a corrupt database file. */
drhe3c41372001-09-17 20:25:58 +000055
drhe0bc4042002-06-25 01:09:11 +000056 assert( argc==5 );
drhd78eeee2001-09-13 16:18:53 +000057 switch( argv[0][0] ){
drh17f71932002-02-21 12:01:27 +000058 case 'v':
drhd78eeee2001-09-13 16:18:53 +000059 case 'i':
drh17f71932002-02-21 12:01:27 +000060 case 't': { /* CREATE TABLE, CREATE INDEX, or CREATE VIEW statements */
drhadbca9c2001-09-27 15:11:53 +000061 if( argv[3] && argv[3][0] ){
drh17f71932002-02-21 12:01:27 +000062 /* Call the parser to process a CREATE TABLE, INDEX or VIEW.
drh382c0242001-10-06 16:33:02 +000063 ** But because sParse.initFlag is set to 1, no VDBE code is generated
64 ** or executed. All the parser does is build the internal data
drh17f71932002-02-21 12:01:27 +000065 ** structures that describe the table, index, or view.
drh382c0242001-10-06 16:33:02 +000066 */
drhadbca9c2001-09-27 15:11:53 +000067 memset(&sParse, 0, sizeof(sParse));
drhc2311722002-07-19 17:46:38 +000068 sParse.db = pData->db;
drhadbca9c2001-09-27 15:11:53 +000069 sParse.initFlag = 1;
drhe0bc4042002-06-25 01:09:11 +000070 sParse.isTemp = argv[4][0] - '0';
drhadbca9c2001-09-27 15:11:53 +000071 sParse.newTnum = atoi(argv[2]);
drhc2311722002-07-19 17:46:38 +000072 sqliteRunParser(&sParse, argv[3], pData->pzErrMsg);
drhadbca9c2001-09-27 15:11:53 +000073 }else{
drh382c0242001-10-06 16:33:02 +000074 /* If the SQL column is blank it means this is an index that
75 ** was created to be the PRIMARY KEY or to fulfill a UNIQUE
drhaacc5432002-01-06 17:07:40 +000076 ** constraint for a CREATE TABLE. The index should have already
drh382c0242001-10-06 16:33:02 +000077 ** been created when we processed the CREATE TABLE. All we have
drhaacc5432002-01-06 17:07:40 +000078 ** to do here is record the root page number for that index.
drh382c0242001-10-06 16:33:02 +000079 */
drhc2311722002-07-19 17:46:38 +000080 Index *pIndex = sqliteFindIndex(pData->db, argv[1]);
drhadbca9c2001-09-27 15:11:53 +000081 if( pIndex==0 || pIndex->tnum!=0 ){
drhda9e0342002-01-10 14:31:48 +000082 /* This can occur if there exists an index on a TEMP table which
83 ** has the same name as another index on a permanent index. Since
84 ** the permanent table is hidden by the TEMP table, we can also
85 ** safely ignore the index on the permanent table.
86 */
87 /* Do Nothing */;
drhadbca9c2001-09-27 15:11:53 +000088 }else{
89 pIndex->tnum = atoi(argv[2]);
90 }
91 }
drhd78eeee2001-09-13 16:18:53 +000092 break;
93 }
94 default: {
95 /* This can not happen! */
96 nErr = 1;
97 assert( nErr==0 );
98 }
drh28037572000-08-02 13:47:41 +000099 }
drh75897232000-05-29 14:26:00 +0000100 return nErr;
101}
102
103/*
drh491791a2002-07-18 00:34:09 +0000104** This is a callback procedure used to reconstruct a table. The
105** name of the table to be reconstructed is passed in as argv[0].
106**
107** This routine is used to automatically upgrade a database from
108** format version 1 or 2 to version 3. The correct operation of
109** this routine relys on the fact that no indices are used when
110** copying a table out to a temporary file.
111*/
drhc2311722002-07-19 17:46:38 +0000112static
113int upgrade_3_callback(void *pInit, int argc, char **argv, char **NotUsed){
114 InitData *pData = (InitData*)pInit;
drh491791a2002-07-18 00:34:09 +0000115 int rc;
drh8e5ba842002-07-18 01:27:17 +0000116 Table *pTab;
117 Trigger *pTrig;
drhc2311722002-07-19 17:46:38 +0000118 char *zErr;
drh491791a2002-07-18 00:34:09 +0000119
drhc2311722002-07-19 17:46:38 +0000120 pTab = sqliteFindTable(pData->db, argv[0]);
drh8e5ba842002-07-18 01:27:17 +0000121 if( pTab ){
122 pTrig = pTab->pTrigger;
123 pTab->pTrigger = 0; /* Disable all triggers before rebuilding the table */
124 }
drhc2311722002-07-19 17:46:38 +0000125 rc = sqlite_exec_printf(pData->db,
drh491791a2002-07-18 00:34:09 +0000126 "CREATE TEMP TABLE sqlite_x AS SELECT * FROM '%q'; "
127 "DELETE FROM '%q'; "
128 "INSERT INTO '%q' SELECT * FROM sqlite_x; "
129 "DROP TABLE sqlite_x;",
drhc2311722002-07-19 17:46:38 +0000130 0, 0, &zErr, argv[0], argv[0], argv[0]);
131 if( zErr ){
132 sqliteSetString(pData->pzErrMsg, zErr, 0);
133 sqlite_freemem(zErr);
134 }
drh8e5ba842002-07-18 01:27:17 +0000135 if( pTab ) pTab->pTrigger = pTrig; /* Re-enable triggers */
drh491791a2002-07-18 00:34:09 +0000136 return rc!=SQLITE_OK;
137}
138
139
140
141/*
drh58b95762000-06-02 01:17:37 +0000142** Attempt to read the database schema and initialize internal
143** data structures. Return one of the SQLITE_ error codes to
144** indicate success or failure.
drhbed86902000-06-02 13:27:59 +0000145**
146** After the database is initialized, the SQLITE_Initialized
147** bit is set in the flags field of the sqlite structure. An
148** attempt is made to initialize the database as soon as it
149** is opened. If that fails (perhaps because another process
150** has the sqlite_master table locked) than another attempt
151** is made the first time the database is accessed.
drh75897232000-05-29 14:26:00 +0000152*/
drhe0bc4042002-06-25 01:09:11 +0000153int sqliteInit(sqlite *db, char **pzErrMsg){
drh58b95762000-06-02 01:17:37 +0000154 int rc;
drhe0bc4042002-06-25 01:09:11 +0000155 BtCursor *curMain;
156 int size;
157 Table *pTab;
158 char *azArg[6];
159 int meta[SQLITE_N_BTREE_META];
160 Parse sParse;
drhc2311722002-07-19 17:46:38 +0000161 InitData initData;
drh58b95762000-06-02 01:17:37 +0000162
163 /*
164 ** The master database table has a structure like this
165 */
drh75897232000-05-29 14:26:00 +0000166 static char master_schema[] =
drhe0bc4042002-06-25 01:09:11 +0000167 "CREATE TABLE sqlite_master(\n"
168 " type text,\n"
169 " name text,\n"
170 " tbl_name text,\n"
171 " rootpage integer,\n"
172 " sql text\n"
173 ")"
174 ;
175 static char temp_master_schema[] =
176 "CREATE TEMP TABLE sqlite_temp_master(\n"
drh75897232000-05-29 14:26:00 +0000177 " type text,\n"
178 " name text,\n"
179 " tbl_name text,\n"
drhadbca9c2001-09-27 15:11:53 +0000180 " rootpage integer,\n"
drh75897232000-05-29 14:26:00 +0000181 " sql text\n"
182 ")"
183 ;
184
drhe0bc4042002-06-25 01:09:11 +0000185 /* The following SQL will read the schema from the master tables.
186 ** The first version works with SQLite file formats 2 or greater.
187 ** The second version is for format 1 files.
drh75897232000-05-29 14:26:00 +0000188 **
drhe0bc4042002-06-25 01:09:11 +0000189 ** Beginning with file format 2, the rowid for new table entries
190 ** (including entries in sqlite_master) is an increasing integer.
191 ** So for file format 2 and later, we can play back sqlite_master
192 ** and all the CREATE statements will appear in the right order.
193 ** But with file format 1, table entries were random and so we
194 ** have to make sure the CREATE TABLEs occur before their corresponding
195 ** CREATE INDEXs. (We don't have to deal with CREATE VIEW or
196 ** CREATE TRIGGER in file format 1 because those constructs did
197 ** not exist then.)
drh75897232000-05-29 14:26:00 +0000198 */
drhe0bc4042002-06-25 01:09:11 +0000199 static char init_script[] =
200 "SELECT type, name, rootpage, sql, 1 FROM sqlite_temp_master "
201 "UNION ALL "
202 "SELECT type, name, rootpage, sql, 0 FROM sqlite_master";
203 static char older_init_script[] =
204 "SELECT type, name, rootpage, sql, 1 FROM sqlite_temp_master "
205 "UNION ALL "
206 "SELECT type, name, rootpage, sql, 0 FROM sqlite_master "
207 "WHERE type='table' "
208 "UNION ALL "
209 "SELECT type, name, rootpage, sql, 0 FROM sqlite_master "
210 "WHERE type='index'";
drh17f71932002-02-21 12:01:27 +0000211
drh603240c2002-03-05 01:11:12 +0000212
drhe0bc4042002-06-25 01:09:11 +0000213 /* Construct the schema tables: sqlite_master and sqlite_temp_master
drh58b95762000-06-02 01:17:37 +0000214 */
drhe0bc4042002-06-25 01:09:11 +0000215 azArg[0] = "table";
216 azArg[1] = MASTER_NAME;
217 azArg[2] = "2";
218 azArg[3] = master_schema;
219 azArg[4] = "0";
220 azArg[5] = 0;
drhc2311722002-07-19 17:46:38 +0000221 initData.db = db;
222 initData.pzErrMsg = pzErrMsg;
223 sqliteInitCallback(&initData, 5, azArg, 0);
drhe0bc4042002-06-25 01:09:11 +0000224 pTab = sqliteFindTable(db, MASTER_NAME);
225 if( pTab ){
226 pTab->readOnly = 1;
drhd8bc7082000-06-07 23:51:50 +0000227 }
drhe0bc4042002-06-25 01:09:11 +0000228 azArg[1] = TEMP_MASTER_NAME;
229 azArg[3] = temp_master_schema;
230 azArg[4] = "1";
drhc2311722002-07-19 17:46:38 +0000231 sqliteInitCallback(&initData, 5, azArg, 0);
drhe0bc4042002-06-25 01:09:11 +0000232 pTab = sqliteFindTable(db, TEMP_MASTER_NAME);
233 if( pTab ){
234 pTab->readOnly = 1;
235 }
236
237 /* Create a cursor to hold the database open
238 */
239 if( db->pBe==0 ) return SQLITE_OK;
240 rc = sqliteBtreeCursor(db->pBe, 2, 0, &curMain);
241 if( rc ) return rc;
242
243 /* Get the database meta information
244 */
245 rc = sqliteBtreeGetMeta(db->pBe, meta);
246 if( rc ){
247 sqliteBtreeCloseCursor(curMain);
248 return rc;
249 }
250 db->schema_cookie = meta[1];
251 db->next_cookie = db->schema_cookie;
252 db->file_format = meta[2];
253 size = meta[3];
254 if( size==0 ){ size = MAX_PAGES; }
255 db->cache_size = size;
256 sqliteBtreeSetCacheSize(db->pBe, size);
257
258 /*
259 ** file_format==1 Version 2.1.0.
260 ** file_format==2 Version 2.2.0. Add support for INTEGER PRIMARY KEY.
drh491791a2002-07-18 00:34:09 +0000261 ** file_format==3 Version 2.6.0. Fix empty-string index bug.
262 ** file_format==4 Version 2.7.0. Add support for separate numeric and
drhe0bc4042002-06-25 01:09:11 +0000263 ** text datatypes.
264 */
265 if( db->file_format==0 ){
drh491791a2002-07-18 00:34:09 +0000266 /* This happens if the database was initially empty */
267 db->file_format = 3;
268 }else if( db->file_format>3 ){
drhe0bc4042002-06-25 01:09:11 +0000269 sqliteBtreeCloseCursor(curMain);
drhd78eeee2001-09-13 16:18:53 +0000270 sqliteSetString(pzErrMsg, "unsupported file format", 0);
drh8e5ba842002-07-18 01:27:17 +0000271 return SQLITE_ERROR;
drh28037572000-08-02 13:47:41 +0000272 }
drhaacc5432002-01-06 17:07:40 +0000273
drhe0bc4042002-06-25 01:09:11 +0000274 /* Read the schema information out of the schema tables
drhaacc5432002-01-06 17:07:40 +0000275 */
drhe0bc4042002-06-25 01:09:11 +0000276 memset(&sParse, 0, sizeof(sParse));
277 sParse.db = db;
278 sParse.pBe = db->pBe;
279 sParse.xCallback = sqliteInitCallback;
drhc2311722002-07-19 17:46:38 +0000280 sParse.pArg = (void*)&initData;
drhe0bc4042002-06-25 01:09:11 +0000281 sParse.initFlag = 1;
282 sqliteRunParser(&sParse,
283 db->file_format>=2 ? init_script : older_init_script,
284 pzErrMsg);
285 if( sqlite_malloc_failed ){
286 sqliteSetString(pzErrMsg, "out of memory", 0);
287 sParse.rc = SQLITE_NOMEM;
288 sqliteBtreeRollback(db->pBe);
289 sqliteResetInternalSchema(db);
290 }
291 if( sParse.rc==SQLITE_OK ){
drh58b95762000-06-02 01:17:37 +0000292 db->flags |= SQLITE_Initialized;
drh5e00f6c2001-09-13 13:46:56 +0000293 sqliteCommitInternalChanges(db);
drhe0bc4042002-06-25 01:09:11 +0000294 }else{
295 db->flags &= ~SQLITE_Initialized;
296 sqliteResetInternalSchema(db);
drh58b95762000-06-02 01:17:37 +0000297 }
drhe0bc4042002-06-25 01:09:11 +0000298 sqliteBtreeCloseCursor(curMain);
299 return sParse.rc;
drh58b95762000-06-02 01:17:37 +0000300}
301
302/*
drhb217a572000-08-22 13:40:18 +0000303** The version of the library
304*/
drh3d0b5592000-08-22 13:40:51 +0000305const char sqlite_version[] = SQLITE_VERSION;
drhb217a572000-08-22 13:40:18 +0000306
307/*
drh297ecf12001-04-05 15:57:13 +0000308** Does the library expect data to be encoded as UTF-8 or iso8859? The
309** following global constant always lets us know.
310*/
311#ifdef SQLITE_UTF8
drhfbc3eab2001-04-06 16:13:42 +0000312const char sqlite_encoding[] = "UTF-8";
drh297ecf12001-04-05 15:57:13 +0000313#else
drhfbc3eab2001-04-06 16:13:42 +0000314const char sqlite_encoding[] = "iso8859";
drh297ecf12001-04-05 15:57:13 +0000315#endif
316
317/*
drh58b95762000-06-02 01:17:37 +0000318** Open a new SQLite database. Construct an "sqlite" structure to define
319** the state of this database and return a pointer to that structure.
320**
321** An attempt is made to initialize the in-memory data structures that
322** hold the database schema. But if this fails (because the schema file
323** is locked) then that step is deferred until the first call to
324** sqlite_exec().
325*/
326sqlite *sqlite_open(const char *zFilename, int mode, char **pzErrMsg){
327 sqlite *db;
328 int rc;
329
330 /* Allocate the sqlite data structure */
drh75897232000-05-29 14:26:00 +0000331 db = sqliteMalloc( sizeof(sqlite) );
332 if( pzErrMsg ) *pzErrMsg = 0;
drhdaffd0e2001-04-11 14:28:42 +0000333 if( db==0 ) goto no_mem_on_open;
drhbeae3192001-09-22 18:12:08 +0000334 sqliteHashInit(&db->tblHash, SQLITE_HASH_STRING, 0);
335 sqliteHashInit(&db->idxHash, SQLITE_HASH_STRING, 0);
danielk1977c3f9bad2002-05-15 08:30:12 +0000336 sqliteHashInit(&db->trigHash, SQLITE_HASH_STRING, 0);
drh0bce8352002-02-28 00:41:10 +0000337 sqliteHashInit(&db->aFunc, SQLITE_HASH_STRING, 1);
drh28f4b682002-06-09 10:14:18 +0000338 sqliteRegisterBuiltinFunctions(db);
drh1c928532002-01-31 15:54:21 +0000339 db->onError = OE_Default;
drh5cf8e8c2002-02-19 22:42:05 +0000340 db->priorNewRowid = 0;
drh247be432002-05-10 05:44:55 +0000341 db->magic = SQLITE_MAGIC_BUSY;
drh75897232000-05-29 14:26:00 +0000342
343 /* Open the backend database driver */
drha1b351a2001-09-14 16:42:12 +0000344 rc = sqliteBtreeOpen(zFilename, mode, MAX_PAGES, &db->pBe);
drh5e00f6c2001-09-13 13:46:56 +0000345 if( rc!=SQLITE_OK ){
346 switch( rc ){
347 default: {
drhaacc5432002-01-06 17:07:40 +0000348 sqliteSetString(pzErrMsg, "unable to open database: ", zFilename, 0);
drh5e00f6c2001-09-13 13:46:56 +0000349 }
350 }
drh75897232000-05-29 14:26:00 +0000351 sqliteFree(db);
drh5edc3122001-09-13 21:53:09 +0000352 sqliteStrRealloc(pzErrMsg);
drhbe0072d2001-09-13 14:46:09 +0000353 return 0;
drh75897232000-05-29 14:26:00 +0000354 }
355
drh58b95762000-06-02 01:17:37 +0000356 /* Attempt to read the schema */
357 rc = sqliteInit(db, pzErrMsg);
drhc67980b2002-06-14 20:54:14 +0000358 db->magic = SQLITE_MAGIC_OPEN;
drhdaffd0e2001-04-11 14:28:42 +0000359 if( sqlite_malloc_failed ){
drh6d4abfb2001-10-22 02:58:08 +0000360 sqlite_close(db);
drhdaffd0e2001-04-11 14:28:42 +0000361 goto no_mem_on_open;
362 }else if( rc!=SQLITE_OK && rc!=SQLITE_BUSY ){
drh58b95762000-06-02 01:17:37 +0000363 sqlite_close(db);
drh5edc3122001-09-13 21:53:09 +0000364 sqliteStrRealloc(pzErrMsg);
drh58b95762000-06-02 01:17:37 +0000365 return 0;
drhaacc5432002-01-06 17:07:40 +0000366 }else if( pzErrMsg ){
drhdaffd0e2001-04-11 14:28:42 +0000367 sqliteFree(*pzErrMsg);
drhbed86902000-06-02 13:27:59 +0000368 *pzErrMsg = 0;
drh75897232000-05-29 14:26:00 +0000369 }
drh491791a2002-07-18 00:34:09 +0000370
371 /* If the database is in formats 1 or 2, then upgrade it to
372 ** version 3. This will reconstruct all indices. If the
373 ** upgrade fails for any reason (ex: out of disk space, database
374 ** is read only, interrupt receive, etc.) then refuse to open.
375 */
376 if( db->file_format<3 ){
drhc2311722002-07-19 17:46:38 +0000377 char *zErr = 0;
378 InitData initData;
drh491791a2002-07-18 00:34:09 +0000379 int meta[SQLITE_N_BTREE_META];
380
drhc2311722002-07-19 17:46:38 +0000381 initData.db = db;
382 initData.pzErrMsg = &zErr;
drh491791a2002-07-18 00:34:09 +0000383 db->file_format = 3;
384 rc = sqlite_exec(db,
385 "BEGIN; SELECT name FROM sqlite_master WHERE type='table';",
386 upgrade_3_callback,
drhc2311722002-07-19 17:46:38 +0000387 &initData,
drh491791a2002-07-18 00:34:09 +0000388 &zErr);
389 if( rc==SQLITE_OK ){
390 sqliteBtreeGetMeta(db->pBe, meta);
391 meta[2] = 3;
392 sqliteBtreeUpdateMeta(db->pBe, meta);
393 sqlite_exec(db, "COMMIT", 0, 0, 0);
394 }
395 if( rc!=SQLITE_OK ){
396 sqliteSetString(pzErrMsg,
397 "unable to upgrade database to the version 2.6 format",
398 zErr ? ": " : 0, zErr, 0);
drhc2311722002-07-19 17:46:38 +0000399 sqlite_freemem(zErr);
drh491791a2002-07-18 00:34:09 +0000400 sqliteStrRealloc(pzErrMsg);
401 sqlite_close(db);
402 return 0;
403 }
drhc2311722002-07-19 17:46:38 +0000404 sqlite_freemem(zErr);
drh491791a2002-07-18 00:34:09 +0000405 }
406
407 /* Return a pointer to the newly opened database structure */
drh75897232000-05-29 14:26:00 +0000408 return db;
drhdaffd0e2001-04-11 14:28:42 +0000409
410no_mem_on_open:
411 sqliteSetString(pzErrMsg, "out of memory", 0);
412 sqliteStrRealloc(pzErrMsg);
413 return 0;
drh75897232000-05-29 14:26:00 +0000414}
415
416/*
drhaf9ff332002-01-16 21:00:27 +0000417** Return the ROWID of the most recent insert
418*/
419int sqlite_last_insert_rowid(sqlite *db){
420 return db->lastRowid;
421}
422
423/*
drhc8d30ac2002-04-12 10:08:59 +0000424** Return the number of changes in the most recent call to sqlite_exec().
425*/
426int sqlite_changes(sqlite *db){
427 return db->nChange;
428}
429
430/*
drh50e5dad2001-09-15 00:57:28 +0000431** Close an existing SQLite database
432*/
433void sqlite_close(sqlite *db){
drh8e0a2f92002-02-23 23:45:45 +0000434 HashElem *i;
drhc22bd472002-05-10 13:14:07 +0000435 if( sqliteSafetyCheck(db) || sqliteSafetyOn(db) ){ return; }
drh247be432002-05-10 05:44:55 +0000436 db->magic = SQLITE_MAGIC_CLOSED;
drh50e5dad2001-09-15 00:57:28 +0000437 sqliteBtreeClose(db->pBe);
drhe0bc4042002-06-25 01:09:11 +0000438 sqliteResetInternalSchema(db);
drhf57b3392001-10-08 13:22:32 +0000439 if( db->pBeTemp ){
440 sqliteBtreeClose(db->pBeTemp);
441 }
drh0bce8352002-02-28 00:41:10 +0000442 for(i=sqliteHashFirst(&db->aFunc); i; i=sqliteHashNext(i)){
443 FuncDef *pFunc, *pNext;
444 for(pFunc = (FuncDef*)sqliteHashData(i); pFunc; pFunc=pNext){
drh8e0a2f92002-02-23 23:45:45 +0000445 pNext = pFunc->pNext;
446 sqliteFree(pFunc);
447 }
448 }
drh0bce8352002-02-28 00:41:10 +0000449 sqliteHashClear(&db->aFunc);
drh75897232000-05-29 14:26:00 +0000450 sqliteFree(db);
451}
452
453/*
454** Return TRUE if the given SQL string ends in a semicolon.
drhce9079c2002-05-15 14:17:44 +0000455**
456** Special handling is require for CREATE TRIGGER statements.
457** Whenever the CREATE TRIGGER keywords are seen, the statement
458** must end with ";END;".
drh75897232000-05-29 14:26:00 +0000459*/
460int sqlite_complete(const char *zSql){
drhce9079c2002-05-15 14:17:44 +0000461 int isComplete = 1;
462 int requireEnd = 0;
463 int seenText = 0;
danielk1977c3f9bad2002-05-15 08:30:12 +0000464 int seenCreate = 0;
drh8c82b352000-12-10 18:23:50 +0000465 while( *zSql ){
466 switch( *zSql ){
467 case ';': {
468 isComplete = 1;
drhce9079c2002-05-15 14:17:44 +0000469 seenText = 1;
470 seenCreate = 0;
drh75897232000-05-29 14:26:00 +0000471 break;
drh8c82b352000-12-10 18:23:50 +0000472 }
473 case ' ':
474 case '\t':
475 case '\n':
476 case '\f': {
drh75897232000-05-29 14:26:00 +0000477 break;
drh8c82b352000-12-10 18:23:50 +0000478 }
drh969fa7c2002-02-18 18:30:32 +0000479 case '[': {
480 isComplete = 0;
drhce9079c2002-05-15 14:17:44 +0000481 seenText = 1;
482 seenCreate = 0;
drh969fa7c2002-02-18 18:30:32 +0000483 zSql++;
484 while( *zSql && *zSql!=']' ){ zSql++; }
485 if( *zSql==0 ) return 0;
486 break;
487 }
drhce9079c2002-05-15 14:17:44 +0000488 case '"':
drh8c82b352000-12-10 18:23:50 +0000489 case '\'': {
drhce9079c2002-05-15 14:17:44 +0000490 int c = *zSql;
drh8c82b352000-12-10 18:23:50 +0000491 isComplete = 0;
drhce9079c2002-05-15 14:17:44 +0000492 seenText = 1;
493 seenCreate = 0;
drh8c82b352000-12-10 18:23:50 +0000494 zSql++;
drhce9079c2002-05-15 14:17:44 +0000495 while( *zSql && *zSql!=c ){ zSql++; }
drh8c82b352000-12-10 18:23:50 +0000496 if( *zSql==0 ) return 0;
497 break;
498 }
499 case '-': {
500 if( zSql[1]!='-' ){
501 isComplete = 0;
drhce9079c2002-05-15 14:17:44 +0000502 seenCreate = 0;
drh8c82b352000-12-10 18:23:50 +0000503 break;
504 }
505 while( *zSql && *zSql!='\n' ){ zSql++; }
drhce9079c2002-05-15 14:17:44 +0000506 if( *zSql==0 ) return seenText && isComplete && requireEnd==0;
507 break;
508 }
509 case 'c':
510 case 'C': {
511 seenText = 1;
512 if( !isComplete ) break;
513 isComplete = 0;
514 if( sqliteStrNICmp(zSql, "create", 6)!=0 ) break;
515 if( !isspace(zSql[6]) ) break;
516 zSql += 5;
517 seenCreate = 1;
518 while( isspace(zSql[1]) ) zSql++;
519 if( sqliteStrNICmp(&zSql[1],"trigger", 7)!=0 ) break;
520 zSql += 7;
521 requireEnd++;
522 break;
523 }
524 case 't':
525 case 'T': {
526 seenText = 1;
527 if( !seenCreate ) break;
528 seenCreate = 0;
529 isComplete = 0;
530 if( sqliteStrNICmp(zSql, "trigger", 7)!=0 ) break;
531 if( !isspace(zSql[7]) ) break;
532 zSql += 6;
533 requireEnd++;
534 break;
535 }
536 case 'e':
537 case 'E': {
538 seenCreate = 0;
539 seenText = 1;
540 if( !isComplete ) break;
541 isComplete = 0;
542 if( requireEnd==0 ) break;
543 if( sqliteStrNICmp(zSql, "end", 3)!=0 ) break;
544 zSql += 2;
545 while( isspace(zSql[1]) ) zSql++;
546 if( zSql[1]==';' ){
547 zSql++;
548 isComplete = 1;
549 requireEnd--;
550 }
drh8c82b352000-12-10 18:23:50 +0000551 break;
drh9adf9ac2002-05-15 11:44:13 +0000552 }
drh8c82b352000-12-10 18:23:50 +0000553 default: {
drhce9079c2002-05-15 14:17:44 +0000554 seenCreate = 0;
555 seenText = 1;
drh8c82b352000-12-10 18:23:50 +0000556 isComplete = 0;
557 break;
558 }
drh75897232000-05-29 14:26:00 +0000559 }
drh8c82b352000-12-10 18:23:50 +0000560 zSql++;
drh75897232000-05-29 14:26:00 +0000561 }
drhce9079c2002-05-15 14:17:44 +0000562 return seenText && isComplete && requireEnd==0;
drh75897232000-05-29 14:26:00 +0000563}
564
565/*
drhbed86902000-06-02 13:27:59 +0000566** Execute SQL code. Return one of the SQLITE_ success/failure
567** codes. Also write an error message into memory obtained from
568** malloc() and make *pzErrMsg point to that message.
569**
570** If the SQL is a query, then for each row in the query result
571** the xCallback() function is called. pArg becomes the first
572** argument to xCallback(). If xCallback=NULL then no callback
573** is invoked, even for queries.
drh75897232000-05-29 14:26:00 +0000574*/
575int sqlite_exec(
576 sqlite *db, /* The database on which the SQL executes */
drh9f71c2e2001-11-03 23:57:09 +0000577 const char *zSql, /* The SQL to be executed */
drh75897232000-05-29 14:26:00 +0000578 sqlite_callback xCallback, /* Invoke this callback routine */
579 void *pArg, /* First argument to xCallback() */
580 char **pzErrMsg /* Write error messages here */
581){
582 Parse sParse;
drh75897232000-05-29 14:26:00 +0000583
584 if( pzErrMsg ) *pzErrMsg = 0;
drhc22bd472002-05-10 13:14:07 +0000585 if( sqliteSafetyOn(db) ) goto exec_misuse;
drh70562cd2002-07-13 17:23:21 +0000586 if( (db->flags & SQLITE_InTrans)!=0 && db->pid!=sqliteOsProcessId() ){
587 goto exec_misuse;
588 }
drh58b95762000-06-02 01:17:37 +0000589 if( (db->flags & SQLITE_Initialized)==0 ){
590 int rc = sqliteInit(db, pzErrMsg);
drhdaffd0e2001-04-11 14:28:42 +0000591 if( rc!=SQLITE_OK ){
592 sqliteStrRealloc(pzErrMsg);
drh247be432002-05-10 05:44:55 +0000593 sqliteSafetyOff(db);
drhdaffd0e2001-04-11 14:28:42 +0000594 return rc;
595 }
drh58b95762000-06-02 01:17:37 +0000596 }
drh491791a2002-07-18 00:34:09 +0000597 if( db->file_format<3 ){
598 sqliteSafetyOff(db);
599 sqliteSetString(pzErrMsg, "obsolete database file format", 0);
600 return SQLITE_ERROR;
601 }
drhc8d30ac2002-04-12 10:08:59 +0000602 if( db->recursionDepth==0 ){ db->nChange = 0; }
603 db->recursionDepth++;
drh75897232000-05-29 14:26:00 +0000604 memset(&sParse, 0, sizeof(sParse));
605 sParse.db = db;
drh5e00f6c2001-09-13 13:46:56 +0000606 sParse.pBe = db->pBe;
drh75897232000-05-29 14:26:00 +0000607 sParse.xCallback = xCallback;
608 sParse.pArg = pArg;
drh4c504392000-10-16 22:06:40 +0000609 sqliteRunParser(&sParse, zSql, pzErrMsg);
drhdaffd0e2001-04-11 14:28:42 +0000610 if( sqlite_malloc_failed ){
611 sqliteSetString(pzErrMsg, "out of memory", 0);
612 sParse.rc = SQLITE_NOMEM;
drh6d4abfb2001-10-22 02:58:08 +0000613 sqliteBtreeRollback(db->pBe);
614 if( db->pBeTemp ) sqliteBtreeRollback(db->pBeTemp);
615 db->flags &= ~SQLITE_InTrans;
drhe0bc4042002-06-25 01:09:11 +0000616 sqliteResetInternalSchema(db);
drhdaffd0e2001-04-11 14:28:42 +0000617 }
618 sqliteStrRealloc(pzErrMsg);
drh50e5dad2001-09-15 00:57:28 +0000619 if( sParse.rc==SQLITE_SCHEMA ){
drhe0bc4042002-06-25 01:09:11 +0000620 sqliteResetInternalSchema(db);
drh50e5dad2001-09-15 00:57:28 +0000621 }
drhc8d30ac2002-04-12 10:08:59 +0000622 db->recursionDepth--;
drhc22bd472002-05-10 13:14:07 +0000623 if( sqliteSafetyOff(db) ) goto exec_misuse;
drh4c504392000-10-16 22:06:40 +0000624 return sParse.rc;
drhc22bd472002-05-10 13:14:07 +0000625
626exec_misuse:
627 if( pzErrMsg ){
628 *pzErrMsg = 0;
629 sqliteSetString(pzErrMsg, sqlite_error_string(SQLITE_MISUSE), 0);
630 sqliteStrRealloc(pzErrMsg);
631 }
632 return SQLITE_MISUSE;
drh75897232000-05-29 14:26:00 +0000633}
drh2dfbbca2000-07-28 14:32:48 +0000634
635/*
drhc22bd472002-05-10 13:14:07 +0000636** Return a static string that describes the kind of error specified in the
637** argument.
drh247be432002-05-10 05:44:55 +0000638*/
drhc22bd472002-05-10 13:14:07 +0000639const char *sqlite_error_string(int rc){
640 const char *z;
641 switch( rc ){
642 case SQLITE_OK: z = "not an error"; break;
643 case SQLITE_ERROR: z = "SQL logic error or missing database"; break;
644 case SQLITE_INTERNAL: z = "internal SQLite implementation flaw"; break;
645 case SQLITE_PERM: z = "access permission denied"; break;
646 case SQLITE_ABORT: z = "callback requested query abort"; break;
647 case SQLITE_BUSY: z = "database is locked"; break;
648 case SQLITE_LOCKED: z = "database table is locked"; break;
649 case SQLITE_NOMEM: z = "out of memory"; break;
650 case SQLITE_READONLY: z = "attempt to write a readonly database"; break;
651 case SQLITE_INTERRUPT: z = "interrupted"; break;
652 case SQLITE_IOERR: z = "disk I/O error"; break;
653 case SQLITE_CORRUPT: z = "database disk image is malformed"; break;
654 case SQLITE_NOTFOUND: z = "table or record not found"; break;
655 case SQLITE_FULL: z = "database is full"; break;
656 case SQLITE_CANTOPEN: z = "unable to open database file"; break;
657 case SQLITE_PROTOCOL: z = "database locking protocol failure"; break;
658 case SQLITE_EMPTY: z = "table contains no data"; break;
659 case SQLITE_SCHEMA: z = "database schema has changed"; break;
660 case SQLITE_TOOBIG: z = "too much data for one table row"; break;
661 case SQLITE_CONSTRAINT: z = "constraint failed"; break;
662 case SQLITE_MISMATCH: z = "datatype mismatch"; break;
663 case SQLITE_MISUSE: z = "library routine called out of sequence";break;
664 default: z = "unknown error"; break;
drh247be432002-05-10 05:44:55 +0000665 }
drhc22bd472002-05-10 13:14:07 +0000666 return z;
drh247be432002-05-10 05:44:55 +0000667}
668
669/*
drh2dfbbca2000-07-28 14:32:48 +0000670** This routine implements a busy callback that sleeps and tries
671** again until a timeout value is reached. The timeout value is
672** an integer number of milliseconds passed in as the first
673** argument.
674*/
drhdaffd0e2001-04-11 14:28:42 +0000675static int sqliteDefaultBusyCallback(
drh2dfbbca2000-07-28 14:32:48 +0000676 void *Timeout, /* Maximum amount of time to wait */
677 const char *NotUsed, /* The name of the table that is busy */
678 int count /* Number of times table has been busy */
679){
drh8cfbf082001-09-19 13:22:39 +0000680#if SQLITE_MIN_SLEEP_MS==1
681 int delay = 10;
drh2dfbbca2000-07-28 14:32:48 +0000682 int prior_delay = 0;
683 int timeout = (int)Timeout;
684 int i;
685
686 for(i=1; i<count; i++){
687 prior_delay += delay;
688 delay = delay*2;
drh8cfbf082001-09-19 13:22:39 +0000689 if( delay>=1000 ){
690 delay = 1000;
691 prior_delay += 1000*(count - i - 1);
drh2dfbbca2000-07-28 14:32:48 +0000692 break;
693 }
694 }
drh3109e022001-10-09 13:46:01 +0000695 if( prior_delay + delay > timeout ){
696 delay = timeout - prior_delay;
drh2dfbbca2000-07-28 14:32:48 +0000697 if( delay<=0 ) return 0;
698 }
drh8cfbf082001-09-19 13:22:39 +0000699 sqliteOsSleep(delay);
drh2dfbbca2000-07-28 14:32:48 +0000700 return 1;
701#else
702 int timeout = (int)Timeout;
703 if( (count+1)*1000 > timeout ){
704 return 0;
705 }
drh8cfbf082001-09-19 13:22:39 +0000706 sqliteOsSleep(1000);
drh2dfbbca2000-07-28 14:32:48 +0000707 return 1;
708#endif
709}
710
711/*
712** This routine sets the busy callback for an Sqlite database to the
713** given callback function with the given argument.
714*/
715void sqlite_busy_handler(
716 sqlite *db,
717 int (*xBusy)(void*,const char*,int),
718 void *pArg
719){
720 db->xBusyCallback = xBusy;
721 db->pBusyArg = pArg;
722}
723
724/*
725** This routine installs a default busy handler that waits for the
726** specified number of milliseconds before returning 0.
727*/
728void sqlite_busy_timeout(sqlite *db, int ms){
729 if( ms>0 ){
drhdaffd0e2001-04-11 14:28:42 +0000730 sqlite_busy_handler(db, sqliteDefaultBusyCallback, (void*)ms);
drh2dfbbca2000-07-28 14:32:48 +0000731 }else{
732 sqlite_busy_handler(db, 0, 0);
733 }
734}
drh4c504392000-10-16 22:06:40 +0000735
736/*
737** Cause any pending operation to stop at its earliest opportunity.
738*/
739void sqlite_interrupt(sqlite *db){
740 db->flags |= SQLITE_Interrupt;
741}
drhfa86c412002-02-02 15:01:15 +0000742
743/*
744** Windows systems should call this routine to free memory that
745** is returned in the in the errmsg parameter of sqlite_open() when
746** SQLite is a DLL. For some reason, it does not work to call free()
747** directly.
748**
749** Note that we need to call free() not sqliteFree() here, since every
750** string that is exported from SQLite should have already passed through
751** sqliteStrRealloc().
752*/
753void sqlite_freemem(void *p){ free(p); }
754
755/*
756** Windows systems need functions to call to return the sqlite_version
757** and sqlite_encoding strings.
758*/
759const char *sqlite_libversion(void){ return sqlite_version; }
760const char *sqlite_libencoding(void){ return sqlite_encoding; }
drh8e0a2f92002-02-23 23:45:45 +0000761
762/*
763** Create new user-defined functions. The sqlite_create_function()
764** routine creates a regular function and sqlite_create_aggregate()
765** creates an aggregate function.
766**
767** Passing a NULL xFunc argument or NULL xStep and xFinalize arguments
768** disables the function. Calling sqlite_create_function() with the
769** same name and number of arguments as a prior call to
770** sqlite_create_aggregate() disables the prior call to
771** sqlite_create_aggregate(), and vice versa.
772**
773** If nArg is -1 it means that this function will accept any number
774** of arguments, including 0.
775*/
776int sqlite_create_function(
777 sqlite *db, /* Add the function to this database connection */
778 const char *zName, /* Name of the function to add */
779 int nArg, /* Number of arguments */
drh1350b032002-02-27 19:00:20 +0000780 void (*xFunc)(sqlite_func*,int,const char**), /* The implementation */
781 void *pUserData /* User data */
drh8e0a2f92002-02-23 23:45:45 +0000782){
drh0bce8352002-02-28 00:41:10 +0000783 FuncDef *p;
drhc22bd472002-05-10 13:14:07 +0000784 if( db==0 || zName==0 || sqliteSafetyCheck(db) ) return 1;
drh0bce8352002-02-28 00:41:10 +0000785 p = sqliteFindFunction(db, zName, strlen(zName), nArg, 1);
drh4e0f9952002-02-27 01:53:13 +0000786 if( p==0 ) return 1;
drh8e0a2f92002-02-23 23:45:45 +0000787 p->xFunc = xFunc;
788 p->xStep = 0;
789 p->xFinalize = 0;
drh1350b032002-02-27 19:00:20 +0000790 p->pUserData = pUserData;
drh8e0a2f92002-02-23 23:45:45 +0000791 return 0;
792}
793int sqlite_create_aggregate(
794 sqlite *db, /* Add the function to this database connection */
795 const char *zName, /* Name of the function to add */
796 int nArg, /* Number of arguments */
drh1350b032002-02-27 19:00:20 +0000797 void (*xStep)(sqlite_func*,int,const char**), /* The step function */
798 void (*xFinalize)(sqlite_func*), /* The finalizer */
799 void *pUserData /* User data */
drh8e0a2f92002-02-23 23:45:45 +0000800){
drh0bce8352002-02-28 00:41:10 +0000801 FuncDef *p;
drhc22bd472002-05-10 13:14:07 +0000802 if( db==0 || zName==0 || sqliteSafetyCheck(db) ) return 1;
drh0bce8352002-02-28 00:41:10 +0000803 p = sqliteFindFunction(db, zName, strlen(zName), nArg, 1);
drh4e0f9952002-02-27 01:53:13 +0000804 if( p==0 ) return 1;
drh8e0a2f92002-02-23 23:45:45 +0000805 p->xFunc = 0;
806 p->xStep = xStep;
807 p->xFinalize = xFinalize;
drh1350b032002-02-27 19:00:20 +0000808 p->pUserData = pUserData;
drh8e0a2f92002-02-23 23:45:45 +0000809 return 0;
810}
drhc9b84a12002-06-20 11:36:48 +0000811
812/*
drh411995d2002-06-25 19:31:18 +0000813** Change the datatype for all functions with a given name. See the
814** header comment for the prototype of this function in sqlite.h for
815** additional information.
drhc9b84a12002-06-20 11:36:48 +0000816*/
817int sqlite_function_type(sqlite *db, const char *zName, int dataType){
818 FuncDef *p = (FuncDef*)sqliteHashFind(&db->aFunc, zName, strlen(zName));
819 while( p ){
820 p->dataType = dataType;
821 p = p->pNext;
822 }
drhf46f9052002-06-22 02:33:38 +0000823 return SQLITE_OK;
drhc9b84a12002-06-20 11:36:48 +0000824}
drh411995d2002-06-25 19:31:18 +0000825
826/*
827** Attempt to open the file named in the argument as the auxiliary database
828** file. The auxiliary database file is used to store TEMP tables. But
829** by using this API, it is possible to trick SQLite into opening two
830** separate databases and acting on them as if they were one.
831**
832** This routine closes the existing auxiliary database file, which will
833** cause any previously created TEMP tables to be created.
834**
835** The zName parameter can be a NULL pointer or an empty string to cause
836** a temporary file to be opened and automatically deleted when closed.
837*/
838int sqlite_open_aux_file(sqlite *db, const char *zName, char **pzErrMsg){
839 int rc;
840 if( zName && zName[0]==0 ) zName = 0;
841 if( sqliteSafetyOn(db) ) goto openaux_misuse;
842 sqliteResetInternalSchema(db);
843 if( db->pBeTemp!=0 ){
844 sqliteBtreeClose(db->pBeTemp);
845 }
846 rc = sqliteBtreeOpen(zName, 0, MAX_PAGES, &db->pBeTemp);
847 if( rc ){
848 if( zName==0 ) zName = "a temporary file";
849 sqliteSetString(pzErrMsg, "unable to open ", zName,
850 ": ", sqlite_error_string(rc), 0);
851 sqliteStrRealloc(pzErrMsg);
852 sqliteSafetyOff(db);
853 return rc;
854 }
855 rc = sqliteInit(db, pzErrMsg);
856 if( sqliteSafetyOff(db) ) goto openaux_misuse;
857 sqliteStrRealloc(pzErrMsg);
858 return rc;
859
860openaux_misuse:
861 sqliteSetString(pzErrMsg, sqlite_error_string(SQLITE_MISUSE), 0);
862 sqliteStrRealloc(pzErrMsg);
863 return SQLITE_MISUSE;
864}