您当前的位置:首页 > 电脑百科 > 程序开发 > 语言 > Python

如何用Python操作数据库?

时间:2019-06-28 10:15:23  来源:  作者:

1.安装引入模块

 

如何用Python操作数据库?听听老程序员怎么说

 

windows里安装mysql模块

如何用Python操作数据库?听听老程序员怎么说

 

linux里安装mysql模块

  • 在文件中引入模块import pymysql

 

2.Connection对象

  • 用于建立与数据库的连接
  • 创建对象:调用connect()方法
  • conn=connect(参数列表)
  • 参数host:连接的mysql主机,如果本机是'localhost'
  • 参数port:连接的mysql主机的端口,默认是3306
  • 参数db:数据库的名称
  • 参数user:连接的用户名
  • 参数password:连接的密码
  • 参数charset:通信采用的编码方式,默认是'gb2312',要求与数据库创建时指定的编码一致,否则中文会乱码

3.对象的方法

  • 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()

4.对象的属性

  • rowcount只读属性,表示最近一次execute()执行后受影响的行数
  • connection获得当前连接对象

 

增删改查

1.增

  • 创建testInsert.py文件,向学生表中插入一条数据
#encoding=utf-8
import 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,e:
 print(e)

2.修改

  • 创建testUpdate.py文件,修改学生表的一条数据
#encoding=utf-8
import 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,e:
 print(e)

3.删除

  • 创建testDelete.py文件,删除学生表的一条数据
#encoding=utf-8
import 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)

4.查

  • 创建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=utf8
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')
 result=cur.fetchall()
 print result
 cur.close()
 conn.close()
except Exception as e:
 print(e)

实例一:参数

# 导入python操作mysql的模块
import pymysql
import 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 pymysql
try:
 conn = None
 cur = 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()

封装

我们可以封装一个py文件,方便每次进行调用。把这个库定义为:mySqlHelper

"""
python操作mysql进行增删改查的封装
1、增删改,代码类似
2、查询
代码分析
1、获取连接对象
2、sql语句不同,参数不同
3、获取执行对象
"""
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 = charset
 def 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 dataOne
 def 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 dataall
 def __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 count
 def 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()

测试

1.测试查询多条数据

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,0
 print('没有数据.')
helper.close()

2.测试查询一条数据

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,0
 print('没有数据.')

3.测试增删改

import mysqlHelper
import 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,0
 print('操作失败.')

4.简单的登录和注册

做项目的时候会有个尝试登录和注册的时候需要对密码进行加密进行存储,刚好结合sql语句进行一个简单的交互。

注意:

  • 需要对密码进行加密
  • 如果使用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);

登录与注册

import hashlib
from mysqlHelper import MysqlHelper
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()

实际项目中的登录注册往往加入了各种验证,这里的代码只是一个简单的登录注册,只为了学习交流。

来源网络,侵权联系删除



