参考教程：

https://www.runoob.com/python/python-mysql.html

准备：

在python中安装pymysql和mysql-client两个包：

pip install pymysql

pip install mysqlclient

连接数据库

在python脚本中导入：

import MySQLdb

连接已有数据库test，并获取版本信息：

# 打开数据库连接

db = MySQLdb.connect("localhost", "root", "root@123", "test", charset='utf8' )

# 使用cursor()方法获取操作游标

cursor = db.cursor()

# 使用execute方法执行SQL语句

cursor.execute("SELECT VERSION()")

# 使用 fetchone() 方法获取一条数据

data = cursor.fetchone()

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

# 关闭数据库连接

db.close()

创建数据库表

如果数据库连接存在我们可以使用execute()方法来为数据库创建表EMPLOYEE。

# 打开数据库连接

db = MySQLdb.connect("localhost", "root", "root@123", "test", charset='utf8' )

# 使用cursor()方法获取操作游标

cursor = db.cursor()

# 如果数据表已经存在使用 execute() 方法删除表。

cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")

# 创建数据表SQL语句

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()

验证查看数据表：

数据库表插入操作

使用执行 SQL INSERT 语句向表 EMPLOYEE 插入记录：

# 打开数据库连接

db = MySQLdb.connect("localhost", "root", "root@123", "test", charset='utf8' )

# 使用cursor()方法获取操作游标

cursor = db.cursor()

# SQL 插入语句

sql = """INSERT INTO EMPLOYEE(FIRST_NAME,

        LAST_NAME, AGE, SEX, INCOME)

        VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""

try:

  # 执行sql语句

  cursor.execute(sql)

  # 提交到数据库执行

  db.commit()

except:

  # Rollback in case there is any error

  db.rollback()

# 关闭数据库连接

db.close()

SQL 插入语句也可以写成如下形式：

sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \

      LAST_NAME, AGE, SEX, INCOME) \

      VALUES (%s, %s, %s, %s, %s )" % \

      ('Mac', 'Mohan', 20, 'M', 2000)

使用变量向SQL语句中传递参数:

user_id = "test123"

password = "password"

con.execute('insert into Login values(%s, %s)' % \

            (user_id, password))

数据库查询操作

Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall() 方法获取多条数据。

fetchone(): 该方法获取下一个查询结果集。结果集是一个对象

fetchall():接收全部的返回结果行.

rowcount: 这是一个只读属性，并返回执行execute()方法后影响的行数。

# 打开数据库连接

db = MySQLdb.connect("localhost", "root", "root@123", "test", charset='utf8' )

# 使用cursor()方法获取操作游标

cursor = db.cursor()

# SQL 查询语句

sql = "SELECT * FROM EMPLOYEE \

      WHERE INCOME > %s" % (1000)

try:

  # 执行SQL语句

  cursor.execute(sql)

  # 获取所有记录列表

  results = cursor.fetchall()

  for row in results:

      fname = row[0]

      lname = row[1]

      age = row[2]

      sex = row[3]

      income = row[4]

      # 打印结果

      print ("fname=%s,lname=%s,age=%s,sex=%s,income=%s" % (fname, lname, age, sex, income ) )

except:

  print ("Error: unable to fecth data")

# 关闭数据库连接

db.close()

jupyter的执行结果：

数据库更新操作

更新操作用于更新数据表的的数据，以下实例将 EMPLOYEE 表中的 SEX 字段为 'M' 的 AGE 字段递增 1：

# 打开数据库连接

db = MySQLdb.connect("localhost", "root", "root@123", "test", charset='utf8' )

# 使用cursor()方法获取操作游标

cursor = db.cursor()

# SQL 更新语句

sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')

try:

  # 执行SQL语句

  cursor.execute(sql)

  # 提交到数据库执行

  db.commit()

except:

  # 发生错误时回滚

  db.rollback()

# 关闭数据库连接

db.close()

验证执行结果：

删除操作

删除操作用于删除数据表中的数据，以下实例演示了删除数据表 EMPLOYEE 中 AGE 大于 20 的所有数据：

# 打开数据库连接

db = MySQLdb.connect("localhost","root", "root@123", "test",charset='utf8' )

# 使用cursor()方法获取操作游标

cursor = db.cursor()

# SQL 删除语句

sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)

try:

  # 执行SQL语句

  cursor.execute(sql)

  # 提交修改

  db.commit()

except:

  # 发生错误时回滚

  db.rollback()

# 关闭连接

db.close()

验证删除结果，数据记录已被删除：

执行事务

事务机制可以确保数据一致性。

事务应该具有4个属性：原子性、一致性、隔离性、持久性。这四个属性通常称为ACID特性。

对于支持事务的数据库， 在Python数据库编程中，当游标建立之时，就自动开始了一个隐形的数据库事务。

commit()方法游标的所有更新操作，rollback（）方法回滚当前游标的所有操作。每一个方法都开始了一个新的事务。