PyMySQL数据库操作

1.连接数据库

pymysql.connect()的前四个方法是必需的

示例：

import pymysql
try:
    # 打开数据库连接
    db = pymysql.connect(
        host='localhost',
        user='root',
        password='123456',
        database='zqf')
    print("数据库连接成功！")
except:
    print("数据库连接失败！")

2.创建表

可以使用execute()方法来为数据库创建表

• cursor() 方法创建一个游标对象 cursor

  cursor = db.cursor()

• 使用 execute() 方法执行 SQL，如果表存在则删除

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

• 编写创建表的SQL语句

sql = """CREATE TABLE mymessage(
         myname  varchar(20),
         grade  varchar(20),
         major varchar(20),  
         id varchar(20) )"""

• 执行操作

  cursor.execute(sql)

示例：

import pymysql
try:
    # 打开数据库连接
    db = pymysql.connect(
        host='localhost',
        user='root',   #用户名
        password='123456',  #密码
        database='zqf')    #数据库名称
    print("数据库连接成功！")

    cursor = db.cursor()

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

    sql = """CREATE TABLE mymessages (
              myname  varchar(20),
              grade  varchar(20),
              major varchar(20),  
              id varchar(20) )"""
    cursor.execute(sql)#执行
    print("表创建成功！")

except:
    print("表创建失败！")

3.插入数据

• 编写SQL语句

  sql = """INSERT INTO mymessages(myname,
           grade, major, id)
           VALUES ('张庆峰', '大二', '软件工程', '542013460851')"""

• 使用execute()方法执行SQL语句

  try:
     # 执行sql语句
     cursor.execute(sql)
     # 提交到数据库执行
     db.commit()
  except:
     # 如果发生错误则回滚
     db.rollback()

示例：

import pymysql

# 打开数据库连接
db = pymysql.connect(
    host='localhost',
    user='root',   #用户名
    password='123456',  #密码
    database='zqf')    #数据库名称

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

# SQL 插入语句
sql = """INSERT INTO mymessages(myname,
         grade, major, id)
         VALUES ('张庆峰', '大二', '软件工程', '542013460851')"""
try:
    # 执行sql语句
    cursor.execute(sql)
    # 提交到数据库执行
    db.commit()
    print("插入成功！")
except:
    # 如果发生错误则回滚
    db.rollback()
    print("插入失败！")

4.查询数据

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

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

示例：

import pymysql

# 打开数据库连接
db = pymysql.connect(
    host='localhost',
    user='root',   #用户名
    password='123456',  #密码
    database='zqf')    #数据库名称

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

# SQL 插入语句
sqlQuery = "SELECT * FROM mymessages "
try:
    # 执行sql语句
    cursor.execute(sqlQuery)
    # 获取所有记录列表
    results = cursor.fetchall()
    for row in results:
        myname = row[0]
        grade = row[1]
        major = row[2]
        id = row[3]
        # 打印结果
        print("myname=%s,grade=%s,major=%s,id=%s" % \
              (myname, grade, major, id))
except:
    print("查询数据失败！")

5.更新数据

• 编辑sql语句

  sql = "UPDATE mymessages SET grade=%s WHERE myname=%s"
  

• 编辑更新的信息

  value = ('大四', '小明')

示例：

import pymysql

# 打开数据库连接
db = pymysql.connect(
    host='localhost',
    user='root',   #用户名
    password='123456',  #密码
    database='zqf')    #数据库名称

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

# SQL 插入语句
sql = "UPDATE mymessages SET grade=%s WHERE myname=%s"
value = ('大四', '小明')

try:
   # 执行SQL语句
   cursor.execute(sql,value)
   # 提交到数据库执行
   db.commit()
   print("更新数据成功！")
except:
   # 发生错误时回滚
   db.rollback()
   print("更新数据失败！")

6.删除数据

import pymysql

# 打开数据库连接
db = pymysql.connect(
    host='localhost',
    user='root',   #用户名
    password='123456',  #密码
    database='zqf')    #数据库名称

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

# SQL 插入语句
sql = "DELETE FROM mymessages WHERE id = %s"
value = ('123')

try:
   # 执行SQL语句
   cursor.execute(sql,value)
   # 提交到数据库执行
   db.commit()
   print("删除数据成功！")
except:
   # 发生错误时回滚
   db.rollback()
   print("删除数据失败！")

7.删除表

import pymysql

# 打开数据库连接
db = pymysql.connect(
    host='localhost',
    user='root',   #用户名
    password='123456',  #密码
    database='zqf')    #数据库名称

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

# SQL 插入语句
sql = 'DROP TABLE IF EXISTS mymessages'

cursor.execute(sql)
print('表删除成功!')