38、mysql数据库(pymysql及事务)

时间:2021-04-20 08:03:40

38.1、python之pymysql模块:

1、说明:

pymsql是Python中操作MySQL的模块,其使用方法和py2的MySQLdb几乎相同。

2、模块安装:

pip install pymysql

3、在pycharm中添加pymysql模块:

File——>settings——>Project:python——>Project Interpreter——>点击"+"——>输入pymysql——>Install Package

38、mysql数据库(pymysql及事务)

4、执行sql语句:

import pymysql

#导入pymysql模块

conn =pymysql.connect(host="127.0.0.1", port=3306, user="root", passwd="123456", db="lc2", charset="utf8")

#连接数据库

cursor = conn.cursor()

#得到数据库游标对象

#创建表

# create_table_employee = """CREATE TABLE EMPLOYEE(

# id INT primary key AUTO_INCREMENT,

# FIRST_NAME CHAR(20) NOT NULL unique,

# LAST_NAME CHAR(20),

# AGE INT,

# SEX CHAR(1),

# INCOME FLOAT)"""

# create_table_employee_result=cursor.execute(create_table_employee)

# print(create_table_employee_result)

# 创建表成功后返回0,创建失败报错

#插入数据

# insert_sql="INSERT INTO employee(id,first_name,last_name,age,sex,income)" \

# "values(1,'汤姆猫','tom',2,'男',1995),(2,'杰瑞鼠','jierui','2','男',1995)"

# insert_sql_result=cursor.execute(insert_sql)

# print(insert_sql_result)

# 插入成功后返回插入记录的条数,插入失败报错

# print(cursor.lastrowid)

#在插入语句后查看获取插入的最后一条数据的自增ID

# 更新数据

# update_sql="update employee set sex='女' where LAST_NAME='jierui'"

# update_sql_result=cursor.execute(update_sql)

# print(update_sql_result)

# 更新成功后返回插入记录的条数,更新失败报错,没有更新记录返回0

# 查询数据

query_sql = "select * from employee"

query_sql_result=cursor.execute(query_sql)

# print(query_sql_result)

# 查询成功后返回记录的条数,等价于select count(*) from employee,查询失败报错

query_sql_one = cursor.fetchone()

print(query_sql_one)

# 获取一条记录(row),返回单层元组,如果没有结果则返回None

# (1, '汤姆猫', 'tom', 2, '男', 1995.0)

# query_sql_many=cursor.fetchmany(1)

# print(query_sql_many)

# 获取指定条记录(row),返回双层元组,如果没有结果则返回()

# ((1, '汤姆猫', 'tom', 2, '男', 1995.0),)

# query_sql_all=cursor.fetchall()

# print(query_sql_all)

# 返回多条记录(rows),返回双层元组,如果没有结果则返回()

# ((1, '汤姆猫', 'tom', 2, '男', 1995.0), (2, '杰瑞鼠', 'jierui', 2, '女', 1995.0))

# 更改数据库游标对象的位置

# cursor.scroll(-1,mode='relative')

# 相对当前位置移动

# cursor.scroll(2,mode='absolute')

# 相对绝对位置移动

conn.commit()

#提交事物

cursor.close()

#关闭mysql游标对象

conn.close()

#关闭和mysql的连接

38.2、事物:

1、事物命令:

(1)事务指逻辑上的一组操作,组成这组操作的各个单元,要不全部成功,要不全部不成功。

(2)数据库开启事务命令:

1)说明:

数据库事务起始于SQL语句,终止于以下4种事件之一,事务结束后,下一条SQL语句将开始一

个新的事务。

A、COMMIT或ROLLBACK语句。

B、DDL(创建/删除视图、触发器、存储过程、自定义函数、索引,修改表结构)/DCL(用户赋权或减权)隐式提交。

C、用户退出时自动提交。

D、系统强行关闭时取消事务。

2)start transaction:开启事务。

PS:

设置不自动提交(commit)也是开启了事务,mysql默认是自动提交事务,oracle默认是不自动提交事务。

pymysql模块自动开启了不自动提交。

在不同的连接(session)下,使用'commit;'是相互不影响的。

3)Rollback:回滚事务,即撤销指定的sql语句(只能回退insert delete update语句),回滚

到上一次commit的位置。

4)Commit:提交事务,提交未存储的事务。

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

退不同),回退到更早的点就不能回退到最近的点了。

savepoint delete1;

--创建保留点

rollback to delete1;

--还原保留

commit;

--提交事务

(3)转账实例:

UPDATE account set balance=balance-5000 WHERE name="lc1";

UPDATE account set balance=balance+5000 WHERE name="lc2";

(4)python中调用数据库启动事物的方式:

