怎样给Python的MySQL模块加功能

介绍

小编给大家分享一下怎样给Python的MySQL模块加功能,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获、下面让我们一起去了解一下吧!

使用Python操作MySQL数据库的时候常使用MySQLdb这个模块。在开发的过程发现MySQLdb.connect有些参数没法设置。通过这个页面我们看到的是在连接的时候,可以设置的选项和client_flags和MySQLcapi相比差不少。下面小编来讲解下如何给Python的MySQL模块加功能吗?

如何给Python的MySQL模块加功能

一个很重要的参数MYSQL_OPT_READ_TIMEOUT没法设置,这个参数如果不设置,极致状况MySQL处于挂住,自动切换IP漂移,客户端无法重连到新MySQL。

给MySQLdb加选项很简单,只要修改_mysql。c这个把Python对象映射到MySQL操作的文件,添加参数,再加一段mysql_option即可。

  下面是修改后的gitdiff文件

diff--gita/_mysql.cb/_mysql.cindexd42cc54..61a9b34100644---a/_mysql.c+++b/_mysql.c@@-489,9+489,10@@_mysql_ConnectionObject_Initialize("named_pipe","init_command","read_default_file","read_default_group","client_flag","ssl",-"local_infile",+"local_infile","read_timeout",NULL};intconnect_timeout=0;+intread_timeout=0;intcompress=-1,named_pipe=-1,local_infile=-1;char*init_command=NULL,*read_default_file=NULL,@@-500,7+501,7@@_mysql_ConnectionObject_Initialize(self->converter=NULL;self->open=0;check_server_init(-1);-if(!PyArg_ParseTupleAndKeywords(args,kwargs,"|ssssisOiiisssiOi:connect",+if(!PyArg_ParseTupleAndKeywords(args,kwargs,"|ssssisOiiisssiOii:connect",kwlist,&host,&user,&passwd,&db,&port,&unix_socket,&conv,@@-509,7+510,8@@_mysql_ConnectionObject_Initialize(&init_command,&read_default_file,&read_default_group,&client_flag,&ssl,-&local_infile/*DONOTPATCHFORRECONNECT,IDIOTS+&local_infile,&read_timeout+/*DONOTPATCHFORRECONNECT,IDIOTSIFYOUDOTHIS,IWILLNOTSUPPORTYOURPACKAGES.*/))return-1;@@-540,6+542,12@@_mysql_ConnectionObject_Initialize(mysql_options(&(self->connection),MYSQL_OPT_CONNECT_TIMEOUT,(char*)&timeout);}++if(read_timeout){+unsignedinttimeout=read_timeout;+mysql_options(&(self->connection),MYSQL_OPT_READ_TIMEOUT,(char*)&timeout);+}+if(compress!=-1){mysql_options(&(self->connection),MYSQL_OPT_COMPRESS,0);client_flag|=CLIENT_COMPRESS;

  代码修改完毕,pythonsetup.pyinstall即可,如果出现mysql_config找不到的问题。你还要修改setup_posix.py文件。

hoterran@hoterran-laptop: ~/项目/MySQL-python-1.2.3 gitdiffsetup_posix.pydiff美元——吉塔/setup_posix.pyb setup_posix.pyindex86432f5 . . f4f08f1100644————/setup_posix.py + + + b/setup_posix.py@@-23, 7 + 23日7 @@defmysql_config(什么):ifret/256在1:raiseEnvironmentError (“% snotfound" % (mysql_config.path)) returndata-mysql_config.path=癿ysql_config" + mysql_config.path=?usr/地方/mysql/bin/mysql_config" defget_config (): importos, sys

如何给Python的mysql模块加功能

编译通过,我们来试试添加的read_timeout这个参数。

康涅狄格州=MySQLdb.connect(主机=DB_SERVER用户=DB_USERNAME passwd=DB_PASSWORD db=DB_NAME端口=int (DB_PORT) client_flag=2, read_timeout=10)

然后执行语句前,你试着把mysql用gdbhang住10 s后,Python就会异常抛错

OperationalError: (2013 & # 39; LostconnectiontoMySQLserverduringquery& # 39;)在/home/hoterran/项目/dbaas/箱子/dbtest.py(18)()在mydb.execute_sql(康涅狄格州、sql) (Pdb)返回,在/home/hoterran/项目/dbaas/箱子/dbtest.py (18) ()→None> mydb.execute_sql(康涅狄格州、sql) (Pdb) OperationalError: (2013 & # 39; LostconnectiontoMySQLserverduringquery& # 39;)在(1)()→没有

以上是“怎样给Python的mysql模块加功能”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注行业资讯频道!

怎样给Python的MySQL模块加功能