← Back to branch summary

~ubuntu-branches/ubuntu/maverick/python3.1/maverick

« back to all changes in this revision

Viewing changes to Modules/_sqlite/cursor.c

  • Committer: Bazaar Package Importer
  • Author(s): Matthias Klose
  • Date: 2009-03-23 00:01:27 UTC
  • Revision ID: james.westby@ubuntu.com-20090323000127-5fstfxju4ufrhthq
Tags: upstream-3.1~a1+20090322
Import upstream version 3.1~a1+20090322

Show diffs side-by-side

added added

removed removed

Lines of Context:
Modules/_sqlite/cursor.c
 
1
/* cursor.c - the cursor type
 
2
 *
 
3
 * Copyright (C) 2004-2007 Gerhard Häring <gh@ghaering.de>
 
4
 *
 
5
 * This file is part of pysqlite.
 
6
 *
 
7
 * This software is provided 'as-is', without any express or implied
 
8
 * warranty.  In no event will the authors be held liable for any damages
 
9
 * arising from the use of this software.
 
10
 *
 
11
 * Permission is granted to anyone to use this software for any purpose,
 
12
 * including commercial applications, and to alter it and redistribute it
 
13
 * freely, subject to the following restrictions:
 
14
 *
 
15
 * 1. The origin of this software must not be misrepresented; you must not
 
16
 *    claim that you wrote the original software. If you use this software
 
17
 *    in a product, an acknowledgment in the product documentation would be
 
18
 *    appreciated but is not required.
 
19
 * 2. Altered source versions must be plainly marked as such, and must not be
 
20
 *    misrepresented as being the original software.
 
21
 * 3. This notice may not be removed or altered from any source distribution.
 
22
 */
 
23
 
 
24
#include "cursor.h"
 
25
#include "module.h"
 
26
#include "util.h"
 
27
#include "sqlitecompat.h"
 
28
 
 
29
/* used to decide wether to call PyLong_FromLong or PyLong_FromLongLong */
 
30
#ifndef INT32_MIN
 
31
#define INT32_MIN (-2147483647 - 1)
 
32
#endif
 
33
#ifndef INT32_MAX
 
34
#define INT32_MAX 2147483647
 
35
#endif
 
36
 
 
37
PyObject* pysqlite_cursor_iternext(pysqlite_Cursor* self);
 
38
 
 
39
static pysqlite_StatementKind detect_statement_type(const char* statement)
 
40
{
 
41
    char buf[20];
 
42
    const char* src;
 
43
    char* dst;
 
44
 
 
45
    src = statement;
 
46
    /* skip over whitepace */
 
47
    while (*src == '\r' || *src == '\n' || *src == ' ' || *src == '\t') {
 
48
        src++;
 
49
    }
 
50
 
 
51
    if (*src == 0)
 
52
        return STATEMENT_INVALID;
 
53
 
 
54
    dst = buf;
 
55
    *dst = 0;
 
56
    while (isalpha(*src) && dst - buf < sizeof(buf) - 2) {
 
57
        *dst++ = tolower(*src++);
 
58
    }
 
59
 
 
60
    *dst = 0;
 
61
 
 
62
    if (!strcmp(buf, "select")) {
 
63
        return STATEMENT_SELECT;
 
64
    } else if (!strcmp(buf, "insert")) {
 
65
        return STATEMENT_INSERT;
 
66
    } else if (!strcmp(buf, "update")) {
 
67
        return STATEMENT_UPDATE;
 
68
    } else if (!strcmp(buf, "delete")) {
 
69
        return STATEMENT_DELETE;
 
70
    } else if (!strcmp(buf, "replace")) {
 
71
        return STATEMENT_REPLACE;
 
72
    } else {
 
73
        return STATEMENT_OTHER;
 
74
    }
 
75
}
 
76
 
 
77
int pysqlite_cursor_init(pysqlite_Cursor* self, PyObject* args, PyObject* kwargs)
 
78
{
 
79
    pysqlite_Connection* connection;
 
80
 
 
81
    if (!PyArg_ParseTuple(args, "O!", &pysqlite_ConnectionType, &connection))
 
82
    {
 
83
        return -1;
 
84
    }
 
85
 
 
86
    Py_INCREF(connection);
 
87
    self->connection = connection;
 
88
    self->statement = NULL;
 
89
    self->next_row = NULL;
 
90
 
 
91
    self->row_cast_map = PyList_New(0);
 
92
    if (!self->row_cast_map) {
 
93
        return -1;
 
94
    }
 
95
 
 
96
    Py_INCREF(Py_None);
 
97
    self->description = Py_None;
 
98
 
 
99
    Py_INCREF(Py_None);
 
100
    self->lastrowid= Py_None;
 
101
 
 
102
    self->arraysize = 1;
 
103
 
 
104
    self->rowcount = -1L;
 
105
 
 
106
    Py_INCREF(Py_None);
 
107
    self->row_factory = Py_None;
 
108
 
 
109
    if (!pysqlite_check_thread(self->connection)) {
 
110
        return -1;
 
111
    }
 
112
 
 
113
    return 0;
 
114
}
 
115
 
 
116
void pysqlite_cursor_dealloc(pysqlite_Cursor* self)
 
117
{
 
118
    int rc;
 
119
 
 
120
    /* Reset the statement if the user has not closed the cursor */
 
121
    if (self->statement) {
 
122
        rc = pysqlite_statement_reset(self->statement);
 
123
        Py_DECREF(self->statement);
 
124
    }
 
125
 
 
126
    Py_XDECREF(self->connection);
 
127
    Py_XDECREF(self->row_cast_map);
 
128
    Py_XDECREF(self->description);
 
129
    Py_XDECREF(self->lastrowid);
 
130
    Py_XDECREF(self->row_factory);
 
131
    Py_XDECREF(self->next_row);
 
132
 
 
133
    Py_TYPE(self)->tp_free((PyObject*)self);
 
134
}
 
