我是靠谱客的博主 醉熏康乃馨,最近开发中收集的这篇文章主要介绍全网最牛最全的Pymysql,学完轻松使用Python链接数据库  重点:学习资料学习当然离不开资料,这里当然也给你们准备了600G的学习资料,觉得挺不错的,现在分享给大家,希望可以做个参考。

概述

【文章末尾给大家留下了大量的福利】

PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库,Python2中则使用mysqldb。

1、安装pymysql

PyMySQL:这是一个使Python连接到MySQL的库,它是一个纯Python库。

PyMySQL是一个开源项目 :https://github.com/PyMySQL/PyMySQL

通过下面的命令来进行安装pymysql模块:

 

pip3 install PyMySQL

2、连接数据库

安装好pymysql后,在python程序中可以用 import pymysql 来导入模块。

在连接数据库前,首先要确定数据库服务端已启动。在数据库中有已经创建好的数据库,这里连接数据库‘mydb’,使用的用户名为‘root’,密码为‘mysql’,你可以可以自己设定。

比较常用的参数包括:

  • host:数据库主机名.默认是用本地主机

  • user:数据库登陆名.默认是当前用户

  • passwd:数据库登陆的秘密.默认为空

  • db:要使用的数据库名.没有默认值

  • port:MySQL服务使用的TCP端口.默认是3306

  • charset:数据库编码

 

导入pymysql

import pymysql

打开数据库连接

db = pymysql.connect(

    host = '127.0.0.1',   服务端地址

    port = 3306,    服务端端口

    user = 'root',   用户名

    password = 'mysql',   密码

    database = 'mydb',   要连接的数据库

    charset = 'utf8'    设置数据库编码

)

使用 cursor() 方法创建一个游标对象 cursor

cursor = db.cursor()

关闭数据库连接

db.close()

3、创建表

 

导入pymysql

import pymysql

打开数据库连接

db = pymysql.connect(

    host = '127.0.0.1',

    port = 3306, 

    user = 'root',

    password = 'mysql', 

    database = 'mydb', 

    charset = 'utf8' 

)

cursor = db.cursor()

使用预处理语句创建表,要确定数据库中不存在该表,如果存在会报错InternalError,无法进行创建

sql = """CREATE TABLE EMPLOYEE (

ID  Int NOT NULL AUTO_INCREMENT,

         NAME  CHAR(20) NOT NULL,

         PASSWORD  CHAR(20),

         AGE INT,  

         SEX CHAR(1),

         PRIMARY KEY (ID))"""

使用 execute()  方法执行 SQL语句

cursor.execute(sql)

db.close()

4、插入数据

这个连接对象也提供了对事务操作的支持,标准的方法:

  • commit() 提交数据

  • rollback() 发生错误后回滚

commit()方法游标的所有更新操作,rollback()方法回滚当前游标的所有操作

 

import pymysql

db = pymysql.connect(

    host = '127.0.0.1', 

    port = 3306,

    user = 'root',

    password = 'mysql',  

    database = 'mydb',  

    charset = 'utf8' 

)

cursor = db.cursor()

sql = """INSERT INTO EMPLOYEE(NAME,

         PASSWORD, AGE, SEX)

         VALUES ('LinWoW', 'mysql', 20, 'M')"""

try

cursor.execute(sql)

确认数据无误之后 commit之后才会将数据真正修改到数据库,如果不执行,程序运行正常,但是数据实际未插入成功

db.commit()

except:

    print('插入数据失败!')

    发生错误时回滚

    db.rollback()

db.close()

为了操作方便,可以在打开数据库连接的参数中添加下面的语句,修改完数据后就不需要手动确认数据执行。

 

autocommit = True

5、查询数据

Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall() 方法获取多条数据

  • fetchone():该方法获取下一个查询结果集。结果集是一个对象

  • etchall():接收全部的返回结果行.

  • rowcount:这是一个只读属性,并返回执行execute()方法后影响的行数。

 

import pymysql

db = pymysql.connect(

    host = '127.0.0.1', 

    port = 3306,

    user = 'root',

    password = 'mysql',  

    database = 'mydb',  

    charset = 'utf8',

    autocommit = True

)

cursor = db.cursor(pymysql.cursors.DictCursor)  设置为字典的形式返回数据(默认是元组)

