MySQL与Python的交互1.交互类型2.增删改查(CRUD)3.封装

程序猿 • 2025年11月6日 07:14:22 • 系统教程 • 阅读 0

交互类型

安装引入模块

安装

mysql

模块，在

Windows

和

Ubuntu

中：

在Windows中安装mysql模块：

立即学习“Python免费学习笔记（深入）”；

在Linux中安装mysql模块：

在文件中引入模块：

import pymysql

Connection对象用于建立与数据库的连接

创建对象：调用

connect()

方法

conn = connect(参数列表)

参数：

host

：连接的mysql主机，如果本机是’localhost’

port

：连接的mysql主机的端口，默认是3306

db

：数据库的名称

user

：连接的用户名

password

：连接的密码

charset

：通信采用的编码方式，默认是’gb2312’，要求与数据库创建时指定的编码一致，否则中文会乱码对象的方法

close()

：关闭连接

commit()

：事务，所以需要提交才会生效

rollback()

：事务，放弃之前的操作

cursor()

：返回Cursor对象，用于执行sql语句并获得结果

Cursor对象：

执行sql语句

创建对象：调用Connection对象的

cursor()

方法

cursor1 = conn.cursor()

对象的方法：

close()

：关闭

execute(operation [, parameters ])

：执行语句，返回受影响的行数

fetchone()

：执行查询语句时，获取查询结果集的第一个行数据，返回一个元组

next()

：执行查询语句时，获取当前行的下一行

fetchall()

：执行查询时，获取结果集的所有行，一行构成一个元组，再将这些元组装入一个元组返回

scroll(value[,mode])

：将行指针移动到某个位置

mode

表示移动的方式，

mode

的默认值为

relative

，表示基于当前行移动到

value

，

value

为正则向下移动，

value

为负则向上移动。相对的

mode

的值为

absolute

，表示基于第一条数据的位置，第一条数据的位置为0，绝对的。举个例子便于理解：

# 导入python操作mysql的模块import pymysql获取连接对象
conn = pymysql.connect(host='127.0.0.1', user='root', password='123456', database='python01', port=3306, charset='utf8')
获取执行工具
cur = conn.cursor()
sql语句,增删改
sql = 'select birthday from t_user'
sql = 'select id,name,pwd,birthday from t_user'
执行,返回值。如果是增删改，返回受影响的行数，如果是查询，返回查询的行数
count = cur.execute(sql)print('查询的结果有%s条数据'%count)
获取第一行
dateOne = cur.fetchone()print(dateOne)
向上移动一行
cur.scroll(-1)
向下移动一行
cur.scroll(1)
cur.scroll(1,mode='absolute')   # 绝对的，这里指的是第一行cur.scroll(1,mode='relative')   # 相对的
获取所有行的数据
dataAll = cur.fetchall()print(dataAll)
for temp in dataAll:print(temp)print(dataAll[-1][2])      #dataAll[-1]得到的是一个用户所有的信息，dataAll[-1][2]获取最后一个人的密码
for temp in cur:print(temp)
s = 'id:%s,name:%s,pwd:%s,birthday:%s'for temp in dataAll:print(s%(temp[0],temp[1],temp[2],temp[3]))
关闭
cur.close()conn.close()

对象的属性

rowcount

：只读属性，表示最近一次

execute()

执行后受影响的行数

connection

：获得当前连接对象

增删改查(CRUD)

增

创建

testInsert.py

文件，向学生表中插入一条数据：

#encoding=utf-8import pymysql
try:conn=pymysql.connect(host='localhost',port=3306,db='test1',user='root',passwd='mysql',charset='utf8')cs1=conn.cursor()count=cs1.execute("insert into students(sname) values('张良')")print(count)conn.commit()cs1.close()conn.close()except Exception as e:print(e)

修改

创建

testUpdate.py

文件，修改学生表的一条数据：

#encoding=utf-8import pymysql
try:conn=pymysql.connect(host='localhost',port=3306,db='test1',user='root',passwd='mysql',charset='utf8')cs1=conn.cursor()count=cs1.execute("update students set sname='刘邦' where id=6")print(count)conn.commit()cs1.close()conn.close()except Exception as e:print(e)