135
 
 
136
PyObject* _pysqlite_get_converter(PyObject* key)
 
137
{
 
138
    PyObject* upcase_key;
 
139
    PyObject* retval;
 
140
 
 
141
    upcase_key = PyObject_CallMethod(key, "upper", "");
 
142
    if (!upcase_key) {
 
143
        return NULL;
 
144
    }
 
145
 
 
146
    retval = PyDict_GetItem(converters, upcase_key);
 
147
    Py_DECREF(upcase_key);
 
148
 
 
149
    return retval;
 
150
}
 
151
 
 
152
int pysqlite_build_row_cast_map(pysqlite_Cursor* self)
 
153
{
 
154
    int i;
 
155
    const char* type_start = (const char*)-1;
 
156
    const char* pos;
 
157
 
 
158
    const char* colname;
 
159
    const char* decltype;
 
160
    PyObject* py_decltype;
 
161
    PyObject* converter;
 
162
    PyObject* key;
 
163
 
 
164
    if (!self->connection->detect_types) {
 
165
        return 0;
 
166
    }
 
167
 
 
168
    Py_XDECREF(self->row_cast_map);
 
169
    self->row_cast_map = PyList_New(0);
 
170
 
 
171
    for (i = 0; i < sqlite3_column_count(self->statement->st); i++) {
 
172
        converter = NULL;
 
173
 
 
174
        if (self->connection->detect_types & PARSE_COLNAMES) {
 
175
            colname = sqlite3_column_name(self->statement->st, i);
 
176
            if (colname) {
 
177
                for (pos = colname; *pos != 0; pos++) {
 
178
                    if (*pos == '[') {
 
179
                        type_start = pos + 1;
 
180
                    } else if (*pos == ']' && type_start != (const char*)-1) {
 
181
                        key = PyUnicode_FromStringAndSize(type_start, pos - type_start);
 
182
                        if (!key) {
 
183
                            /* creating a string failed, but it is too complicated
 
184
                             * to propagate the error here, we just assume there is
 
185
                             * no converter and proceed */
 
186
                            break;
 
187
                        }
 
188
 
 
189
                        converter = _pysqlite_get_converter(key);
 
190
                        Py_DECREF(key);
 
191
                        break;
 
192
                    }
 
193
                }
 
194
            }
 
195
        }
 
196
 
 
197
        if (!converter && self->connection->detect_types & PARSE_DECLTYPES) {
 
198
            decltype = sqlite3_column_decltype(self->statement->st, i);
 
199
            if (decltype) {
 
200
                for (pos = decltype;;pos++) {
 
201
                    /* Converter names are split at '(' and blanks.
 
202
                     * This allows 'INTEGER NOT NULL' to be treated as 'INTEGER' and
 
203
                     * 'NUMBER(10)' to be treated as 'NUMBER', for example.
 
204
                     * In other words, it will work as people expect it to work.*/
 
205
                    if (*pos == ' ' || *pos == '(' || *pos == 0) {
 
206
                        py_decltype = PyUnicode_FromStringAndSize(decltype, pos - decltype);
 
207
                        if (!py_decltype) {
 
208
                            return -1;
 
209
                        }
 
210
                        break;
 
211
                    }
 
212
                }
 
213
 
 
214
                converter = _pysqlite_get_converter(py_decltype);
 
215
                Py_DECREF(py_decltype);
 
216
            }
 
217
        }
 
218
 
 
219
        if (!converter) {
 
220
            converter = Py_None;
 
221
        }
 
222
 
 
223
        if (PyList_Append(self->row_cast_map, converter) != 0) {
 
224
            if (converter != Py_None) {
 
225
                Py_DECREF(converter);
 
226
            }
 
227
            Py_XDECREF(self->row_cast_map);
 
228
            self->row_cast_map = NULL;
 
229
 
 
230
            return -1;
 
231
        }
 
232
    }
 
233
 
 
234
    return 0;
 
235
}
 
236
 
 
237
PyObject* _pysqlite_build_column_name(const char* colname)
 
238
{
 
239
    const char* pos;
 
240
 
 
241
    if (!colname) {
 
242
        Py_INCREF(Py_None);
 
243
        return Py_None;
 
244
    }
 
245
 
 
246
    for (pos = colname;; pos++) {
 
247
        if (*pos == 0 || *pos == '[') {
 
248
            if ((*pos == '[') && (pos > colname) && (*(pos-1) == ' ')) {
 
249
                pos--;
 
250
            }
 
251
            return PyUnicode_FromStringAndSize(colname, pos - colname);
 
252
        }
 
253
    }
 
254
}
 
255
 
 
256
PyObject* pysqlite_unicode_from_string(const char* val_str, int optimize)
 
257
{
 
258
    return PyUnicode_FromString(val_str);
 
259
}
 
260
 
 
261
/*
 
262
 * Returns a row from the currently active SQLite statement
 
263
 *
 
264
 * Precondidition:
 
265
 * - sqlite3_step() has been called before and it returned SQLITE_ROW.
 
266
 */
 
267
PyObject* _pysqlite_fetch_one_row(pysqlite_Cursor* self)
 
