pymyspl模块

pymysql的下载和使用

　　该模块本质就是一个套接字客户端软件,使用前需要事先安装,能够让我们在

　　python程序中操作数据库.

 

　　pymysql模块的下载:

　　在python安装文件中找到scripts文件 shift+右键打开powershell,接着如下图:

 

　　pymysql的使用 (数据均已存在)

　　

 

 　　实现:

#导入模块
import pymysql

username = input('请输入用户名:')
password = input('请输入密码:')

#创建连接
conn = pymysql.connect(
    host = '127.0.0.1',
    user = 'root',
    database = 'db1',
    port = 3306,
    charset = 'utf8'
)
#创建游标
cur = conn.cursor()
sql = 'select * from login where name = "%s" and password = %s ' %(username,password)
#注意 name 在创建的表中未vachar类型 ,所以必选要加 "" .
print(sql)

rescount = cur.execute(sql)#执行sql语句,返回sql查询成功的记录数目
print(rescount)

if rescount:
    print('成功')
else:
    print('失败')
#关闭连接,游标
cur.close()
conn.close

　　注意 : -- + 空格 为注释

 

　　前端是不安全的,在上述的操作中存在漏洞,

　　

　　正确解决方法为:

 

#导入模块
import pymysql

username = input('请输入用户名:')
password = input('请输入密码:')

#创建连接
conn = pymysql.connect(
    host = '127.0.0.1',
    user = 'root',
    database = 'db1',
    port = 3306,
    charset = 'utf8'
)
#创建游标
cur = conn.cursor()
sql = 'select * from login where name = %s and password = %s '
#注意 name 在此时不能再加 "" .
print(sql)

rescount = cur.execute(sql,[username,password])
#由我们对sql进行字符串拼接改为execute帮我们做字符串拼接,可以是列表 元祖 字典.pymysql模块自动帮我们解决sql注入问题.
print(rescount)

if rescount:
    print('成功')
else:
    print('失败')
#关闭
cur.close()
conn.close

 

　　注意:当为字典时:

 

增 删 改 (conn.commit())

　commit() 方法:在数据库里增删改的时候,必须进行提交,否则插入的数据不生效.

import pymysql
username = input('请输入用户名：')

pwd = input('请输入密码：')



# 1.连接
conn = pymysql.connect(host='localhost', port=3306, user='root', password='', db='db1', charset='utf8')


# 2.创建游标
cursor = conn.cursor()


# 操作
# 增
# sql = "insert into userinfo(username,password) values (%s,%s)"


# effect_row = cursor.execute(sql,(username,password))
#同时插入多条数据
#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)


#一定记得commit
conn.commit()

# 4.关闭游标
cursor.close()

# 5.关闭连接
conn.close()

 

查  fetchone , fetchmany , fetchall 

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

 

　　查看一下表内容:

 

#导入模块
import pymysql

#创建连接
conn = pymysql.connect(
    host = '127.0.0.1',
    user = 'root',
    database = 'db1',
    port = 3306,
    charset = 'utf8'
)
#创建游标
cur = conn.cursor(cursor=pymysql.cursors.dictcursor)#加入此句可以让结果以字典的形式呈现.
#cur = conn.cursor()#默认我们获取到的返回值是元祖,只能看到每行的数据,却不知到每一列
#代表的是什么.
sql = 'select * from login'
print(sql)

rescount = cur.execute(sql)
print(rescount)

# row = cur.fetchone()
# print(row)
# row = cur.fetchone()#上一条查询后光标会向下移动
# print(row)
row1 = cur.fetchall()#查出所有结果
print(row1)
#fetchmany....
#关闭
cur.close()
conn.close

 

  　在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) # (1, 'mjj', '123')

# 查询第二行数据
row = cursor.fetchone() # (3, '张三', '110')
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': 'mjj', 'pwd': '123'}
{'id': 3, 'username': '张三', 'pwd': '110'}
{'id': 3, 'username': '张三', 'pwd': '110'}
{'id': 1, 'username': 'mjj', 'pwd': '123'}