专栏首页python3Python3 操作Mysql数据库

Python3 操作Mysql数据库

Pymysql介绍

PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库,而Python2中则使用mysqldb。 PyMySQL 遵循 Python 数据库 API v2.0 规范,并包含了 pure-Python MySQL 客户端库。

通用步骤:

1.引入模块 2.获取与数据库的连接 3.执行SQL语句和存储过程 4.关闭数据库连接

PyMySQL 安装

1.打开cmd命令

cd C:\Users\Administrator\AppData\Local\Programs\Python\Python37\Scripts #切换目录 pip install pymysql

数据库连接

import pymysql #模块导入 #打开数据库连接 db = pymysql.connect( host='数据库ip', user='用户名, passwd='密码', db='数据库名', port=3306, charset='utf8' ) #使用 cursor() 方法创建一个游标对象 cursor cursor = db.cursor() #使用 execute() 方法执行 SQL 查询 cursor.execute("SELECT VERSION()") #使用 fetchone() 方法获取单条数据. data = cursor.fetchone() print ("Database version : %s " % data) #关闭数据库连接 db.close()

脚本输出结果:

Database version : 5.6.24-log

创建数据库表

import pymysql #打开数据库连接 db = pymysql.connect( host='数据库ip', user='用户名, passwd='密码', db='数据库名', port=3306, charset='utf8' ) #使用 cursor() 方法创建一个游标对象 cursor cursor = db.cursor() #使用 execute() 方法执行 SQL,如果表存在则删除 cursor.execute("DROP TABLE IF EXISTS info") #使用预处理语句创建表 sql = """create table info (id int not null,name char(6),score decimal(5,2),age int(4));""" cursor.execute(sql) #关闭数据库连接 db.close()

脚本验证

数据库插入操作

import pymysql #打开数据库连接 db = pymysql.connect( host='数据库ip', user='用户名, passwd='密码', db='数据库名', port=3306, charset='utf8' ) #使用cursor()方法获取操作游标 cursor = db.cursor() #SQL 插入语句 sql_1= """insert into info (id,name,score,age)values(1,'张三',88,33);""" sql_2 = """insert into info (id,name,score,age)values(2,'李四',78,23);""" sql_3 = """insert into info (id,name,score,age)values(3,'王五',58,43);""" try: #执行sql语句 cursor.execute(sql_1) cursor.execute(sql_2) cursor.execute(sql_3) #提交到数据库执行 db.commit() except: #如果发生错误则回滚 db.rollback() #关闭数据库连接 db.close()

插入数据验证

数据库查询操作

Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall() 方法获取多条数据。 fetchone(): 该方法获取下一个查询结果集。结果集是一个对象 fetchall(): 接收全部的返回结果行. rowcount: 这是一个只读属性,并返回执行execute()方法后影响的行数。

脚本文件:

import pymysql #打开数据库连接 db = pymysql.connect( host='数据库ip', user='用户名, passwd='密码', db='数据库名', port=3306, charset='utf8' ) #使用cursor()方法获取操作游标 cursor = db.cursor() #SQL 查询语句 sql = 'select * from info;' #执行SQL语句 cursor.execute(sql) #获取所有记录列表 res = cur.fetchall() #打印结果 print(res) #打印出每个元组 print(res[0]) print(res[1]) print(res[2]) |#关闭游标 cur.close() #关闭数据库 db.close()

查询验证

数据库更新操作

import pymysql #打开数据库连接 db = pymysql.connect( host='数据库ip', user='用户名, passwd='密码', db='数据库名', port=3306, charset='utf8' ) #使用cursor()方法获取操作游标 cursor = db.cursor() #SQL 查询语句 sql = 'UPDATE info SET AGE = AGE + 1 WHERE id=3' #执行SQL语句 cursor.execute(sql) try: #执行SQL语句 cursor.execute(sql) #提交到数据库执行 db.commit() except: #发生错误时回滚 db.rollback() #关闭数据库连接 db.close()

更新验证

删除操作

