查阅pymysql源代码后

作者:澳门娱乐

在行使pymysql的时候,通过fetchall()或fetchone()能够收获查询结果,但以此重回数据是不分包字段新闻的(不比php方便)。查阅pymysql源代码后,其实获得查询结果源代码也是极其轻巧的,直接调用cursor.description就可以。

一、MySQL简介

譬如:

动用Python进行MySQL的库尊敬有多少个,Python-MySQL(更熟谙的名字大概是MySQLdb),PyMySQL和SQLAlchemy。

 

Python-MySQL资格最老,焦点由C语言构建,接口精炼,质量最好,瑕疵是意况信任比较多,安装复杂,近四年已告一段落更新,只帮忙Python2,不支持Python3。

 代码如下

PyMySQL为代表Python-MySQL而生,纯python构建,接口与Python-MySQL包容,安装方便,辅助Python3。

db=pymysql.connect(...)

SQLAlchemy是贰个ORM框架,它并不提供底层的数据库操作,而是要依附MySQLdb、PyMySQL等级三方库来完成,近来SQLAlchemy在Web编制程序领域使用分布。

cur=db.cursor()

二、MySQL安装方式

cur.execute(sql)

软件版本:

print(cur.description)

MYQSL:mysql-5.7.17

result=cur.fetchall()

PYTHON:Python 3.4.4

data_dict=[]

1.Computer端的安装MYQSL来作为server:详细的情况操作步骤见MySQL+Python 3.4.4、MySQL图像和文字安装教程

forfieldincur.description:

2.Python端安装pymysql,轻易的下令安装情势:pip install pymysql

  data_dict.append(field[0])

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

print(data_dict)

图片 1

 

安装成功申明

在pymysql的 pymysql/cursors.py 中,找到 class Cursor 能够看出如下代码:

三、数据库常用命令

 

1.Python下链接数据库的接口剖判:

 代码如下

pymysql.Connect()参数表明

def__init__(self, connection):

host(str):      MySQL服务器地址

  self.connection=connection

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

  self.description=None

user(str):      用户名

  self.rownumber=0

passwd(str):    密码

  self.rowcount=-1

db(str):        数据库名称

  self.arraysize=1

charset(str):  连接编码

  self._executed=None

connection对象支持的法子

  self._result=None

cursor()        使用该连接创制并赶回游标

  self._rows=None

commit()        提交当前事务

  self._warnings_handled=False

rollback()      回滚当前职业

 

close()        关闭连接

因而,调用 cur.rowcount 是足以快捷回到查询结果记录数的,无需通过 len() 获得。

cursor对象协理的措施

原稿链接:

execute(op)    实施二个数据库的询问命令

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

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

fetchall()      获取结果聚集的有着行

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

close()        关闭游标对象

2.数据库游标对象cursor帮忙的主意:

图片 2

游标cursor方法

3.MySQL数据库常用命令:

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

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

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

show tables;    //查看test库上面包车型地铁表

CREATE  TABLE  user (name VARCHA汉兰达(20),password VARCHA奥迪Q7(20));    //成立user表,name 和password 八个字段

insert into user values('汤姆','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服务端

图片 3

MySQL server 5.7

连日来操作需领会主机地址host、端口port、客户名user、用户密码password、数据库名和编码格局charset(编码形式可写可不写)

图片 4

数据库连接操作

创设数据表

图片 5

始建数据表

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

图片 6

插入多条数据

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

图片 7

查询数据操作

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

图片 8

更新数据操作

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

图片 9

删除操作

九、数据库代码重构

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.查看数据库顾客名称和密码

图片 10

user数据库中的客户名和密码

3.运行上述代码,输入user数据库中的客商名和密码举行测验

图片 11

运作结果

MySQL演练权且停止,以上代码还需继续优化,否则老是操作数据库时不撤销掉创制表格等操作的话会招致代码运营提醒错误,后续继续优化代码。。。

本文由澳门娱乐6165发布,转载请注明来源

关键词: