怎样用Python操作数据库呢？手把手教你
1.安装引入模组
安装mysql模组，在windows和ubuntu中
windows里安装mysql模组
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()
实际专案中的登入注册往往加入了各种验证，这里的程式码只是一个简单的登入注册，只为了学习交流。
赶紧不错的话给小编点个赞 转发一下哦！ 如果需要python资料 数据库的小伙伴 也可以私信小编免费领取。
