pyMysqL这款第三方库可以帮助我们利用python语言与MysqL进行链接
首先要下载pyMysqL
pip install pymsql 以下是pyMysqL的基本使用
import pyMysqL# 链接，C/S架构，TCP链接conn = pyMysqL.connect( host="localhost",database="db1",charset="utf8mb4",user="root",cursorclass=pyMysqL.cursors.DictCursor,# 记录结果，字典显示 # password = "your password",) # 游标cursor = conn.cursor()# 执行sqlsql = "show tables"res = cursor.execute(sql) # 提交执行，返回sql影响成功的行数print(res) # 2 代表该数据库下有2个表print(cursor.fetchall()) # [{'tables_in_db1': 't1'},{'tables_in_db1': 't2'}]cursor.close() # 关闭游标conn.close()可以看到在上面的示例中有一个游标的概念，其实这个也非常简单，就等同于光标的上下移动，每移动一次代表一条记录。
在pymsql中，对于select等 *** 作返回的结果都可以通过游标的移动配合相应方法函数来进行读取。
如果你的某些sql语句要进行字符串拼接，那么一定要使用pyMysqL提供的execute()方法进行拼接，不要去用python中的%或format()方法，这可能导致出现sql注入问题带来不安全的隐患。
注意：使用
execute()时，不可传入表名，数据库名。否则会抛出语法错误，这是因为在拼接时会自动添加上``号
import pyMysqL# 链接conn = pyMysqL.connect( host="localhost",) # 游标cursor=conn.cursor()# 执行sqlsql = "select * from t1 where ID=%s"res = cursor.execute(sql,("1",)) # 提交执行，返回sql影响成功的行数 这里拼接能预防sql注入问题print(res) # 1 查出一条记录print(cursor.fetchall()) # 拿到所有记录的结果cursor.close() # 关闭游标conn.close() 在执行UPDATE/INSERT/DELETE之类的 *** 作，必须使用conn.commit()进行事务提交后方可生效。
或者你可以在实例化conn对象时为他指定auto_commit参数为true即可自动提交事务。
当 *** 作出现问题时，可以使用conn.rollback()进行事务回滚。
import pyMysqL# 链接conn = pyMysqL.connect( host="localhost",# 记录结果，字典显示 autocommit = True,# 自动提交 # password = "your password",) # 游标cursor=conn.cursor()# 执行sqlsql = "insert into t1(name) values(%s)"res = cursor.execute(sql,("新记录",)) # 提交执行，返回sql影响成功的行数 这里拼接能预防sql注入问题print(res) # 1 成功插入一条记录print(cursor.lastrowID) #在插入语句后查看，查看最后一条记录的行号print(cursor.fetchall())# conn.commit() # 手动提交cursor.close() # 关闭游标conn.close() 使用cursor.executemany()方法可一次性提交多条sql *** 作。
import pyMysqL# 链接conn = pyMysqL.connect( host="localhost",) # 游标cursor=conn.cursor()# 执行sqlsql = "insert into t1(name) values(%s)" # 同一条命令，执行3次res = cursor.executemany(sql,[("新记录1"),("新纪录2"),("新纪录3")]) # 提交执行，返回sql影响成功的行数 这里拼接能预防sql注入问题print(res) # 3 成功插入三条记录print(cursor.lastrowID) #在插入语句后查看，查看最后一条记录的行号print(cursor.fetchall())cursor.close() # 关闭游标conn.close()获取到一条记录后，我们可以控制游标移动。
也可以控制查看游标后的多少条记录
游标每移动一次代表一条记录
| 命令解析 | 描述 |
|---|---|
| cursor.scroll(3,mode='absolute') | 游标以绝对位置向后移动3条记录 |
| cursor.scroll(3,mode='relative') | 游标以当前位置向后移动3条记录 |
| 注意：游标移动的条数即为记录的条数，如果移动值为负N就代表上N条记录 | |
如果我们想获取记录，可使用以下三个方法
| 命令解析 | 描述 |
|---|---|
| cursor.fetchone() | 获取第一条记录，游标向下移动一行 |
| cursor.fetchmany(2) | 获取接下来的两条记录，游标向下移动两行 |
| cursor.fetchall() | 获取全部记录，游标移动到末尾，返回的是一个列表 |
import pyMysqL# 链接conn = pyMysqL.connect( host="localhost",) # 游标cursor=conn.cursor()# 执行sqlsql = "select * from t1" # t1表中4条记录cursor.execute(sql)print(cursor.fetchone()) 游标移动到2的位置cursor.scroll(2,mode='relative') 向下移动2，当前游标为4print(cursor.fetchone())cursor.close() # 关闭游标conn.close()"""{'ID': 1,'name': '记录1'}{'ID': 4,'name': '记录4'}""" 如果执行的是INSERT *** 作，可以在插入后查看最后插入的ID行号
import pyMysqL# 链接conn = pyMysqL.connect( host="localhost",("新纪录3")]) # 提交执行，返回sql影响成功的行数 这里拼接能预防sql注入问题print(res) # 3 成功插入三条记录print(cursor.lastrowID) #在插入语句后查看，查看最后一条记录的行号print(cursor.fetchall())# conn.commit() # 手动提交cursor.close() # 关闭游标conn.close() MysqL中的存储过程也可在pyMysqL中进行调用。
-- MysqL中创建了一个存储过程delimiter $ -- delimiter是指自定义结束符，MysqL中以;号结束，使用自定义结束符后则以自定义结束符为准 CREATE PROCEDURE p2(in n1 int,out res int) -- 创建存储过程 参数1，传入参数，int类型，参数2，返回值，int类型 BEGIN -- 书写程序逻辑 select ID from t1 where ID = n1; set res = 1; -- 设置返回值 -- 逻辑完毕 END $ -- 存储过程创建完毕delimiter ;-- MysqL调用set @res = 0; -- 先将接受返回值的变量进行ding'yicall p2(1,@res); -- 参数1，传入值，参数2，返回值select @res; -- 查看返回值# Python中调用存储过程#!/usr/bin/env python# -*- Coding:utf-8 -*-import pyMysqLconn = pyMysqL.connect(host='127.0.0.1',port=3306,user='root',passwd='123',db='t1')cursor = conn.cursor(cursor=pyMysqL.cursors.DictCursor)# 执行存储过程cursor.callproc('p2',args=(1,0)) # 第一个参数为传入参数，第二个参数为返回值。相当于set @res = 0;# 获取执行完存储的参数cursor.execute("select @_p2_0,@_p2_1") # @_p2_0 传入参数，@_p2_1 返回值result = cursor.fetchall()conn.commit()cursor.close()conn.close()print(result)以上是内存溢出为你收集整理的Python pymsql模块全部内容，希望文章能够帮你解决Python pymsql模块所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）