删除

创建

testDelete.py

文件，删除学生表的一条数据：

#encoding=utf-8import pymysql
try:conn=pymysql.connect(host='localhost',port=3306,db='test1',user='root',passwd='mysql',charset='utf8')cs1=conn.cursor()count=cs1.execute("delete from students where id=6")print(count)conn.commit()cs1.close()conn.close()except Exception as e:print(e)

查

创建

testSelectOne.py

文件，查询一条学生信息：

import pymysql
try:conn=pymysql.connect(host='localhost',port=3306,db='test1',user='root',passwd='mysql',charset='utf8')cur=conn.cursor()cur.execute('select * from students where id=7')result=cur.fetchone()print(result)cur.close()conn.close()except Exception as e:print(e)

创建

testSelectMany.py

文件，查询全部学生信息：

#encoding=utf8import pymysql
try:conn=pymysql.connect(host='localhost',port=3306,db='test1',user='root',passwd='mysql',charset='utf8')cur=conn.cursor()cur.execute('select * from students')result=cur.fetchall()print(result)cur.close()conn.close()except Exception as e:print(e)

实例一：参数

# 导入python操作mysql的模块import pymysqlimport time
获取连接对象
conn = pymysql.connect(host='127.0.0.1', user='root', password='123456', database='python01', port=3306, charset='utf8')
获取执行工具
cur = conn.cursor()
sql语句,增删改，sql注入
sql = 'insert into t_user(name,pwd,birthday) values(%s,%s,%s)'
                                                                                                                                                    云雀语言模型                            云雀是一款由字节跳动研发的语言模型，通过便捷的自然语言交互，能够高效的完成互动对话
                                                                                            54                            
                        
                                                    查看详情                                                                        
                参数列表
name = input('输入姓名:')pwd = input('输入密码:')birthday = input('输入生日:')     # 2017年10月01日-->日期struct_time(--->2017-10-01)birthday = time.strptime(birthday,'%Y年%m月%d日')      #这里我们就用到了时间与字符串的相互转换(详情见MySQL高级)params = [name,pwd,birthday]
执行,返回值。如果是增删改，返回受影响的行数，如果是查询，返回查询的行数
count = cur.execute(sql,params)
提交
conn.commit()print('受影响的行数:%s'%count)
关闭
cur.close()conn.close()

实例二：抛出异常

# 导入python操作mysql的模块import pymysql
try:conn = Nonecur = None
# 获取连接对象conn = pymysql.connect(host='127.0.0.1',                       user='root',                       password='123456',                       database='python01',                       port=3306,                       charset='utf8')# 模拟异常# a = 1 / 0# 获取执行工具cur = conn.cursor()# sql语句,增删改sql = 'insert into t_user(name,pwd,birthday) values("小伊","123456",str_to_date("2017年10月20日","%Y年%m月%d日"))'# 执行,返回值。如果是增删改，返回受影响的行数，如果是查询，返回查询的行数count = cur.execute(sql)# 提交conn.commit()print('受影响的行数:%s' % count)
except Exception as ex:
打印异常信息，测试时候使用，项目上线，去掉
print(str(ex))# 将异常继续抛出# raise
finally:if cur != None:cur.close()if conn != None:conn.close()
实例三：
# 导入python操作mysql的模块import pymysql
获取连接对象
conn = pymysql.connect(host='127.0.0.1', user='root', password='123456', database='python01', port=3306, charset='utf8')
获取执行工具
cur = conn.cursor()
sql语句,增删改
sql = 'select birthday from t_user'
sql = 'select id,name,pwd,birthday from t_user'
执行,返回值。如果是增删改，返回受影响的行数，如果是查询，返回查询的行数
count = cur.execute(sql)print('查询的结果有%s条数据'%count)
获取第一行
dateOne = cur.fetchone()
print(dateOne)
for temp in cur:
print(temp)
s = 'id:%s,name:%s,pwd:%s,birthday:%s'for temp in dataAll:print(s%(temp[0],temp[1],temp[2],temp[3]))
关闭
cur.close()conn.close()
封装
这个库的名字：
mySqlHelper

