Commit 6e1afcf9 authored by Gerhard Häring's avatar Gerhard Häring

Fixes issue #3103. In the sqlite3 module, made one more function static. All...

Fixes issue #3103. In the sqlite3 module, made one more function static. All renaming public symbos now have the pysqlite prefix to avoid name clashes. This at least once created problems where the same symbol name appeared somewhere in Apache and the sqlite3 module was used from mod_python.
parent ef2276b6
...@@ -148,6 +148,9 @@ Extension Modules ...@@ -148,6 +148,9 @@ Extension Modules
- sqlite3: Changed docstring of iterdump() to mark method as "Non-standard". - sqlite3: Changed docstring of iterdump() to mark method as "Non-standard".
- Issue #3103: Reduced globals symbols used by sqlite3 module and made sure all
remaining ones have "pysqlite_" prefix.
Tests Tests
----- -----
......
...@@ -38,7 +38,7 @@ ...@@ -38,7 +38,7 @@
static int pysqlite_connection_set_isolation_level(pysqlite_Connection* self, PyObject* isolation_level); static int pysqlite_connection_set_isolation_level(pysqlite_Connection* self, PyObject* isolation_level);
void _sqlite3_result_error(sqlite3_context* ctx, const char* errmsg, int len) static void _sqlite3_result_error(sqlite3_context* ctx, const char* errmsg, int len)
{ {
/* in older SQLite versions, calling sqlite3_result_error in callbacks /* in older SQLite versions, calling sqlite3_result_error in callbacks
* triggers a bug in SQLite that leads either to irritating results or * triggers a bug in SQLite that leads either to irritating results or
...@@ -363,7 +363,7 @@ PyObject* _pysqlite_connection_begin(pysqlite_Connection* self) ...@@ -363,7 +363,7 @@ PyObject* _pysqlite_connection_begin(pysqlite_Connection* self)
goto error; goto error;
} }
rc = _sqlite_step_with_busyhandler(statement, self); rc = pysqlite_step(statement, self);
if (rc == SQLITE_DONE) { if (rc == SQLITE_DONE) {
self->inTransaction = 1; self->inTransaction = 1;
} else { } else {
...@@ -406,7 +406,7 @@ PyObject* pysqlite_connection_commit(pysqlite_Connection* self, PyObject* args) ...@@ -406,7 +406,7 @@ PyObject* pysqlite_connection_commit(pysqlite_Connection* self, PyObject* args)
goto error; goto error;
} }
rc = _sqlite_step_with_busyhandler(statement, self); rc = pysqlite_step(statement, self);
if (rc == SQLITE_DONE) { if (rc == SQLITE_DONE) {
self->inTransaction = 0; self->inTransaction = 0;
} else { } else {
...@@ -452,7 +452,7 @@ PyObject* pysqlite_connection_rollback(pysqlite_Connection* self, PyObject* args ...@@ -452,7 +452,7 @@ PyObject* pysqlite_connection_rollback(pysqlite_Connection* self, PyObject* args
goto error; goto error;
} }
rc = _sqlite_step_with_busyhandler(statement, self); rc = pysqlite_step(statement, self);
if (rc == SQLITE_DONE) { if (rc == SQLITE_DONE) {
self->inTransaction = 0; self->inTransaction = 0;
} else { } else {
......
...@@ -605,7 +605,7 @@ PyObject* _pysqlite_query_execute(pysqlite_Cursor* self, int multiple, PyObject* ...@@ -605,7 +605,7 @@ PyObject* _pysqlite_query_execute(pysqlite_Cursor* self, int multiple, PyObject*
/* Keep trying the SQL statement until the schema stops changing. */ /* Keep trying the SQL statement until the schema stops changing. */
while (1) { while (1) {
/* Actually execute the SQL statement. */ /* Actually execute the SQL statement. */
rc = _sqlite_step_with_busyhandler(self->statement->st, self->connection); rc = pysqlite_step(self->statement->st, self->connection);
if (rc == SQLITE_DONE || rc == SQLITE_ROW) { if (rc == SQLITE_DONE || rc == SQLITE_ROW) {
/* If it worked, let's get out of the loop */ /* If it worked, let's get out of the loop */
break; break;
...@@ -803,7 +803,7 @@ PyObject* pysqlite_cursor_executescript(pysqlite_Cursor* self, PyObject* args) ...@@ -803,7 +803,7 @@ PyObject* pysqlite_cursor_executescript(pysqlite_Cursor* self, PyObject* args)
/* execute statement, and ignore results of SELECT statements */ /* execute statement, and ignore results of SELECT statements */
rc = SQLITE_ROW; rc = SQLITE_ROW;
while (rc == SQLITE_ROW) { while (rc == SQLITE_ROW) {
rc = _sqlite_step_with_busyhandler(statement, self->connection); rc = pysqlite_step(statement, self->connection);
/* TODO: we probably need more error handling here */ /* TODO: we probably need more error handling here */
} }
...@@ -871,7 +871,7 @@ PyObject* pysqlite_cursor_iternext(pysqlite_Cursor *self) ...@@ -871,7 +871,7 @@ PyObject* pysqlite_cursor_iternext(pysqlite_Cursor *self)
} }
if (self->statement) { if (self->statement) {
rc = _sqlite_step_with_busyhandler(self->statement->st, self->connection); rc = pysqlite_step(self->statement->st, self->connection);
if (rc != SQLITE_DONE && rc != SQLITE_ROW) { if (rc != SQLITE_DONE && rc != SQLITE_ROW) {
(void)pysqlite_statement_reset(self->statement); (void)pysqlite_statement_reset(self->statement);
Py_DECREF(next_row); Py_DECREF(next_row);
......
...@@ -35,10 +35,10 @@ ...@@ -35,10 +35,10 @@
PyObject *psyco_adapters; PyObject *psyco_adapters;
/* microprotocols_init - initialize the adapters dictionary */ /* pysqlite_microprotocols_init - initialize the adapters dictionary */
int int
microprotocols_init(PyObject *dict) pysqlite_microprotocols_init(PyObject *dict)
{ {
/* create adapters dictionary and put it in module namespace */ /* create adapters dictionary and put it in module namespace */
if ((psyco_adapters = PyDict_New()) == NULL) { if ((psyco_adapters = PyDict_New()) == NULL) {
...@@ -49,10 +49,10 @@ microprotocols_init(PyObject *dict) ...@@ -49,10 +49,10 @@ microprotocols_init(PyObject *dict)
} }
/* microprotocols_add - add a reverse type-caster to the dictionary */ /* pysqlite_microprotocols_add - add a reverse type-caster to the dictionary */
int int
microprotocols_add(PyTypeObject *type, PyObject *proto, PyObject *cast) pysqlite_microprotocols_add(PyTypeObject *type, PyObject *proto, PyObject *cast)
{ {
PyObject* key; PyObject* key;
int rc; int rc;
...@@ -70,10 +70,10 @@ microprotocols_add(PyTypeObject *type, PyObject *proto, PyObject *cast) ...@@ -70,10 +70,10 @@ microprotocols_add(PyTypeObject *type, PyObject *proto, PyObject *cast)
return rc; return rc;
} }
/* microprotocols_adapt - adapt an object to the built-in protocol */ /* pysqlite_microprotocols_adapt - adapt an object to the built-in protocol */
PyObject * PyObject *
microprotocols_adapt(PyObject *obj, PyObject *proto, PyObject *alt) pysqlite_microprotocols_adapt(PyObject *obj, PyObject *proto, PyObject *alt)
{ {
PyObject *adapter, *key; PyObject *adapter, *key;
...@@ -132,11 +132,11 @@ microprotocols_adapt(PyObject *obj, PyObject *proto, PyObject *alt) ...@@ -132,11 +132,11 @@ microprotocols_adapt(PyObject *obj, PyObject *proto, PyObject *alt)
/** module-level functions **/ /** module-level functions **/
PyObject * PyObject *
psyco_microprotocols_adapt(pysqlite_Cursor *self, PyObject *args) pysqlite_adapt(pysqlite_Cursor *self, PyObject *args)
{ {
PyObject *obj, *alt = NULL; PyObject *obj, *alt = NULL;
PyObject *proto = (PyObject*)&pysqlite_PrepareProtocolType; PyObject *proto = (PyObject*)&pysqlite_PrepareProtocolType;
if (!PyArg_ParseTuple(args, "O|OO", &obj, &proto, &alt)) return NULL; if (!PyArg_ParseTuple(args, "O|OO", &obj, &proto, &alt)) return NULL;
return microprotocols_adapt(obj, proto, alt); return pysqlite_microprotocols_adapt(obj, proto, alt);
} }
...@@ -41,15 +41,15 @@ extern PyObject *psyco_adapters; ...@@ -41,15 +41,15 @@ extern PyObject *psyco_adapters;
/** exported functions **/ /** exported functions **/
/* used by module.c to init the microprotocols system */ /* used by module.c to init the microprotocols system */
extern int microprotocols_init(PyObject *dict); extern int pysqlite_microprotocols_init(PyObject *dict);
extern int microprotocols_add( extern int pysqlite_microprotocols_add(
PyTypeObject *type, PyObject *proto, PyObject *cast); PyTypeObject *type, PyObject *proto, PyObject *cast);
extern PyObject *microprotocols_adapt( extern PyObject *pysqlite_microprotocols_adapt(
PyObject *obj, PyObject *proto, PyObject *alt); PyObject *obj, PyObject *proto, PyObject *alt);
extern PyObject * extern PyObject *
psyco_microprotocols_adapt(pysqlite_Cursor* self, PyObject *args); pysqlite_adapt(pysqlite_Cursor* self, PyObject *args);
#define psyco_microprotocols_adapt_doc \ #define pysqlite_adapt_doc \
"adapt(obj, protocol, alternate) -> adapt obj to given protocol. Non-standard." "adapt(obj, protocol, alternate) -> adapt obj to given protocol. Non-standard."
#endif /* !defined(PSYCOPG_MICROPROTOCOLS_H) */ #endif /* !defined(PSYCOPG_MICROPROTOCOLS_H) */
...@@ -160,7 +160,7 @@ static PyObject* module_register_adapter(PyObject* self, PyObject* args) ...@@ -160,7 +160,7 @@ static PyObject* module_register_adapter(PyObject* self, PyObject* args)
pysqlite_BaseTypeAdapted = 1; pysqlite_BaseTypeAdapted = 1;
} }
rc = microprotocols_add(type, (PyObject*)&pysqlite_PrepareProtocolType, caster); rc = pysqlite_microprotocols_add(type, (PyObject*)&pysqlite_PrepareProtocolType, caster);
if (rc == -1) if (rc == -1)
return NULL; return NULL;
...@@ -244,8 +244,8 @@ static PyMethodDef module_methods[] = { ...@@ -244,8 +244,8 @@ static PyMethodDef module_methods[] = {
METH_VARARGS, module_register_adapter_doc}, METH_VARARGS, module_register_adapter_doc},
{"register_converter", (PyCFunction)module_register_converter, {"register_converter", (PyCFunction)module_register_converter,
METH_VARARGS, module_register_converter_doc}, METH_VARARGS, module_register_converter_doc},
{"adapt", (PyCFunction)psyco_microprotocols_adapt, METH_VARARGS, {"adapt", (PyCFunction)pysqlite_adapt, METH_VARARGS,
psyco_microprotocols_adapt_doc}, pysqlite_adapt_doc},
{"enable_callback_tracebacks", (PyCFunction)enable_callback_tracebacks, {"enable_callback_tracebacks", (PyCFunction)enable_callback_tracebacks,
METH_VARARGS, enable_callback_tracebacks_doc}, METH_VARARGS, enable_callback_tracebacks_doc},
{NULL, NULL} {NULL, NULL}
...@@ -423,7 +423,7 @@ PyMODINIT_FUNC init_sqlite3(void) ...@@ -423,7 +423,7 @@ PyMODINIT_FUNC init_sqlite3(void)
Py_DECREF(tmp_obj); Py_DECREF(tmp_obj);
/* initialize microprotocols layer */ /* initialize microprotocols layer */
microprotocols_init(dict); pysqlite_microprotocols_init(dict);
/* initialize the default converters */ /* initialize the default converters */
converters_init(dict); converters_init(dict);
......
...@@ -250,7 +250,7 @@ void pysqlite_statement_bind_parameters(pysqlite_Statement* self, PyObject* para ...@@ -250,7 +250,7 @@ void pysqlite_statement_bind_parameters(pysqlite_Statement* self, PyObject* para
if (!_need_adapt(current_param)) { if (!_need_adapt(current_param)) {
adapted = current_param; adapted = current_param;
} else { } else {
adapted = microprotocols_adapt(current_param, (PyObject*)&pysqlite_PrepareProtocolType, NULL); adapted = pysqlite_microprotocols_adapt(current_param, (PyObject*)&pysqlite_PrepareProtocolType, NULL);
if (adapted) { if (adapted) {
Py_DECREF(current_param); Py_DECREF(current_param);
} else { } else {
...@@ -295,7 +295,7 @@ void pysqlite_statement_bind_parameters(pysqlite_Statement* self, PyObject* para ...@@ -295,7 +295,7 @@ void pysqlite_statement_bind_parameters(pysqlite_Statement* self, PyObject* para
if (!_need_adapt(current_param)) { if (!_need_adapt(current_param)) {
adapted = current_param; adapted = current_param;
} else { } else {
adapted = microprotocols_adapt(current_param, (PyObject*)&pysqlite_PrepareProtocolType, NULL); adapted = pysqlite_microprotocols_adapt(current_param, (PyObject*)&pysqlite_PrepareProtocolType, NULL);
if (adapted) { if (adapted) {
Py_DECREF(current_param); Py_DECREF(current_param);
} else { } else {
......
...@@ -24,7 +24,7 @@ ...@@ -24,7 +24,7 @@
#include "module.h" #include "module.h"
#include "connection.h" #include "connection.h"
int _sqlite_step_with_busyhandler(sqlite3_stmt* statement, pysqlite_Connection* connection) int pysqlite_step(sqlite3_stmt* statement, pysqlite_Connection* connection)
{ {
int rc; int rc;
......
...@@ -28,7 +28,7 @@ ...@@ -28,7 +28,7 @@
#include "sqlite3.h" #include "sqlite3.h"
#include "connection.h" #include "connection.h"
int _sqlite_step_with_busyhandler(sqlite3_stmt* statement, pysqlite_Connection* connection); int pysqlite_step(sqlite3_stmt* statement, pysqlite_Connection* connection);
/** /**
* Checks the SQLite error code and sets the appropriate DB-API exception. * Checks the SQLite error code and sets the appropriate DB-API exception.
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment