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()
原文地址:https://www.cnblogs.com/wualin/p/9919435.html