blob: 0ffe0040970c647b51cb5d7f8360c4ed3f6676a6 [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**
danielk1977172bc392004-05-22 08:09:11 +000017** $Id: main.c,v 1.183 2004/05/22 08:09:40 danielk1977 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
danielk19774adee202004-05-08 08:23:19 +000025** from sqlite3Init into the sqlite3InitCallback.
drhc2311722002-07-19 17:46:38 +000026*/
27typedef struct {
28 sqlite *db; /* The database being initialized */
29 char **pzErrMsg; /* Error message stored here */
30} InitData;
31
drh8bf8dc92003-05-17 17:35:10 +000032/*
33** Fill the InitData structure with an error message that indicates
34** that the database is corrupt.
35*/
drh1d85d932004-02-14 23:05:52 +000036static void corruptSchema(InitData *pData, const char *zExtra){
danielk19774adee202004-05-08 08:23:19 +000037 sqlite3SetString(pData->pzErrMsg, "malformed database schema",
drh1d85d932004-02-14 23:05:52 +000038 zExtra!=0 && zExtra[0]!=0 ? " - " : (char*)0, zExtra, (char*)0);
drh8bf8dc92003-05-17 17:35:10 +000039}
drhc2311722002-07-19 17:46:38 +000040
41/*
drh75897232000-05-29 14:26:00 +000042** This is the callback routine for the code that initializes the
danielk19774adee202004-05-08 08:23:19 +000043** database. See sqlite3Init() below for additional information.
drh382c0242001-10-06 16:33:02 +000044**
45** Each callback contains the following information:
drh28037572000-08-02 13:47:41 +000046**
drh4a324312001-12-21 14:30:42 +000047** argv[0] = "file-format" or "schema-cookie" or "table" or "index"
drhe3c41372001-09-17 20:25:58 +000048** argv[1] = table or index name or meta statement type.
49** argv[2] = root page number for table or index. NULL for meta.
drhe78e8282003-01-19 03:59:45 +000050** argv[3] = SQL text for a CREATE TABLE or CREATE INDEX statement.
drh1c2d8412003-03-31 00:30:47 +000051** argv[4] = "1" for temporary files, "0" for main database, "2" or more
52** for auxiliary database files.
drhd78eeee2001-09-13 16:18:53 +000053**
drh75897232000-05-29 14:26:00 +000054*/
drhc2311722002-07-19 17:46:38 +000055static
danielk19774adee202004-05-08 08:23:19 +000056int sqlite3InitCallback(void *pInit, int argc, char **argv, char **azColName){
drhc2311722002-07-19 17:46:38 +000057 InitData *pData = (InitData*)pInit;
drhd78eeee2001-09-13 16:18:53 +000058 int nErr = 0;
drh75897232000-05-29 14:26:00 +000059
drhe0bc4042002-06-25 01:09:11 +000060 assert( argc==5 );
drh98e3e602003-07-27 17:26:22 +000061 if( argv==0 ) return 0; /* Might happen if EMPTY_RESULT_CALLBACKS are on */
drh8bf8dc92003-05-17 17:35:10 +000062 if( argv[0]==0 ){
drh1d85d932004-02-14 23:05:52 +000063 corruptSchema(pData, 0);
drh8bf8dc92003-05-17 17:35:10 +000064 return 1;
65 }
drhd78eeee2001-09-13 16:18:53 +000066 switch( argv[0][0] ){
drh17f71932002-02-21 12:01:27 +000067 case 'v':
drhd78eeee2001-09-13 16:18:53 +000068 case 'i':
drh17f71932002-02-21 12:01:27 +000069 case 't': { /* CREATE TABLE, CREATE INDEX, or CREATE VIEW statements */
drh1d85d932004-02-14 23:05:52 +000070 sqlite *db = pData->db;
drh8bf8dc92003-05-17 17:35:10 +000071 if( argv[2]==0 || argv[4]==0 ){
drh1d85d932004-02-14 23:05:52 +000072 corruptSchema(pData, 0);
drh8bf8dc92003-05-17 17:35:10 +000073 return 1;
74 }
drhadbca9c2001-09-27 15:11:53 +000075 if( argv[3] && argv[3][0] ){
drh17f71932002-02-21 12:01:27 +000076 /* Call the parser to process a CREATE TABLE, INDEX or VIEW.
drh1d85d932004-02-14 23:05:52 +000077 ** But because db->init.busy is set to 1, no VDBE code is generated
drh382c0242001-10-06 16:33:02 +000078 ** or executed. All the parser does is build the internal data
drh17f71932002-02-21 12:01:27 +000079 ** structures that describe the table, index, or view.
drh382c0242001-10-06 16:33:02 +000080 */
drh1d85d932004-02-14 23:05:52 +000081 char *zErr;
82 assert( db->init.busy );
83 db->init.iDb = atoi(argv[4]);
84 assert( db->init.iDb>=0 && db->init.iDb<db->nDb );
85 db->init.newTnum = atoi(argv[2]);
danielk197724b03fd2004-05-10 10:34:34 +000086 if( sqlite3_exec(db, argv[3], 0, 0, &zErr) ){
drh1d85d932004-02-14 23:05:52 +000087 corruptSchema(pData, zErr);
danielk197724b03fd2004-05-10 10:34:34 +000088 sqlite3_freemem(zErr);
drh1d85d932004-02-14 23:05:52 +000089 }
90 db->init.iDb = 0;
drhadbca9c2001-09-27 15:11:53 +000091 }else{
drh382c0242001-10-06 16:33:02 +000092 /* If the SQL column is blank it means this is an index that
93 ** was created to be the PRIMARY KEY or to fulfill a UNIQUE
drhaacc5432002-01-06 17:07:40 +000094 ** constraint for a CREATE TABLE. The index should have already
drh382c0242001-10-06 16:33:02 +000095 ** been created when we processed the CREATE TABLE. All we have
drhaacc5432002-01-06 17:07:40 +000096 ** to do here is record the root page number for that index.
drh382c0242001-10-06 16:33:02 +000097 */
drhd24cc422003-03-27 12:51:24 +000098 int iDb;
99 Index *pIndex;
100
101 iDb = atoi(argv[4]);
drh1d85d932004-02-14 23:05:52 +0000102 assert( iDb>=0 && iDb<db->nDb );
danielk19774adee202004-05-08 08:23:19 +0000103 pIndex = sqlite3FindIndex(db, argv[1], db->aDb[iDb].zName);
drhadbca9c2001-09-27 15:11:53 +0000104 if( pIndex==0 || pIndex->tnum!=0 ){
drhda9e0342002-01-10 14:31:48 +0000105 /* This can occur if there exists an index on a TEMP table which
106 ** has the same name as another index on a permanent index. Since
107 ** the permanent table is hidden by the TEMP table, we can also
108 ** safely ignore the index on the permanent table.
109 */
110 /* Do Nothing */;
drhadbca9c2001-09-27 15:11:53 +0000111 }else{
112 pIndex->tnum = atoi(argv[2]);
113 }
114 }
drhd78eeee2001-09-13 16:18:53 +0000115 break;
116 }
117 default: {
118 /* This can not happen! */
119 nErr = 1;
120 assert( nErr==0 );
121 }
drh28037572000-08-02 13:47:41 +0000122 }
drh75897232000-05-29 14:26:00 +0000123 return nErr;
124}
125
126/*
drh58b95762000-06-02 01:17:37 +0000127** Attempt to read the database schema and initialize internal
drh1c2d8412003-03-31 00:30:47 +0000128** data structures for a single database file. The index of the
129** database file is given by iDb. iDb==0 is used for the main
130** database. iDb==1 should never be used. iDb>=2 is used for
131** auxiliary databases. Return one of the SQLITE_ error codes to
drh58b95762000-06-02 01:17:37 +0000132** indicate success or failure.
drh75897232000-05-29 14:26:00 +0000133*/
danielk19774adee202004-05-08 08:23:19 +0000134static int sqlite3InitOne(sqlite *db, int iDb, char **pzErrMsg){
drh58b95762000-06-02 01:17:37 +0000135 int rc;
drhe0bc4042002-06-25 01:09:11 +0000136 BtCursor *curMain;
137 int size;
138 Table *pTab;
139 char *azArg[6];
drh1c2d8412003-03-31 00:30:47 +0000140 char zDbNum[30];
drha3b321d2004-05-11 09:31:31 +0000141 int meta[10];
drhc2311722002-07-19 17:46:38 +0000142 InitData initData;
drh58b95762000-06-02 01:17:37 +0000143
144 /*
145 ** The master database table has a structure like this
146 */
drh75897232000-05-29 14:26:00 +0000147 static char master_schema[] =
drhe0bc4042002-06-25 01:09:11 +0000148 "CREATE TABLE sqlite_master(\n"
149 " type text,\n"
150 " name text,\n"
151 " tbl_name text,\n"
152 " rootpage integer,\n"
153 " sql text\n"
154 ")"
155 ;
156 static char temp_master_schema[] =
157 "CREATE TEMP TABLE sqlite_temp_master(\n"
drh75897232000-05-29 14:26:00 +0000158 " type text,\n"
159 " name text,\n"
160 " tbl_name text,\n"
drhadbca9c2001-09-27 15:11:53 +0000161 " rootpage integer,\n"
drh75897232000-05-29 14:26:00 +0000162 " sql text\n"
163 ")"
164 ;
165
drhe0bc4042002-06-25 01:09:11 +0000166 /* The following SQL will read the schema from the master tables.
drh75897232000-05-29 14:26:00 +0000167 */
danielk1977bf57cfe2004-05-11 09:50:02 +0000168 static char init_script1[] =
169 "SELECT type, name, rootpage, sql, 1 FROM sqlite_temp_master";
170 static char init_script2[] =
drhe0bc4042002-06-25 01:09:11 +0000171 "SELECT type, name, rootpage, sql, 0 FROM sqlite_master";
drh603240c2002-03-05 01:11:12 +0000172
drh1c2d8412003-03-31 00:30:47 +0000173 assert( iDb>=0 && iDb!=1 && iDb<db->nDb );
174
drhe0bc4042002-06-25 01:09:11 +0000175 /* Construct the schema tables: sqlite_master and sqlite_temp_master
drh58b95762000-06-02 01:17:37 +0000176 */
danielk19774adee202004-05-08 08:23:19 +0000177 sqlite3SafetyOff(db);
drhe0bc4042002-06-25 01:09:11 +0000178 azArg[0] = "table";
179 azArg[1] = MASTER_NAME;
danielk19778e150812004-05-10 01:17:37 +0000180 azArg[2] = "1";
drhe0bc4042002-06-25 01:09:11 +0000181 azArg[3] = master_schema;
drh1c2d8412003-03-31 00:30:47 +0000182 sprintf(zDbNum, "%d", iDb);
183 azArg[4] = zDbNum;
drhe0bc4042002-06-25 01:09:11 +0000184 azArg[5] = 0;
drhc2311722002-07-19 17:46:38 +0000185 initData.db = db;
186 initData.pzErrMsg = pzErrMsg;
danielk19774adee202004-05-08 08:23:19 +0000187 sqlite3InitCallback(&initData, 5, azArg, 0);
188 pTab = sqlite3FindTable(db, MASTER_NAME, "main");
drhe0bc4042002-06-25 01:09:11 +0000189 if( pTab ){
190 pTab->readOnly = 1;
drhd8bc7082000-06-07 23:51:50 +0000191 }
drh1c2d8412003-03-31 00:30:47 +0000192 if( iDb==0 ){
193 azArg[1] = TEMP_MASTER_NAME;
194 azArg[3] = temp_master_schema;
195 azArg[4] = "1";
danielk19774adee202004-05-08 08:23:19 +0000196 sqlite3InitCallback(&initData, 5, azArg, 0);
197 pTab = sqlite3FindTable(db, TEMP_MASTER_NAME, "temp");
drh1c2d8412003-03-31 00:30:47 +0000198 if( pTab ){
199 pTab->readOnly = 1;
200 }
drhe0bc4042002-06-25 01:09:11 +0000201 }
danielk19774adee202004-05-08 08:23:19 +0000202 sqlite3SafetyOn(db);
drhe0bc4042002-06-25 01:09:11 +0000203
204 /* Create a cursor to hold the database open
205 */
drh1c2d8412003-03-31 00:30:47 +0000206 if( db->aDb[iDb].pBt==0 ) return SQLITE_OK;
danielk19778e150812004-05-10 01:17:37 +0000207 rc = sqlite3BtreeCursor(db->aDb[iDb].pBt, MASTER_ROOT, 0, 0, 0, &curMain);
drhf328bc82004-05-10 23:29:49 +0000208 if( rc!=SQLITE_OK && rc!=SQLITE_EMPTY ){
danielk197724b03fd2004-05-10 10:34:34 +0000209 sqlite3SetString(pzErrMsg, sqlite3_error_string(rc), (char*)0);
drh92ed08a2002-07-30 18:43:40 +0000210 return rc;
211 }
drhe0bc4042002-06-25 01:09:11 +0000212
drha3b321d2004-05-11 09:31:31 +0000213 /* Get the database meta information.
214 **
215 ** Meta values are as follows:
216 ** meta[0] Schema cookie. Changes with each schema change.
217 ** meta[1] File format of schema layer.
218 ** meta[2] Size of the page cache.
219 ** meta[3] Synchronous setting. 1:off, 2:normal, 3:full
danielk1977172bc392004-05-22 08:09:11 +0000220 ** meta[4] Db text encoding. 1:UTF-8 2:UTF-16 LE 3:UTF-16 BE
drha3b321d2004-05-11 09:31:31 +0000221 ** meta[5] Pragma temp_store value. See comments on BtreeFactory
222 ** meta[6]
223 ** meta[7]
224 ** meta[8]
225 ** meta[9]
danielk1977172bc392004-05-22 08:09:11 +0000226 **
227 ** Note: The hash defined TEXT_Utf* symbols in sqliteInt.h correspond to
228 ** the possible values of meta[4].
drhe0bc4042002-06-25 01:09:11 +0000229 */
drhf328bc82004-05-10 23:29:49 +0000230 if( rc==SQLITE_OK ){
231 int i;
drha3b321d2004-05-11 09:31:31 +0000232 for(i=0; rc==SQLITE_OK && i<sizeof(meta)/sizeof(meta[0]); i++){
233 rc = sqlite3BtreeGetMeta(db->aDb[iDb].pBt, i+1, &meta[i]);
danielk19774adee202004-05-08 08:23:19 +0000234 }
drhf328bc82004-05-10 23:29:49 +0000235 if( rc ){
236 sqlite3SetString(pzErrMsg, sqlite3_error_string(rc), (char*)0);
237 sqlite3BtreeCloseCursor(curMain);
238 return rc;
239 }
240 }else{
241 memset(meta, 0, sizeof(meta));
drhe0bc4042002-06-25 01:09:11 +0000242 }
drha3b321d2004-05-11 09:31:31 +0000243 db->aDb[iDb].schema_cookie = meta[0];
drh1c2d8412003-03-31 00:30:47 +0000244 if( iDb==0 ){
drha3b321d2004-05-11 09:31:31 +0000245 db->next_cookie = meta[0];
246 db->file_format = meta[1];
danielk1977172bc392004-05-22 08:09:11 +0000247 if( meta[4] ){
248 /* If meta[4] is still zero, then we are opening a previously empty
249 ** file. Leave db->enc to the default value set by the sqlite3_open()
250 ** call in this case.
251 */
252 db->enc = (u8)meta[4];
253 }
drha3b321d2004-05-11 09:31:31 +0000254 size = meta[2];
drh1c2d8412003-03-31 00:30:47 +0000255 if( size==0 ){ size = MAX_PAGES; }
256 db->cache_size = size;
drha3b321d2004-05-11 09:31:31 +0000257 db->safety_level = meta[3];
258 if( meta[5]>0 && meta[5]<=2 && db->temp_store==0 ){
259 db->temp_store = meta[5];
drh1bdd9b52004-04-23 17:04:44 +0000260 }
drh1c2d8412003-03-31 00:30:47 +0000261 if( db->safety_level==0 ) db->safety_level = 2;
drhe0bc4042002-06-25 01:09:11 +0000262
drh1c2d8412003-03-31 00:30:47 +0000263 /*
drhf328bc82004-05-10 23:29:49 +0000264 ** file_format==1 Version 3.0.0.
drh1c2d8412003-03-31 00:30:47 +0000265 */
266 if( db->file_format==0 ){
267 /* This happens if the database was initially empty */
drhf328bc82004-05-10 23:29:49 +0000268 db->file_format = 1;
269 }else if( db->file_format>1 ){
danielk19774adee202004-05-08 08:23:19 +0000270 sqlite3BtreeCloseCursor(curMain);
271 sqlite3SetString(pzErrMsg, "unsupported file format", (char*)0);
drh1c2d8412003-03-31 00:30:47 +0000272 return SQLITE_ERROR;
273 }
drha3b321d2004-05-11 09:31:31 +0000274 }else if( db->file_format!=meta[1] ){
275 if( meta[1]==0 ){
danielk19774adee202004-05-08 08:23:19 +0000276 sqlite3SetString(pzErrMsg, "cannot attach empty database: ",
drh41743982003-12-06 21:43:55 +0000277 db->aDb[iDb].zName, (char*)0);
drh2d458342003-04-05 03:42:26 +0000278 }else{
danielk19774adee202004-05-08 08:23:19 +0000279 sqlite3SetString(pzErrMsg, "incompatible file format in auxiliary "
drh41743982003-12-06 21:43:55 +0000280 "database: ", db->aDb[iDb].zName, (char*)0);
drh2d458342003-04-05 03:42:26 +0000281 }
danielk19774adee202004-05-08 08:23:19 +0000282 sqlite3BtreeClose(db->aDb[iDb].pBt);
drh1c2d8412003-03-31 00:30:47 +0000283 db->aDb[iDb].pBt = 0;
284 return SQLITE_FORMAT;
drh28037572000-08-02 13:47:41 +0000285 }
danielk19774adee202004-05-08 08:23:19 +0000286 sqlite3BtreeSetCacheSize(db->aDb[iDb].pBt, db->cache_size);
drha3b321d2004-05-11 09:31:31 +0000287 sqlite3BtreeSetSafetyLevel(db->aDb[iDb].pBt, meta[3]==0 ? 2 : meta[3]);
drhaacc5432002-01-06 17:07:40 +0000288
drhe0bc4042002-06-25 01:09:11 +0000289 /* Read the schema information out of the schema tables
drhaacc5432002-01-06 17:07:40 +0000290 */
drh1d85d932004-02-14 23:05:52 +0000291 assert( db->init.busy );
danielk19774adee202004-05-08 08:23:19 +0000292 sqlite3SafetyOff(db);
drhf328bc82004-05-10 23:29:49 +0000293 if( rc==SQLITE_EMPTY ){
294 /* For an empty database, there is nothing to read */
295 rc = SQLITE_OK;
drh1c2d8412003-03-31 00:30:47 +0000296 }else{
drhf328bc82004-05-10 23:29:49 +0000297 if( iDb==0 ){
danielk1977bf57cfe2004-05-11 09:50:02 +0000298 /* This SQL statement tries to read the temp.* schema from the
danielk19778d059842004-05-12 11:24:02 +0000299 ** sqlite_temp_master table. It might return SQLITE_EMPTY.
danielk1977bf57cfe2004-05-11 09:50:02 +0000300 */
danielk1977bf57cfe2004-05-11 09:50:02 +0000301 rc = sqlite3_exec(db, init_script1, sqlite3InitCallback, &initData, 0);
danielk1977bf57cfe2004-05-11 09:50:02 +0000302 if( rc==SQLITE_OK || rc==SQLITE_EMPTY ){
303 rc = sqlite3_exec(db, init_script2, sqlite3InitCallback, &initData, 0);
304 }
drhf328bc82004-05-10 23:29:49 +0000305 }else{
306 char *zSql = 0;
307 sqlite3SetString(&zSql,
308 "SELECT type, name, rootpage, sql, ", zDbNum, " FROM \"",
309 db->aDb[iDb].zName, "\".sqlite_master", (char*)0);
310 rc = sqlite3_exec(db, zSql, sqlite3InitCallback, &initData, 0);
311 sqliteFree(zSql);
312 }
313 sqlite3SafetyOn(db);
314 sqlite3BtreeCloseCursor(curMain);
drh1c2d8412003-03-31 00:30:47 +0000315 }
danielk197724b03fd2004-05-10 10:34:34 +0000316 if( sqlite3_malloc_failed ){
danielk19774adee202004-05-08 08:23:19 +0000317 sqlite3SetString(pzErrMsg, "out of memory", (char*)0);
drh1d85d932004-02-14 23:05:52 +0000318 rc = SQLITE_NOMEM;
danielk19774adee202004-05-08 08:23:19 +0000319 sqlite3ResetInternalSchema(db, 0);
drhe0bc4042002-06-25 01:09:11 +0000320 }
drh1d85d932004-02-14 23:05:52 +0000321 if( rc==SQLITE_OK ){
drh8bf8dc92003-05-17 17:35:10 +0000322 DbSetProperty(db, iDb, DB_SchemaLoaded);
323 if( iDb==0 ){
324 DbSetProperty(db, 1, DB_SchemaLoaded);
325 }
drh1c2d8412003-03-31 00:30:47 +0000326 }else{
danielk19774adee202004-05-08 08:23:19 +0000327 sqlite3ResetInternalSchema(db, iDb);
drh1c2d8412003-03-31 00:30:47 +0000328 }
drh1d85d932004-02-14 23:05:52 +0000329 return rc;
drh1c2d8412003-03-31 00:30:47 +0000330}
331
332/*
333** Initialize all database files - the main database file, the file
334** used to store temporary tables, and any additional database files
335** created using ATTACH statements. Return a success code. If an
336** error occurs, write an error message into *pzErrMsg.
337**
338** After the database is initialized, the SQLITE_Initialized
339** bit is set in the flags field of the sqlite structure. An
340** attempt is made to initialize the database as soon as it
341** is opened. If that fails (perhaps because another process
342** has the sqlite_master table locked) than another attempt
343** is made the first time the database is accessed.
344*/
danielk19774adee202004-05-08 08:23:19 +0000345int sqlite3Init(sqlite *db, char **pzErrMsg){
drh1c2d8412003-03-31 00:30:47 +0000346 int i, rc;
347
drh1d85d932004-02-14 23:05:52 +0000348 if( db->init.busy ) return SQLITE_OK;
drh1c2d8412003-03-31 00:30:47 +0000349 assert( (db->flags & SQLITE_Initialized)==0 );
350 rc = SQLITE_OK;
drh1d85d932004-02-14 23:05:52 +0000351 db->init.busy = 1;
drh1c2d8412003-03-31 00:30:47 +0000352 for(i=0; rc==SQLITE_OK && i<db->nDb; i++){
drh8bf8dc92003-05-17 17:35:10 +0000353 if( DbHasProperty(db, i, DB_SchemaLoaded) ) continue;
354 assert( i!=1 ); /* Should have been initialized together with 0 */
danielk19774adee202004-05-08 08:23:19 +0000355 rc = sqlite3InitOne(db, i, pzErrMsg);
drh8ef83ff2004-02-12 15:31:21 +0000356 if( rc ){
danielk19774adee202004-05-08 08:23:19 +0000357 sqlite3ResetInternalSchema(db, i);
drh8ef83ff2004-02-12 15:31:21 +0000358 }
drh1c2d8412003-03-31 00:30:47 +0000359 }
drh1d85d932004-02-14 23:05:52 +0000360 db->init.busy = 0;
drh1c2d8412003-03-31 00:30:47 +0000361 if( rc==SQLITE_OK ){
drh58b95762000-06-02 01:17:37 +0000362 db->flags |= SQLITE_Initialized;
danielk19774adee202004-05-08 08:23:19 +0000363 sqlite3CommitInternalChanges(db);
drh2d71ca92004-02-10 02:27:04 +0000364 }
365
drh2d71ca92004-02-10 02:27:04 +0000366 if( rc!=SQLITE_OK ){
drhe0bc4042002-06-25 01:09:11 +0000367 db->flags &= ~SQLITE_Initialized;
drh58b95762000-06-02 01:17:37 +0000368 }
drh1c2d8412003-03-31 00:30:47 +0000369 return rc;
drh58b95762000-06-02 01:17:37 +0000370}
371
372/*
drhb217a572000-08-22 13:40:18 +0000373** The version of the library
374*/
drh096c4972002-07-19 19:03:41 +0000375const char rcsid[] = "@(#) \044Id: SQLite version " SQLITE_VERSION " $";
danielk197724b03fd2004-05-10 10:34:34 +0000376const char sqlite3_version[] = SQLITE_VERSION;
drhb217a572000-08-22 13:40:18 +0000377
378/*
drh297ecf12001-04-05 15:57:13 +0000379** Does the library expect data to be encoded as UTF-8 or iso8859? The
380** following global constant always lets us know.
381*/
382#ifdef SQLITE_UTF8
danielk197724b03fd2004-05-10 10:34:34 +0000383const char sqlite3_encoding[] = "UTF-8";
drh297ecf12001-04-05 15:57:13 +0000384#else
danielk197724b03fd2004-05-10 10:34:34 +0000385const char sqlite3_encoding[] = "iso8859";
drh297ecf12001-04-05 15:57:13 +0000386#endif
387
388/*
drhd3d39e92004-05-20 22:16:29 +0000389** This is the default collating function named "BINARY" which is always
390** available.
391*/
392static int binaryCollatingFunc(
393 void *NotUsed,
394 int nKey1, const void *pKey1,
395 int nKey2, const void *pKey2
396){
397 int rc, n;
398 n = nKey1<nKey2 ? nKey1 : nKey2;
399 rc = memcmp(pKey1, pKey2, n);
400 if( rc==0 ){
401 rc = nKey1 - nKey2;
402 }
403 return rc;
404}
405
406/*
drhaf9ff332002-01-16 21:00:27 +0000407** Return the ROWID of the most recent insert
408*/
danielk197724b03fd2004-05-10 10:34:34 +0000409int sqlite3_last_insert_rowid(sqlite *db){
drhaf9ff332002-01-16 21:00:27 +0000410 return db->lastRowid;
411}
412
413/*
danielk197724b03fd2004-05-10 10:34:34 +0000414** Return the number of changes in the most recent call to sqlite3_exec().
drhc8d30ac2002-04-12 10:08:59 +0000415*/
danielk197724b03fd2004-05-10 10:34:34 +0000416int sqlite3_changes(sqlite *db){
drhc8d30ac2002-04-12 10:08:59 +0000417 return db->nChange;
418}
419
rdcf146a772004-02-25 22:51:06 +0000420/*
421** Return the number of changes produced by the last INSERT, UPDATE, or
422** DELETE statement to complete execution. The count does not include
423** changes due to SQL statements executed in trigger programs that were
424** triggered by that statement
425*/
danielk197724b03fd2004-05-10 10:34:34 +0000426int sqlite3_last_statement_changes(sqlite *db){
rdcb0c374f2004-02-20 22:53:38 +0000427 return db->lsChange;
428}
429
drhc8d30ac2002-04-12 10:08:59 +0000430/*
drh50e5dad2001-09-15 00:57:28 +0000431** Close an existing SQLite database
432*/
danielk197724b03fd2004-05-10 10:34:34 +0000433void sqlite3_close(sqlite *db){
drh8e0a2f92002-02-23 23:45:45 +0000434 HashElem *i;
drh001bbcb2003-03-19 03:14:00 +0000435 int j;
drh94e92032003-02-16 22:21:32 +0000436 db->want_to_close = 1;
danielk19774adee202004-05-08 08:23:19 +0000437 if( sqlite3SafetyCheck(db) || sqlite3SafetyOn(db) ){
drh94e92032003-02-16 22:21:32 +0000438 /* printf("DID NOT CLOSE\n"); fflush(stdout); */
439 return;
440 }
drh247be432002-05-10 05:44:55 +0000441 db->magic = SQLITE_MAGIC_CLOSED;
drh001bbcb2003-03-19 03:14:00 +0000442 for(j=0; j<db->nDb; j++){
drh4d189ca2004-02-12 18:46:38 +0000443 struct Db *pDb = &db->aDb[j];
444 if( pDb->pBt ){
danielk19774adee202004-05-08 08:23:19 +0000445 sqlite3BtreeClose(pDb->pBt);
drh4d189ca2004-02-12 18:46:38 +0000446 pDb->pBt = 0;
drh113088e2003-03-20 01:16:58 +0000447 }
drhf57b3392001-10-08 13:22:32 +0000448 }
danielk19774adee202004-05-08 08:23:19 +0000449 sqlite3ResetInternalSchema(db, 0);
drh1c2d8412003-03-31 00:30:47 +0000450 assert( db->nDb<=2 );
451 assert( db->aDb==db->aDbStatic );
drh0bce8352002-02-28 00:41:10 +0000452 for(i=sqliteHashFirst(&db->aFunc); i; i=sqliteHashNext(i)){
453 FuncDef *pFunc, *pNext;
454 for(pFunc = (FuncDef*)sqliteHashData(i); pFunc; pFunc=pNext){
drh8e0a2f92002-02-23 23:45:45 +0000455 pNext = pFunc->pNext;
456 sqliteFree(pFunc);
457 }
458 }
danielk19774adee202004-05-08 08:23:19 +0000459 sqlite3HashClear(&db->aFunc);
danielk19776622cce2004-05-20 11:00:52 +0000460 sqlite3Error(db, SQLITE_OK, 0); /* Deallocates any cached error strings. */
drh75897232000-05-29 14:26:00 +0000461 sqliteFree(db);
462}
463
464/*
drh001bbcb2003-03-19 03:14:00 +0000465** Rollback all database files.
466*/
danielk19774adee202004-05-08 08:23:19 +0000467void sqlite3RollbackAll(sqlite *db){
drh001bbcb2003-03-19 03:14:00 +0000468 int i;
469 for(i=0; i<db->nDb; i++){
470 if( db->aDb[i].pBt ){
danielk19774adee202004-05-08 08:23:19 +0000471 sqlite3BtreeRollback(db->aDb[i].pBt);
drh001bbcb2003-03-19 03:14:00 +0000472 db->aDb[i].inTrans = 0;
473 }
474 }
danielk19774adee202004-05-08 08:23:19 +0000475 sqlite3ResetInternalSchema(db, 0);
476 /* sqlite3RollbackInternalChanges(db); */
drh001bbcb2003-03-19 03:14:00 +0000477}
478
479/*
drha1f9b5e2004-02-14 16:31:02 +0000480** Execute SQL code. Return one of the SQLITE_ success/failure
481** codes. Also write an error message into memory obtained from
482** malloc() and make *pzErrMsg point to that message.
483**
484** If the SQL is a query, then for each row in the query result
485** the xCallback() function is called. pArg becomes the first
486** argument to xCallback(). If xCallback=NULL then no callback
487** is invoked, even for queries.
drh75897232000-05-29 14:26:00 +0000488*/
danielk197724b03fd2004-05-10 10:34:34 +0000489int sqlite3_exec(
drh75897232000-05-29 14:26:00 +0000490 sqlite *db, /* The database on which the SQL executes */
drh9f71c2e2001-11-03 23:57:09 +0000491 const char *zSql, /* The SQL to be executed */
drh75897232000-05-29 14:26:00 +0000492 sqlite_callback xCallback, /* Invoke this callback routine */
493 void *pArg, /* First argument to xCallback() */
drha1f9b5e2004-02-14 16:31:02 +0000494 char **pzErrMsg /* Write error messages here */
495){
496 int rc = SQLITE_OK;
497 const char *zLeftover;
498 sqlite_vm *pVm;
499 int nRetry = 0;
500 int nChange = 0;
drhd6502752004-02-16 03:44:01 +0000501 int nCallback;
drha1f9b5e2004-02-14 16:31:02 +0000502
503 if( zSql==0 ) return SQLITE_OK;
504 while( rc==SQLITE_OK && zSql[0] ){
505 pVm = 0;
danielk197724b03fd2004-05-10 10:34:34 +0000506 rc = sqlite3_compile(db, zSql, &zLeftover, &pVm, pzErrMsg);
drha1f9b5e2004-02-14 16:31:02 +0000507 if( rc!=SQLITE_OK ){
danielk197724b03fd2004-05-10 10:34:34 +0000508 assert( pVm==0 || sqlite3_malloc_failed );
drha1f9b5e2004-02-14 16:31:02 +0000509 return rc;
510 }
511 if( pVm==0 ){
512 /* This happens if the zSql input contained only whitespace */
513 break;
514 }
515 db->nChange += nChange;
drhd6502752004-02-16 03:44:01 +0000516 nCallback = 0;
drha1f9b5e2004-02-14 16:31:02 +0000517 while(1){
518 int nArg;
519 char **azArg, **azCol;
danielk197724b03fd2004-05-10 10:34:34 +0000520 rc = sqlite3_step(pVm, &nArg, (const char***)&azArg,(const char***)&azCol);
drha1f9b5e2004-02-14 16:31:02 +0000521 if( rc==SQLITE_ROW ){
drhd6502752004-02-16 03:44:01 +0000522 if( xCallback!=0 && xCallback(pArg, nArg, azArg, azCol) ){
danielk197724b03fd2004-05-10 10:34:34 +0000523 sqlite3_finalize(pVm, 0);
drha1f9b5e2004-02-14 16:31:02 +0000524 return SQLITE_ABORT;
525 }
drhd6502752004-02-16 03:44:01 +0000526 nCallback++;
drha1f9b5e2004-02-14 16:31:02 +0000527 }else{
drhd6502752004-02-16 03:44:01 +0000528 if( rc==SQLITE_DONE && nCallback==0
529 && (db->flags & SQLITE_NullCallback)!=0 && xCallback!=0 ){
530 xCallback(pArg, nArg, azArg, azCol);
531 }
danielk197724b03fd2004-05-10 10:34:34 +0000532 rc = sqlite3_finalize(pVm, pzErrMsg);
drha1f9b5e2004-02-14 16:31:02 +0000533 if( rc==SQLITE_SCHEMA && nRetry<2 ){
534 nRetry++;
535 rc = SQLITE_OK;
536 break;
537 }
538 if( db->pVdbe==0 ){
539 nChange = db->nChange;
540 }
541 nRetry = 0;
542 zSql = zLeftover;
543 while( isspace(zSql[0]) ) zSql++;
544 break;
545 }
546 }
547 }
548 return rc;
549}
550
551
552/*
553** Compile a single statement of SQL into a virtual machine. Return one
554** of the SQLITE_ success/failure codes. Also write an error message into
555** memory obtained from malloc() and make *pzErrMsg point to that message.
556*/
danielk197724b03fd2004-05-10 10:34:34 +0000557int sqlite3_compile(
drha1f9b5e2004-02-14 16:31:02 +0000558 sqlite *db, /* The database on which the SQL executes */
559 const char *zSql, /* The SQL to be executed */
drhb86ccfb2003-01-28 23:13:10 +0000560 const char **pzTail, /* OUT: Next statement after the first */
561 sqlite_vm **ppVm, /* OUT: The virtual machine */
562 char **pzErrMsg /* OUT: Write error messages here */
drh75897232000-05-29 14:26:00 +0000563){
564 Parse sParse;
drh75897232000-05-29 14:26:00 +0000565
drh799550b2003-01-18 17:04:08 +0000566 if( pzErrMsg ) *pzErrMsg = 0;
danielk19774adee202004-05-08 08:23:19 +0000567 if( sqlite3SafetyOn(db) ) goto exec_misuse;
drh1d85d932004-02-14 23:05:52 +0000568 if( !db->init.busy ){
569 if( (db->flags & SQLITE_Initialized)==0 ){
570 int rc, cnt = 1;
danielk19774adee202004-05-08 08:23:19 +0000571 while( (rc = sqlite3Init(db, pzErrMsg))==SQLITE_BUSY
drh1d85d932004-02-14 23:05:52 +0000572 && db->xBusyCallback
573 && db->xBusyCallback(db->pBusyArg, "", cnt++)!=0 ){}
574 if( rc!=SQLITE_OK ){
danielk19774adee202004-05-08 08:23:19 +0000575 sqlite3StrRealloc(pzErrMsg);
576 sqlite3SafetyOff(db);
drh1d85d932004-02-14 23:05:52 +0000577 return rc;
578 }
579 if( pzErrMsg ){
580 sqliteFree(*pzErrMsg);
581 *pzErrMsg = 0;
582 }
583 }
drh58b95762000-06-02 01:17:37 +0000584 }
drh1d85d932004-02-14 23:05:52 +0000585 assert( (db->flags & SQLITE_Initialized)!=0 || db->init.busy );
drh326dce72003-01-29 14:06:07 +0000586 if( db->pVdbe==0 ){ db->nChange = 0; }
drh75897232000-05-29 14:26:00 +0000587 memset(&sParse, 0, sizeof(sParse));
588 sParse.db = db;
danielk19774adee202004-05-08 08:23:19 +0000589 sqlite3RunParser(&sParse, zSql, pzErrMsg);
drh276fd582004-03-17 18:44:45 +0000590 if( db->xTrace && !db->init.busy ){
rdcaa5707c2004-03-04 19:09:20 +0000591 /* Trace only the statment that was compiled.
592 ** Make a copy of that part of the SQL string since zSQL is const
593 ** and we must pass a zero terminated string to the trace function
594 ** The copy is unnecessary if the tail pointer is pointing at the
595 ** beginnig or end of the SQL string.
596 */
597 if( sParse.zTail && sParse.zTail!=zSql && *sParse.zTail ){
598 char *tmpSql = sqliteStrNDup(zSql, sParse.zTail - zSql);
599 if( tmpSql ){
600 db->xTrace(db->pTraceArg, tmpSql);
601 free(tmpSql);
602 }else{
603 /* If a memory error occurred during the copy,
604 ** trace entire SQL string and fall through to the
danielk197724b03fd2004-05-10 10:34:34 +0000605 ** sqlite3_malloc_failed test to report the error.
rdcaa5707c2004-03-04 19:09:20 +0000606 */
607 db->xTrace(db->pTraceArg, zSql);
608 }
609 }else{
610 db->xTrace(db->pTraceArg, zSql);
611 }
612 }
danielk197724b03fd2004-05-10 10:34:34 +0000613 if( sqlite3_malloc_failed ){
danielk19774adee202004-05-08 08:23:19 +0000614 sqlite3SetString(pzErrMsg, "out of memory", (char*)0);
drhdaffd0e2001-04-11 14:28:42 +0000615 sParse.rc = SQLITE_NOMEM;
danielk19774adee202004-05-08 08:23:19 +0000616 sqlite3RollbackAll(db);
617 sqlite3ResetInternalSchema(db, 0);
drh001bbcb2003-03-19 03:14:00 +0000618 db->flags &= ~SQLITE_InTrans;
drhdaffd0e2001-04-11 14:28:42 +0000619 }
drh326dce72003-01-29 14:06:07 +0000620 if( sParse.rc==SQLITE_DONE ) sParse.rc = SQLITE_OK;
drhb798fa62002-09-03 19:43:23 +0000621 if( sParse.rc!=SQLITE_OK && pzErrMsg && *pzErrMsg==0 ){
danielk197724b03fd2004-05-10 10:34:34 +0000622 sqlite3SetString(pzErrMsg, sqlite3_error_string(sParse.rc), (char*)0);
drhb798fa62002-09-03 19:43:23 +0000623 }
danielk19774adee202004-05-08 08:23:19 +0000624 sqlite3StrRealloc(pzErrMsg);
drh50e5dad2001-09-15 00:57:28 +0000625 if( sParse.rc==SQLITE_SCHEMA ){
danielk19774adee202004-05-08 08:23:19 +0000626 sqlite3ResetInternalSchema(db, 0);
drh50e5dad2001-09-15 00:57:28 +0000627 }
drha1f9b5e2004-02-14 16:31:02 +0000628 assert( ppVm );
629 *ppVm = (sqlite_vm*)sParse.pVdbe;
630 if( pzTail ) *pzTail = sParse.zTail;
danielk19774adee202004-05-08 08:23:19 +0000631 if( sqlite3SafetyOff(db) ) goto exec_misuse;
drh4c504392000-10-16 22:06:40 +0000632 return sParse.rc;
drhc22bd472002-05-10 13:14:07 +0000633
634exec_misuse:
635 if( pzErrMsg ){
636 *pzErrMsg = 0;
danielk197724b03fd2004-05-10 10:34:34 +0000637 sqlite3SetString(pzErrMsg, sqlite3_error_string(SQLITE_MISUSE), (char*)0);
danielk19774adee202004-05-08 08:23:19 +0000638 sqlite3StrRealloc(pzErrMsg);
drhc22bd472002-05-10 13:14:07 +0000639 }
640 return SQLITE_MISUSE;
drh75897232000-05-29 14:26:00 +0000641}
drh2dfbbca2000-07-28 14:32:48 +0000642
drh50457892003-09-06 01:10:47 +0000643
644/*
drhb86ccfb2003-01-28 23:13:10 +0000645** The following routine destroys a virtual machine that is created by
danielk197724b03fd2004-05-10 10:34:34 +0000646** the sqlite3_compile() routine.
drhb86ccfb2003-01-28 23:13:10 +0000647**
648** The integer returned is an SQLITE_ success/failure code that describes
649** the result of executing the virtual machine. An error message is
650** written into memory obtained from malloc and *pzErrMsg is made to
651** point to that error if pzErrMsg is not NULL. The calling routine
danielk197724b03fd2004-05-10 10:34:34 +0000652** should use sqlite3_freemem() to delete the message when it has finished
drhb86ccfb2003-01-28 23:13:10 +0000653** with it.
654*/
danielk197724b03fd2004-05-10 10:34:34 +0000655int sqlite3_finalize(
drhb86ccfb2003-01-28 23:13:10 +0000656 sqlite_vm *pVm, /* The virtual machine to be destroyed */
657 char **pzErrMsg /* OUT: Write error messages here */
658){
danielk19774adee202004-05-08 08:23:19 +0000659 int rc = sqlite3VdbeFinalize((Vdbe*)pVm, pzErrMsg);
660 sqlite3StrRealloc(pzErrMsg);
drh483750b2003-01-29 18:46:51 +0000661 return rc;
drhb86ccfb2003-01-28 23:13:10 +0000662}
663
664/*
drh50457892003-09-06 01:10:47 +0000665** Terminate the current execution of a virtual machine then
666** reset the virtual machine back to its starting state so that it
667** can be reused. Any error message resulting from the prior execution
668** is written into *pzErrMsg. A success code from the prior execution
669** is returned.
danielk1977999af642003-07-22 09:24:43 +0000670*/
danielk197724b03fd2004-05-10 10:34:34 +0000671int sqlite3_reset(
danielk1977999af642003-07-22 09:24:43 +0000672 sqlite_vm *pVm, /* The virtual machine to be destroyed */
drh50457892003-09-06 01:10:47 +0000673 char **pzErrMsg /* OUT: Write error messages here */
danielk1977999af642003-07-22 09:24:43 +0000674){
danielk19774adee202004-05-08 08:23:19 +0000675 int rc = sqlite3VdbeReset((Vdbe*)pVm, pzErrMsg);
676 sqlite3VdbeMakeReady((Vdbe*)pVm, -1, 0);
677 sqlite3StrRealloc(pzErrMsg);
danielk1977999af642003-07-22 09:24:43 +0000678 return rc;
679}
680
681/*
drhc22bd472002-05-10 13:14:07 +0000682** Return a static string that describes the kind of error specified in the
683** argument.
drh247be432002-05-10 05:44:55 +0000684*/
danielk197724b03fd2004-05-10 10:34:34 +0000685const char *sqlite3_error_string(int rc){
drhc22bd472002-05-10 13:14:07 +0000686 const char *z;
687 switch( rc ){
688 case SQLITE_OK: z = "not an error"; break;
689 case SQLITE_ERROR: z = "SQL logic error or missing database"; break;
690 case SQLITE_INTERNAL: z = "internal SQLite implementation flaw"; break;
691 case SQLITE_PERM: z = "access permission denied"; break;
692 case SQLITE_ABORT: z = "callback requested query abort"; break;
693 case SQLITE_BUSY: z = "database is locked"; break;
694 case SQLITE_LOCKED: z = "database table is locked"; break;
695 case SQLITE_NOMEM: z = "out of memory"; break;
696 case SQLITE_READONLY: z = "attempt to write a readonly database"; break;
697 case SQLITE_INTERRUPT: z = "interrupted"; break;
698 case SQLITE_IOERR: z = "disk I/O error"; break;
699 case SQLITE_CORRUPT: z = "database disk image is malformed"; break;
700 case SQLITE_NOTFOUND: z = "table or record not found"; break;
701 case SQLITE_FULL: z = "database is full"; break;
702 case SQLITE_CANTOPEN: z = "unable to open database file"; break;
703 case SQLITE_PROTOCOL: z = "database locking protocol failure"; break;
704 case SQLITE_EMPTY: z = "table contains no data"; break;
705 case SQLITE_SCHEMA: z = "database schema has changed"; break;
706 case SQLITE_TOOBIG: z = "too much data for one table row"; break;
707 case SQLITE_CONSTRAINT: z = "constraint failed"; break;
708 case SQLITE_MISMATCH: z = "datatype mismatch"; break;
709 case SQLITE_MISUSE: z = "library routine called out of sequence";break;
drh8766c342002-11-09 00:33:15 +0000710 case SQLITE_NOLFS: z = "kernel lacks large file support"; break;
drhed6c8672003-01-12 18:02:16 +0000711 case SQLITE_AUTH: z = "authorization denied"; break;
jplyon892f6712003-06-12 08:59:00 +0000712 case SQLITE_FORMAT: z = "auxiliary database format error"; break;
drh7c972de2003-09-06 22:18:07 +0000713 case SQLITE_RANGE: z = "bind index out of range"; break;
drhc602f9a2004-02-12 19:01:04 +0000714 case SQLITE_NOTADB: z = "file is encrypted or is not a database";break;
drhc22bd472002-05-10 13:14:07 +0000715 default: z = "unknown error"; break;
drh247be432002-05-10 05:44:55 +0000716 }
drhc22bd472002-05-10 13:14:07 +0000717 return z;
drh247be432002-05-10 05:44:55 +0000718}
719
720/*
drh2dfbbca2000-07-28 14:32:48 +0000721** This routine implements a busy callback that sleeps and tries
722** again until a timeout value is reached. The timeout value is
723** an integer number of milliseconds passed in as the first
724** argument.
725*/
drhdaffd0e2001-04-11 14:28:42 +0000726static int sqliteDefaultBusyCallback(
drh2dfbbca2000-07-28 14:32:48 +0000727 void *Timeout, /* Maximum amount of time to wait */
728 const char *NotUsed, /* The name of the table that is busy */
729 int count /* Number of times table has been busy */
730){
drh8cfbf082001-09-19 13:22:39 +0000731#if SQLITE_MIN_SLEEP_MS==1
drhd1bec472004-01-15 13:29:31 +0000732 static const char delays[] =
733 { 1, 2, 5, 10, 15, 20, 25, 25, 25, 50, 50, 50, 100};
734 static const short int totals[] =
735 { 0, 1, 3, 8, 18, 33, 53, 78, 103, 128, 178, 228, 287};
736# define NDELAY (sizeof(delays)/sizeof(delays[0]))
drh2dfbbca2000-07-28 14:32:48 +0000737 int timeout = (int)Timeout;
drhd1bec472004-01-15 13:29:31 +0000738 int delay, prior;
drh2dfbbca2000-07-28 14:32:48 +0000739
drhd1bec472004-01-15 13:29:31 +0000740 if( count <= NDELAY ){
741 delay = delays[count-1];
742 prior = totals[count-1];
743 }else{
744 delay = delays[NDELAY-1];
745 prior = totals[NDELAY-1] + delay*(count-NDELAY-1);
drh2dfbbca2000-07-28 14:32:48 +0000746 }
drhd1bec472004-01-15 13:29:31 +0000747 if( prior + delay > timeout ){
748 delay = timeout - prior;
drh2dfbbca2000-07-28 14:32:48 +0000749 if( delay<=0 ) return 0;
750 }
danielk19774adee202004-05-08 08:23:19 +0000751 sqlite3OsSleep(delay);
drh2dfbbca2000-07-28 14:32:48 +0000752 return 1;
753#else
754 int timeout = (int)Timeout;
755 if( (count+1)*1000 > timeout ){
756 return 0;
757 }
danielk19774adee202004-05-08 08:23:19 +0000758 sqlite3OsSleep(1000);
drh2dfbbca2000-07-28 14:32:48 +0000759 return 1;
760#endif
761}
762
763/*
764** This routine sets the busy callback for an Sqlite database to the
765** given callback function with the given argument.
766*/
danielk197724b03fd2004-05-10 10:34:34 +0000767void sqlite3_busy_handler(
drh2dfbbca2000-07-28 14:32:48 +0000768 sqlite *db,
769 int (*xBusy)(void*,const char*,int),
770 void *pArg
771){
772 db->xBusyCallback = xBusy;
773 db->pBusyArg = pArg;
774}
775
danielk1977348bb5d2003-10-18 09:37:26 +0000776#ifndef SQLITE_OMIT_PROGRESS_CALLBACK
777/*
778** This routine sets the progress callback for an Sqlite database to the
779** given callback function with the given argument. The progress callback will
780** be invoked every nOps opcodes.
781*/
danielk197724b03fd2004-05-10 10:34:34 +0000782void sqlite3_progress_handler(
danielk1977348bb5d2003-10-18 09:37:26 +0000783 sqlite *db,
784 int nOps,
785 int (*xProgress)(void*),
786 void *pArg
787){
788 if( nOps>0 ){
789 db->xProgress = xProgress;
790 db->nProgressOps = nOps;
791 db->pProgressArg = pArg;
792 }else{
793 db->xProgress = 0;
794 db->nProgressOps = 0;
795 db->pProgressArg = 0;
796 }
797}
798#endif
799
800
drh2dfbbca2000-07-28 14:32:48 +0000801/*
802** This routine installs a default busy handler that waits for the
803** specified number of milliseconds before returning 0.
804*/
danielk197724b03fd2004-05-10 10:34:34 +0000805void sqlite3_busy_timeout(sqlite *db, int ms){
drh2dfbbca2000-07-28 14:32:48 +0000806 if( ms>0 ){
danielk197724b03fd2004-05-10 10:34:34 +0000807 sqlite3_busy_handler(db, sqliteDefaultBusyCallback, (void*)ms);
drh2dfbbca2000-07-28 14:32:48 +0000808 }else{
danielk197724b03fd2004-05-10 10:34:34 +0000809 sqlite3_busy_handler(db, 0, 0);
drh2dfbbca2000-07-28 14:32:48 +0000810 }
811}
drh4c504392000-10-16 22:06:40 +0000812
813/*
814** Cause any pending operation to stop at its earliest opportunity.
815*/
danielk197724b03fd2004-05-10 10:34:34 +0000816void sqlite3_interrupt(sqlite *db){
drh4c504392000-10-16 22:06:40 +0000817 db->flags |= SQLITE_Interrupt;
818}
drhfa86c412002-02-02 15:01:15 +0000819
820/*
821** Windows systems should call this routine to free memory that
danielk197724b03fd2004-05-10 10:34:34 +0000822** is returned in the in the errmsg parameter of sqlite3_open() when
drhfa86c412002-02-02 15:01:15 +0000823** SQLite is a DLL. For some reason, it does not work to call free()
824** directly.
825**
826** Note that we need to call free() not sqliteFree() here, since every
827** string that is exported from SQLite should have already passed through
danielk19774adee202004-05-08 08:23:19 +0000828** sqlite3StrRealloc().
drhfa86c412002-02-02 15:01:15 +0000829*/
danielk197724b03fd2004-05-10 10:34:34 +0000830void sqlite3_freemem(void *p){ free(p); }
drhfa86c412002-02-02 15:01:15 +0000831
832/*
danielk197724b03fd2004-05-10 10:34:34 +0000833** Windows systems need functions to call to return the sqlite3_version
834** and sqlite3_encoding strings since they are unable to access constants
drhe78e8282003-01-19 03:59:45 +0000835** within DLLs.
drhfa86c412002-02-02 15:01:15 +0000836*/
danielk197724b03fd2004-05-10 10:34:34 +0000837const char *sqlite3_libversion(void){ return sqlite3_version; }
838const char *sqlite3_libencoding(void){ return sqlite3_encoding; }
drh8e0a2f92002-02-23 23:45:45 +0000839
840/*
danielk197724b03fd2004-05-10 10:34:34 +0000841** Create new user-defined functions. The sqlite3_create_function()
842** routine creates a regular function and sqlite3_create_aggregate()
drh8e0a2f92002-02-23 23:45:45 +0000843** creates an aggregate function.
844**
845** Passing a NULL xFunc argument or NULL xStep and xFinalize arguments
danielk197724b03fd2004-05-10 10:34:34 +0000846** disables the function. Calling sqlite3_create_function() with the
drh8e0a2f92002-02-23 23:45:45 +0000847** same name and number of arguments as a prior call to
danielk197724b03fd2004-05-10 10:34:34 +0000848** sqlite3_create_aggregate() disables the prior call to
849** sqlite3_create_aggregate(), and vice versa.
drh8e0a2f92002-02-23 23:45:45 +0000850**
851** If nArg is -1 it means that this function will accept any number
drh268380c2004-02-25 13:47:31 +0000852** of arguments, including 0. The maximum allowed value of nArg is 127.
drh8e0a2f92002-02-23 23:45:45 +0000853*/
danielk197724b03fd2004-05-10 10:34:34 +0000854int sqlite3_create_function(
drh8e0a2f92002-02-23 23:45:45 +0000855 sqlite *db, /* Add the function to this database connection */
856 const char *zName, /* Name of the function to add */
857 int nArg, /* Number of arguments */
drh1350b032002-02-27 19:00:20 +0000858 void (*xFunc)(sqlite_func*,int,const char**), /* The implementation */
859 void *pUserData /* User data */
drh8e0a2f92002-02-23 23:45:45 +0000860){
drh0bce8352002-02-28 00:41:10 +0000861 FuncDef *p;
drh4b59ab52002-08-24 18:24:51 +0000862 int nName;
danielk19774adee202004-05-08 08:23:19 +0000863 if( db==0 || zName==0 || sqlite3SafetyCheck(db) ) return 1;
drh268380c2004-02-25 13:47:31 +0000864 if( nArg<-1 || nArg>127 ) return 1;
drh4b59ab52002-08-24 18:24:51 +0000865 nName = strlen(zName);
866 if( nName>255 ) return 1;
danielk19774adee202004-05-08 08:23:19 +0000867 p = sqlite3FindFunction(db, zName, nName, nArg, 1);
drh4e0f9952002-02-27 01:53:13 +0000868 if( p==0 ) return 1;
drh8e0a2f92002-02-23 23:45:45 +0000869 p->xFunc = xFunc;
870 p->xStep = 0;
871 p->xFinalize = 0;
drh1350b032002-02-27 19:00:20 +0000872 p->pUserData = pUserData;
drh8e0a2f92002-02-23 23:45:45 +0000873 return 0;
874}
danielk197724b03fd2004-05-10 10:34:34 +0000875int sqlite3_create_aggregate(
drh8e0a2f92002-02-23 23:45:45 +0000876 sqlite *db, /* Add the function to this database connection */
877 const char *zName, /* Name of the function to add */
878 int nArg, /* Number of arguments */
drh1350b032002-02-27 19:00:20 +0000879 void (*xStep)(sqlite_func*,int,const char**), /* The step function */
880 void (*xFinalize)(sqlite_func*), /* The finalizer */
881 void *pUserData /* User data */
drh8e0a2f92002-02-23 23:45:45 +0000882){
drh0bce8352002-02-28 00:41:10 +0000883 FuncDef *p;
drh4b59ab52002-08-24 18:24:51 +0000884 int nName;
danielk19774adee202004-05-08 08:23:19 +0000885 if( db==0 || zName==0 || sqlite3SafetyCheck(db) ) return 1;
drh268380c2004-02-25 13:47:31 +0000886 if( nArg<-1 || nArg>127 ) return 1;
drh4b59ab52002-08-24 18:24:51 +0000887 nName = strlen(zName);
888 if( nName>255 ) return 1;
danielk19774adee202004-05-08 08:23:19 +0000889 p = sqlite3FindFunction(db, zName, nName, nArg, 1);
drh4e0f9952002-02-27 01:53:13 +0000890 if( p==0 ) return 1;
drh8e0a2f92002-02-23 23:45:45 +0000891 p->xFunc = 0;
892 p->xStep = xStep;
893 p->xFinalize = xFinalize;
drh1350b032002-02-27 19:00:20 +0000894 p->pUserData = pUserData;
drh8e0a2f92002-02-23 23:45:45 +0000895 return 0;
896}
drhc9b84a12002-06-20 11:36:48 +0000897
898/*
drh411995d2002-06-25 19:31:18 +0000899** Change the datatype for all functions with a given name. See the
900** header comment for the prototype of this function in sqlite.h for
901** additional information.
drhc9b84a12002-06-20 11:36:48 +0000902*/
danielk197724b03fd2004-05-10 10:34:34 +0000903int sqlite3_function_type(sqlite *db, const char *zName, int dataType){
danielk19774adee202004-05-08 08:23:19 +0000904 FuncDef *p = (FuncDef*)sqlite3HashFind(&db->aFunc, zName, strlen(zName));
drhc9b84a12002-06-20 11:36:48 +0000905 while( p ){
906 p->dataType = dataType;
907 p = p->pNext;
908 }
drhf46f9052002-06-22 02:33:38 +0000909 return SQLITE_OK;
drhc9b84a12002-06-20 11:36:48 +0000910}
drh411995d2002-06-25 19:31:18 +0000911
912/*
drh18de4822003-01-16 16:28:53 +0000913** Register a trace function. The pArg from the previously registered trace
914** is returned.
915**
916** A NULL trace function means that no tracing is executes. A non-NULL
917** trace is a pointer to a function that is invoked at the start of each
danielk197724b03fd2004-05-10 10:34:34 +0000918** sqlite3_exec().
drh18de4822003-01-16 16:28:53 +0000919*/
danielk197724b03fd2004-05-10 10:34:34 +0000920void *sqlite3_trace(sqlite *db, void (*xTrace)(void*,const char*), void *pArg){
drh18de4822003-01-16 16:28:53 +0000921 void *pOld = db->pTraceArg;
922 db->xTrace = xTrace;
923 db->pTraceArg = pArg;
924 return pOld;
drh0d1a6432003-04-03 15:46:04 +0000925}
paulb0208cc2003-04-13 18:26:49 +0000926
drhaa940ea2004-01-15 02:44:03 +0000927/*** EXPERIMENTAL ***
928**
929** Register a function to be invoked when a transaction comments.
930** If either function returns non-zero, then the commit becomes a
931** rollback.
932*/
danielk197724b03fd2004-05-10 10:34:34 +0000933void *sqlite3_commit_hook(
drhaa940ea2004-01-15 02:44:03 +0000934 sqlite *db, /* Attach the hook to this database */
935 int (*xCallback)(void*), /* Function to invoke on each commit */
936 void *pArg /* Argument to the function */
937){
938 void *pOld = db->pCommitArg;
939 db->xCommitCallback = xCallback;
940 db->pCommitArg = pArg;
941 return pOld;
942}
943
944
paulb0208cc2003-04-13 18:26:49 +0000945/*
drh13bff812003-04-15 01:19:47 +0000946** This routine is called to create a connection to a database BTree
947** driver. If zFilename is the name of a file, then that file is
948** opened and used. If zFilename is the magic name ":memory:" then
949** the database is stored in memory (and is thus forgotten as soon as
950** the connection is closed.) If zFilename is NULL then the database
951** is for temporary use only and is deleted as soon as the connection
952** is closed.
953**
drh13bff812003-04-15 01:19:47 +0000954** A temporary database can be either a disk file (that is automatically
955** deleted when the file is closed) or a set of red-black trees held in memory,
956** depending on the values of the TEMP_STORE compile-time macro and the
957** db->temp_store variable, according to the following chart:
958**
959** TEMP_STORE db->temp_store Location of temporary database
960** ---------- -------------- ------------------------------
961** 0 any file
962** 1 1 file
963** 1 2 memory
964** 1 0 file
965** 2 1 file
966** 2 2 memory
967** 2 0 memory
968** 3 any memory
paulb0208cc2003-04-13 18:26:49 +0000969*/
danielk19774adee202004-05-08 08:23:19 +0000970int sqlite3BtreeFactory(
paulb0208cc2003-04-13 18:26:49 +0000971 const sqlite *db, /* Main database when opening aux otherwise 0 */
972 const char *zFilename, /* Name of the file containing the BTree database */
973 int omitJournal, /* if TRUE then do not journal this file */
974 int nCache, /* How many pages in the page cache */
danielk19774adee202004-05-08 08:23:19 +0000975 Btree **ppBtree /* Pointer to new Btree object written here */
976){
danielk19774adee202004-05-08 08:23:19 +0000977 int btree_flags = 0;
978
drheec983e2004-05-08 10:11:36 +0000979 assert( ppBtree != 0);
danielk19774adee202004-05-08 08:23:19 +0000980 if( omitJournal ){
981 btree_flags |= BTREE_OMIT_JOURNAL;
paulb0208cc2003-04-13 18:26:49 +0000982 }
danielk19774adee202004-05-08 08:23:19 +0000983 if( !zFilename ){
984 btree_flags |= BTREE_MEMORY;
985 }
986
987 return sqlite3BtreeOpen(zFilename, ppBtree, nCache, btree_flags);
paulb0208cc2003-04-13 18:26:49 +0000988}
danielk19774adee202004-05-08 08:23:19 +0000989
danielk19774ad17132004-05-21 01:47:26 +0000990/*
991** Return UTF-8 encoded English language explanation of the most recent
992** error.
993*/
danielk19776622cce2004-05-20 11:00:52 +0000994const char *sqlite3_errmsg(sqlite3 *db){
danielk19774ad17132004-05-21 01:47:26 +0000995 if( !db ){
996 /* If db is NULL, then assume that a malloc() failed during an
997 ** sqlite3_open() call.
998 */
999 return sqlite3_error_string(SQLITE_NOMEM);
1000 }
danielk19776622cce2004-05-20 11:00:52 +00001001 if( db->zErrMsg ){
1002 return db->zErrMsg;
1003 }
1004 return sqlite3_error_string(db->errCode);
1005}
1006
danielk19774ad17132004-05-21 01:47:26 +00001007/*
1008** Return UTF-16 encoded English language explanation of the most recent
1009** error.
1010*/
danielk19776622cce2004-05-20 11:00:52 +00001011const void *sqlite3_errmsg16(sqlite3 *db){
danielk19774ad17132004-05-21 01:47:26 +00001012 if( !db ){
1013 /* If db is NULL, then assume that a malloc() failed during an
1014 ** sqlite3_open() call. We have a static version of the string
1015 ** "out of memory" encoded using UTF-16 just for this purpose.
1016 **
1017 ** Because all the characters in the string are in the unicode
1018 ** range 0x00-0xFF, if we pad the big-endian string with a
1019 ** zero byte, we can obtain the little-endian string with
1020 ** &big_endian[1].
1021 */
1022 static char outOfMemBe[] = {
1023 0, 'o', 0, 'u', 0, 't', 0, ' ',
1024 0, 'o', 0, 'f', 0, ' ',
1025 0, 'm', 0, 'e', 0, 'm', 0, 'o', 0, 'r', 0, 'y', 0, 0, 0
1026 };
1027 static char *outOfMemLe = &outOfMemBe[1];
1028
1029 if( SQLITE3_BIGENDIAN ){
1030 return (void *)outOfMemBe;
1031 }else{
1032 return (void *)outOfMemLe;
1033 }
1034 }
danielk19776622cce2004-05-20 11:00:52 +00001035 if( !db->zErrMsg16 ){
1036 char const *zErr8 = sqlite3_errmsg(db);
1037 if( SQLITE3_BIGENDIAN ){
1038 db->zErrMsg16 = sqlite3utf8to16be(zErr8, -1);
1039 }else{
1040 db->zErrMsg16 = sqlite3utf8to16le(zErr8, -1);
1041 }
1042 }
1043 return db->zErrMsg16;
1044}
1045
1046int sqlite3_errcode(sqlite3 *db){
1047 return db->errCode;
1048}
1049
1050/*
1051** Compile the UTF-8 encoded SQL statement zSql into a statement handle.
1052*/
1053int sqlite3_prepare(
1054 sqlite3 *db, /* Database handle. */
1055 const char *zSql, /* UTF-8 encoded SQL statement. */
1056 int nBytes, /* Length of zSql in bytes. */
1057 sqlite3_stmt **ppStmt, /* OUT: A pointer to the prepared statement */
1058 const char** pzTail /* OUT: End of parsed string */
1059){
1060 Parse sParse;
1061 char *zErrMsg = 0;
1062 int rc = SQLITE_OK;
1063
1064 if( sqlite3SafetyOn(db) ){
1065 rc = SQLITE_MISUSE;
1066 goto prepare_out;
1067 }
1068
1069 if( !db->init.busy ){
1070 if( (db->flags & SQLITE_Initialized)==0 ){
1071 int rc, cnt = 1;
1072 while( (rc = sqlite3Init(db, &zErrMsg))==SQLITE_BUSY
1073 && db->xBusyCallback
1074 && db->xBusyCallback(db->pBusyArg, "", cnt++)!=0 ){}
1075 if( rc!=SQLITE_OK ){
1076 goto prepare_out;
1077 }
1078 if( zErrMsg ){
1079 sqliteFree(zErrMsg);
1080 zErrMsg = 0;
1081 }
1082 }
1083 }
1084 assert( (db->flags & SQLITE_Initialized)!=0 || db->init.busy );
1085
1086 if( db->pVdbe==0 ){ db->nChange = 0; }
1087 memset(&sParse, 0, sizeof(sParse));
1088 sParse.db = db;
1089 sqlite3RunParser(&sParse, zSql, &zErrMsg);
1090
1091 if( db->xTrace && !db->init.busy ){
1092 /* Trace only the statment that was compiled.
1093 ** Make a copy of that part of the SQL string since zSQL is const
1094 ** and we must pass a zero terminated string to the trace function
1095 ** The copy is unnecessary if the tail pointer is pointing at the
1096 ** beginnig or end of the SQL string.
1097 */
1098 if( sParse.zTail && sParse.zTail!=zSql && *sParse.zTail ){
1099 char *tmpSql = sqliteStrNDup(zSql, sParse.zTail - zSql);
1100 if( tmpSql ){
1101 db->xTrace(db->pTraceArg, tmpSql);
1102 free(tmpSql);
1103 }else{
1104 /* If a memory error occurred during the copy,
1105 ** trace entire SQL string and fall through to the
1106 ** sqlite3_malloc_failed test to report the error.
1107 */
1108 db->xTrace(db->pTraceArg, zSql);
1109 }
1110 }else{
1111 db->xTrace(db->pTraceArg, zSql);
1112 }
1113 }
1114
1115 if( sqlite3_malloc_failed ){
1116 rc = SQLITE_NOMEM;
1117 sqlite3RollbackAll(db);
1118 sqlite3ResetInternalSchema(db, 0);
1119 db->flags &= ~SQLITE_InTrans;
1120 goto prepare_out;
1121 }
1122 if( sParse.rc==SQLITE_DONE ) sParse.rc = SQLITE_OK;
1123 if( sParse.rc==SQLITE_SCHEMA ){
1124 sqlite3ResetInternalSchema(db, 0);
1125 }
1126 assert( ppStmt );
1127 *ppStmt = (sqlite3_stmt*)sParse.pVdbe;
1128 if( pzTail ) *pzTail = sParse.zTail;
1129
1130 if( sqlite3SafetyOff(db) ){
1131 rc = SQLITE_MISUSE;
1132 goto prepare_out;
1133 }
1134
1135 rc = sParse.rc;
1136
1137prepare_out:
1138 if( zErrMsg ){
1139 sqlite3Error(db, rc, "%s", zErrMsg);
1140 }else{
1141 sqlite3Error(db, rc, 0);
1142 }
1143 return rc;
1144}
1145
1146/*
1147** Compile the UTF-16 encoded SQL statement zSql into a statement handle.
1148*/
1149int sqlite3_prepare16(
1150 sqlite3 *db, /* Database handle. */
1151 const void *zSql, /* UTF-8 encoded SQL statement. */
1152 int nBytes, /* Length of zSql in bytes. */
1153 sqlite3_stmt **ppStmt, /* OUT: A pointer to the prepared statement */
1154 const void **pzTail /* OUT: End of parsed string */
1155){
1156 /* This function currently works by first transforming the UTF-16
1157 ** encoded string to UTF-8, then invoking sqlite3_prepare(). The
1158 ** tricky bit is figuring out the pointer to return in *pzTail.
1159 */
1160 char *zSql8 = 0;
1161 char const *zTail8 = 0;
1162 int rc;
1163
danielk1977b1bc9532004-05-22 03:05:33 +00001164 zSql8 = sqlite3utf16to8(zSql, nBytes, SQLITE3_BIGENDIAN);
danielk19776622cce2004-05-20 11:00:52 +00001165 if( !zSql8 ){
1166 sqlite3Error(db, SQLITE_NOMEM, 0);
1167 return SQLITE_NOMEM;
1168 }
1169 rc = sqlite3_prepare(db, zSql8, -1, ppStmt, &zTail8);
1170
1171 if( zTail8 && pzTail ){
1172 /* If sqlite3_prepare returns a tail pointer, we calculate the
1173 ** equivalent pointer into the UTF-16 string by counting the unicode
1174 ** characters between zSql8 and zTail8, and then returning a pointer
1175 ** the same number of characters into the UTF-16 string.
1176 */
1177 int chars_parsed = sqlite3utf8CharLen(zSql8, zTail8-zSql8);
1178 *pzTail = (u8 *)zSql + sqlite3utf16ByteLen(zSql, chars_parsed);
1179 }
1180
1181 return rc;
1182}
1183
danielk19774ad17132004-05-21 01:47:26 +00001184/*
1185** This routine does the work of opening a database on behalf of
1186** sqlite3_open() and sqlite3_open16(). The database filename "zFilename"
1187** is UTF-8 encoded. The fourth argument, "def_enc" is one of the TEXT_*
1188** macros from sqliteInt.h. If we end up creating a new database file
1189** (not opening an existing one), the text encoding of the database
1190** will be set to this value.
1191*/
1192static int openDatabase(
1193 const char *zFilename, /* Database filename UTF-8 encoded */
1194 sqlite3 **ppDb, /* OUT: Returned database handle */
1195 const char **options, /* Null terminated list of db options, or null */
1196 u8 def_enc /* One of TEXT_Utf8, TEXT_Utf16le or TEXT_Utf16be */
1197){
1198 sqlite3 *db;
1199 int rc, i;
1200 char *zErrMsg = 0;
1201
1202 /* Allocate the sqlite data structure */
1203 db = sqliteMalloc( sizeof(sqlite) );
1204 if( db==0 ) goto opendb_out;
1205 db->onError = OE_Default;
1206 db->priorNewRowid = 0;
1207 db->magic = SQLITE_MAGIC_BUSY;
1208 db->nDb = 2;
1209 db->aDb = db->aDbStatic;
danielk1977b1bc9532004-05-22 03:05:33 +00001210 db->enc = def_enc;
danielk19774ad17132004-05-21 01:47:26 +00001211 /* db->flags |= SQLITE_ShortColNames; */
1212 sqlite3HashInit(&db->aFunc, SQLITE_HASH_STRING, 1);
1213 sqlite3HashInit(&db->aCollSeq, SQLITE_HASH_STRING, 0);
1214 for(i=0; i<db->nDb; i++){
1215 sqlite3HashInit(&db->aDb[i].tblHash, SQLITE_HASH_STRING, 0);
1216 sqlite3HashInit(&db->aDb[i].idxHash, SQLITE_HASH_STRING, 0);
1217 sqlite3HashInit(&db->aDb[i].trigHash, SQLITE_HASH_STRING, 0);
1218 sqlite3HashInit(&db->aDb[i].aFKey, SQLITE_HASH_STRING, 1);
1219 }
1220 db->pDfltColl =
1221 sqlite3ChangeCollatingFunction(db, "BINARY", 6, 0, binaryCollatingFunc);
1222
1223 /* Open the backend database driver */
1224 if( zFilename[0]==':' && strcmp(zFilename,":memory:")==0 ){
1225 db->temp_store = 2;
1226 }
1227 rc = sqlite3BtreeFactory(db, zFilename, 0, MAX_PAGES, &db->aDb[0].pBt);
1228 if( rc!=SQLITE_OK ){
1229 /* FIX ME: sqlite3BtreeFactory() should call sqlite3Error(). */
1230 sqlite3Error(db, rc, 0);
1231 db->magic = SQLITE_MAGIC_CLOSED;
1232 goto opendb_out;
1233 }
1234 db->aDb[0].zName = "main";
1235 db->aDb[1].zName = "temp";
1236
1237 /* Attempt to read the schema */
1238 sqlite3RegisterBuiltinFunctions(db);
1239 rc = sqlite3Init(db, &zErrMsg);
1240 if( sqlite3_malloc_failed ){
1241 sqlite3_close(db);
1242 db = 0;
1243 goto opendb_out;
1244 }else if( rc!=SQLITE_OK && rc!=SQLITE_BUSY ){
1245 sqlite3Error(db, rc, "%s", zErrMsg, 0);
1246 db->magic = SQLITE_MAGIC_CLOSED;
1247 }else{
1248 db->magic = SQLITE_MAGIC_OPEN;
1249 }
1250 if( zErrMsg ) sqliteFree(zErrMsg);
1251
1252opendb_out:
1253 *ppDb = db;
1254 return sqlite3_errcode(db);
1255}
1256
1257/*
1258** Open a new database handle.
1259*/
1260int sqlite3_open_new(
1261 const char *zFilename,
1262 sqlite3 **ppDb,
1263 const char **options
1264){
1265 return openDatabase(zFilename, ppDb, options, TEXT_Utf8);
danielk1977b1bc9532004-05-22 03:05:33 +00001266 /* return openDatabase(zFilename, ppDb, options, TEXT_Utf16le); */
danielk19774ad17132004-05-21 01:47:26 +00001267}
1268
danielk197783ab5a82004-05-21 11:39:05 +00001269sqlite *sqlite3_open(const char *zFilename, int mode, char **pzErrMsg){
1270 sqlite3 *db;
1271 int rc;
1272
1273 rc = sqlite3_open_new(zFilename, &db, 0);
1274 if( rc!=SQLITE_OK && pzErrMsg ){
1275 char *err = sqlite3_errmsg(db);
1276 *pzErrMsg = malloc(strlen(err)+1);
1277 strcpy(*pzErrMsg, err);
1278 }
1279 return db;
1280}
1281
danielk19774ad17132004-05-21 01:47:26 +00001282/*
1283** Open a new database handle.
1284*/
1285int sqlite3_open16(
1286 const void *zFilename,
1287 sqlite3 **ppDb,
1288 const char **options
1289){
1290 char *zFilename8; /* zFilename encoded in UTF-8 instead of UTF-16 */
1291 int rc;
1292
1293 assert( ppDb );
1294
danielk1977b1bc9532004-05-22 03:05:33 +00001295 zFilename8 = sqlite3utf16to8(zFilename, -1, SQLITE3_BIGENDIAN);
danielk19774ad17132004-05-21 01:47:26 +00001296 if( !zFilename8 ){
1297 *ppDb = 0;
1298 return SQLITE_NOMEM;
1299 }
1300
1301 if( SQLITE3_BIGENDIAN ){
1302 rc = openDatabase(zFilename8, ppDb, options, TEXT_Utf16be);
1303 }else{
1304 rc = openDatabase(zFilename8, ppDb, options, TEXT_Utf16le);
1305 }
1306
1307 sqliteFree(zFilename8);
1308 return rc;
1309}
1310
danielk1977106bb232004-05-21 10:08:53 +00001311/*
1312** The following routine destroys a virtual machine that is created by
1313** the sqlite3_compile() routine. The integer returned is an SQLITE_
1314** success/failure code that describes the result of executing the virtual
1315** machine.
1316**
1317** This routine sets the error code and string returned by
1318** sqlite3_errcode(), sqlite3_errmsg() and sqlite3_errmsg16().
1319*/
1320int sqlite3_finalize_new(sqlite3_stmt *pStmt){
1321 return sqlite3VdbeFinalize((Vdbe*)pStmt, 0);
1322}
1323
1324/*
1325** Terminate the current execution of an SQL statement and reset it
1326** back to its starting state so that it can be reused. A success code from
1327** the prior execution is returned.
1328**
1329** This routine sets the error code and string returned by
1330** sqlite3_errcode(), sqlite3_errmsg() and sqlite3_errmsg16().
1331*/
1332int sqlite3_reset_new(sqlite3_stmt *pStmt){
1333 int rc = sqlite3VdbeReset((Vdbe*)pStmt, 0);
1334 sqlite3VdbeMakeReady((Vdbe*)pStmt, -1, 0);
1335 return rc;
1336}
danielk19776622cce2004-05-20 11:00:52 +00001337
danielk19774adee202004-05-08 08:23:19 +00001338#if 0
1339
1340/*
1341** sqlite3_open
1342**
1343*/
1344int sqlite3_open(const char *filename, sqlite3 **pDb, const char **options){
danielk197724b03fd2004-05-10 10:34:34 +00001345 *pDb = sqlite3_open(filename, 0, &errmsg);
danielk19774adee202004-05-08 08:23:19 +00001346 return (*pDb?SQLITE_OK:SQLITE_ERROR);
1347}
1348int sqlite3_open16(const void *filename, sqlite3 **pDb, const char **options){
1349 int rc;
1350 char * filename8;
1351
danielk1977b1bc9532004-05-22 03:05:33 +00001352 filename8 = sqlite3utf16to8(filename, -1, SQLITE3_BIGENDIAN);
danielk19774adee202004-05-08 08:23:19 +00001353 if( !filename8 ){
1354 return SQLITE_NOMEM;
1355 }
1356
1357 rc = sqlite3_open(filename8, pDb, options);
1358 sqliteFree(filename8);
1359
1360 return rc;
1361}
1362
1363/*
1364** sqlite3_close
1365**
1366*/
1367int sqlite3_close(sqlite3 *db){
danielk197724b03fd2004-05-10 10:34:34 +00001368 return sqlite3_close(db);
danielk19774adee202004-05-08 08:23:19 +00001369}
1370
1371/*
1372** sqlite3_errmsg
1373**
1374** TODO: !
1375*/
1376const char *sqlite3_errmsg(sqlite3 *db){
1377 assert(!"TODO");
1378}
1379const void *sqlite3_errmsg16(sqlite3 *db){
1380 assert(!"TODO");
1381}
1382
1383/*
1384** sqlite3_errcode
1385**
1386** TODO: !
1387*/
1388int sqlite3_errcode(sqlite3 *db){
1389 assert(!"TODO");
1390}
1391
1392struct sqlite_stmt {
1393};
1394
1395/*
danielk19774adee202004-05-08 08:23:19 +00001396** sqlite3_finalize
1397*/
1398int sqlite3_finalize(sqlite3_stmt *stmt){
danielk197724b03fd2004-05-10 10:34:34 +00001399 return sqlite3_finalize(stmt, 0);
danielk19774adee202004-05-08 08:23:19 +00001400}
1401
1402/*
1403** sqlite3_reset
1404*/
1405int sqlite3_reset(sqlite3_stmt*){
danielk197724b03fd2004-05-10 10:34:34 +00001406 return sqlite3_reset(stmt, 0);
danielk19774adee202004-05-08 08:23:19 +00001407}
1408
1409/*
1410** sqlite3_step
1411*/
1412int sqlite3_step(sqlite3_stmt *pStmt){
danielk197724b03fd2004-05-10 10:34:34 +00001413 return sqlite3_step(pStmt);
danielk19774adee202004-05-08 08:23:19 +00001414}
1415
danielk19774adee202004-05-08 08:23:19 +00001416int sqlite3_column_count(sqlite3_stmt*){
1417}
1418
1419int sqlite3_column_type(sqlite3_stmt*,int){
1420}
1421
1422const char *sqlite3_column_decltype(sqlite3_stmt*,int){
1423}
1424
1425const void *sqlite3_column_decltype16(sqlite3_stmt*,int){
1426}
1427
1428const char *sqlite3_column_name(sqlite3_stmt*,int){
1429}
1430
1431const void *sqlite3_column_name16(sqlite3_stmt*,int){
1432}
1433
1434const unsigned char *sqlite3_column_data(sqlite3_stmt*,int){
1435}
1436
1437const void *sqlite3_column_data16(sqlite3_stmt*,int){
1438}
1439
1440int sqlite3_column_bytes(sqlite3_stmt*,int){
1441}
1442
1443long long int sqlite3_column_int(sqlite3_stmt*,int){
1444}
1445
1446double sqlite3_column_float(sqlite3_stmt*,int){
1447}
1448
1449#endif