# python操作mysql进行增删改查的封装
1、增删改，代码类似
2、查询
代码分析
1、获取连接对象
2、sql语句不同，参数不同
3、获取执行对象
增删改
查询
1、fetchone
2、fetchall
4、处理结果
5、关闭
面向对象  建立类，封装属性和函数
import pymysql
class MysqlHelper:'''python操作mysql的增删改查的封装'''
def __init__(self, host, user, password, database, port=3306, charset='utf8'):    '''    初始化参数    :param host:        主机    :param user:        用户名    :param password:    密码    :param database:    数据库    :param port:        端口号，默认是3306    :param charset:     编码，默认是utf8    '''    self.host = host    self.port = port    self.database = database    self.user = user    self.password = password    self.charset = charsetdef connect(self):    '''    获取连接对象和执行对象    :return:    '''    self.conn = pymysql.connect(host=self.host,                                user=self.user,                                password=self.password,                                database=self.database,                                port=self.port,                                charset=self.charset)    self.cur = self.conn.cursor()def fetchone(self, sql, params=None):    '''    根据sql和参数获取一行数据    :param sql:          sql语句    :param params:       sql语句对象的参数元组，默认值为None    :return:             查询的一行数据    '''    dataOne = None    try:        count = self.cur.execute(sql, params)        if count != 0:            dataOne = self.cur.fetchone()    except Exception as ex:        print(ex)    finally:        self.close()    return dataOnedef fetchall(self, sql, params=None):    '''    根据sql和参数获取一行数据    :param sql:          sql语句    :param params:       sql语句对象的参数列表，默认值为None    :return:             查询的一行数据    '''    dataall = None    try:        count = self.cur.execute(sql, params)        if count != 0:            dataall = self.cur.fetchall()    except Exception as ex:        print(ex)    finally:        self.close()    return dataalldef __item(self, sql, params=None):    '''    执行增删改    :param sql:           sql语句    :param params:        sql语句对象的参数列表，默认值为None    :return:              受影响的行数    '''    count = 0    try:        count = self.cur.execute(sql, params)        self.conn.commit()    except Exception as ex:        print(ex)    finally:        self.close()    return countdef update(self, sql, params=None):    '''    执行修改    :param sql:     sql语句    :param params:  sql语句对象的参数列表，默认值为None    :return:        受影响的行数    '''    return self.__item(sql, params)def insert(self, sql, params=None):    '''    执行新增    :param sql:     sql语句    :param params:  sql语句对象的参数列表，默认值为None    :return:        受影响的行数    '''    return self.__item(sql, params)def delete(self, sql, params=None):    '''    执行删除    :param sql:     sql语句    :param params:  sql语句对象的参数列表，默认值为None    :return:        受影响的行数    '''    return self.__item(sql, params)def close(self):    '''    关闭执行工具和连接对象    '''    if self.cur != None:        self.cur.close()    if self.conn != None:        self.conn.close()

测试查询多条数据

import mysqlHelper

