pymysql的链接池实现

在使用pymysql做为MySQL驱动时，在多线程模型下，若是咱们没有为每一个线程建立一个单独的链接的话，就会遇到下列错误

pymysql.err.InternalError: Packet sequence number wrong - got 0 expected 1

这是由于pymysql的threadsafety级别为 1: Threads may share the module, but not connections.

可是为每一个线程建立单独的链接的话，若是任务量比较大同时使用线程池的场景下，会形成client和MySQL server之间的频繁“链接-登陆-退出”，这显然是不优雅的。因此咱们须要一个“链接池”，以达到client和MySQL之间只需维持较少的链接，便可完成任务的效果。

笔者实现了一个基于pymysql的链接池模块pymysql_pool，包含两个类

• pymysql_pool.Connection类，继承自pymysql.connections.Connection类，在保证使用方法一致的前提下，增长了对链接池的维护

• pymysql_pool.ConnectionPool类，表明链接池，其中包含指定数目的pymysql_pool.Connection对象。这里的pymysql_pool.Connection对象相比pymysql.connections.Connection对象，增长了一个属性来标明该链接所属的链接池，也正是经过该属性来区分一个普通链接和一个池中的链接，进而对链接对象的close()方法和Context Manager Protocol进行不一样的处理

项目详情请移步github