SQL Server Concurrency
并发存在会产生的问题,直接导致了我们需要的并发控制模型。SQL SERVER的每一种并发控制模型都是针对这些问题而设计的,所以首先我们要了解并发的潜在问题有哪些,然后去探索并发控制的模型。 并发控制模型,采用的是锁机制,详细了解了各种锁的兼容机制,才
并发存在会产生的问题,直接导致了我们需要的并发控制模型。SQL SERVER的每一种并发控制模型都是针对这些问题而设计的,所以首先我们要了解并发的潜在问题有哪些,然后去探索并发控制的模型。
并发控制模型,采用的是锁机制,详细了解了各种锁的兼容机制,才能更好了解隔离模型之间的兼容性。锁,所涉及到的概念很多,锁的对象,锁的所属对象,锁的持续时间,锁的种类等等。
知道锁的概念就要学会适当的去用锁。两种方法,事务隔离机制以及锁暗示(lock hint).
1 使用事务隔离机制
set transaction isolation level serializable
begin transaction
select top 10 * from dbo.fctdbsize
commit transaction
这里实例用了*别的隔离机制,当目前这个事务在运行时,其他事务都将等待这个事务里用到的资源。除了serializable, 还有 read uncommitted, read committed, read snapshot, read repeated.将这些代入上面的set 语句就可以了。
所需要关心的是各个隔离机制之间是如何兼容的,比如 read uncommitted事务与 serializable 事务之间的竞争关系。从上到下的理解,事务其实用的还是锁,事务之间的兼容最终还是回归到锁之间的兼容。
看下提交一个serializable 事务,但是不提交,看看中间状态的事务,都有哪些特性?
use lenistest3
go
set transaction isolation level serializable
begin transaction trans_serializable with mark 'test for serializable transaction'
select top 10 * from dbo.fctdbsize
这里给事务标记一个事务名字,并附上Mark.
select db_name(dbt.database_id) as databaseName
, at.name as transactionName
, at.transaction_id
,at.transaction_begin_time
, case
when at.transaction_type = 1 then 'read and write transaction'
when at.transaction_type = 2 then 'read only transaction'
when at.transaction_type = 3 then 'system transaction'
when at.transaction_type = 4 then 'distributed transaction'
end as transaction_type
, case
when at.transaction_state = 0 then 'The transaction has not been completely initialized yet.'
when at.transaction_state = 1 then 'The transaction has been initialized but has not started.'
when at.transaction_state = 2 then 'The transaction is active'
when at.transaction_state = 3 then 'The transaction has ended. This is used for read-only transactions'
when at.transaction_state = 4 then 'The commit process has been initiated on the distributed transaction. This is for distributed transactions only. The distributed transaction is still active but further processing cannot take place'
when at.transaction_state = 5 then 'The transaction is in a prepared state and waiting resolution'
when at.transaction_state = 6 then 'The transaction has been committed.'
when at.transaction_state = 7 then 'The transaction is being rolled back.'
when at.transaction_state = 8 then 'The transaction has been rolled back'
end as transaction_staus
, trl.request_session_id
, trl.request_mode
, trl.request_type
, trl.request_status
, trl.request_owner_type
, datediff(ss,at.transaction_begin_time, getdate()) as request_lifetime_s
, trl.resource_type
, trl.resource_description
, trl.resource_associated_entity_id
, case
when trl.resource_type = 'OBJECT' then object_name(convert(varchar,trl.resource_associated_entity_id))
else
'other objects not table'
end as objectName
, logs.host_name
, logs.program_name
, logs.login_name
, req.blocking_session_id
from sys.dm_tran_database_transactions dbt
left join sys.dm_tran_active_transactions at on dbt.transaction_id = at.transaction_id
left join sys.dm_tran_session_transactions st on st.transaction_id = dbt.transaction_id
left join sys.dm_tran_locks trl on trl.request_session_id = st.session_id
left join sys.dm_exec_sessions logs on logs.session_id = st.session_id
left join sys.dm_exec_requests req on req.session_id = st.session_id
where dbt.database_id = db_id(N'lenistest3')
TransactionName这一列和我们刚才定义的事务名称一样;
Transaction_Type其实并不十分精确,因为我们没做写的操作;
Request_mode都是S, 无论是对数据库,还是针对表; request_status表示已经得到这个锁
现在我们尝试往这个表里insert一条记录:
insert into dbo.fctdbsize(record_date,type_desc,name,size,size_mb,size_gb,x_flag ) select top 1 record_date,type_desc,name,size,size_mb,size_gb,x_flag from dbo.fctdbsize
没有提示完成,说明在等待,我们看下等待在哪里,用上面的SQL来查:
这里对应了request_mode – IX, request_status为WAIT 。我们从sys.dm_exec_requests 取了一个 blocking_session_id给它 ,因为这个query包含了所有的transaction,所以很容易察看到谁在产生Block.
我们将 transaction isolation level改为 read committed.
use lenistest3
go
set transaction isolation level read committed
begin transaction trans_serializable with mark 'test for serializable transaction'
select top 10 * from dbo.fctdbsize
再执行一边 insert,会发现这次执行成功了。 锁在不同的隔离机制下,持续的时间也会不同。一旦独到这个数据,就释放锁。Serializable的隔离,使得锁停留在对象上的时间直到事务结束。
依次尝试这些transaction isolation level,看看哪些会对insert有影响:
SET TRANSACTION ISOLATION LEVEL
{ READ UNCOMMITTED
| READ COMMITTED
| REPEATABLE READ
| SNAPSHOT
| SERIALIZABLE
}
[ ; ]
除了 Serializable,还有 repeatable read也使用了大量的行锁,repeatable read对page, table也有IS锁,这是为了保证已读取的数据在整个事务中的一致性,如果insert不小心要更改这些已被读取的数据或者页,都会等待, IS不影响X,这里的insert随机读取一条数据,table上有IS锁,但insert还是成功提交的。
上面讨论的是读在前,写在后的场景。我们接下来讨论写在前,而读在后的情况。
use lenistest3
go
set transaction isolation level serializable
begin transaction trans_serializable with mark 'test for serializable transaction'
update dbo.salesman set man_name = man_name + ' test for trans' where man_id = 1
在表salesman上,事务加上一个 X锁,一直保留到事务结束。这里仅仅是堆表,还需要考虑到有索引的情况,过会讨论 。
然后执行一条只读事务:
set transaction isolation level read committed
begin transaction read_committed
select * from salesman where man_id = 1
这里可以看到IS锁被 X锁给block了。
还有个有趣的现象,我们不设置事务锁,只执行
select * from salesman where man_id = 1
如果我们的监控语句不用left join是不会显示这个单条select语句,原因是在 sys.dm_tran_session_transactions里面不会记录这种ad hoc的事务。所以我们把我们的监控语句改成left join.虽然也不准,但是至少告诉你有这个ad hoc的存在。
这里我们可以用 read uncommitted来读取这条暂时未被提交的事务。Read uncommitted隔离机制,我猜想是没有加任何的锁,除了database share这个锁之外,告诉别的session还有人在用这个数据库,请勿作database一级的处理,比如删除数据库等
还可以用snapshot隔离事务,只读更改前的数据。这个隔离机制也不加锁(我猜).
set transaction isolation level snapshot
begin transaction read_committed
select * from salesman where man_id = 1
我们用监控语句也发现之有database一级的share操作。
Repeatable Read隔离机制 在这里的作用和 read committed一样的。使用了IS锁都会被X锁block住。
综上, read uncommitted, snapshot都是不加锁的,所以这两种隔离机制中,任何读都不会被write给block住。Read committed, Serializable, Repeatable Read三种隔离机制中,任何读都会被write给block住(当然是针对同一资源而言)。
那我们猜测下,读和读会不会互相block呢? 从最高隔离机制开始:
use lenistest3
go
set transaction isolation level serializable
begin transaction trans_serializable with mark 'test for serializable transaction'
select * from salesman where man_id = 1
再执行第二个只读事务:
use lenistest3
go
set transaction isolation level serializable
begin transaction trans_serializable1 with mark 'test for serializable transaction 2'
select * from salesman where man_id = 1
通过监控语句 ,发现两者互不干扰,只是hold S lock的时间长了点。
上面提到有index的时候,update带来的锁情况。我们将表扩大一点:
declare @loop int = 0
while @loop 16
上一篇: PHP贪婪算法解决0-1背包问题实例分析
下一篇: paip.odbc DSN的存储与读取