Python MySQL
Python 可以在数据库应用程序中使用。
MySQL 是最受欢迎的数据库之一。
MySQL 数据库
为了能够试验本教程中的代码示例，您应该在计算机上安装 MySQL。
请在这里下载免费的 MySQL 数据库：MySQL :: MySQL Downloads。
安装 MySQL 驱动程序
Python 需要 MySQL 驱动程序来访问 MySQL 数据库。
在本教程中，我们将使用驱动程序 "MySQL Connector"。
我们建议您使用 PIP 安装 "MySQL Connector"。
PIP 很可能已经安装在 Python 环境中。
将命令行导航到 PIP 的位置，然后键入以下内容：
下载并安装 "MySQL Connector"：
python -m pip install mysql-connector
测试 MySQL Connector
如需测试安装是否成功，或者您是否已安装 "MySQL Connector"，请创建一张包含以下内容的 Python 页面：
demo_mysql_test.py:
import mysql.connector
如果执行上述代码没有错误，则 "MySQL Connector" 已安装并待用。
创建连接
首先创建与数据库的连接。
使用 MySQL 数据库中的用户名和密码：
demo_mysql_connection.py:
import mysql.connector mydb = mysql.connector.connect( host="localhost", user="bd", passwd="123456" ) print(mydb)
现在，您可以开始使用 SQL 语句查询数据库了。
Python 创建数据库
创建数据库
如需在 MySQL 中创建数据库，请使用 "CREATE DATABASE" 语句：
实例
创建名为 "mydatabase" 的数据库：
import mysql.connector mydb = mysql.connector.connect( host="localhost", user="bd", passwd="123456" ) mycursor = mydb.cursor() mycursor.execute("CREATE DATABASE mydatabase")
如果执行上面的代码没有错误，则您已成功创建数据库。
检查数据库是否存在
您可以通过使用 "SHOW DATABASES" 语句列出系统中的所有数据库，检查数据库是否存在：
实例
返回系统中的数据库列表：
import mysql.connector mydb = mysql.connector.connect( host="localhost", user="bd", passwd="123456" ) mycursor = mydb.cursor() mycursor.execute("SHOW DATABASES") for x in mycursor: print(x)
或者您可以在建立连接时尝试访问数据库：
实例
尝试连接数据库 "mydatabase"：
import mysql.connector mydb = mysql.connector.connect( host="localhost", user="bd", passwd="123456", database="mydatabase" )
如果数据库不存在，会收到错误。
Python 创建表
创建表
如需在 MySQL 中创建表，请使用 "CREATE TABLE" 语句。
请确保在创建连接时定义数据库的名称。
实例
创建表 "customers"：
import mysql.connector mydb = mysql.connector.connect( host="localhost", user="bd", passwd="123456", database="mydatabase" ) mycursor = mydb.cursor() mycursor.execute("CREATE TABLE customers (name VARCHAR(255), address VARCHAR(255))")
如果执行上面的代码没有错误，那么您现在已经成功创建了一个表。
检查表是否存在
您可以通过使用 "SHOW TABLES" 语句列出数据库中的所有表，来检查表是否存在：
实例
返回系统中的数据库列表：
import mysql.connector mydb = mysql.connector.connect( host="localhost", user="bd", passwd="123456", database="mydatabase" ) mycursor = mydb.cursor() mycursor.execute("SHOW TABLES") for x in mycursor: print(x)
主键
创建表时，您还应该为每条记录创建一个具有唯一键的列。
这可以通过定义 PRIMARY KEY 来完成。
我们使用语句 "INT AUTO_INCREMENT PRIMARY KEY"，它将为每条记录插入唯一的编号。从 1 开始，每个记录递增 1。
实例
创建表时创建主键：
import mysql.connector mydb = mysql.connector.connect( host="localhost", user="bd", passwd="123456", database="mydatabase" ) mycursor = mydb.cursor() mycursor.execute("CREATE TABLE customers (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), address VARCHAR(255))")
如果表已存在，请使用 ALTER TABLE 关键字：
实例
在已有的表上创建主键：
import mysql.connector mydb = mysql.connector.connect( host="localhost", user="bd", passwd="123456", database="mydatabase" ) mycursor = mydb.cursor() mycursor.execute("ALTER TABLE customers ADD COLUMN id INT AUTO_INCREMENT PRIMARY KEY")
插入表
如需填充 MySQL 中的表，请使用 "INSERT INTO" 语句。
实例
在表 "customers" 中插入记录：
import mysql.connector mydb = mysql.connector.connect( host="localhost", user="bd", passwd="123456", database="mydatabase" ) mycursor = mydb.cursor() sql = "INSERT INTO customers (name, address) VALUES (%s, %s)" val = ("John", "Highway 21") mycursor.execute(sql, val) mydb.commit() print(mycursor.rowcount, "record inserted.")
重要：请注意语句 mydb.commit()。需要进行更改，否则表不会有任何改变。
插入多行
要在表中插入多行，请使用 executemany() 方法。
executemany() 方法的第二个参数是元组列表，包含要插入的数据：
实例
用数据填充 "customers" 表：
import mysql.connector mydb = mysql.connector.connect( host="localhost", user="bd", passwd="123456", database="mydatabase" ) mycursor = mydb.cursor() sql = "INSERT INTO customers (name, address) VALUES (%s, %s)" val = [ ('Peter', 'Lowstreet 4'), ('Amy', 'Apple st 652'), ('Hannah', 'Mountain 21'), ('Michael', 'Valley 345'), ('Sandy', 'Ocean blvd 2'), ('Betty', 'Green Grass 1'), ('Richard', 'Sky st 331'), ('Susan', 'One way 98'), ('Vicky', 'Yellow Garden 2'), ('Ben', 'Park Lane 38'), ('William', 'Central st 954'), ('Chuck', 'Main Road 989'), ('Viola', 'Sideway 1633') ] mycursor.executemany(sql, val) mydb.commit() print(mycursor.rowcount, "was inserted.")
获取已插入 ID
您可以通过询问 cursor 对象来获取刚插入的行的 id。
注释：如果插入不止一行，则返回最后插入行的 id。
实例
插入一行，并返回 id：
import mysql.connector mydb = mysql.connector.connect( host="localhost", user="bd", passwd="123456", database="mydatabase" ) mycursor = mydb.cursor() sql = "INSERT INTO customers (name, address) VALUES (%s, %s)" val = ("Michelle", "Blue Village") mycursor.execute(sql, val) mydb.commit() print("1 record inserted, ID:", mycursor.lastrowid)
从表中选取
如需从 MySQL 中的表中进行选择，请使用 "SELECT" 语句：
实例
从表 "customers" 中选取所有记录，并显示结果：
import mysql.connector mydb = mysql.connector.connect( host="localhost", user="bd", passwd="123456", database="mydatabase" ) mycursor = mydb.cursor() mycursor.execute("SELECT * FROM customers") myresult = mycursor.fetchall() for x in myresult: print(x)
注释：我们用了 fetchall() 方法，该方法从最后执行的语句中获取所有行。
选取列
如需只选择表中的某些列，请使用 "SELECT" 语句，后跟列名：
实例
仅选择名称和地址列：
import mysql.connector mydb = mysql.connector.connect( host="localhost", user="bd", passwd="123456", database="mydatabase" ) mycursor = mydb.cursor() mycursor.execute("SELECT name, address FROM customers") myresult = mycursor.fetchall() for x in myresult: print(x)
使用 fetchone() 方法
如果您只对一行感兴趣，可以使用 fetchone() 方法。
fetchone() 方法将返回结果的第一行：
实例
仅获取一行：
import mysql.connector mydb = mysql.connector.connect( host="localhost", user="bd", passwd="123456", database="mydatabase" ) mycursor = mydb.cursor() mycursor.execute("SELECT * FROM customers") myresult = mycursor.fetchone() print(myresult)
使用筛选器来选取
从表中选择记录时，可以使用 "WHERE" 语句对选择进行筛选：
实例
选择记录为 "Park Lane 38" 的记录，结果：
import mysql.connector mydb = mysql.connector.connect( host="localhost", user="bd", passwd="123456", database="mydatabase" ) mycursor = mydb.cursor() sql = "SELECT * FROM customers WHERE address ='Park Lane 38'" mycursor.execute(sql) myresult = mycursor.fetchall() for x in myresult: print(x)
