目录

一、安装pymysql

二、连接数据库

三、数据库操作

3.1 查询

3.2 更新

3.3 使用循环批量更新

 Python 系列文章学习记录： 

Python系列之Windows环境安装配置_开着拖拉机回家的博客-CSDN博客

Python系列之变量和运算符_开着拖拉机回家的博客-CSDN博客

Python系列之判断和循环_开着拖拉机回家的博客-CSDN博客

Python系列之字符串和列表_开着拖拉机回家的博客-CSDN博客

Python系列之文件操作和函数_开着拖拉机回家的博客-CSDN博客

Python系列模块之标准库OS详解_开着拖拉机回家的博客-CSDN博客

Python系列模块之标准库re详解_开着拖拉机回家的博客-CSDN博客

Python系列模块之标准库json详解_开着拖拉机回家的博客-CSDN博客

Python系列模块之标准库shutil详解_开着拖拉机回家的博客-CSDN博客

一、安装pymysql

在PyCharm 中 输入 import pyMysql , 根据提示 我们直接点击安装，模块会安装到默认的 python 安装目录的 lib目录，如下是我 安装好 pymysql 模块路径。

或者使用pip

二、连接数据库

使用connect函数创建连接对象，此连接对象提供关闭数据库、事务回滚等操作
一般传参为：host, user, passWord, port(默认为3306), database（想要连接的数据库名）

connect() 方法参数

参数 说明:

max_allowed_packet

连接对象的常见方法：

cursor游标对象的常见方法

三、数据库操作

3.1 查询

import pymysql# 创建数据库连接对象db = pymysql.connect(host="192.168.2.211",                     user="root",                     password="winner@001",                     database="ipvacloud",                     charset="utf8")# 创建一个新游标来执行查询curses = db.cursor()siteId = "Ahczlcc_P00001"# 查询SQLselectSQL = """    SELECT SiteId,SiteName from  site_all_info where SiteId ='%s'; """ % siteIdtry:    # 执行sql语句，也可执行数据库命令    curses.execute(selectSQL)    # 所有结果    result = curses.fetchall()    print(type(result))    print(result)except Exception as e:    db.rollback()     # 回滚    print("查询失败", e)finally:    curses.close()    # 关闭当前游标    db.close()        # 关闭数据库连接

查询结果:

增删改需要有提交事务的操作，查不需要提交事务，但如果循环查询，务必提交事务，否则结果都是重复的。

3.2 更新

import pymysql# 创建数据库连接对象db = pymysql.connect(host="192.168.2.211",                     user="root",                     password="winner@001",                     database="ipvacloud",                     charset="utf8")# 创建一个新游标来执行查询curses = db.cursor()siteId = "Ahczlcc_P00001"siteName = "大中国安徽滁州乐彩城"# 查询SQLselectSQL = """    update  site_all_info set sitename = '%s' where SiteId ='%s'; """ % (siteName, siteId)try:    # 执行sql语句，也可执行数据库命令    curses.execute(selectSQL)    # 增删改，必须执行事务    db.commit()    # 所有结果    result = curses.fetchall()    print(type(result))    print(result)except Exception as e:    db.rollback()     # 回滚    print("查询失败", e)finally:    curses.close()    # 关闭当前游标    db.close()        # 关闭数据库连接

查询是否更新成功

3.3 使用循环批量更新

import pymysql# 创建数据库连接对象db = pymysql.connect(host="192.168.2.211",                     user="root",                     password="winner@001",                     database="ipvacloud",                     charset="utf8")# 创建一个新游标来执行查询curses = db.cursor()siteId = "Ahczlcc_P00001"siteName = "大中国安徽滁州乐彩城"table_name = "site_all_info"update_list = ['Ahczlcc_P00001S00004', 'Ahczlcc_P00001S00005']update_condition_list = ['北餐饮门', '北大门']for i in range(len(update_list)):    # 查询SQL    selectSQL = """        update  %s set sitename = '%s' where SiteId ='%s';     """ % (table_name, update_condition_list[i], update_list[i])    print(table_name, update_condition_list[i], update_list[i])    try:        # 执行sql语句        curses.execute(selectSQL)        # 执行事务        db.commit()    except Exception as e:        db.rollback()        print(e)curses.close()db.close()

执行结果对比：

Python 系列文章学习记录： 

Python系列之Windows环境安装配置_开着拖拉机回家的博客-CSDN博客

Python系列之变量和运算符_开着拖拉机回家的博客-CSDN博客

Python系列之判断和循环_开着拖拉机回家的博客-CSDN博客

Python系列之字符串和列表_开着拖拉机回家的博客-CSDN博客

Python系列之文件操作和函数_开着拖拉机回家的博客-CSDN博客

Python系列模块之标准库OS详解_开着拖拉机回家的博客-CSDN博客

Python系列模块之标准库re详解_开着拖拉机回家的博客-CSDN博客

Python系列模块之标准库json详解_开着拖拉机回家的博客-CSDN博客

Python系列模块之标准库shutil详解_开着拖拉机回家的博客-CSDN博客

参考：

python——数据库操作PyMysql使用详解_南京丛林Jungle的博客-CSDN博客

来源地址：https://blog.csdn.net/qq_35995514/article/details/130984339