Lines Matching refs:connection
45 PyErr_SetString(cur->connection->ProgrammingError,
59 * Registers a cursor with the connection.
64 register_cursor(pysqlite_Connection *connection, PyObject *cursor)
71 if (PyList_Append(connection->cursors, weakref) < 0) {
83 connection: object(type='pysqlite_Connection *', subclass_of='clinic_state()->ConnectionType')
90 pysqlite_Connection *connection)
97 Py_INCREF(connection);
98 Py_XSETREF(self->connection, connection);
115 if (!pysqlite_check_thread(self->connection)) {
119 if (!register_cursor(connection, (PyObject *)self)) {
150 Py_VISIT(self->connection);
162 Py_CLEAR(self->connection);
221 if (!self->connection->detect_types) {
233 if (self->connection->detect_types & PARSE_COLNAMES) {
246 pysqlite_state *state = self->connection->state;
258 if (!converter && self->connection->detect_types & PARSE_DECLTYPES) {
267 pysqlite_state *state = self->connection->state;
299 if (self->connection->detect_types & PARSE_COLNAMES) {
343 sqlite3 *db = self->connection->db;
345 if (self->connection->detect_types
397 if (self->connection->text_factory == (PyObject*)&PyUnicode_Type) {
410 PyObject *exc = self->connection->OperationalError;
418 } else if (self->connection->text_factory == (PyObject*)&PyBytes_Type) {
420 } else if (self->connection->text_factory == (PyObject*)&PyByteArray_Type) {
423 converted = PyObject_CallFunction(self->connection->text_factory, "y#", text, nbytes);
469 PyErr_SetString(cur->connection->state->ProgrammingError,
474 return (pysqlite_check_thread(cur->connection)
475 && pysqlite_check_connection(cur->connection)
512 PyObject *cache = self->connection->statement_cache;
852 pysqlite_state *state = self->connection->state;
861 pysqlite_statement_create(self->connection, operation));
873 if (self->connection->isolation_level
875 && sqlite3_get_autocommit(self->connection->db))
877 if (begin_transaction(self->connection) < 0) {
906 _pysqlite_seterror(state, self->connection->db);
949 self->rowcount = (long)sqlite3_changes(self->connection->db);
957 self->rowcount += (long)sqlite3_changes(self->connection->db);
968 lastrowid = sqlite3_last_insert_rowid(self->connection->db);
1045 int max_length = sqlite3_limit(self->connection->db,
1048 PyErr_SetString(self->connection->DataError,
1054 sqlite3 *db = self->connection->db;
1097 _pysqlite_seterror(self->connection->state, db);
1129 self->rowcount = (long)sqlite3_changes(self->connection->db);
1135 (void)_pysqlite_seterror(self->connection->state,
1136 self->connection->db);
1296 if (!self->connection) {
1303 if (!pysqlite_check_thread(self->connection) || !pysqlite_check_connection(self->connection)) {
1332 {"connection", T_OBJECT, offsetof(pysqlite_Cursor, connection), READONLY},