268
{
 
269
    int i, numcols;
 
270
    PyObject* row;
 
271
    PyObject* item = NULL;
 
272
    int coltype;
 
273
    PY_LONG_LONG intval;
 
274
    PyObject* converter;
 
275
    PyObject* converted;
 
276
    Py_ssize_t nbytes;
 
277
    PyObject* buffer;
 
278
    const char* val_str;
 
279
    char buf[200];
 
280
    const char* colname;
 
281
    PyObject* buf_bytes;
 
282
    PyObject* error_obj;
 
283
 
 
284
    Py_BEGIN_ALLOW_THREADS
 
285
    numcols = sqlite3_data_count(self->statement->st);
 
286
    Py_END_ALLOW_THREADS
 
287
 
 
288
    row = PyTuple_New(numcols);
 
289
    if (!row) {
 
290
        return NULL;
 
291
    }
 
292
 
 
293
    for (i = 0; i < numcols; i++) {
 
294
        if (self->connection->detect_types) {
 
295
            converter = PyList_GetItem(self->row_cast_map, i);
 
296
            if (!converter) {
 
297
                converter = Py_None;
 
298
            }
 
299
        } else {
 
300
            converter = Py_None;
 
301
        }
 
302
 
 
303
        if (converter != Py_None) {
 
304
            nbytes = sqlite3_column_bytes(self->statement->st, i);
 
305
            val_str = (const char*)sqlite3_column_blob(self->statement->st, i);
 
306
            if (!val_str) {
 
307
                Py_INCREF(Py_None);
 
308
                converted = Py_None;
 
309
            } else {
 
310
                item = PyBytes_FromStringAndSize(val_str, nbytes);
 
311
                if (!item) {
 
312
                    return NULL;
 
313
                }
 
314
                converted = PyObject_CallFunction(converter, "O", item);
 
315
                Py_DECREF(item);
 
316
                if (!converted) {
 
317
                    break;
 
318
                }
 
319
            }
 
320
        } else {
 
321
            Py_BEGIN_ALLOW_THREADS
 
322
            coltype = sqlite3_column_type(self->statement->st, i);
 
323
            Py_END_ALLOW_THREADS
 
324
            if (coltype == SQLITE_NULL) {
 
325
                Py_INCREF(Py_None);
 
326
                converted = Py_None;
 
327
            } else if (coltype == SQLITE_INTEGER) {
 
328
                intval = sqlite3_column_int64(self->statement->st, i);
 
329
                if (intval < INT32_MIN || intval > INT32_MAX) {
 
330
                    converted = PyLong_FromLongLong(intval);
 
331
                } else {
 
332
                    converted = PyLong_FromLong((long)intval);
 
333
                }
 
334
            } else if (coltype == SQLITE_FLOAT) {
 
335
                converted = PyFloat_FromDouble(sqlite3_column_double(self->statement->st, i));
 
336
            } else if (coltype == SQLITE_TEXT) {
 
337
                val_str = (const char*)sqlite3_column_text(self->statement->st, i);
 
338
                if ((self->connection->text_factory == (PyObject*)&PyUnicode_Type)
 
339
                    || (self->connection->text_factory == pysqlite_OptimizedUnicode)) {
 
340
 
 
341
                    converted = pysqlite_unicode_from_string(val_str,
 
342
                        self->connection->text_factory == pysqlite_OptimizedUnicode ? 1 : 0);
 
343
 
 
344
                    if (!converted) {
 
345
                        colname = sqlite3_column_name(self->statement->st, i);
 
346
                        if (!colname) {
 
347
                            colname = "<unknown column name>";
 
348
                        }
 
349
                        PyOS_snprintf(buf, sizeof(buf) - 1, "Could not decode to UTF-8 column '%s' with text '%s'",
 
350
                                     colname , val_str);
 
351
                        buf_bytes = PyByteArray_FromStringAndSize(buf, strlen(buf)); 
 
352
                        if (!buf_bytes) {
 
353
                            PyErr_SetString(pysqlite_OperationalError, "Could not decode to UTF-8");
 
354
                        } else {
 
355
                            error_obj = PyUnicode_FromEncodedObject(buf_bytes, "ascii", "replace");
 
356
                            if (!error_obj) {
 
357
                                PyErr_SetString(pysqlite_OperationalError, "Could not decode to UTF-8");
 
358
                            } else {
 
359
                                PyErr_SetObject(pysqlite_OperationalError, error_obj);
 
360
                                Py_DECREF(error_obj);
 
361
                            }
 
362
                            Py_DECREF(buf_bytes);
 
363
                        }
 
364
                    }
 
365
                } else if (self->connection->text_factory == (PyObject*)&PyBytes_Type) {
 
366
                    converted = PyBytes_FromString(val_str);
 
367
                } else if (self->connection->text_factory == (PyObject*)&PyByteArray_Type) {
 
368
                    converted = PyByteArray_FromStringAndSize(val_str, strlen(val_str));
 
369
                } else {
 
370
                    converted = PyObject_CallFunction(self->connection->text_factory, "y", val_str);
 
371
                }
 
372
            } else {
 
373
                /* coltype == SQLITE_BLOB */
 
374
                nbytes = sqlite3_column_bytes(self->statement->st, i);
 
375
                buffer = PyBytes_FromStringAndSize(
 
376
                    sqlite3_column_blob(self->statement->st, i), nbytes);
 
377
                if (!buffer) {
 
378
                    break;
 
379
                }
 
380
                converted = buffer;
 
381
            }
 
382
        }
 
383
 
 
384
        if (converted) {
 
385
            PyTuple_SetItem(row, i, converted);
 
386
        } else {
 
387
            Py_INCREF(Py_None);
 
388
            PyTuple_SetItem(row, i, Py_None);
 
389
        }
 
390
    }
 
391
 
 
392
    if (PyErr_Occurred()) {
 
393
        Py_DECREF(row);
 
394
        row = NULL;
 
395
    }
 
396
 
 
397
    return row;
 
398
}
 
399
 
 
400
PyObject* _pysqlite_query_execute(pysqlite_Cursor* self, int multiple, PyObject* args)
 