初始化对象
helper = mysqlHelper.MysqlHelper('127.0.0.1', 'root', '123456', 'python01')
连接
helper.connect()
sql
sql = 'select * from t_user where name = %s and id > %s'
params
params = ['小茗',1]
执行
data = helper.fetchall(sql, params)
判断
if data:for temp in data:print(temp)else:  # None,False,0print('没有数据.')
helper.close()
测试查询一条数据
import mysqlHelper
初始化对象
helper = mysqlHelper.MysqlHelper('127.0.0.1', 'root', '123456', 'python01')
连接
helper.connect()
sql
sql = 'select * from t_user where id = %s'
sql = 'select * from t_user where id = 1'
params
params = [2]
执行
data = helper.fetchone(sql, params)
data = helper.fetchone(sql)
判断
if data:print(data)else:  # None,False,0print('没有数据.')
测试增删改
import mysqlHelperimport time
初始化对象
helper = mysqlHelper.MysqlHelper('127.0.0.1', 'root', '123456', 'python01')
连接
helper.connect()
sql
sql = 'update t_user set name =%s,pwd=%s,birthday=%s where id=%s'
params
id = input('输入编号:')name = input('输入姓名:')pwd = input('输入密码:')birthday = time.strptime(input('输入生日:'), '%Y年%m月%d日')params = [name, pwd, birthday,id]
执行
count = helper.update(sql, params)
判断
if count:print('操作成功.')else:  # None,False,0print('操作失败.')
登录和注册
登录和注册的时候需要对密码进行加密。
注意：
需要对密码进行加密，如果使用md5加密，则密码包含32个字符；如果使用sha1加密，则密码包含40个字符，这里使用这种方式。
create table userinfos(id int primary key auto_increment,uname varchar(20),upwd char(40),isdelete bit default 0);
/ret = doPwd('123')print(ret)结果：40bd001563085fc35165329ea1ff5c5ecbdbbeef/
-- 插入如下数据，用户名为123,密码为123,这是sha1加密后的值insert into userinfos values(1,'123','40bd001563085fc35165329ea1ff5c5ecbdbbeef',0);
登录与注册：
from mysqlHelper import MysqlHelperimport hashlib
def login():'''登录'''name = input('输入用户名:')pwd = input('输入密码:')
加密pwd = doPwd(pwd)helper = MysqlHelper('127.0.0.1', 'root', '123456', 'python01')helper.connect()sql = 'select * from t_user where name=%s and pwd=%s'params = [name, pwd]data = helper.fetchone(sql, params)if data:    print('登录成功.')else:  # None,False,0    print('登录失败.')
def doPwd(pwd):'''sha1编码'''mysha1 = hashlib.sha1()mysha1.update(pwd.encode('utf-8'))pwd = mysha1.hexdigest()return pwd
def register():'''注册'''name = input('输入用户名:')pwd = input('输入密码:')
加密
pwd = doPwd(pwd)helper = MysqlHelper('127.0.0.1', 'root', '123456', 'python01')helper.connect()sql = 'insert into t_user(name,pwd) values(%s,%s)'params = [name, pwd]count = helper.insert(sql, params)if count:    print('操作成功.')else:  # None,False,0    print('操作失败.')
if name == 'main':
register()
login()
以上就是MySQL与Python的交互1.交互类型2.增删改查(CRUD)3.封装的详细内容，更多请关注创想鸟其它相关文章！
                                                        版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。

如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。

发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/369946.html

ai java javascript linux mysql python ubuntu windows word 工具

打赏

微信扫一扫

支付宝扫一扫

0 0

关于作者

程序猿签约作者

364.6K 文章

0 评论

1 粉丝

这个人很懒，什么都没有留下～

微软 Loop 正式向所有用户开放：带来大量新功能和改进

上一篇 2025年11月6日 07:13:44

Win10出现无法定位序数怎么解决？Win10出现无法定位序数解决方法

下一篇 2025年11月6日 07:15:02

好文分享

c++如何获取map中所有的值_C++遍历映射容器获取value列表方法

使用范围for循环可遍历std::map提取所有value，如for (const auto& pair : data) values.push_back(pair.second)，最终得到值的集合。在C++中，std::map 是一个关联容器，存储键值对（key-value pairs）…

程序猿
2025年12月19日
0000
好文分享

C++ C++20的concepts怎么用_C++20概念与模板约束使用方法

C++20的concepts允许为模板参数定义约束，提升代码可读性和错误提示；通过concept关键字定义谓词，如Integral或Addable，并结合requires表达式检查操作合法性；标准库提供std::integral等常用concept，可应用于函数、类模板及简写函数语法，增强类型安全与…

程序猿
2025年12月19日
0000
好文分享

c++怎么理解和应用SFINAE_c++模板选择与编译期分支技巧

SFINAE指替换失败不引发错误，而是将无效模板从重载候选中移除。当编译器实例化函数模板时，若类型替换导致非法，该模板被静默排除，只要存在其他可行重载即可。这一机制用于编译期类型判断与条件选择，如通过std::enable_if限制模板参数，或利用decltype检测成员函数是否存在。C++17引入…