import pymysql #打开数据库连接 db = pymysql.connect( host='数据库ip', user='用户名, passwd='密码', db='数据库名', port=3306, charset='utf8' ) #使用cursor()方法获取操作游标 cursor = db.cursor() #SQL 查询语句 sql = 'DELETE FROM info WHERE id=3;' #执行SQL语句 cursor.execute(sql) try: #执行SQL语句 cursor.execute(sql) #提交到数据库执行 db.commit() except: #发生错误时回滚 db.rollback() #关闭数据库连接 db.close()

删除验证

执行事务

事务机制可以确保数据一致性。 事务应该具有4个属性:原子性、一致性、隔离性、持久性。这四个属性通常称为ACID特性。 原子性(atomicity)。一个事务是一个不可分割的工作单位,事务中包括的诸操作要么都做,要么都不做。 一致性(consistency)。事务必须是使数据库从一个一致性状态变到另一个一致性状态。一致性与原子性是密切相关的。 隔离性(isolation)。一个事务的执行不能被其他事务干扰。即一个事务内部的操作及使用的数据对并发的其他事务是隔离的,并发执行的各个事务之间不能互相干扰。 持久性(durability)。持续性也称永久性(permanence),指一个事务一旦提交,它对数据库中数据的改变就应该是永久性的。接下来的其他操作或故障不应该对其有任何影响。 Python DB API 2.0 的事务提供了两个方法 commit 或 rollback。

错误处理

总结:

1.本文参考了菜鸟教程和亲自操作后写出来的。 2.python2和pyhton3 模块不一样,这里主要介绍pymysql。 3.这里只是介绍最基本的知识,出发点是为自己做一份笔记,方便日后查阅! 4.增加,删除,更新数据都要提交事务,否则数据库不执行该操作。 5.同时操作多条sql语句的方法,可以参考数据库插入操作。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 【新梦想干货】RobotFramework环境搭建步骤

    RobotFramework作为公司能快速落地实现UI自动化测试的一款框架,同时也非常适合刚入门自动化测试的朋友们去快速学习自动化,笔者计划通过从搭建逐步到完成...

    新梦想IT职业教育
  • Python正则表达式匹配换行符

    默认时,Python正则中的.是不能匹配换行符的,如果碰到下面这种带有换行的js字符串该怎么办呢?

    SeanCheney
  • python|对Python中函数的学习

    在python中,定义一个函数需要使用def语句,依次写出函数名,括号,括号中的参数和冒号:,接着在缩进后编写函数,函数的返回值用return语句返回。定义函数...

    算法与编程之美
  • Python 中如何实现参数化测试?

    之前,我曾转过一个单元测试框架系列的文章,里面介绍了 unittest、nose/nose2 与 pytest 这三个最受人欢迎的 Python 测试框架。

    Python猫
  • 队列、进程互斥锁、线程

    并行: 并行是指两者同时执行,比如赛跑,两个人都在不停的往前跑;(资源够用,比如三个线程,四核的CPU )

    用户6817597
  • exec()和元类

    exec执行储存在字符串或文件中的 Python 语句,相比于 eval,exec可以执行更复杂的 Python 代码,

    用户6817597
  • Django之路由层

    以图书管理系统为例我们在数据库建立四张表:图书表、出版社表、作者表、作者信息,这里表与标的对应关系如下:

    用户6817597
  • 进程队列补充、socket实现服务器并发、线程完结

    解释型语言单个进程下多个线程不可以并行,但是向C语言等其他语言中在多核情况下是可以实现并行的,所有语言在单核下都是无法实现并行的,只能并发。

    用户6817597
  • 异常处理

    在python中不同的异常可以用不同的类型(python中统一了类与类型,类型即类)去标识,一个异常标识一种错误。

    用户6817597
  • Deepin配置TF GPU环境

    使用conda安装GPU加速版本的TensorFlow时,将自动安装GPU支持所需的CUDA和CuDNN库。不需要再额外安装这些库了。而且与 pip 安装相比,...

    故事尾音

扫码关注云+社区

领取腾讯云代金券