Python 3 与 MySQL 5.6

时间：2021-12-21 22:00:07

主要简单说下Python 3.3搭配MySQL Community Server 5.6的使用。在Python 3系列和MySQL 5.0系列里面下面的代码应该都通用。（没有验证）

准备

python 3 这个在python的官方网站就能download. http://www.python.org/

MySQL Community Server 5.6 在MySQL的官网也能找到： http://dev.mysql.com/downloads/mysql/5.6.html

MySQL官方已经提供了支持Python 3.0的connector，地址： http://dev.mysql.com/downloads/connector/ （这里包含了MySQL对C, C++, Python, Java, .NET等语言的连接器）

简述

Python3访问MySQL 5.6过程和访问其他的数据没有太大的不同。都经历以下几个步骤：

  1. 建立连接。
  2. 建立游标cursor。
  3. 调用cursor的execute方法，以SQL语句和变量为参数，执行数据库操作。
  4. 返回结果。
  5. 关闭游标，关闭连接。

在操作之前，看下MySQL数据库里面的数据结构

Python 3 与 MySQL 5.6

读数据

从数据库读数据的基本操作。基本就是遵循上面的步骤。

eg1>>> import mysql

>>> from mysql import connector

>>> user = 'herbert'

>>> pwd = '851020'

>>> host = '127.0.0.1'

>>> db = 'world'

>>> cnx = mysql.connector.connect(user=user, password=pwd, host=host,

                                      database=db)

>>> cursor = cnx.cursor()

>>> cursor.execute("SELECT * FROM CITY WHERE COUNTRYCODE = 'CHN';")

>>> cities = cursor.fetchall()

>>> cities

[(1890, 'Shanghai', 'CHN', 'Shanghai', 9696300), (1891, 'Peking', 'CHN', 'Peking', 7472000), (1892, 'Chongqing', 'CHN', 'Chongqing', 6351600), (1893, 'Tianjin', 'CHN', 'Tianjin', 5286800), ....

最后调用相应的方法关闭连接。里面关于Exception的处理方法和一般数据库连接相似，但是python里面每个数据库都定义了自己的DatabaseError。对于MySQL的DatabaseError是定义在mysql.connector模块中的。可以通过mysql.connector来查看和使用。

eg2>>> cursor.close()

True

>>> cnx.close()

>>> cnx

<mysql.connector.connection.MySQLConnection object at 0x00000000037FF160>

>>> cnx.is_connected()

False

>>>

写数据

如何更新数据库数据或者插入新数据。写入完成后，最好调用下连接器的commit()提交下数据（虽然它也会自动commit）

eg3>>> import mysql

>>> from mysql import connector

>>> user = 'herbert'

>>> pwd = '*****'

>>> host = '127.0.0.1'

>>> db = 'world'

>>> cnx = mysql.connector.connect(user=user, password=pwd, host=host,

                                      database=db)

>>> cursor = cnx.cursor()

>>> cursor.execute("Update city Set Population = 9696500 Where ID = 1890 AND \

NAME = 'Shanghai';")

>>> cursor.close()

True

>>> cnx.commit()

>>> cnx.is_connected()

True

>>> cnx.close()

>>> cnx.is_connected()

False

>>>

更新后的数据库数据

Python 3 与 MySQL 5.6

参数化

在实际使用过程中，SQL语句的使用往往会带有参数，不是固定的，会接受用户的参数来返回用户想要的结果。同时这样做也可以防范一些SQL注入的危险。

在python的数据库模块中，每种数据库对应的参数处理形式往往是不同的。要根据具体的数据库的paramstyle选用相应的参数传入形式。有以下几种形式：

  1. qmark 问号类型。 eg. cur.execute(“… where name = ? and account = ?”,  (symbol, account))
  2. numberic 数字类型。eg. cur.execute(“… where name = :0 and account = :1”,  (symbol, account))
  3. named 命名类型。ORACLE数据库采用的形式。eg. cur.execute(“… where name = : symbol and account = :account”,  {‘symbol’:value1, ‘account’: value2})
  4. format 格式代码。eg. cur.execute(“… where name = %s and account = %d”,  (symbol, account))
  5. pyformat 扩展格式代码。MySQL采用的就是这种形式。eg. cur.execute(“… where name = %(name)s and account = %(account)d”,  {‘symbol’:value1, ‘account’: value2})

paramstyle查看：

eg5>>> mysql.connector.paramstyle

'pyformat'

示例

eg4>>> import mysql

>>> from mysql import connector

>>> user = 'herbert'

>>> pwd = '851020'

>>> host = '127.0.0.1'

>>> db = 'world'

>>> country = 'CHN'

>>> cnx = mysql.connector.connect(user=user, password=pwd, host=host,

                                      database=db)

>>> cursor = cnx.cursor()

>>> cursor.execute("SELECT * FROM CITY where CountryCode = %(country)s", {'country':country})

>>>

上面的示例同样也适用与更新和写入新数据操作。这样比字符串拼接有更好的安全性。

额外注意

  • paramstyle在不同的数据库上的不同。
  • cursor.execute方法在不同的数据库上适用略有不同。比如在ORACLE数据库上，还要先调用其cursor.prepare（）方法，传入SQL语句。
  • 对于数据库操作过程中的各种exception的处理，包括更新和写操作成功性的判断，进行commit或者rollback操作。
  • 对于数据库读取的返回的数据的处理，可以使用namedtuple.但是还有更好的方法，在后面的文章进行专门讲述。
  • 关于cursor的其他的方法的使用。python操作数据库最关键的还是cursor的各种方法调用。

相关文章