数据库 - Navicat与pymysql模块

一、Nabicat

 在生产环境中操作MySQL数据库还是推荐使用命令行工具mysql，但在我们自己开发测试时，
 可以使用可视化工具Navicat，以图形界面的形式操作MySQL数据库

 官网下载：https://www.navicat.com/en/products/navicat-for-mysql
 网盘下载：https://pan.baidu.com/s/1bpo5mqj
 链接：https://pan.baidu.com/s/1Hu-x0mPuSW3g9CxNFlnAng 密码：pqe5

 # 打开 双击：
 # D:\navicatformysql\Navicat for MySQL\navicat

 需要掌握的基本操作
 掌握：
     #1. 测试+链接数据库
     #2. 新建库
     #3. 新建表，新增字段+类型+约束
     #4. 设计表：外键
     #5. 新建查询
     #6. 备份库/表

 注意：
     批量加注释：ctrl+？键
     批量去注释：ctrl+shift+？键

二、pymysql模块

介绍：

在python程序中操作数据库呢？这就用到了pymysql模块，
该模块本质就是一个套接字客户端软件，使用前需要事先安装
pip3 install pymysql

前提：

授权加创建
grant all on *.* to 'root'@'%' identified by '123';
flush privileges;

# -*- coding:utf-8 -*-

"""

端口:3306

ip: 10.10.32.107

mysql -uroot -p123 -h 10.10.32.107

"""

import pymysql

name = input('user>>>:').strip()           # egon1

password = input('password>>>:').strip()  #

# 建连接

conn = pymysql.connect(

    host = '10.10.32.107',

    port = 3306,

    user = 'root',

    password = '',

    db = 'egon',

    charset = 'utf8'

)

# 拿游标

cursor = conn.cursor()

# 执行sql语句

sql = 'select * from userinfo where name= "%s" and password = "%s"'%(name,password)

rows = cursor.execute(sql)

print(rows)

# 关闭

cursor.close()

conn.close()

# 进行判断

if rows:

    print('登录成功')

else:

    print('登录失败')

Pymysql的使用方法

SQL注入：

注意：符号--会注释掉它之后的sql，正确的语法：--后至少有一个任意字符
1、sql注入之：用户存在，绕过密码
egon' -- 任意字符

2、sql注入之：用户不存在，绕过用户与密码
xxx' or 1=1 -- 任意字符

解决方法

# 原来是我们对sql进行字符串拼接
# sql="select * from userinfo where name='%s' and password='%s'" %(user,pwd)
# print(sql)
# res=cursor.execute(sql)

#改写为（execute帮我们做字符串拼接，我们无需且一定不能再为%s加引号了）
sql="select * from userinfo where name=%s and password=%s" #！！！注意%s需要去掉引号，因为pymysql会自动为我们加上
res=cursor.execute(sql,[user,pwd]) #pymysql模块自动帮我们解决sql注入的问题，只要我们按照pymysql的规矩来。

# -*- coding:utf-8 -*-

import pymysql

name = input('name>>>:').strip()

password = input('password>>>:').strip()

conn = pymysql.connect(

    host = '10.10.32.107',

    port = 3306,

    user = 'root',

    password = '',

    db = 'egon',

    charset = 'utf8'

)

cursor = conn.cursor()

# sql = 'select * from userinfo where name = "%s" and password = "%s"'%(name,password)

# rows = cursor.execute(sql)

sql = 'select * from userinfo where name=%s and password = %s'

rows = cursor.execute(sql,(name,password))   #执行sql语句，返回sql影响成功的行数

print(sql)

print(rows)

cursor.close()

conn.close()

if rows:

    print('登录成功')

else:

    print('登录失败')

"""

name>>>:egon1" -- x          #需要帐号,sql注入 -- 表示 注释掉 只需要判断user 不需要判断password

password>>>:

select * from userinfo where name = "egon1" -- x" and password = ""

1

登录成功

"""

"""

name>>>:xxx" or 1=1 -- xxx   #不需要帐号密码,sql注入 太恐怖!!

password>>>:

select * from userinfo where name = "xxx" or 1=1 -- xxx" and password = ""

3

登录成功

"""

"""

解决办法:

    sql = 'select * from userinfo where name=%s and password = %s'

    rows = cursor.execute(sql,(name,password))

"""

sql注入

SQL代码注入

三、pymysql模块中增删改查

增：

sql = 'insert into userinfo(name,password) values(%s,%s)'

rows = cursor.execute(sql,('lily',''))

conn.commit() # 注意只有执行了commit() 才会更新到数据库中

批量:

rows = cursor.executemany(sql,[('alice4',''),('alice5',''),('alice6','')])

print(cursor.lastrowid) # 显示插入数据前的id 走到哪

删：

sql = 'delete from userinfo where name = %s'

rows = cursor.execute(sql,('alice5'))

conn.commit()

改：

sql = 'update userinfo set name = %s where id = %s '

rows = cursor.execute(sql,('abcd',2))

conn.commit()

查：

# 元祖形式

cursor = conn.cursor()

rows = cursor.execute(sql)

print(cursor.fetchone())

print(cursor.fetchmany(3))

print(cursor.fetchall())

print(cursor.fetchone()) # None 没有数据了!

((1, 'aaabbb', ''), (2, 'abcd', ''), (3, 'egon3', ''))

# 字典形式

cursor = conn.cursor(pymysql.cursors.DictCursor)

cursor.fetchone() cursor.fetchmany(2) cursor.fetchall()

[{'id': 3, 'name': 'egon3', 'password': ''}, {'id': 6, 'name': 'alice', 'password': ''}]

# 相对 绝对 移动游标

print(cursor.fetchone())

cursor.scroll(5,'absolute')

# cursor.scroll(5,'relative')

print(cursor.fetchmany(2))

import  pymysql

#建立连接

conn = pymysql.connect(

    host='10.10.32.107',

    port=3306,

    user='root',

    password='',

    db='db9',

    charset='utf8'

)

#拿到游标

cursor=conn.cursor()

#执行sql

# 增、删、改

#增

sql = 'insert into userinfo(user, pwd) values(%s, %s)'

# rows = cursor.execute(sql,('wxx','123'))

# print(rows)

# rows = cursor.executemany(sql,[('yxx','123'),('egon1','111')]) #插入多行

# print(rows)

rows = cursor.executemany(sql,[('egon2',''),('egon3','')])

print(cursor.lastrowid) #查看id字段走到哪了

#删

# sql = 'truncate table userinfo'

# rows = cursor.execute(sql)

#改

sql = 'update  userinfo set user = "yxw" where pwd =123'

rows = cursor.execute(sql)

conn.commit() #提交操作

#关闭

cursor.close()

conn.close()

"""查"""

import pymysql

conn = pymysql.connect(

    host = '192.168.1.102',

    port = 3306,

    user = "root",

    password = '',

    db = 'egon',

    charset = 'utf8'

)

cursor = conn.cursor()

# cursor = conn.cursor(pymysql.cursors.DictCursor)

sql = 'select * from userinfo'

rows = cursor.execute(sql)  #执行sql语句，返回sql影响成功的行数rows,将结果放入一个集合，等待被查询

print(rows)

# print(cursor.fetchone())

# print(cursor.fetchone())

# print(cursor.fetchmany(2))

# print(cursor.fetchall())

# print(cursor.fetchone())  # None

print(cursor.fetchone())

cursor.scroll(5,'absolute')

# cursor.scroll(5,'relative')

print(cursor.fetchmany(2))

cursor.close()

conn.close()

if rows:

    print('操作成功')

else:

    print('失败')

具体操作代码

巴特西

数据库 - Navicat与pymysql模块

最新文章

热门文章