MySQL

数据库连接

连接数据库前，请先确认以下事项：

您已经创建了数据库 world。
在TESTDB数据库中您已经创建了表 City。
City 表字段为 NAME, CONTINENT，POPULATION。
连接数据库 world 使用的用户名为 "root" ，密码为 "mysql1996",你可以可以自己设定或者直接使用root用户名及其密码，Mysql 数据库用户授权请使用Grant命令。

#!/usr/bin/python3
import pymysql
# 打开数据库连接
db = pymysql.connect("localhost","root","mysql1996","wolrd" )
# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()
# 使用 execute()  方法执行 SQL 查询 
cursor.execute("SELECT VERSION()")
# 使用 fetchone() 方法获取单条数据.
data = cursor.fetchone()
print ("Database version : %s " % data)
# 关闭数据库连接
db.close()

>>> # 输出结果
Database version: 8.0.20

创建数据库表

如果数据库连接存在我们可以使用execute()方法来为数据库创建表，如下所示创建表CITY：

#!/usr/bin/python3
import pymysql
# 打开数据库连接
db = pymysql.connect("localhost","root","mysql1996","world" )
# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()
# 使用 execute() 方法执行 SQL，如果表存在则删除
cursor.execute("DROP TABLE IF EXISTS CITY")
# 使用预处理语句创建表
sql = """CREATE TABLE CITY (
         NAME  CHAR(20) NOT NULL,
         CONTINENT  CHAR(20),
         POPULATION INT"""
cursor.execute(sql)
# 关闭数据库连接
db.close()

数据库插入操作

以下实例使用执行 SQL INSERT 语句向表 CITY 插入记录：

#!/usr/bin/python3
import pymysql
# 打开数据库连接
db = pymysql.connect("localhost","root","mysql1996","world" )
# 使用cursor()方法获取操作游标 
cursor = db.cursor()
# SQL 插入语句
sql = """INSERT INTO CITY(NAME,
         CONTINENT, POPULATION)
         VALUES ('XXX', 'ASIA', 20000)"""
try:
   # 执行sql语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # 如果发生错误则回滚
   db.rollback()
# 关闭数据库连接
db.close()

数据库查询操作

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

fetchone(): 该方法获取下一个查询结果集。结果集是一个对象
fetchall(): 接收全部的返回结果行.
rowcount: 这是一个只读属性，并返回执行execute()方法后影响的行数。

#!/usr/bin/python3
import pymysql
# 打开数据库连接
db = pymysql.connect("localhost","root","mysql1996","world" )
# 使用cursor()方法获取操作游标 
cursor = db.cursor()
# SQL 查询语句
sql = "SELECT * FROM city \
       WHERE POPULATION > %s" % (1000)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 获取所有记录列表
   results = cursor.fetchall()
   for row in results:
      name = row[0]
      continent = row[1]
      population = row[2]
       # 打印结果
      print ("name=%s,continent=%s,population=%s" % \
             (name,continent,population))
except:
   print ("Error: unable to fetch data")
# 关闭数据库连接
db.close()

数据库更新/删除操作

#!/usr/bin/python3
import pymysql
# 打开数据库连接
db = pymysql.connect("localhost","root","mysql1996","world" )
# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 更新语句
sql = "UPDATE CITY SET POPULATION = POPULATION + 1000 WHERE CONTINENT = 'ASIA'"
# SQL 删除语句
sql = "DELETE FROM CITY WHERE POPULATION > %s" % (2000)

try:
   # 执行SQL语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()
# 关闭数据库连接
db.close()