欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

PyMySQL模块的使用

程序员文章站 2022-09-11 17:02:01
安装: 基本使用 pymysql增删该查 增删改 查询 ......

安装:

pip3 install pymysql

基本使用

import pymysql
# 建立连接
conn = pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='root',
    password='123456',
    db='db5',
    charset='utf8'
)
user = input('user >>>')
pwd = input('pwd >>>')
# 拿到游标
cursor = conn.cursor()

# 执行sql语句
sql = 'select * from userinfo where user=%s and password=%s'
rows = cursor.execute(sql,(user,pwd))#解决mysql注入问题

# 关闭连接
cursor.close()
conn.close()
if rows:
    print('111')
else:
    print(rows)

pymysql增删该查

  • 增删改
import pymysql
# 建立连接
conn = pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='root',
    password='123456',
    db='db5',
    charset='utf8'
)
# 拿到游标
cursor = conn.cursor()

# 执行sql语句
#增删改,只需要将insert更换成对应语句即可
sql = 'insert into userinfo(user,password) values (%s,%s)'
# rows = cursor.execute(sql,('miao',321))#解决mysql注入问题
rows = cursor.executemany(sql,[('wxx',123),('mxx',1234)]) # 插入多行
print(cursor.lastrowid)#查看之前游标走到哪里了
conn.commit()# 提交
# 关闭连接
cursor.close()
conn.close()
if rows:
    print('111')
else:
    print(rows)
  • 查询
import pymysql
conn = pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='root',
    password='123456',
    db='db5',
    charset='utf8'
)
cursor = conn.cursor(pymysql.cursors.dictcursor)# 以字典形式返回查询结果,调用cursor.fetchon打印出来的结果以字典形式打印
# 查询
rows = cursor.execute('select * from userinfo;')
print(cursor.fetchone())# 打印一行
print(cursor.fetchall())# 打印全部
# print(cursor.fetchmany())# 指定查询个数
cursor.scroll(3,mode='relative')# 相对当前位置移动
cursor.scroll(2,mode='abssolute')# 相对绝对位置移动
cursor.close()
conn.close()