程序猿
2025年12月19日
0000
好文分享

C++怎么实现一个位集(bitset)的动态版本_C++动态位数组与空间优化

动态位集通过std::vector存储比特位，支持运行时指定大小和动态扩容。核心设计包括位索引到字索引的映射、按位操作及resize/push_back等动态行为，兼顾内存紧凑与访问效率。在C++中，std::bitset 是一个非常高效的固定大小位容器，适用于编译时已知长度的场景。但当需要动态调…

程序猿
2025年12月19日
0000
好文分享

C++怎么实现一个访问者模式(Visitor)_C++设计模式与访问者模式实现

访问者模式通过双重分发在不修改元素类的情况下添加新操作，由Element、ConcreteElement、Visitor、ConcreteVisitor和ObjectStructure组成，适用于数据结构稳定而操作多变的场景。访问者模式（Visitor Pattern）是一种行为设计模式，它允许你…

程序猿
2025年12月19日
0000
好文分享

c++怎么实现一个简单的模糊搜索算法_C++中实现模糊匹配与编辑距离算法

编辑距离指将一个字符串转为另一个的最少单字符操作次数，常用动态规划实现，通过设定最大允许距离实现模糊搜索。在C++中实现模糊搜索，核心思路是通过计算两个字符串之间的“距离”来衡量它们的相似度。最常用的方法是编辑距离（Levenshtein Distance）算法。它表示将一个字符串转换为另一个字符…

程序猿
2025年12月19日
0000
好文分享

c++如何动态分配二维数组_C++使用new分配二维内存示例

C++中动态分配二维数组有两种常用方法：一是使用指针数组，先分配行指针再为每行分配内存，灵活性高；二是用一维数组模拟，分配连续内存并通过下标换算访问元素，效率更高。前者适合需要灵活管理的场景，后者适用于大数据量且大小固定的场合，使用时需注意匹配new与delete[]以避免内存泄漏。在C++中，使…

程序猿
2025年12月19日
0000
好文分享

C++如何使用std::optional_C++可选类型与std::optional实践指南

std::optional是C++17引入的模板类，用于安全表示可能缺失的值。它封装一个值，通过has_value()或条件判断检查是否存在，支持value()、value_or()等方式访问，避免使用歧义特殊值。适用于查找函数、配置读取等场景，推荐用std::make_optional构造，提升代…

程序猿
2025年12月19日
0000
好文分享

c++怎么在vector中查找一个元素_c++ vector查找元素的多种实现方式

C++中查找vector元素常用方法包括：1. std::find通过迭代器返回位置，适用于无序序列；2. std::find_if配合谓词查找满足条件的元素；3. 封装contains函数判断元素是否存在；4. 有序情况下使用std::binary_search实现高效O(log n)查找。根据需…

程序猿
2025年12月19日
0000
好文分享

c++中try-catch如何使用_C++异常捕获与错误处理

C++中try-catch用于捕获异常提升程序健壮性，try块放置可能出错代码，throw抛出异常，catch按类型匹配处理，支持多类型捕获且需从具体到一般排列，结合RAII确保资源安全。在C++中，try-catch 机制是处理程序运行时异常的核心方式。它允许程序在出现错误时进行捕获并做出相应处…

程序猿
2025年12月19日
0000
好文分享

C++怎么实现一个无锁队列_C++并发编程与无锁队列实现

无锁队列通过原子操作实现多线程高效安全的数据共享，避免互斥锁开销。其核心是使用CAS等原子指令更新head和tail指针，确保线程安全。SPSC场景下可用循环缓冲区简化实现，MPMC则常用Michael-Scott链表算法，通过原子操作维护节点连接，并解决ABA问题与内存回收难题。需注意内存序选择、…

程序猿
2025年12月19日
0000
好文分享

c++中std::unordered_map的哈希冲突如何解决_c++哈希表原理与性能优化

