Python 操作Mysql 简单的增删改查

文章目录

1. 1. pip简介
2. 2. 下载安装
3. 3. 执行新增
4. 4. 执行删除
5. 5. 执行修改
6. 6. 执行查询

pymysql 是python操作mysql数据库的模块

pip简介

pip 是通用的Python包管理工具，提供了对 Python
包的查找、下载、安装、卸载的功能。通过pip管里的Python包默认下载安装到python根目录/lib/site-packages目录下。

下载安装

pip3 install pymysql

执行新增

import pymysql;

#创建连接
conn = pymysql.connect(host="127.0.0.1",port=3306,user="root",passwd="",db="firstmysql")

#创建游标
cursor = conn.cursor()
#执行函数  返回受影响的函数
effect_rows = cursor.execute("insert into db1(des) values('cs1')")
print("受影响的行数",effect_rows)
conn.commit()
#关闭游标
cursor.close()
#关闭连接
conn.close()
# 获取最新自增ID
new_id = cursor.lastrowid
print("自增ID",new_id)

执行删除

import pymysql

#创建连接
conn = pymysql.connect(host="127.0.0.1",port=3306,user="root",passwd="",db="firstmysql")

#创建游标
cursor = conn.cursor()
#执行函数  返回受影响的函数
effect_rows = cursor.execute("delete from db1  where id=1")
print("受影响的行数",effect_rows)
conn.commit()
#关闭游标
cursor.close()
#关闭连接
conn.close()

执行修改

import pymysql

#创建连接
conn = pymysql.connect(host="127.0.0.1",port=3306,user="root",passwd="",db="firstmysql")

#创建游标
cursor = conn.cursor()
#执行函数  返回受影响的函数
effect_rows = cursor.execute("update db1 set des='222222222'  where id=2")
print("受影响的行数",effect_rows)
conn.commit()
#关闭游标
cursor.close()
#关闭连接
conn.close()

执行查询

import pymysql

#创建连接
conn = pymysql.connect(host="127.0.0.1",port=3306,user="root",passwd="",db="firstmysql")

#创建游标 默认元祖
#cursor = conn.cursor()
#游标设置为字典
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
#执行函数  返回受影响的函数
effect_rows = cursor.execute("select des from db1")
print("受影响的行数",effect_rows)

# #获取前一条数据
# print(cursor.fetchone()) 
# #获取前N条数据
# print(cursor.fetchmany(2))
#获取全部数据
print(cursor.fetchall())
conn.commit()
#关闭游标
cursor.close()
#关闭连接
conn.close()

fetch 默认查询返回元祖类型，可通过设置游标 cursor`=pymysql.cursors.DictCursor 设置成字典类型`

在fetch数据时按照顺序进行，可以使用cursor.scroll(num,mode)来移动游标位置，如：

• cursor.scroll(1,mode=’relative’) # 相对当前位置移动
• cursor.scroll(2,mode=’absolute’) # 相对绝对位置移动