start transaction 开启事务

Rollback 回滚事务,即撤销指定的sql语句(只能回退insert delete update语句)，回滚到上一次commit的位置

Commit 提交事务，提交未存储的事务

savepoint 保留点 ，事务处理中设置的临时占位符 你可以对它发布回退(与整个事务回退不同)   

UPDATE account set balance=balance-5000 WHERE name=”yuan”;

UPDATE account set balance=balance+5000 WHERE name=”xialv”;

-- 创建表

create table test2(id int PRIMARY KEY auto_increment,name VARCHAR(20)) engine=innodb;

-- 插入数据

INSERT INTO test2(name) VALUE ("alvin"),

                              ("yuan"),

                              ("xialv");

start transaction; -- 开启事务

insert into test2 (name)values('silv');

select * from test2;

commit;   -- 提交事务

-- 保留点

start transaction;

insert into test2 (name)values('wu');

savepoint insert_wu; -- 给上面刚才insert的命令起了个名字叫insert_wu,并设置一个保留点，对重要的sql,要紧挨着设置保留点

select * from test2;

delete from test2 where id=4;

savepoint delete1;

select * from test2;

delete from test2 where id=1;

savepoint delete2;

select * from test2;

rollback to delete1;  -- 回滚到某个设置的节点

select * from test2;

savepoint

--一个事务读取到了另一个事务未提交的数据,这是特别危险的，要尽力防止。

        a 1000

        b 1000

        a:

            start transaction；

            update set money=money+100 where name=b;

        b:

            start transaction;

            select * from account where name=b;--1100

            commit;

        a:

            rollback;

        b:  start transaction;

            select * from account where name=b;--1000

--在一个事务内读取表中的某一行数据，多次读取结果不同。（一个事务读取到了另一个事务已经提交

-- 的数据--增加记录、删除记录、修改记录），在某写情况下并不是问题，在另一些情况下就是问题。

a:

start transaction;

select 活期账户 from account where name=b;--1000    活期账户：1000

select 定期账户 from account where name=b；--1000   定期账户:1000

select 固定资产 from account where name=b；--1000   固定资产：1000

------------------------------

b:

start transaction;

update set money=0 where name=b;(把某一个账户的资金置为0)

commit;

------------------------------

select 活期+定期+固定 from account where name=b; --2000 总资产： 2000

是指在一个事务内读取到了别的事务插入的数据，导致前后读取不一致。
（一个事务读取到了另一个事务已经提交的数据---增加记录、删除记录），在某写情况下并不是问题，在另一些情况下就是问题。

b 1000

c 2000

d 3000

a:

start transaction

select sum(money) from account;---3000       3000(b+c)

-------------------

d:start transaction;

insert into account values(d,3000);

commit;

-------------------

select count(*)from account;---3                         3(算上插入的d总共三个人)

3000/3 = 1000                                            1000 （但是总金额还是按照b和c两个人算的，所以平均金额不对）

set [global/session] transaction isolation level xxxx;

select @@tx_isolation;

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

import pymysql.cursors

# 连接数据库

connect = pymysql.Connect(

    host='localhost',

    port=3310,

    user='user',

    passwd='',

    db='test',

    charset='utf8'

)

# 事务处理

sql_1 = "UPDATE staff SET saving = saving + 1000 WHERE user_id = '1001' "

sql_2 = "UPDATE staff SET expend = expend + 1000 WHERE user_id = '1001' "

sql_3 = "UPDATE staff SET income = income + 2000 WHERE user_id = '1001' "

try:

    cursor.execute(sql_1)  # 储蓄增加1000

    cursor.execute(sql_2)  # 支出增加1000

    cursor.execute(sql_3)  # 收入增加2000

except Exception as e:

    connect.rollback()  # 事务回滚

    print('事务处理失败', e)

else:

    connect.commit()  # 事务提交

    print('事务处理成功', cursor.rowcount)

# 关闭连接

cursor.close()

connect.close()

你看一下MySQLdb下面的cursors模块，DictCursor的这个功能是继承于CursorDictRowsMixIn，这个MixIn提供了3个额外的方法: fetchoneDict、fetchmanyDict、fetchallDict。