1)创建试验表和所需要的数据:

--创建表

CREATE TABLE ACCOUNT(

id INT primary key AUTO_INCREMENT,

NAME CHAR(20) NOT NULL unique,

salary FLOAT);

--插入数据

INSERT INTO ACCOUNT(id,name,salary) values(1,'tom',1000),(2,'jack',2000);

--查询数据

select * from account;

38、mysql数据库(pymysql及事务)

2)代码:

import pymysql

try:

conn = pymysql.connect(host="127.0.0.1", port=3306, user="root", passwd="123456", db="lc2", charset="utf8")

cursor = conn.cursor()

insertSQL0 = "INSERT INTO ACCOUNT (name,salary) VALUES ('lc',3000)"

insertSQL1 = "UPDATE account set salary=salary-30 WHERE name='tom'"

insertSQL2 = "UPDATE account set salary=salary+30 WHERE name='jack'"

cursor.execute(insertSQL0)

conn.commit()

# insertSQL0是一个事务,事务完成就提交。

cursor.execute(insertSQL1)

raise Exception

# insertSQL1抛出异常,下面的内容都不再执行。

cursor.execute(insertSQL2)

conn.commit()

# insertSQL1和insertSQL2加起来是一个事务。

except Exception as e:

conn.rollback()

# 出现异常后回滚数据到上次commit的位置,又进入到一个新的事务。

conn.commit()

# 再次提交数据

cursor.close()

# 关闭数据库游标

conn.close()

# 关闭数据库连接

2、事物特性:

(1)原子性(Atomicity):

原子性是指事务是一个不可分割的工作单位,事务中的操作要么都发生,要么都不发生。

(2)一致性(Consistency):

事务前后数据的完整性必须保持一致,在事务执行之前数据库是符合数据完整性约束的,

无论事务是否执行成功,事务结束后的数据库中的数据也应该是符合完整性约束的。在

某一时间点,如果数据库中的所有记录都能保证满足当前数据库中的所有约束,则可以

说当前的数据库是符合数据完整性约束的。比如删部门表前应该删掉关联员工(已经建

立外键),如果数据库服务器发生错误,有一个员工没删掉,那么此时员工的部门表已

经删除,那么就不符合完整性约束了,所以这样的数据库也就性能太差啦。

(3)隔离性(Isolation):

1)事务的隔离性是指多个用户并发访问数据库时,一个用户的事务不能被其它用户的事务

所干扰,多个并发事务之间数据要相互隔离。

2)将数据库设计为串行化程的数据库,让一张表在同一时间内只能有一个线程来操作,如

果将数据库设计为这样,那数据库的效率太低了,所以数据库的设计者没有直接将数据库设

计为串行化,而是为数据库提供多个隔离级别选项,使数据库的使用者可以根据使用情况自

己定义到底需要什么样的隔离级别。

3)mysql隔离级别和事物并发对应的关系:

38、mysql数据库(pymysql及事务)

A、脏读:一个事务读取到了另一个事务未提交的数据,这样做特别的危险,要尽力防止。

B、不可重复读:在一个事物内读取表中的某一行数据,多次读取结果不同(一个事物读

取到了另一个事务已经提交的数据—增加记录、删除记录、修改记录),在某些情况下并

不是问题,在另一些情况下就是问题。

C、幻读:指在一个事务内读取到了别的事务插入的数据,导致前后不一致(一个事务读

取到了另一个事务已经提交的数据—增加记录、删除记录、修改记录),在某些情况下并

不是问题,在另一些情况下就是问题。

4)数据库的安全性和效率:

安全性考虑:Serializable>Repeatable read>Read committed>Read uncommitted

数据库效率:Read uncommitted>Read committed>Repeatable read>Serializable

一般情况下,我们会使用Repeatable read、Read committed,mysql数据库默认的数

据库隔离级别Repeatable read,oracle数据库默认的数据隔离级别是Read committed。

5)mysql中设置数据库的隔离级别语句:

set global/session transaction isolation level xxxx;

如果使用global,则修改的是数据库的默认隔离级别,所有新开的窗口的隔离级别继承自这

个默认隔离级别。如果使用session修改,则修改的是当前客户端的隔离级别,和数据库默

认隔离级别无关,当前的客户端是什么隔离级别,就能防止什么隔离级别问题,和其他客户

端是什么隔离级别无关。

6)查看mysql中设置数据库的隔离级别语句:

show global variables like '%tx_isolation%';

select @@tx_isolation;

--@@代表的是全局变量

38、mysql数据库(pymysql及事务)

(4)持久性(Durability):

持久性是指一个事务一旦被提交,它对数据库中数据的改变就是永久性的,接下来即使

数据库发生故障也不应该对其有任何影响。