hcq/openGauss-connector-python-psycopg2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

解决python3.9连接数据库挂掉问题

Browse Source
This commit is contained in:
zcl
2024-09-25 17:08:07 +08:00
parent 1f46b0a708
commit b9d27b0dbc
1 changed files with 13 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
psycopg/connection_type.c
View File

@ -1356,8 +1356,8 @@ register_type_uint(connectionObject *self, PyThreadState **tstate)
} }
if (typecast_add((PyObject *)obj, self->string_types, 0) < 0) { goto end; } if (typecast_add((PyObject *)obj, self->string_types, 0) < 0) { goto end; }
rv = 0; rv = 0;
free(_typecast_INTEGER_types);
end: end:
free(_typecast_INTEGER_types);
Py_XDECREF(values); Py_XDECREF(values);
Py_XDECREF(name); Py_XDECREF(name);
return rv; return rv;
@ -1428,15 +1428,26 @@ connection_setup(connectionObject *self, const char *dsn, long int async)
Dprintf("connection_setup: good connection object at %p, refcnt = " Dprintf("connection_setup: good connection object at %p, refcnt = "
FORMAT_CODE_PY_SSIZE_T, FORMAT_CODE_PY_SSIZE_T,
self, Py_REFCNT(self)); self, Py_REFCNT(self));
PyThreadState *tstate = (PyThreadState *)malloc(sizeof(PyThreadState));
Py_BEGIN_ALLOW_THREADS; Py_BEGIN_ALLOW_THREADS;
pthread_mutex_lock(&self->lock); pthread_mutex_lock(&self->lock);
sql_compatibility_value = pq_get_guc_locked(self, "sql_compatibility", &_save); sql_compatibility_value = pq_get_guc_locked(self, "sql_compatibility", &_save);
set_sql_compatibility(self, sql_compatibility_value); set_sql_compatibility(self, sql_compatibility_value);
if (register_type_uint(self, &_save)) { goto exit; } memcpy(tstate, _save, sizeof(_save));
pthread_mutex_unlock(&self->lock); pthread_mutex_unlock(&self->lock);
Py_END_ALLOW_THREADS; Py_END_ALLOW_THREADS;
pthread_mutex_lock(&self->lock);
if (register_type_uint(self, &tstate)) {
goto exit;
}
if (tstate) {
free(tstate);
tstate = NULL;
}
pthread_mutex_unlock(&self->lock);
exit: exit:
if (sql_compatibility_value){ if (sql_compatibility_value){
free(sql_compatibility_value); free(sql_compatibility_value);