用python实现接口测试(四、操作MySQL)-阿里云开发者社区

开发者社区> 数据库> 正文

用python实现接口测试(四、操作MySQL)

简介: 一、MySQL简介 使用Python进行MySQL的库主要有三个,Python-MySQL(更熟悉的名字可能是MySQLdb),PyMySQL和SQLAlchemy。

一、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.4MySQL图文安装教程

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

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

img_d3abce3c97dacd81a77eda9412755e89.png
安装成功标志

三、数据库常用指令

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支持的方法:

img_ca43f5bfbd15cce271f64c459987f767.png
游标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服务端

img_fb18127e0ae8c5849f6312e3631c738c.png
MySQL server 5.7

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

img_114bd08e524b81c636a3fcda102adff1.png
数据库连接操作

创建数据表

img_e44630a4fb8638fc396892305e937f1f.png
创建数据表

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

img_6f7d5308c6e8c9d2917968fd3d3214da.png
插入多条数据

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

img_0df18f7ab01317f191a1b9fda7573e93.png
查询数据操作

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

img_c9c845162d909eeb04156d1772b44239.png
更新数据操作

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

img_57cd116d1ee5c73eeaa3a05e52c0c473.png
删除操作

九、数据库代码重构

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

#coding:utf-8

conn_dict=dict(host='127.0.0.1', user='root', passwd='123456', db='user',charset='utf8')

2.查看数据库用户名称和密码

img_d6066a2edd68bbe8aeec9fa71d026851.png
user数据库中的用户名和密码

3.运行上述代码,输入user数据库中的用户名和密码进行测试

img_62daa9592b1679f0ce80b615bd55abca.png
运行结果

MySQL练习暂时告一段落,以上代码还需继续优化,不然每次操作数据库时不注销掉创建表格等操作的话会导致代码运行提示错误,后续继续优化代码。。。

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

分享:
数据库
使用钉钉扫一扫加入圈子
+ 订阅

分享数据库前沿,解构实战干货,推动数据库技术变革

其他文章