pymsql操作mysql的方式

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介:

python操作mysql的方式都是通过模块的形式:
原生的:pymsql
ORM框架 SQLAchemy

pymysql模块

pymsql 是python中的mysql模块,要想使用这个模块,就需要先安装,安装步骤如下:

pip3 install pymysql
或者
easy_install pymysql
AI 代码解读

pymysql的使用

使用步骤:
1、导入模块
2、创建连接
3、创建拿去数据的游标(手)
4、执行sql,并返回受影响的行数
5、关闭游标(拿回手)
6、关闭连接
代码如下:

#导入模块
import pymysql
#创建连接
conn = pymysql.connect(host='localhost',port=3306,user='kk',passwd='123',db='pysqltest')
#创建游标
course = conn.cursor()
#执行sql
插入表
row1 = course.execute("create table t1(id int auto_increment PRIMARY KEY ,name VARCHAR (32) not NULL )")
插入多天数据用executemany这个函数,后面用列表
# row2 = course.executemany("insert into t1 (name) VALUES (%s)",[("kk"),("gg")])
更新表,这个会把name一列全部修改为www
# row3 = course.execute("update t1 set name='www'")
条件修改,只把后面的id=1的修改
row4 = course.execute("update t1 set name='ee' WHERE id = %s",1)

#提交到数据库
conn.commit()
#关闭游标
course.close()
#关闭数据库连接
conn.close()
AI 代码解读

结果:
pymsql操作mysql的方式

获取自己增ID

这个就是数据库表里面的auto_increment的最后一个值,我们在数据库中可以通过alter 表名+set auto_increment_increment=xx来设置,这里我们通过pymysql怎么获取这个值那?

# 获取最新自增ID,把这个写到py文件里面,就可以获得当前操作后得到的id值
new_id = cursor.lastrowid
AI 代码解读

获取数据

pymysql是通过游标来拿去数据,可以一条一条的拿 也可以一次全部都拿回来

import pymysql

conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123', db='t1')
cursor = conn.cursor()
cursor.execute("select * from hosts")
# 获取第一行数据
row_1 = cursor.fetchone()

# 获取前n行数据
# row_2 = cursor.fetchmany(3)
# 获取所有数据
# row_3 = cursor.fetchall() 
conn.commit()
cursor.close()
conn.close()
AI 代码解读

在fetch数据时按照顺序进行,可以使用cursor.scroll(num,mode)来移动游标位置,如:
cursor.scroll(1,mode='relative') # 相对当前位置移动
cursor.scroll(2,mode='absolute') # 相对绝对位置移动


fetch默认得到的值是元祖的数据,要想得到字典的数据,要在建立游标的时候指定:
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)



本文转自 kesungang 51CTO博客,原文链接:http://blog.51cto.com/sgk2011/2052364,如需转载请自行联系原作者

相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
MySQL 中 GRANT 操作会引起复制中断吗?
GRANT 操作并不是一个原子性操作,不管执行成功与否,都会触发一个隐式重载授权表的行为。 在生产环境中需要规范用户创建及授权的操作,不推荐使用 DML 语句去直接变更 mysql.user 表,可能会引发其他的问题,若使用了 DML 语句进行变更, 需要手工执行 flush privileges。
141 4
【mysql技巧】如何在这个mysql语句执行前加个前提,也就是只有表里没有相同数据才进行添加插入操作
【mysql技巧】如何在这个mysql语句执行前加个前提,也就是只有表里没有相同数据才进行添加插入操作
70 1
创建nodejs项目并接入mysql,完成用户相关的增删改查的详细操作
创建nodejs项目并接入mysql,完成用户相关的增删改查的详细操作
120 0
面试题MySQL问题之简单的SELECT操作在MVCC下加锁如何解决
面试题MySQL问题之简单的SELECT操作在MVCC下加锁如何解决
80 2
实时计算 Flink版操作报错合集之从mysql读数据写到hive报错,是什么原因
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
实时计算 Flink版操作报错合集之运行mysql to doris pipeline时报错,该如何排查
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
实时计算 Flink版操作报错合集之整库同步mysql到starRock提交任务异常,该如何处理
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
「Python入门」python操作MySQL和SqlServer
**摘要:** 了解如何使用Python的pymysql模块与MySQL数据库交互。首先,通过`pip install pymysql`安装模块。pymysql提供与MySQL的连接功能,例如创建数据库连接、执行SQL查询。在设置好MySQL环境后,使用`pymysql.connect()`建立连接,并通过游标执行SQL(如用户登录验证)。注意防止SQL注入,使用参数化查询。增删改操作需调用`conn.commit()`来保存更改。pymssql模块类似,但导入和连接对象创建略有不同。
122 0
「Python入门」python操作MySQL和SqlServer
『Django』模型入门教程-操作MySQL
一个后台如果没有数据库可以说废了一半。日常开发中大多数时候都在与数据库打交道。Django 为我们提供了一种更简单的操作数据库的方式。 在 Django 中,模型(Model)是用来定义数据库结构的类。每个模型类通常对应数据库中的一个表,类的属性对应表中的列。通过定义模型,Django 的 ORM(Object-Relational Mapping)可以将 Python 对象映射到数据库表,并提供一套 API 来进行数据库操作。 本文介绍模型的用法。

热门文章

最新文章