401
{
 
402
    PyObject* operation;
 
403
    const char* operation_cstr;
 
404
    Py_ssize_t operation_len;
 
405
    PyObject* parameters_list = NULL;
 
406
    PyObject* parameters_iter = NULL;
 
407
    PyObject* parameters = NULL;
 
408
    int i;
 
409
    int rc;
 
410
    PyObject* func_args;
 
411
    PyObject* result;
 
412
    int numcols;
 
413
    PY_LONG_LONG lastrowid;
 
414
    int statement_type;
 
415
    PyObject* descriptor;
 
416
    PyObject* second_argument = NULL;
 
417
    int allow_8bit_chars;
 
418
 
 
419
    if (!pysqlite_check_thread(self->connection) || !pysqlite_check_connection(self->connection)) {
 
420
        return NULL;
 
421
    }
 
422
 
 
423
    /* Make shooting yourself in the foot with not utf-8 decodable 8-bit-strings harder */
 
424
    allow_8bit_chars = ((self->connection->text_factory != (PyObject*)&PyUnicode_Type) &&
 
425
        (self->connection->text_factory != (PyObject*)&PyUnicode_Type && pysqlite_OptimizedUnicode));
 
426
 
 
427
    Py_XDECREF(self->next_row);
 
428
    self->next_row = NULL;
 
429
 
 
430
    if (multiple) {
 
431
        /* executemany() */
 
432
        if (!PyArg_ParseTuple(args, "OO", &operation, &second_argument)) {
 
433
            return NULL;
 
434
        }
 
435
 
 
436
        if (!PyUnicode_Check(operation)) {
 
437
            PyErr_SetString(PyExc_ValueError, "operation parameter must be str");
 
438
            return NULL;
 
439
        }
 
440
 
 
441
        if (PyIter_Check(second_argument)) {
 
442
            /* iterator */
 
443
            Py_INCREF(second_argument);
 
444
            parameters_iter = second_argument;
 
445
        } else {
 
446
            /* sequence */
 
447
            parameters_iter = PyObject_GetIter(second_argument);
 
448
            if (!parameters_iter) {
 
449
                return NULL;
 
450
            }
 
451
        }
 
452
    } else {
 
453
        /* execute() */
 
454
        if (!PyArg_ParseTuple(args, "O|O", &operation, &second_argument)) {
 
455
            return NULL;
 
456
        }
 
457
 
 
458
        if (!PyUnicode_Check(operation)) {
 
459
            PyErr_SetString(PyExc_ValueError, "operation parameter must be str");
 
460
            return NULL;
 
461
        }
 
462
 
 
463
        parameters_list = PyList_New(0);
 
464
        if (!parameters_list) {
 
465
            return NULL;
 
466
        }
 
467
 
 
468
        if (second_argument == NULL) {
 
469
            second_argument = PyTuple_New(0);
 
470
            if (!second_argument) {
 
471
                goto error;
 
472
            }
 
473
        } else {
 
474
            Py_INCREF(second_argument);
 
475
        }
 
476
        if (PyList_Append(parameters_list, second_argument) != 0) {
 
477
            Py_DECREF(second_argument);
 
478
            goto error;
 
479
        }
 
480
        Py_DECREF(second_argument);
 
481
 
 
482
        parameters_iter = PyObject_GetIter(parameters_list);
 
483
        if (!parameters_iter) {
 
484
            goto error;
 
485
        }
 
486
    }
 
487
 
 
488
    if (self->statement != NULL) {
 
489
        /* There is an active statement */
 
490
        rc = pysqlite_statement_reset(self->statement);
 
491
    }
 
492
 
 
493
    operation_cstr = _PyUnicode_AsStringAndSize(operation, &operation_len);
 
494
    if (operation == NULL)
 
495
        goto error;
 
496
 
 
497
    /* reset description and rowcount */
 
498
    Py_DECREF(self->description);
 
499
    Py_INCREF(Py_None);
 
500
    self->description = Py_None;
 
501
    self->rowcount = -1L;
 
502
 
 
503
    func_args = PyTuple_New(1);
 
504
    if (!func_args) {
 
505
        goto error;
 
506
    }
 
507
    Py_INCREF(operation);
 
508
    if (PyTuple_SetItem(func_args, 0, operation) != 0) {
 
509
        goto error;
 
510
    }
 
511
 
 
512
    if (self->statement) {
 
513
        (void)pysqlite_statement_reset(self->statement);
 
514
        Py_DECREF(self->statement);
 
515
    }
 
516
 
 
517
    self->statement = (pysqlite_Statement*)pysqlite_cache_get(self->connection->statement_cache, func_args);
 
518
    Py_DECREF(func_args);
 
519
 
 
520
    if (!self->statement) {
 
521
        goto error;
 
522
    }
 
523
 
 
524
    if (self->statement->in_use) {
 
525
        Py_DECREF(self->statement);
 
526
        self->statement = PyObject_New(pysqlite_Statement, &pysqlite_StatementType);
 
527
        if (!self->statement) {
 
528
            goto error;
 
529
        }
 
530
        rc = pysqlite_statement_create(self->statement, self->connection, operation);
 
531
        if (rc != SQLITE_OK) {
 
532
            Py_CLEAR(self->statement);
 
533
            goto error;
 
534
        }
 
535
    }
 
536
 
 
537
    pysqlite_statement_reset(self->statement);
 
538
    pysqlite_statement_mark_dirty(self->statement);
 
539
 
 
540
    statement_type = detect_statement_type(operation_cstr);
 
541
    if (self->connection->begin_statement) {
 
542
        switch (statement_type) {
 
543
            case STATEMENT_UPDATE:
 
544
            case STATEMENT_DELETE:
 
545
            case STATEMENT_INSERT:
 
546
            case STATEMENT_REPLACE:
 
547
                if (!self->connection->inTransaction) {
 
548
                    result = _pysqlite_connection_begin(self->connection);
 
549
                    if (!result) {
 
550
                        goto error;
 
551
                    }
 
552
                    Py_DECREF(result);
 
553
                }
 
554
                break;
 
555
            case STATEMENT_OTHER:
 
556
                /* it's a DDL statement or something similar
 
557
                   - we better COMMIT first so it works for all cases */
 
558
                if (self->connection->inTransaction) {
 
559
                    result = pysqlite_connection_commit(self->connection, NULL);
 
560
                    if (!result) {
 
561
                        goto error;
 
562
                    }
 
563
                    Py_DECREF(result);
 
564
                }
 
565
                break;
 
566
            case STATEMENT_SELECT:
 
567
                if (multiple) {
 
568
                    PyErr_SetString(pysqlite_ProgrammingError,
 
569
                                "You cannot execute SELECT statements in executemany().");
 
570
                    goto error;
 
571
                }
 
572
                break;
 
573
        }
 
574
    }
 
575
 
 
576
    func_args = PyTuple_New(1);
 
577
    if (!func_args) {
 
578
        goto error;
 
579
    }
 
580
    Py_INCREF(operation);
 
581
    if (PyTuple_SetItem(func_args, 0, operation) != 0) {
 
582
        goto error;
 
583
    }
 
584
 
 
585
    if (self->statement) {
 
586
        (void)pysqlite_statement_reset(self->statement);
 
587
        Py_DECREF(self->statement);
 
588
    }
 
589
 
 
590
    self->statement = (pysqlite_Statement*)pysqlite_cache_get(self->connection->statement_cache, func_args);
 
591
    Py_DECREF(func_args);
 
592
 
 
593
    if (!self->statement) {
 
594
        goto error;
 
595
    }
 
596
 
 
597
    if (self->statement->in_use) {
 
598
        Py_DECREF(self->statement);
 
599
        self->statement = PyObject_New(pysqlite_Statement, &pysqlite_StatementType);
 
600
        if (!self->statement) {
 
601
            goto error;
 
602
        }
 
603
        rc = pysqlite_statement_create(self->statement, self->connection, operation);
 
604
        if (rc != SQLITE_OK) {
 
605
            Py_CLEAR(self->statement);
 
606
            goto error;
 
607
        }
 
608
    }
 
609
 
 
610
    pysqlite_statement_reset(self->statement);
 
611
    pysqlite_statement_mark_dirty(self->statement);
 
612
 
 
613
    while (1) {
 
614
        parameters = PyIter_Next(parameters_iter);
 
615
        if (!parameters) {
 
616
            break;
 
617
        }
 
618
 
 
619
        pysqlite_statement_mark_dirty(self->statement);
 
620
 
 
621
        pysqlite_statement_bind_parameters(self->statement, parameters, allow_8bit_chars);
 
622
        if (PyErr_Occurred()) {
 
623
            goto error;
 
624
        }
 
625
 
 
626
        if (pysqlite_build_row_cast_map(self) != 0) {
 
627
            PyErr_SetString(pysqlite_OperationalError, "Error while building row_cast_map");
 
628
            goto error;
 
629
        }
 
630
 
 
631
        /* Keep trying the SQL statement until the schema stops changing. */
 
632
        while (1) {
 
633
            /* Actually execute the SQL statement. */
 
634
            rc = pysqlite_step(self->statement->st, self->connection);
 
635
            if (rc == SQLITE_DONE ||  rc == SQLITE_ROW) {
 
636
                /* If it worked, let's get out of the loop */
 
637
                break;
 
638
            }
 
639
            /* Something went wrong.  Re-set the statement and try again. */
 
640
            rc = pysqlite_statement_reset(self->statement);
 
641
            if (rc == SQLITE_SCHEMA) {
 
642
                /* If this was a result of the schema changing, let's try
 
643
                   again. */
 
644
                rc = pysqlite_statement_recompile(self->statement, parameters);
 
645
                if (rc == SQLITE_OK) {
 
646
                    continue;
 
647
                } else {
 
648
                    /* If the database gave us an error, promote it to Python. */
 
649
                    (void)pysqlite_statement_reset(self->statement);
 
650
                    _pysqlite_seterror(self->connection->db, NULL);
 
651
                    goto error;
 
652
                }
 
653
            } else {
 
654
                if (PyErr_Occurred()) {
 
655
                    /* there was an error that occurred in a user-defined callback */
 
656
                    if (_enable_callback_tracebacks) {
 
657
                        PyErr_Print();
 
658
                    } else {
 
659
                        PyErr_Clear();
 
660
                    }
 
661
                }
 
662
                (void)pysqlite_statement_reset(self->statement);
 
663
                _pysqlite_seterror(self->connection->db, NULL);
 
664
                goto error;
 
665
            }
 
666
        }
 
667
 
 
668
        if (pysqlite_build_row_cast_map(self) != 0) {
 
669
            PyErr_SetString(pysqlite_OperationalError, "Error while building row_cast_map");
 
670
            goto error;
 
671
        }
 
672
 
 
673
        if (rc == SQLITE_ROW || (rc == SQLITE_DONE && statement_type == STATEMENT_SELECT)) {
 
674
            Py_BEGIN_ALLOW_THREADS
 
675
            numcols = sqlite3_column_count(self->statement->st);
 
676
            Py_END_ALLOW_THREADS
 
677
 
 
678
            if (self->description == Py_None) {
 
679
                Py_BEGIN_ALLOW_THREADS
 
680
                numcols = sqlite3_column_count(self->statement->st);
 
681
                Py_END_ALLOW_THREADS
 
682
 
 
683
                Py_DECREF(self->description);
 
684
                self->description = PyTuple_New(numcols);
 
685
                if (!self->description) {
 
686
                    goto error;
 
687
                }
 
688
                for (i = 0; i < numcols; i++) {
 
689
                    descriptor = PyTuple_New(7);
 
690
                    if (!descriptor) {
 
691
                        goto error;
 
692
                    }
 
693
                    PyTuple_SetItem(descriptor, 0, _pysqlite_build_column_name(sqlite3_column_name(self->statement->st, i)));
 
694
                    Py_INCREF(Py_None); PyTuple_SetItem(descriptor, 1, Py_None);
 
695
                    Py_INCREF(Py_None); PyTuple_SetItem(descriptor, 2, Py_None);
 
696
                    Py_INCREF(Py_None); PyTuple_SetItem(descriptor, 3, Py_None);
 
697
                    Py_INCREF(Py_None); PyTuple_SetItem(descriptor, 4, Py_None);
 
698
                    Py_INCREF(Py_None); PyTuple_SetItem(descriptor, 5, Py_None);
 
699
                    Py_INCREF(Py_None); PyTuple_SetItem(descriptor, 6, Py_None);
 
700
                    PyTuple_SetItem(self->description, i, descriptor);
 
701
                }
 
702
            }
 
703
        }
 
704
 
 
705
        if (rc == SQLITE_ROW) {
 
706
            if (multiple) {
 
707
                PyErr_SetString(pysqlite_ProgrammingError, "executemany() can only execute DML statements.");
 
708
                goto error;
 
709
            }
 
710
 
 
711
            self->next_row = _pysqlite_fetch_one_row(self);
 
712
        } else if (rc == SQLITE_DONE && !multiple) {
 
713
            pysqlite_statement_reset(self->statement);
 
714
            Py_CLEAR(self->statement);
 
715
        }
 
716
 
 
717
        switch (statement_type) {
 
718
            case STATEMENT_UPDATE:
 
719
            case STATEMENT_DELETE:
 
720
            case STATEMENT_INSERT:
 
721
            case STATEMENT_REPLACE:
 
722
                if (self->rowcount == -1L) {
 
723
                    self->rowcount = 0L;
 
724
                }
 
725
                self->rowcount += (long)sqlite3_changes(self->connection->db);
 
726
        }
 
727
 
 
728
        Py_DECREF(self->lastrowid);
 
729
        if (!multiple && statement_type == STATEMENT_INSERT) {
 
730
            Py_BEGIN_ALLOW_THREADS
 
731
            lastrowid = sqlite3_last_insert_rowid(self->connection->db);
 
732
            Py_END_ALLOW_THREADS
 
733
            self->lastrowid = PyLong_FromLong((long)lastrowid);
 
734
        } else {
 
735
            Py_INCREF(Py_None);
 
736
            self->lastrowid = Py_None;
 
737
        }
 
738
 
 
739
        if (multiple) {
 
740
            rc = pysqlite_statement_reset(self->statement);
 
741
        }
 
742
        Py_XDECREF(parameters);
 
743
    }
 
744
 
 
745
error:
 
746
    /* just to be sure (implicit ROLLBACKs with ON CONFLICT ROLLBACK/OR
 
747
     * ROLLBACK could have happened */
 
748
    #ifdef SQLITE_VERSION_NUMBER
 
749
    #if SQLITE_VERSION_NUMBER >= 3002002
 
750
    self->connection->inTransaction = !sqlite3_get_autocommit(self->connection->db);
 
751
    #endif
 
752
    #endif
 
753
 
 
754
    Py_XDECREF(parameters);
 
755
    Py_XDECREF(parameters_iter);
 
756
    Py_XDECREF(parameters_list);
 
757
 
 
758
    if (PyErr_Occurred()) {
 
759
        self->rowcount = -1L;
 
760
        return NULL;
 
761
    } else {
 
762
        Py_INCREF(self);
 
763
        return (PyObject*)self;
 
764
    }
 
765
}
 