c++kquote>std::unordered_map使用链地址法解决哈希冲突，通过哈希函数将键映射到桶，同桶元素以链表存储；查找时先定位桶再线性搜索。为减少冲突，采用高质量哈希函数（如FNV、MurmurHash）和负载因子控制（默认阈值1.0），当元素数/桶数超限时触发rehash扩容。…

程序猿
2025年12月19日
0000
好文分享

c++中的RAII是什么意思_RAII资源管理机制的原理与应用

RAII的核心是将资源生命周期绑定到对象生命周期上，利用构造函数获取资源、析构函数释放资源，确保异常安全和自动管理。1. 通过智能指针如std::unique_ptr实现内存自动释放；2. 封装文件操作，在FileWrapper析构时关闭文件；3. 使用std::lock_guard等锁管理类，作用…

程序猿
2025年12月19日
0000
好文分享

C++动态链接库(DLL)怎么创建和使用_C++库管理与动态链接库使用

首先创建C++ DLL并导出函数，使用__declspec(dllexport)和extern “C”避免名称修饰；接着在新项目中通过包含头文件、链接.lib文件或动态加载LoadLibrary调用DLL；推荐以抽象接口方式导出C++类，确保跨编译器兼容性。创建和使用C++…

程序猿
2025年12月19日
0000
好文分享

c++怎么使用const关键字_c++常量限定与编译期安全保障

const是C++中保障数据安全与代码可维护性的关键关键字，用于定义不可修改的变量，如const int max_users = 100；可替代宏定义提升类型安全。在C++中，const关键字是实现数据安全和代码可维护性的重要工具。它不仅用于定义不可修改的值，还能影响函数参数、返回值、成员函数的行…

程序猿
2025年12月19日
0000
好文分享

c++怎么获取当前函数名和行号_c++中获取函数调试信息的方法

使用__LINE__、__FILE__和__func__可获取行号、文件路径和函数名，结合__PRETTY_FUNCTION__显示完整函数签名，通过宏封装实现跨平台日志输出。在C++中获取当前函数名和行号，常用于调试、日志记录或异常追踪。虽然C++标准没有直接提供反射机制来获取函数名，但借助编译…

程序猿
2025年12月19日
0000
好文分享

C++如何实现一个简单的JSON写入器_C++数据序列化与JSON写入实现

首先定义JsonValue类型，再实现递归序列化函数。使用std::variant封装JSON支持的null、bool、数字、字符串、数组和对象类型，通过std::visit处理不同类型输出，构造时组合map与vector形成JSON结构，最终生成格式正确的JSON字符串。在C++中实现一个简单的…

程序猿
2025年12月19日
0000
好文分享

c++中无锁编程（lock-free）的挑战和实现_c++并发性能优化与无锁结构实现原理

无锁编程通过原子操作和内存序控制提升并发性能，适用于高竞争场景。它避免互斥锁以减少线程阻塞与死锁风险，但面临ABA问题、内存顺序复杂性、正确性难验证及对象生命周期管理难题。常见结构如无锁栈利用CAS更新头指针，易受ABA影响需结合Hazard Pointer；Michael-Scott队列通过hea…

程序猿
2025年12月19日
0000
好文分享

C++如何实现归并排序_C++分治排序算法Merge Sort的实现与分析

归并排序采用分治思想，先递归分割数组至单元素，再合并有序子数组，时间复杂度恒为O(n log n)，空间复杂度O(n)，稳定且适合大规模数据。归并排序是一种典型的分治算法，通过将数组不断分割成两部分，分别排序后再合并，最终得到有序序列。它的时间复杂度稳定在 O(n log n)，适合处理大规模数据…

程序猿
2025年12月19日
0000
好文分享

C++怎么实现一个队列_C++ STL中std::queue或链表实现队列操作

C++中实现队列有两种方式：使用STL的std::queue或手动链表实现。std::queue基于deque，提供push、pop、front等接口，使用方便且安全，推荐日常使用；手动链表实现需定义节点和头尾指针，操作复杂但有助于理解底层机制，适合学习场景。两者均支持O(1)入队出队，但std::…

程序猿
2025年12月19日
0000