Python3 MySQL 数据库连接 - PyMySQL 驱动

本文我们为大家介绍 Python3 使用 PyMySQL 连接数据库，并实现简单的增删改查。

什么是 PyMySQL？

PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库，Python2中则使用mysqldb。

PyMySQL 遵循 Python 数据库 API v2.0 规范，并包含了 pure-Python MySQL 客户端库。

学习pymysql:

1.首先在连接数据库之前，一定要确认：

   （1）你已经建立了某数据库TESTDB（供db = pymysql.connect("localhost","testuser","test123","TESTDB"使用 )）

   （2） 在此数据库中已经建立了表EMPLOYEE（这个表可以换成别的都可以）（

        供创建数据库表使用----cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
                                         # 使用预处理语句创建表
                                       sql = """CREATE TABLE EMPLOYEE (
                                                       FIRST_NAME  CHAR(20) NOT NULL,
                                                       LAST_NAME  CHAR(20),
                                                      AGE INT, 
                                                      SEX CHAR(1),
                                                       INCOME FLOAT )"""
                                                         ）

（3）在表中写入字段（随便啥都行，应为通过pymysql可以更改。）

（4）连接数据库TESTDB使用的用户名为 "testuser" ，密码为 "test123",你可以可以自己设定或者直接使用root用户名及其密码，Mysql数据库用户授权请使用Grant命令。（这个部分我不是很清楚，也没做任何操作，只是按照db = pymysql.connect("localhost","testuser","test123","TESTDB" 写）） 正确因该是：db = pymysql.connect("localhost","root","123","TESTDB" ））

2. 完成数据库的连接操作：

#!/usr/bin/python3

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )  ##### 连接的主要操作

# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()

# 使用 execute()  方法执行 SQL 查询
cursor.execute("SELECT VERSION()")

# 使用 fetchone() 方法获取单条数据.
data = cursor.fetchone()

print ("Database version : %s " % data)

# 关闭数据库连接
db.close()

3. 创建数据库表

#!/usr/bin/python3

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()

# 使用 execute() 方法执行 SQL，如果表存在则删除
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")

# 使用预处理语句创建表
sql = """CREATE TABLE EMPLOYEE (
         FIRST_NAME  CHAR(20) NOT NULL,
         LAST_NAME  CHAR(20),
         AGE INT, 
         SEX CHAR(1),
         INCOME FLOAT )"""

cursor.execute(sql)

# 关闭数据库连接
db.close()