766
 
 
767
PyObject* pysqlite_cursor_execute(pysqlite_Cursor* self, PyObject* args)
 
768
{
 
769
    return _pysqlite_query_execute(self, 0, args);
 
770
}
 
771
 
 
772
PyObject* pysqlite_cursor_executemany(pysqlite_Cursor* self, PyObject* args)
 
773
{
 
774
    return _pysqlite_query_execute(self, 1, args);
 
775
}
 
776
 
 
777
PyObject* pysqlite_cursor_executescript(pysqlite_Cursor* self, PyObject* args)
 
778
{
 
779
    PyObject* script_obj;
 
780
    PyObject* script_str = NULL;
 
781
    const char* script_cstr;
 
782
    sqlite3_stmt* statement;
 
783
    int rc;
 
784
    PyObject* result;
 
785
    int statement_completed = 0;
 
786
 
 
787
    if (!PyArg_ParseTuple(args, "O", &script_obj)) {
 
788
        return NULL;
 
789
    }
 
790
 
 
791
    if (!pysqlite_check_thread(self->connection) || !pysqlite_check_connection(self->connection)) {
 
792
        return NULL;
 
793
    }
 
794
 
 
795
    if (PyUnicode_Check(script_obj)) {
 
796
        script_cstr = _PyUnicode_AsString(script_obj);
 
797
        if (!script_cstr) {
 
798
            return NULL;
 
799
        }
 
800
    } else {
 
801
        PyErr_SetString(PyExc_ValueError, "script argument must be unicode.");
 
802
        return NULL;
 
803
    }
 
804
 
 
805
    /* commit first */
 
806
    result = pysqlite_connection_commit(self->connection, NULL);
 
807
    if (!result) {
 
808
        goto error;
 
809
    }
 
810
    Py_DECREF(result);
 
811
 
 
812
    while (1) {
 
813
        if (!sqlite3_complete(script_cstr)) {
 
814
            break;
 
815
        }
 
816
        statement_completed = 1;
 
817
 
 
818
        Py_BEGIN_ALLOW_THREADS
 
819
        rc = sqlite3_prepare(self->connection->db,
 
820
                             script_cstr,
 
821
                             -1,
 
822
                             &statement,
 
823
                             &script_cstr);
 
824
        Py_END_ALLOW_THREADS
 
825
        if (rc != SQLITE_OK) {
 
826
            _pysqlite_seterror(self->connection->db, NULL);
 
827
            goto error;
 
828
        }
 
829
 
 
830
        /* execute statement, and ignore results of SELECT statements */
 
831
        rc = SQLITE_ROW;
 
832
        while (rc == SQLITE_ROW) {
 
833
            rc = pysqlite_step(statement, self->connection);
 
834
            /* TODO: we probably need more error handling here */
 
835
        }
 
836
 
 
837
        if (rc != SQLITE_DONE) {
 
838
            (void)sqlite3_finalize(statement);
 
839
            _pysqlite_seterror(self->connection->db, NULL);
 
840
            goto error;
 
841
        }
 
842
 
 
843
        rc = sqlite3_finalize(statement);
 
844
        if (rc != SQLITE_OK) {
 
845
            _pysqlite_seterror(self->connection->db, NULL);
 
846
            goto error;
 
847
        }
 
848
    }
 
849
 
 
850
error:
 
851
    Py_XDECREF(script_str);
 
852
 
 
853
    if (!statement_completed) {
 
854
        PyErr_SetString(pysqlite_ProgrammingError, "you did not provide a complete SQL statement");
 
855
    }
 
856
 
 
857
    if (PyErr_Occurred()) {
 
858
        return NULL;
 
859
    } else {
 
860
        Py_INCREF(self);
 
861
        return (PyObject*)self;
 
862
    }
 
863
}
 
