用python实现接口测试（四、操作MySQL）

用户6367961

发布于 2019-09-29 20:02:58

9910

发布于 2019-09-29 20:02:58

文章被收录于专栏：自学测试之道自学测试之道

一、MySQL简介

使用Python进行MySQL的库主要有三个，Python-MySQL（更熟悉的名字可能是MySQLdb），PyMySQL和SQLAlchemy。

Python-MySQL资格最老，核心由C语言打造，接口精炼，性能最棒，缺点是环境依赖较多，安装复杂，近两年已停止更新，只支持Python2，不支持Python3。

PyMySQL为替代Python-MySQL而生，纯python打造，接口与Python-MySQL兼容，安装方便，支持Python3。

SQLAlchemy是一个ORM框架，它并不提供底层的数据库操作，而是要借助于MySQLdb、PyMySQL等第三方库来完成，目前SQLAlchemy在Web编程领域应用广泛。

二、MySQL安装方式

软件版本：

MYQSL:mysql-5.7.17

PYTHON:Python 3.4.4

1.电脑端的安装MYQSL来作为server：详情操作步骤见MySQL+Python 3.4.4、MySQL图文安装教程

2.Python端安装pymysql，简单的命令安装方式：pip install pymysql

离线安装方式：下载MySQL安装包后，执行命令pip install pymysql-x.x.x.tar.gz

安装成功标志

三、数据库常用指令

1.Python下链接数据库的接口解析：

pymysql.Connect()参数说明

host(str): MySQL服务器地址

port(int): MySQL服务器端口号

user(str): 用户名

passwd(str): 密码

db(str): 数据库名称

charset(str): 连接编码

connection对象支持的方法

cursor() 使用该连接创建并返回游标

commit() 提交当前事务

rollback() 回滚当前事务

close() 关闭连接

cursor对象支持的方法

execute(op) 执行一个数据库的查询命令

fetchone() 取得结果集的下一行

fetchmany(size) 获取结果集的下几行

fetchall() 获取结果集中的所有行

rowcount() 返回数据条数或影响行数

close() 关闭游标对象

2.数据库游标对象cursor支持的方法：

游标cursor方法

3.MySQL数据库常用指令：

show databases; // 查看当前所有的数据库

create database user; //创建user数据库

use test; //作用与test数据库

show tables; //查看test库下面的表

CREATE TABLE user (name VARCHAR(20),password VARCHAR(20)); //创建user表，name 和password 两个字段

insert into user values('Tom','1321'); //向user表内插入若干条数据

select * from user; //查看user表的数据

delete from user where name = 'Jack'; //删除name 等于Jack的数据

update user set password='1111' where name = 'Alen'; //修改name等于Alen 的password 为 1111

select * from user; //查看表内容

四、MySQL操作指令之连接操作

pycharm+pymysql连接mysql之前先打开MySQL server服务端

MySQL server 5.7

连接操作需知道主机地址host、端口port、用户名user、用户密码password、数据库名和编码方式charset（编码方式可写可不写）

数据库连接操作

创建数据表

创建数据表

五、MySQL操作指令之插入操作

插入多条数据

六、MySQL操作指令之查询操作

查询数据操作

七、MySQL操作指令之更新操作

更新数据操作

八、MySQL操作指令之删除操作

删除操作

九、数据库代码重构

1.直接上代码---pymysql.py

#coding:utf-8 import pymysql import config import pymysql.cursors class PyMySQLHelper(object): def __init__(self): self.conn = config.conn_dict def get_one(self, sql, params): conn = pymysql.connect(**self.conn) cur = conn.cursor(cursor = pymysql.cursors.DictCursor) retCount = cur.execute(sql, params) data = cur.fetchone() cur.close() conn.close() return data def get_many(self, sql, params): conn = pymysql.connect(**self.conn) cur = conn.cursor(cursor = pymysql.cursors.DictCursor) retCount = cur.execute(sql, params) data = cur.fetchall() cur.close() conn.close() return data def insert_one(self, sql, params): conn = pymysql.connect(**self.conn) cur = conn.cursor() cur.execute(sql, params) conn.commit() cur.close() return u'插入数据库成功' def insert_many(self, sql, params): conn = pymysql.connect(**self.conn) cur = conn.cursor() cur.executemany(sql, params) conn.commit() cur.close() return u'批量插入数据库成功' def update_one(self, sql, params): conn = pymysql.connect(**self.conn) cur = conn.cursor(cursor = pymysql.cursors.DictCursor) ret = cur.execute(sql, params) conn.commit() cur.close() conn.close() return u'更新数据库成功' def delete_one(self, sql, params): conn = pymysql.connect(**self.conn) cur = conn.cursor(cursor = pymysql.cursors.DictCursor) ret = cur.execute(sql, params) conn.commit() cur.close() conn.close() return u'删除数据库成功' class CheckUser(object): def __init__(self): self.__helper = PyMySQLHelper() def checkValid(self, name, password): sql ='select * from user where name=%s and password=%s' params = (name, password) return self.__helper.get_one(sql, params) def info(): name =raw_input(u'请输入你的用户名:') password =raw_input(u'请输入你的密码:') user = CheckUser() result = user.checkValid(name, password) if not result: print u'用户名或者密码错误，请联系管理员' else: print u'恭喜您，输入正确！' if __name__ =='__main__': info()

config.py