pymysql模块的下载

pip3 install pymysql

 

重要

使用管道连接mysql数据库，插入中文编码问题处理方法：在创建连接对象的时候指定编码格式 conn = pymysql.Connect(host='',port=3306,user='',password='',db='',charset='utf-8')即可。

 

用pymysql执行命令

# 实现：使用Python实现用户登录，如果用户存在则登录成功（假设该用户已在数据库中）import pymysqluser = input('请输入用户名：')pwd = input('请输入密码：')# 1.连接conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', password='', db='db8', charset='utf8')# 2.创建游标cursor = conn.cursor()#注意%s需要加引号sql = "select * from userinfo where username='%s' and pwd='%s'" %(user, pwd)print(sql)# 3.执行sql语句cursor.execute(sql)result=cursor.execute(sql) #执行sql语句，返回sql查询成功的记录数目print(result)# 关闭连接，游标和连接都要关闭cursor.close()conn.close()if result:    print('登陆成功')else:    print('登录失败')

 

增、删、改

import pymysqlusername = input('请输入用户名：')pwd = input('请输入密码：')# 1.连接conn = pymysql.connect(host='localhost', port=3306, user='root', password='', db='db8', charset='utf8')# 2.创建游标cursor = conn.cursor()# 操作# 增# sql = "insert into userinfo(username,pwd) values (%s,%s)"# effect_row = cursor.execute(sql,(username,pwd))#同时插入多条数据#cursor.executemany(sql,[('李四'，'110'),（'王五'，'119'）]) # print(effect_row)## 改# sql = "update userinfo set username = %s  where id = 2"# effect_row = cursor.execute(sql,username)# print(effect_row)# 删sql = "delete from userinfo  where id = 2"effect_row = cursor.execute(sql)print(effect_row)#一定记得commitconn.commit()# 4.关闭游标cursor.close()# 5.关闭连接conn.close()

 

查：fetchone、fetchmany、fetchall

fetchone():获取下一行数据，第一次为首行；fetchall():获取所有行数据源fetchmany(4):获取4行数据

 

使用fetchone():

import pymysql# 1.连接conn = pymysql.connect(host='localhost', port=3306, user='root', password='', db='db8', charset='utf8')# 2.创建游标cursor = conn.cursor()sql = 'select * from userinfo'cursor.execute(sql)# 查询第一行的数据row = cursor.fetchone()print(row) # (1, '李四', '123')# 查询第二行数据row = cursor.fetchone()print(row) # (3, '张三', '110')# 4.关闭游标cursor.close()# 5.关闭连接conn.close()

 

使用fetchall():

import pymysql# 1.连接conn = pymysql.connect(host='localhost', port=3306, user='root', password='', db='db8', charset='utf8')# 2.创建游标cursor = conn.cursor()sql = 'select * from userinfo'cursor.execute(sql)# 获取所有的数据rows = cursor.fetchall()print(rows)# 4.关闭游标cursor.close()# 5.关闭连接conn.close()#运行结果((3, '张三', '110'), (4, '李四', '119'))

在fetchone示例中，在获取行数据的时候，可以理解开始的时候，有一个行指针指着第一行的上方，获取一行，它就向下移动一行，所以当行指针到最后一行的时候，就不能再获取到行的内容

cursor.scroll(1,mode='relative')  # 相对当前位置移动cursor.scroll(2,mode='absolute') # 相对绝对位置移动第一个值为移动的行数，整数为向下移动，负数为向上移动，mode指定了是相对当前位置移动，还是相对于首行移动

# 1.Python实现用户登录# 2.Mysql保存数据import pymysql# 1.连接conn = pymysql.connect(host='localhost', port=3306, user='root', password='', db='db8', charset='utf8')# 2.创建游标cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)sql = 'select * from userinfo'cursor.execute(sql)# 查询第一行的数据row = cursor.fetchone()print(row)# 查询第二行数据row = cursor.fetchone() print(row)cursor.scroll(-1,mode='relative') #设置之后，光标相对于当前位置往前移动了一行，所以打印的结果为第二行的数据row = cursor.fetchone() print(row)cursor.scroll(0,mode='absolute') #设置之后，光标相对于首行没有任何变化，所以打印的结果为第一行数据row = cursor.fetchone() print(row)# 4.关闭游标cursor.close()# 5.关闭连接conn.close()#结果如下{
    'id': 1, 'username': 'zxc', 'pwd': '123'}{
    'id': 3, 'username': '张三', 'pwd': '110'}{
    'id': 3, 'username': '张三', 'pwd': '110'}{
    'id': 1, 'username': 'zxc', 'pwd': '123'}

 

fetchmany():

import pymysql# 1.连接conn = pymysql.connect(host='localhost', port=3306, user='root', password='', db='db8', charset='utf8')# 2.创建游标cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)sql = 'select * from userinfo'cursor.execute(sql)# 获取2条数据rows = cursor.fetchmany(2)print(rows)# 4.关闭游标# rows = cursor.fetchall()# print(rows)cursor.close()# 5.关闭连接conn.close()#结果如下：[{
   'id': 1, 'username': 'zxc', 'pwd': '123'}, {
   'id': 3, 'username': '张三', 'pwd': '110'}]