864
 
 
865
PyObject* pysqlite_cursor_getiter(pysqlite_Cursor *self)
 
866
{
 
867
    Py_INCREF(self);
 
868
    return (PyObject*)self;
 
869
}
 
870
 
 
871
PyObject* pysqlite_cursor_iternext(pysqlite_Cursor *self)
 
872
{
 
873
    PyObject* next_row_tuple;
 
874
    PyObject* next_row;
 
875
    int rc;
 
876
 
 
877
    if (!pysqlite_check_thread(self->connection) || !pysqlite_check_connection(self->connection)) {
 
878
        return NULL;
 
879
    }
 
880
 
 
881
    if (!self->next_row) {
 
882
         if (self->statement) {
 
883
            (void)pysqlite_statement_reset(self->statement);
 
884
            Py_DECREF(self->statement);
 
885
            self->statement = NULL;
 
886
        }
 
887
        return NULL;
 
888
    }
 
889
 
 
890
    next_row_tuple = self->next_row;
 
891
    self->next_row = NULL;
 
892
 
 
893
    if (self->row_factory != Py_None) {
 
894
        next_row = PyObject_CallFunction(self->row_factory, "OO", self, next_row_tuple);
 
895
        Py_DECREF(next_row_tuple);
 
896
    } else {
 
897
        next_row = next_row_tuple;
 
898
    }
 
899
 
 
900
    if (self->statement) {
 
901
        rc = pysqlite_step(self->statement->st, self->connection);
 
902
        if (rc != SQLITE_DONE && rc != SQLITE_ROW) {
 
903
            (void)pysqlite_statement_reset(self->statement);
 
904
            Py_DECREF(next_row);
 
905
            _pysqlite_seterror(self->connection->db, NULL);
 
906
            return NULL;
 
907
        }
 
908
 
 
909
        if (rc == SQLITE_ROW) {
 
910
            self->next_row = _pysqlite_fetch_one_row(self);
 
911
        }
 
912
    }
 
913
 
 
914
    return next_row;
 
915
}
 