使用 execute()  方法执行 SQL 查询 ,这里返回的是查询到数据的总条数

cursor.execute("SELECT * from employee")    

使用 fetchone() 方法获取查询到的单条数据,可以利用该函数实现一条一条数据的读取

data1 = cursor.fetchone()

print (data1)

'''

不设置数据返回类型打印的结果

(2, 'LinWoW', 'mysql', 20, 'M')

设置数据返回类型为字典后打印的结果

{'ID': 2, 'NAME': 'LinWoW', 'PASSWORD': 'mysql', 'AGE': 20, 'SEX': 'M'}

'''

使用 fetchall() 方法获取所有查询到的所有数据

data2 = cursor.fetchall()

print (data2)

'''

[{'ID': 3, 'NAME': 'LinWoW', 'PASSWORD': 'mysql', 'AGE': 20, 'SEX': 'M'}, {'ID': 4, 'NAME': 'LinWoW', 'PASSWORD': 'mysql', 'AGE': 20, 'SEX': 'M'}]

'''

scroll()类似文件操作中的seek(),第一个参数表示偏移量,第二个参数表示偏移的起始位置

绝对移动,参照开始的位置

cursor.scroll(1,'absolute')

相对移动,参照当前光标的位置

cursor.scroll(1,'relative')

db.close()

6、更新数据

 

import pymysql

db = pymysql.connect(

    host = '127.0.0.1', 

    port = 3306,

    user = 'root',

    password = 'mysql',  

    database = 'mydb',  

    charset = 'utf8' 

)

cursor = db.cursor()

sql = "UPDATE EMPLOYEE SET AGE = 18 WHERE ID = %s" % (2)

try

cursor.execute(sql)

db.commit()

except:

    print('修改数据失败!')

    db.rollback()

db.close()

7、删除数据

 

import pymysql

db = pymysql.connect(

    host = '127.0.0.1', 

    port = 3306,

    user = 'root',

    password = 'mysql',  

    database = 'mydb',  

    charset = 'utf8' 

)

cursor = db.cursor()

sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)

try

cursor.execute(sql)

db.commit()

except:

    print('删除数据失败!')

    db.rollback()

db.close()

8、查询优化

为了防止SQL注入,千万不要手动拼接(关键参数)查询条件,通过下面的示例来实现对查询数据的优化。

 

import pymysql

cone = pymysql.connect(

    host = '127.0.0.1',

    port = 3306,

    user = 'root',

    password = 'mysql',

    database = 'day41',

    charset = 'utf8',

    autocommit = True

)

ursor = cone.cursor(pymysql.cursors.DictCursor)

username = input('username>>>:')

password = input('password>>>:')

sql = "select * from employee  where name=%s and password=%s"

res = cursor.execute(sql,(username,password))   利用方法实现字符的自动拼接

if res:

    print('输入正确!')

else:

    print('用户名或密码错误!')

cone.close()

'''

username>>>:LinWoW

password>>>:mysql

输入正确!

username>>>:"qwwqw" or 1=1 --

password>>>:

用户名或密码错误!

  重点:学习资料学习当然离不开资料,这里当然也给你们准备了600G的学习资料

【需要的可以扫描文章末尾的qq群二维码自助拿走】

【记得(备注“csdn000”)】

【或私信000】

群里的免费资料都是笔者十多年测试生涯的精华。还有同行大神一起交流技术哦。

项目实战:

大型电商平台:

全套软件测试自动化测试教学视频

300G教程资料下载【视频教程+PPT+项目源码】

全套软件测试自动化测试大厂面经

python自动化测试++全套模板+性能测试

听说关注我并三连的铁汁都已经升职加薪暴富了哦!!!!

最后

以上就是醉熏康乃馨为你收集整理的全网最牛最全的Pymysql,学完轻松使用Python链接数据库  重点:学习资料学习当然离不开资料,这里当然也给你们准备了600G的学习资料的全部内容,希望文章能够帮你解决全网最牛最全的Pymysql,学完轻松使用Python链接数据库  重点:学习资料学习当然离不开资料,这里当然也给你们准备了600G的学习资料所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
点赞(52)

评论列表共有 0 条评论

立即
投稿
返回
顶部