2.2 python数据库-mysql

devtools/2024/11/6 11:40:02/

以mysql为例,数据库的操作包括:连接、断开、新增库表、新增数据、查询数据、删除数据和修改数据

1. 连接与关闭

python">#!/usr/bin/python3import pymysqldb = pymysql.connect(host='localhost',user='testuser',password='test123',database='TESTDB')# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()# 使用 execute()  方法执行 SQL 查询 
cursor.execute("SELECT VERSION()")# 使用 fetchone() 方法获取单条数据.
data = cursor.fetchone()print ("Database version : %s " % data)# 关闭数据库连接
db.close()

特别注意,使用完后记得调close关闭连接,否则mysql数据库将维持这个连接直到超时断开。

当然,可以结合装饰器或者with、finnaly等关键字,实现兜底。这里不做展开了。

2. 创建库表

python"># 使用预处理语句创建表
sql = """CREATE TABLE EMPLOYEE (FIRST_NAME  CHAR(20) NOT NULL,LAST_NAME  CHAR(20),AGE INT,  SEX CHAR(1),INCOME FLOAT )"""cursor.execute(sql)

3. 查询数据

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

  • fetchone(): 该方法获取下一个查询结果集。结果集是一个对象
  • fetchall(): 接收全部的返回结果行.
  • rowcount: 这是一个只读属性,并返回执行execute()方法后影响的行数。
python"># SQL 查询语句
sql = "SELECT * FROM EMPLOYEE \WHERE INCOME > %s" % (1000)
try:# 执行SQL语句cursor.execute(sql)# 获取所有记录列表results = cursor.fetchall()for row in results:fname = row[0]lname = row[1]age = row[2]sex = row[3]income = row[4]# 打印结果print ("fname=%s,lname=%s,age=%s,sex=%s,income=%s" % \(fname, lname, age, sex, income ))
except:print ("Error: unable to fetch data")

4. 新增数据

python"># SQL 插入语句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,LAST_NAME, AGE, SEX, INCOME)VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
try:# 执行sql语句cursor.execute(sql)# 提交到数据库执行db.commit()
except:# 如果发生错误则回滚db.rollback()

注意:commit方法是用于提交db事务的,主要是ddl操作会自动提交,dml操作不会

这里推荐大家看Python操作Mysql_pymysql commit-CSDN博客这篇文章

5. 修改数据

python"># SQL 更新语句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')
try:# 执行SQL语句cursor.execute(sql)# 提交到数据库执行db.commit()
except:# 发生错误时回滚db.rollback()

6. 删除数据

python"># SQL 删除语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)
try:# 执行SQL语句cursor.execute(sql)# 提交修改db.commit()
except:# 发生错误时回滚db.rollback()

关于mysql的一些基本知识和语法,本文不做展开;另外,大部分时候,我们用到的框架例如django等,都会继承orm,会有一套操作方式,至少目前,用到pymysql操作的,都还是脚本编写时。如果是服务化或常驻化的场景,不推荐使用。

后续章节中会分享django orm相关内容。

参考

Python3 MySQL 数据库连接 – PyMySQL 驱动 | 菜鸟教程

Python操作Mysql_pymysql commit-CSDN博客


http://www.ppmy.cn/devtools/131745.html

相关文章

linux多IP地址环境下,java读取本机实际的IP地址

一、ifconfig 可以看到,本机有许多IP地址,还未许多未截取。 而实际的IP是192.168.8.28 所以我们在读取本机IP的时候,需要去掉无效的IP。 因为本机安装了docker导致生成了许多虚拟网段的IP。 二、源码 import java.net.InetAddress; impor…

Vue.js组件开发:构建高效、可复用的前端应用

Vue.js组件开发:构建高效、可复用的前端应用 Vue.js是一款轻量级、灵活且易于上手的前端框架,广泛应用于构建现代Web应用。Vue.js的核心思想是通过组件化的方式来构建应用,每个组件都是一个独立的、可复用的代码块,负责渲染特定的…

网页版五子棋—— WebSocket 协议

目录 前言 一、背景介绍 二、原理解析 1.连接过程(握手) 2.报文格式 三、代码示例 1.服务端代码 (1)TestAPI 类 (2)WebSocketConfig 类 2.客户端代码 3.代码演示 结尾 前言 从本篇文章开始&am…

Mac删除软件,步骤超简单!

Mac删除软件,有人容易,有人难,但不管怎么样,你确定你删除的软件是彻底干净的吗?看看张女士的故事咯。 周末的下午,张女士坐在咖啡馆里,端着一杯热气腾腾的拿铁,准备用她的MacBook处…

HTB:PermX[WriteUP]

目录 连接至HTB服务器并启动靶机 1.How many TCP ports are listening on PermX? 使用nmap对靶机TCP端口进行开放扫描 2.What is the default domain name used by the web server on the box? 使用curl访问靶机80端口 3.On what subdomain of permx.htb is there an o…

【spark的集群模式搭建】Standalone集群模式的搭建(简单明了的安装教程)

文章目录 1、使用Anaconda部署Python2、上传、解压、重命名3、创建软连接4、配置spark环境变量5、修改 spark-env.sh配置文件6、启动hdfs,创建文件夹7、修改spark-defaults.conf配置文件8、修改workers配置文件9、修改log4j.properties配置文件(可选&…

掌握 Jest 配置文件:优化单元测试的灵活性与可维护性

引言 在现代软件开发中,单元测试是确保代码质量和稳定性的关键步骤。Jest 是一个广泛使用的 JavaScript 测试框架,提供了丰富的配置选项来优化测试过程。通过配置文件,开发者可以更灵活地控制测试环境,确保测试的可靠性和可维护性…

系统学英语 — 句子成分

句子成分 句子成分的类型包括:主、谓、宾、表、定、状、补、同位语。 成分作用充当词类举例主语句子的主体,动作的发出者。表示什么人、什么事。1)名词性词(名词、代词、数词、非谓语动词);2)…