Function MySQL_init

mysql-connector-python/src/mysql_capi.c:401–456

MySQL instance initialization function. MySQL instance initialization function. It handles the connection arguments passed as positional or keyword arguments. Not all connection arguments are used with the initialization function. List of arguments which can be used: buffered, raw, charset_name, connection_timeout, use_unicode, auth_plugin Other connection argument are u

    @retval NULL        Exception
*/
int
MySQL_init(MySQL *self, PyObject *args, PyObject *kwds)
{
    PyObject *charset_name = NULL, *use_unicode = NULL, *auth_plugin = NULL,
             *plugin_dir = NULL, *con_timeout = NULL;

    static char *kwlist[] = {"buffered", "raw", "charset_name",
                             "connection_timeout", "use_unicode", "auth_plugin",
                             "plugin_dir", NULL};

    PyDateTime_IMPORT;

    // Initialization expect -1 when parsing arguments failed
    if (!PyArg_ParseTupleAndKeywords(
            args, kwds, "|O!O!O!O!O!O!O!", kwlist, &PyBool_Type, &self->buffered_at_connect,
            &PyBool_Type, &self->raw_at_connect, &PyUnicode_Type, &charset_name, &PyLong_Type,
            &con_timeout, &PyBool_Type, &use_unicode, &PyUnicode_Type, &auth_plugin,
            &PyUnicode_Type, &plugin_dir))
        return -1;

    if (self->buffered_at_connect) {
        self->buffered = self->buffered_at_connect;
    }

    if (self->raw_at_connect) {
        self->raw = self->raw_at_connect;
    }

    if (use_unicode && use_unicode == Py_False) {
        self->use_unicode = 0;
    }

    if (charset_name) {
        Py_DECREF(self->charset_name);
        self->charset_name = charset_name;
        Py_INCREF(self->charset_name);
    }

    if (auth_plugin && strcmp(PyUnicode_AsUTF8(auth_plugin), "") != 0) {
        Py_DECREF(self->auth_plugin);
        self->auth_plugin = auth_plugin;
        Py_INCREF(self->auth_plugin);
    }

    if (plugin_dir) {
        Py_DECREF(self->plugin_dir);
        self->plugin_dir = plugin_dir;
        Py_INCREF(self->plugin_dir);
    }

    if (con_timeout) {
        self->connection_timeout = (unsigned int)PyLong_AsUnsignedLong(con_timeout);
    }

    return 0;
}

/**