python针对mysql数据库的连接、查询、更新、删除操作示例

2019-11-25 11:44:12

字体：大中小

来源：转载

供稿：网友

本文实例讲述了python针对mysql数据库的连接、查询、更新、删除操作。分享给大家供大家参考，具体如下：

连接

一代码

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

二运行结果

py =======
Database version : 5.7.10-log

查询

一代码

import pymysql# 打开数据库连接db = pymysql.connect("localhost","root","root","db_test01" )# 使用cursor()方法获取操作游标 cursor = db.cursor()# SQL 查询语句sql = "SELECT * FROM EMPLOYEE /    WHERE INCOME > '%d'" % (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=%d,sex=%s,income=%d" % /       (fname, lname, age, sex, income ))except:  print ("Error: unable to fetch data")# 关闭数据库连接db.close()

二运行结果

fname=Mac,lname=Mohan,age=20,sex=M,income=2000

更新

一代码

import pymysql# 打开数据库连接db = pymysql.connect("localhost","root","root","db_test01" )# 使用cursor()方法获取操作游标 cursor = db.cursor()# SQL 更新语句sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')try:  # 执行SQL语句  cursor.execute(sql)  # 提交到数据库执行  db.commit()  print("update OK")except:  # 发生错误时回滚  db.rollback()# 关闭数据库连接db.close()

二运行结果

update OK

删除

一代码

import pymysql# 打开数据库连接db = pymysql.connect("localhost","root","root","db_test01" )# 使用cursor()方法获取操作游标 cursor = db.cursor()# SQL 删除语句sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)try:  # 执行SQL语句  cursor.execute(sql)  # 提交修改  db.commit()  print("delete OK")         except:  # 发生错误时回滚  db.rollback()# 关闭连接db.close()

二运行结果