python/mysqlclient
1
0
Fork 0
mirror of https://github.com/PyMySQL/mysqlclient.git synced 2025-08-15 02:54:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

Add low level APIs for semi-async query.

Browse Source
This commit is contained in:
INADA Naoki
2014-07-03 14:26:38 +09:00
parent 8cc6261fe2
commit 5ba60802c7
1 changed files with 74 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

74
_mysql.c
View File

@ -756,6 +756,16 @@ static int _mysql_ConnectionObject_clear(
return 0;
}
static char _mysql_ConnectionObject_fileno__doc__[] =
"Return underlaying fd for connection";
static PyObject *
_mysql_ConnectionObject_fileno(
_mysql_ConnectionObject *self)
{
return PyInt_FromLong(self->connection.net.fd);
}
static char _mysql_ConnectionObject_close__doc__[] =
"Close the connection. No further activity possible.";
@ -1963,8 +1973,10 @@ _mysql_ConnectionObject_query(
{
char *query;
int len, r;
MYSQL *mysql = &(self->connection);
if (!PyArg_ParseTuple(args, "s#:query", &query, &len)) return NULL;
check_connection(self);
Py_BEGIN_ALLOW_THREADS
r = mysql_real_query(&(self->connection), query, len);
Py_END_ALLOW_THREADS
@ -1974,6 +1986,50 @@ _mysql_ConnectionObject_query(
}
static char _mysql_ConnectionObject_send_query__doc__[] =
"Send a query. Same to query() except not wait response.\n\n\
Use read_query_result() before calling store_result() or use_result()\n";
static PyObject *
_mysql_ConnectionObject_send_query(
_mysql_ConnectionObject *self,
PyObject *args)
{
char *query;
int len, r;
MYSQL *mysql = &(self->connection);
if (!PyArg_ParseTuple(args, "s#:query", &query, &len)) return NULL;
check_connection(self);
Py_BEGIN_ALLOW_THREADS
r = mysql_send_query(mysql, query, len);
Py_END_ALLOW_THREADS
if (r) return _mysql_Exception(self);
Py_INCREF(Py_None);
return Py_None;
}
static char _mysql_ConnectionObject_read_query_result__doc__[] =
"Read result of query sent by send_query().\n";
static PyObject *
_mysql_ConnectionObject_read_query_result(
_mysql_ConnectionObject *self)
{
char *query;
int len, r;
MYSQL *mysql = &(self->connection);
check_connection(self);
Py_BEGIN_ALLOW_THREADS
r = (int)mysql_read_query_result(mysql);
Py_END_ALLOW_THREADS
if (r) return _mysql_Exception(self);
Py_INCREF(Py_None);
return Py_None;
}
static char _mysql_ConnectionObject_select_db__doc__[] =
"Causes the database specified by db to become the default\n\
(current) database on the connection specified by mysql. In subsequent\n\
@ -2344,6 +2400,12 @@ static PyMethodDef _mysql_ConnectionObject_methods[] = {
METH_VARARGS,
_mysql_ConnectionObject_close__doc__
},
{
"fileno",
(PyCFunction)_mysql_ConnectionObject_fileno,
METH_NOARGS,
_mysql_ConnectionObject_fileno__doc__
},
{
"dump_debug_info",
(PyCFunction)_mysql_ConnectionObject_dump_debug_info,
@ -2428,6 +2490,18 @@ static PyMethodDef _mysql_ConnectionObject_methods[] = {
METH_VARARGS,
_mysql_ConnectionObject_query__doc__
},
{
"send_query",
(PyCFunction)_mysql_ConnectionObject_send_query,
METH_VARARGS,
_mysql_ConnectionObject_send_query__doc__,
},
{
"read_query_result",
(PyCFunction)_mysql_ConnectionObject_read_query_result,
METH_NOARGS,
_mysql_ConnectionObject_read_query_result__doc__,
},
{
"select_db",
(PyCFunction)_mysql_ConnectionObject_select_db,