pymysql模块 sql注入 数据库备份与恢复

连接数据库：

import pymysql

conn = pymysql.connect(host='127.0.0.1', user='root', password="123",
                       database='homework')
cur = conn.cursor(cursor=pymysql.cursors.DictCursor)  # 查询返回字典  # 游标
try:
    cur.execute('select * from students')
    ret1 = cur.fetchone()  #  获取所有
    print(ret1)
    ret = cur.fetchmany(5)  # 获取多条结果
    print(ret)
except Exception as f:
    print(f)
cur.close()
conn.close()

数据的插入：

import pymysql

conn = pymysql.connect(host='127.0.0.1',user='root',password='123',database='homework')
cur = conn.cursor()
try:
    # cur.execute('insert into student values (30,"男",3,"大壮")')
    # cur.execute('insert into student values (31,"男",3,"大壮")')
    cur.execute('update student set sid=33 where sid=16')
    conn.commit()   #提交，数据的提交,否则只在内存中执行了。
except Exception as f:
    print(f)
    conn.rollback()  # 之前那一条不执行。
cur.close()
conn.close()

数据的删除：

import pymysql

conn = pymysql.connect(host='127.0.0.1',user='root',password='123',database='homework')
cur = conn.cursor()
try:
    # cur.execute('insert into student values (30,"男",3,"大壮")')
    # cur.execute('insert into student values (31,"男",3,"大壮")')
    # cur.execute('update student set sid=33 where sid=16')
    cur.execute('delete from student where sid=33')
    conn.commit()   #提交，数据的提交,否则只在内存中执行了。
except Exception as f:
    print(f)
    conn.rollback()  # 之前那一条不执行。
cur.close()
conn.close()

rowcount函数：

    cur.execute('select * from student')
    print(cur.rowcount) # 能查出来多少行，便于使用fetchone取所有结果
    for i in range(cur.rowcount):
        print(cur.fetchone())
    conn.commit()   #提交，数据的提交,否则只在内存中执行了。

select * from userinfo where user="alex";-- --" and password = "123";

防止sql注入：

import pymysql


username = input('请输入用户名：')
password = input('请输入密码：')
conn = pymysql.connect(host='127.0.0.1',user='root',password='123',database='day42')
cur = conn.cursor()
sql = 'select * from userinfo where user=%s and password = %s'
cur.execute(sql,(username,password))# 防止sql注入
print(cur.fetchone())

总结
pymysql

　　　　pymysql操作mysql数据库

　　　　　　　　连接数据库

　　　　　　　　获取游标

　　　　　　　　执行sql

　　　　　　　　如果涉及到修改：提交

　　　　　　　　关闭游标

　　　　　　　　关闭库

　　　　sql注入

　　　　　　　　传参数,注意sql注入的问题，传参数通过execute方法来传

　　　　　　　　execute（select    *   from    表   where   name =%s',(alex)）

事务和锁

begin；开启事务

select   *   from    emp     where   id=1    for    update;    查询id值，for    update；   添加行锁

update    emp     set    salary = 10000    where    id  =1 ;      完成更新

commit；      提交事务

 数据库备份(在cmd中执行） ：  mysqldump -h 127.0.0.1 -u root -p student>aaa.sql

恢复数据（在mysql中执行）：  source   aaa.sql

备份库：mysqldump    -uroot    -p123    --databases   homework > ccc.sql

mysqldump   -uroot   -p123   --all-databases;   备份所有数据库