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()

PyMySQL模块的使用

标签：val   模块   多行   ati   建立连接   rowid   input   mysql   基本