交互类型
安装引入模块
安装
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 pymysqltry: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 pymysqltry: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 pymysqltry: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 pymysqltry: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 pymysqltry: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)'
参数列表
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 pymysqltry: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))# 将异常继续抛出# raisefinally: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 hashlibdef 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
微信扫一扫 
支付宝扫一扫 