>>> import MySQLdb

>>> c = MySQLdb.connect('127.0.0.1', 'root', 'password', 'test')

>>> x = c.cursor(MySQLdb.cursors.DictCursor)

>>> x.execute('select * from user')

2L

>>> x.fetchoneDict()

{'age': 26L, 'id': 1L, 'name': 'test'}

二、execute()之sql注入

这里只截图演示三种SQL注入示例截图

1

2

3

解决方法： 

# 原来是我们对sql进行字符串拼接

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

# print(sql)

# result=cursor.execute(sql)

#改写为（execute帮我们做字符串拼接，我们无需且一定不能再为%s加引号了）

sql="select * from userinfo where name=%s and password=%s" #！！！注意%s需要去掉引号，因为pymysql会自动为我们加上

result=cursor.execute(sql,[user,pwd]) #pymysql模块自动帮我们解决sql注入的问题，只要我们按照pymysql的规矩来。

pymysql .cursor属性方法（tcy）

cursor.excutemany(query, args)#执行多个数据库查询或命令
参数：
query - 要在服务器上执行的查询
args - 序列或映射的序列。它用作参数。
返回：
受影响的行数(如果有)
说明：
提高多行INSERT和REPLACE的性能。否则它等同于使用execute()循环遍历args
executemany()生成的最大语句大小为max_allowed_pa​​cket - packet_header_size
cursor.max_stmt_length #1024000
con.max_allowed_packet#16777216
实例：
str_insert = "INSERT INTO Cu_table (id) VALUES (%s)"
cursor.executemany(str_insert,['A','B','C','D']) #一次插入A B C D 四个值

方法：调用函数
cursor.callproc(procname, args=())  # 调用数据库中的存储过程
参数：
procname表示数据库中存储过程的名字，args表示为存储过程传入的参数。
返回：
返回原始args
调用的结果作为输入序列的修改副本返回。
该过程还可以提供结果集作为输出。然后必须通过标准.fetch * ()
方法使其可用

调用无参数存储过程：cursor.callproc('p2')  # 等价cursor.execute("call p2()")
调用有参数存储过程：cursor.callproc('p1', args=(1, 22, 3, 4))

class pymysql.cursors.Cursor(connection)  # 游标结果作为元祖的元祖返回
说明：
这是您用于与数据库交互的对象。
不要自己创建Cursor实例。调用connections.Connection.cursor()
class pymysql.cursors.SSCursor(connection)  # 无缓冲游标结果作为元祖的元祖返回，
用途：
用于返回大量数据查询，或慢速网络连接到远程服务器

不将每行数据复制到缓冲区，根据需要获取行。客户端内存使用少
在慢速网络上或结果集非常大时行返回速度快

限制：
MySQL协议不支持返回总行数，判断有多少行唯一方法是迭代返回的每一行。
目前无法向后滚动，因为只有当前行保存在内存中。
class pymysql.cursors.DictCursor(connection)  # 将结果作为字典返回游标
class pymysql.cursors.SSDictCursor(connection)  # 无缓冲游标结果作为字典返回

游标属性:
cursor.max_stmt_length  # 1024000
cursor.rownumber  # 5 #当前结果集中游标所在行的索引(起始行号为 0)
cursor.arraysize  # 1 #此读/写属性指定用.fetchmany()一次获取的行数。
# 默认1表示一次获取一行；也可以用于执行.executemany()
cursor.lastrowid  # None #只读属性提供上次修改行的rowid
# DB仅在执行单个INSERT 操作时返回rowid 。
# 如未设rowid或DB不支持rowid应将此属性设置为None
# 如最后执行语句修改了多行，例如用INSERT和.executemany()时lastrowid语义是未定义

cursor.rowcount  # 5 #最近一次 execute() 创建或影响的行数
# 如无cursor.execute()或接口无法确定最后一个操作的rowcount则该属性为-1
# 该行数属性可以在动态更新其值的方式来编码。
# 这对于仅在第一次调用.fetch()方法后返回可用rowcount值的 数据库非常有用。

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