916
 
 
917
PyObject* pysqlite_cursor_fetchone(pysqlite_Cursor* self, PyObject* args)
 
918
{
 
919
    PyObject* row;
 
920
 
 
921
    row = pysqlite_cursor_iternext(self);
 
922
    if (!row && !PyErr_Occurred()) {
 
923
        Py_INCREF(Py_None);
 
924
        return Py_None;
 
925
    }
 
926
 
 
927
    return row;
 
928
}
 
929
 
 
930
PyObject* pysqlite_cursor_fetchmany(pysqlite_Cursor* self, PyObject* args, PyObject* kwargs)
 
931
{
 
932
    static char *kwlist[] = {"size", NULL, NULL};
 
933
 
 
934
    PyObject* row;
 
935
    PyObject* list;
 
936
    int maxrows = self->arraysize;
 
937
    int counter = 0;
 
938
 
 
939
    if (!PyArg_ParseTupleAndKeywords(args, kwargs, "|i:fetchmany", kwlist, &maxrows)) {
 
940
        return NULL;
 
941
    }
 
942
 
 
943
    list = PyList_New(0);
 
944
    if (!list) {
 
945
        return NULL;
 
946
    }
 
947
 
 
948
    /* just make sure we enter the loop */
 
949
    row = Py_None;
 
950
 
 
951
    while (row) {
 
952
        row = pysqlite_cursor_iternext(self);
 
953
        if (row) {
 
954
            PyList_Append(list, row);
 
955
            Py_DECREF(row);
 
956
        } else {
 
957
            break;
 
958
        }
 
959
 
 
960
        if (++counter == maxrows) {
 
961
            break;
 
962
        }
 
963
    }
 
964
 
 
965
    if (PyErr_Occurred()) {
 
966
        Py_DECREF(list);
 
967
        return NULL;
 
968
    } else {
 
969
        return list;
 
970
    }
 
971
}
 
972
 
 
973
PyObject* pysqlite_cursor_fetchall(pysqlite_Cursor* self, PyObject* args)
 
974
{
 
975
    PyObject* row;
 
976
    PyObject* list;
 
977
 
 
978
    list = PyList_New(0);
 
979
    if (!list) {
 
980
        return NULL;
 
981
    }
 
982
 
 
983
    /* just make sure we enter the loop */
 
984
    row = (PyObject*)Py_None;
 
985
 
 
986
    while (row) {
 
987
        row = pysqlite_cursor_iternext(self);
 
988
        if (row) {
 
989
            PyList_Append(list, row);
 
990
            Py_DECREF(row);
 
991
        }
 
992
    }
 
993
 
 
994
    if (PyErr_Occurred()) {
 
995
        Py_DECREF(list);
 
996
        return NULL;
 
997
    } else {
 
998
        return list;
 
999
    }
 
1000
}
 
1001
 
 
1002
PyObject* pysqlite_noop(pysqlite_Connection* self, PyObject* args)
 
1003
{
 
1004
    /* don't care, return None */
 
1005
    Py_INCREF(Py_None);
 
1006
    return Py_None;
 
1007
}
 
1008
 
 
1009
PyObject* pysqlite_cursor_close(pysqlite_Cursor* self, PyObject* args)
 
