Python访问MySQL（1）：初步使用PyMySQL包

2022-01-06 00:50:50

Windows 10家庭中文版，MySQL 5.7.20 for Win 64，Python 3.6.4，PyMySQL 0.8.1，2018-05-08

----

使用Python访问MySQL数据库，自己写包？当然可以，但已经有一些很好用的包可以使用了，在PYPI可以找到。

通过搜索“mysql”关键字，找到了1000+的推荐，可是，要选择哪些呢？怎么选？打开各个包的页面可以找到一些

参考标准。不过，在搜索页面的首页没有看到PyMySQL包，在Order by下拉列表框中选择Date last updated，此

时可以看到PyMySQL排在第9位。~~怎么说呢，通过PYPI来找需要的包挺麻烦的，除非你熟悉所有Python包。

怎么办？怎么高效地找到最合适的包呢？百度！通过百度，你可以知道“大家”都在使用什么包在做什么工作，然

后，再去PYPI找相应的包，再决定是否使用它。

我这里为什么会使用PyMySQL包呢？因为我看到教程（菜鸟）里面提到了它，打开PyMySQL的页面后，发现其热

度还挺高的，在GitHub上有3930颗星星，再看了一些其它PyMySQL博文，发现其挺适合自己使用的，于是，就选

它了。

PyMySQL的首页

本文使用的PyMySQL版本是0.8.1，它Python 2.7和3.4及更高版本，支持版本号大于5.5的MySQL和MariaDB。

----

安装PyMySQL

pip3 install pymysql

安装完毕后，可以使用pip3 list查看到PyMySQL包已经安装了。

编写PyMySQL程序

说明，在编程之前看完PyMySQL的相关教程会避免一些陷阱。

按照PyMySQL的首页给出的Example，编写一个程序读取自己的数据库表（上一篇博文中介绍的数据库earth下的表area）。

其实，就是抄抄抄，抄完还不是完全懂，然后还是要读PyMySQL的文档、资料。

主要开发、测试工具：IDLE、Notepad++

代码如下:

 import pymysql.cursors

 # Connect to the database

 conn = pymysql.connect(host='localhost',

                       user='root',

                       password='',

                       db='earth',

                       charset='utf8mb4',

                       cursorclass=pymysql.cursors.DictCursor)

 print(conn.get_server_info())

 print(conn.get_host_info())

 try:

     with conn.cursor() as cursor:

         # Create a new record

         sql = "INSERT INTO area (name_cn, parent_id, name_en) VALUES (%s, %s, %s)"

         cursor.execute(sql, ('中国', , 'China'))

         # conn is not autocommit by default.

         # so you must commit to save these changes.

         conn.commit()

     with conn.cursor() as cursor:

         # read a single record

         sql = "SELECT id, parent_id, name_cn, name_en, create_t, update_t FROM area"

         cursor.execute(sql)

         result = cursor.fetchone()

         print(result)

     with conn.cursor() as cursor:

         # read all records

         sql = 'select id,parent_id,name_cn,name_en from area'

         cursor.execute(sql)

         results = cursor.fetchall()

         for row in results:

             rid = row.get('id')

             rpid = row.get('parent_id')

             rcnn = row.get('name_cn')

             renn = row.get('name_en')

             print("id = %d, pid = %d, name_cn = %s, name_en = %s" % \

                 (rid, rpid, rcnn, renn))

 finally:

     conn.close()