Tags:Python   点击:()  评论:()
声明:本站部分内容及图片来自互联网,转载是出于传递更多信息之目的,内容观点仅代表作者本人,如有任何标注错误或版权侵犯请与我们联系(Email:2595517585@qq.com),我们将及时更正、删除,谢谢。
▌相关推荐
大家好,我是菜鸟哥,今天跟大家一起聊一下Python4的话题! 从2020年的1月1号开始,Python官方正式的停止了对于Python2的维护。Python也正式的进入了Python3的时代。而随着时间的...【详细内容】
2021-12-28  Tags: Python  点击:(1)  评论:(0)  加入收藏
学习Python的初衷是因为它的实践的便捷性,几乎计算机上能完成的各种操作都能在Python上找到解决途径。平时工作需要在线学习。而在线学习的复杂性经常让人抓狂。费时费力且效...【详细内容】
2021-12-28  Tags: Python  点击:(1)  评论:(0)  加入收藏
Python 是一个很棒的语言。它是世界上发展最快的编程语言之一。它一次又一次地证明了在开发人员职位中和跨行业的数据科学职位中的实用性。整个 Python 及其库的生态系统使...【详细内容】
2021-12-27  Tags: Python  点击:(2)  评论:(0)  加入收藏
菜单驱动程序简介菜单驱动程序是通过显示选项列表从用户那里获取输入并允许用户从选项列表中选择输入的程序。菜单驱动程序的一个简单示例是 ATM(自动取款机)。在交易的情况下...【详细内容】
2021-12-27  Tags: Python  点击:(4)  评论:(0)  加入收藏
近日只是为了想尽办法为 Flask 实现 Swagger UI 文档功能,基本上要让 Flask 配合 Flasgger, 所以写了篇 Flask 应用集成 Swagger UI 。然而不断的 Google 过程中偶然间发现了...【详细内容】
2021-12-23  Tags: Python  点击:(6)  评论:(0)  加入收藏
有不少同学学完Python后仍然很难将其灵活运用。我整理15个Python入门的小程序。在实践中应用Python会有事半功倍的效果。01 实现二元二次函数实现数学里的二元二次函数:f(x,...【详细内容】
2021-12-22  Tags: Python  点击:(32)  评论:(0)  加入收藏
Verilog是由一个个module组成的,下面是其中一个module在网表中的样子,我只需要提取module名字、实例化关系。module rst_filter ( ...); 端口声明... wire定义......【详细内容】
2021-12-22  Tags: Python  点击:(9)  评论:(0)  加入收藏
运行环境 如何从 MP4 视频中提取帧 将帧变成 GIF 创建 MP4 到 GIF GUI ...【详细内容】
2021-12-22  Tags: Python  点击:(6)  评论:(0)  加入收藏
面向对象:Object Oriented Programming,简称OOP,即面向对象程序设计。类(Class)和对象(Object)类是用来描述具有相同属性和方法对象的集合。对象是类的具体实例。比如,学生都有...【详细内容】
2021-12-22  Tags: Python  点击:(9)  评论:(0)  加入收藏
所谓内置函数,就是Python提供的, 可以直接拿来直接用的函数,比如大家熟悉的print,range、input等,也有不是很熟,但是很重要的,如enumerate、zip、join等,Python内置的这些函数非常...【详细内容】
2021-12-21  Tags: Python  点击:(5)  评论:(0)  加入收藏
▌简易百科推荐
大家好,我是菜鸟哥,今天跟大家一起聊一下Python4的话题! 从2020年的1月1号开始,Python官方正式的停止了对于Python2的维护。Python也正式的进入了Python3的时代。而随着时间的...【详细内容】
2021-12-28  菜鸟学python    Tags:Python4   点击:(1)  评论:(0)  加入收藏
学习Python的初衷是因为它的实践的便捷性,几乎计算机上能完成的各种操作都能在Python上找到解决途径。平时工作需要在线学习。而在线学习的复杂性经常让人抓狂。费时费力且效...【详细内容】
2021-12-28  风度翩翩的Python    Tags:Python   点击:(1)  评论:(0)  加入收藏
Python 是一个很棒的语言。它是世界上发展最快的编程语言之一。它一次又一次地证明了在开发人员职位中和跨行业的数据科学职位中的实用性。整个 Python 及其库的生态系统使...【详细内容】
2021-12-27  IT资料库    Tags:Python 库   点击:(2)  评论:(0)  加入收藏
菜单驱动程序简介菜单驱动程序是通过显示选项列表从用户那里获取输入并允许用户从选项列表中选择输入的程序。菜单驱动程序的一个简单示例是 ATM(自动取款机)。在交易的情况下...【详细内容】
2021-12-27  子冉爱python    Tags:Python   点击:(4)  评论:(0)  加入收藏
有不少同学学完Python后仍然很难将其灵活运用。我整理15个Python入门的小程序。在实践中应用Python会有事半功倍的效果。01 实现二元二次函数实现数学里的二元二次函数:f(x,...【详细内容】
2021-12-22  程序汪小成    Tags:Python入门   点击:(32)  评论:(0)  加入收藏
Verilog是由一个个module组成的,下面是其中一个module在网表中的样子,我只需要提取module名字、实例化关系。module rst_filter ( ...); 端口声明... wire定义......【详细内容】
2021-12-22  编程啊青    Tags:Verilog   点击:(9)  评论:(0)  加入收藏
运行环境 如何从 MP4 视频中提取帧 将帧变成 GIF 创建 MP4 到 GIF GUI ...【详细内容】
2021-12-22  修道猿    Tags:Python   点击:(6)  评论:(0)  加入收藏
面向对象:Object Oriented Programming,简称OOP,即面向对象程序设计。类(Class)和对象(Object)类是用来描述具有相同属性和方法对象的集合。对象是类的具体实例。比如,学生都有...【详细内容】
2021-12-22  我头秃了    Tags:python   点击:(9)  评论:(0)  加入收藏
所谓内置函数,就是Python提供的, 可以直接拿来直接用的函数,比如大家熟悉的print,range、input等,也有不是很熟,但是很重要的,如enumerate、zip、join等,Python内置的这些函数非常...【详细内容】
2021-12-21  程序员小新ds    Tags:python初   点击:(5)  评论:(0)  加入收藏
Hi,大家好。我们在接口自动化测试项目中,有时候需要一些加密。今天给大伙介绍Python实现各种 加密 ,接口加解密再也不愁。目录一、项目加解密需求分析六、Python加密库PyCrypto...【详细内容】
2021-12-21  Python可乐    Tags:Python   点击:(8)  评论:(0)  加入收藏
最新更新
栏目热门
栏目头条