1010
{
 
1011
    if (!pysqlite_check_thread(self->connection) || !pysqlite_check_connection(self->connection)) {
 
1012
        return NULL;
 
1013
    }
 
1014
 
 
1015
    if (self->statement) {
 
1016
        (void)pysqlite_statement_reset(self->statement);
 
1017
        Py_CLEAR(self->statement);
 
1018
    }
 
1019
 
 
1020
    Py_INCREF(Py_None);
 
1021
    return Py_None;
 
1022
}
 
1023
 
 
1024
static PyMethodDef cursor_methods[] = {
 
1025
    {"execute", (PyCFunction)pysqlite_cursor_execute, METH_VARARGS,
 
1026
        PyDoc_STR("Executes a SQL statement.")},
 
1027
    {"executemany", (PyCFunction)pysqlite_cursor_executemany, METH_VARARGS,
 
1028
        PyDoc_STR("Repeatedly executes a SQL statement.")},
 
1029
    {"executescript", (PyCFunction)pysqlite_cursor_executescript, METH_VARARGS,
 
1030
        PyDoc_STR("Executes a multiple SQL statements at once. Non-standard.")},
 
1031
    {"fetchone", (PyCFunction)pysqlite_cursor_fetchone, METH_NOARGS,
 
1032
        PyDoc_STR("Fetches one row from the resultset.")},
 
1033
    {"fetchmany", (PyCFunction)pysqlite_cursor_fetchmany, METH_VARARGS|METH_KEYWORDS,
 
1034
        PyDoc_STR("Fetches several rows from the resultset.")},
 
1035
    {"fetchall", (PyCFunction)pysqlite_cursor_fetchall, METH_NOARGS,
 
1036
        PyDoc_STR("Fetches all rows from the resultset.")},
 
1037
    {"close", (PyCFunction)pysqlite_cursor_close, METH_NOARGS,
 
1038
        PyDoc_STR("Closes the cursor.")},
 
1039
    {"setinputsizes", (PyCFunction)pysqlite_noop, METH_VARARGS,
 
1040
        PyDoc_STR("Required by DB-API. Does nothing in pysqlite.")},
 
1041
    {"setoutputsize", (PyCFunction)pysqlite_noop, METH_VARARGS,
 
1042
        PyDoc_STR("Required by DB-API. Does nothing in pysqlite.")},
 
1043
    {NULL, NULL}
 
1044
};
 
1045
 
 
1046
static struct PyMemberDef cursor_members[] =
 
1047
{
 
1048
    {"connection", T_OBJECT, offsetof(pysqlite_Cursor, connection), READONLY},
 
1049
    {"description", T_OBJECT, offsetof(pysqlite_Cursor, description), READONLY},
 
1050
    {"arraysize", T_INT, offsetof(pysqlite_Cursor, arraysize), 0},
 
1051
    {"lastrowid", T_OBJECT, offsetof(pysqlite_Cursor, lastrowid), READONLY},
 
1052
    {"rowcount", T_LONG, offsetof(pysqlite_Cursor, rowcount), READONLY},
 
1053
    {"row_factory", T_OBJECT, offsetof(pysqlite_Cursor, row_factory), 0},
 
1054
    {NULL}
 
1055
};
 
1056
 
 
1057
static char cursor_doc[] =
 
1058
PyDoc_STR("SQLite database cursor class.");
 
1059
 
 
1060
PyTypeObject pysqlite_CursorType = {
 
1061
        PyVarObject_HEAD_INIT(NULL, 0)
 
1062
        MODULE_NAME ".Cursor",                          /* tp_name */
 
1063
        sizeof(pysqlite_Cursor),                        /* tp_basicsize */
 
1064
        0,                                              /* tp_itemsize */
 
1065
        (destructor)pysqlite_cursor_dealloc,            /* tp_dealloc */
 
1066
        0,                                              /* tp_print */
 
1067
        0,                                              /* tp_getattr */
 
1068
        0,                                              /* tp_setattr */
 
1069
        0,                                              /* tp_reserved */
 
1070
        0,                                              /* tp_repr */
 
1071
        0,                                              /* tp_as_number */
 
1072
        0,                                              /* tp_as_sequence */
 
1073
        0,                                              /* tp_as_mapping */
 
1074
        0,                                              /* tp_hash */
 
1075
        0,                                              /* tp_call */
 
1076
        0,                                              /* tp_str */
 
1077
        0,                                              /* tp_getattro */
 
1078
        0,                                              /* tp_setattro */
 
1079
        0,                                              /* tp_as_buffer */
 
1080
        Py_TPFLAGS_DEFAULT | Py_TPFLAGS_BASETYPE,       /* tp_flags */
 
1081
        cursor_doc,                                     /* tp_doc */
 
1082
        0,                                              /* tp_traverse */
 
1083
        0,                                              /* tp_clear */
 
1084
        0,                                              /* tp_richcompare */
 
1085
        0,                                              /* tp_weaklistoffset */
 
1086
        (getiterfunc)pysqlite_cursor_getiter,           /* tp_iter */
 
1087
        (iternextfunc)pysqlite_cursor_iternext,         /* tp_iternext */
 
1088
        cursor_methods,                                 /* tp_methods */
 
1089
        cursor_members,                                 /* tp_members */
 
1090
        0,                                              /* tp_getset */
 
1091
        0,                                              /* tp_base */
 
1092
        0,                                              /* tp_dict */
 
1093
        0,                                              /* tp_descr_get */
 
1094
        0,                                              /* tp_descr_set */
 
1095
        0,                                              /* tp_dictoffset */
 
1096
        (initproc)pysqlite_cursor_init,                 /* tp_init */
 
1097
        0,                                              /* tp_alloc */
 
1098
        0,                                              /* tp_new */
 
1099
        0                                               /* tp_free */
 
1100
};
 
1101
 
 
1102
extern int pysqlite_cursor_setup_types(void)
 
1103
{
 
1104
    pysqlite_CursorType.tp_new = PyType_GenericNew;
 
1105
    return PyType_Ready(&pysqlite_CursorType);
 
1106
}