久久久久亚洲av无码专区喷水,欧美黑人激情性久久,精品国产乱码久久久久久1区2区

C#--多進(jìn)程多線程訪問(wèn)數(shù)據(jù)庫(kù)

Posted on 2008-08-26 15:33 Prayer 閱讀(1840) 評(píng)論(0) 編輯收藏引用所屬分類: 數(shù)據(jù)庫(kù),SQL

如何讓多進(jìn)程多線程訪問(wèn)數(shù)據(jù)庫(kù)，而不會(huì)選擇相同的數(shù)據(jù)，這在設(shè)計(jì)分布式程序的時(shí)候經(jīng)常用到，多臺(tái)機(jī)器的多個(gè)進(jìn)程，每個(gè)進(jìn)程都有多個(gè)線程，每個(gè)線程要從數(shù)據(jù)庫(kù)里取數(shù)據(jù)來(lái)處理，要實(shí)現(xiàn)不能漏取數(shù)據(jù)，也不能重復(fù)取數(shù)據(jù)，這里給出答案
創(chuàng)建一個(gè)數(shù)據(jù)表，如下，一個(gè)自增列，一個(gè)表示rss鏈接地址

CREATE TABLE [dbo].[Rss_RssSources](

[SourceId] [int] IDENTITY(1,1) NOT NULL,

[Link] [varchar](1024) NOT NULL

) ON [PRIMARY]

先放1w條數(shù)據(jù)

declare @i int

set @i = 1

while @i < 10000

begin

select @i = @i +1

insert into [Rss_RssSources] values(newid())

end

再創(chuàng)建一個(gè)鎖表，一個(gè)字段表示是否已經(jīng)鎖定的資源，另一個(gè)表示已經(jīng)讀取的rss源的最大id

create table Rss_RssSourceLock

(

IsLock bit,

MaxSourceId int

)
初始化數(shù)據(jù)

insert into Rss_RssSourceLock values (0,0)
下面我們要設(shè)計(jì)一個(gè)存儲(chǔ)過(guò)程，讓這個(gè)存儲(chǔ)過(guò)程每次返回10個(gè)rss源，知道返回所有的rss源，要求無(wú)遺漏，無(wú)重復(fù)返回。如下

CREATE PROCEDURE [dbo].[USP_GetRssSources]

BEGIN

if exists(select * from Rss_RssSourceLock with(READPAST) where IsLock = 0)

begin

declare @select_count int

begin tran

update Rss_RssSourceLock set IsLock = 1

if object_id('tempdb..#t') is not null

drop table #t

select top 10 a.* into #t from [Rss_RssSources] as a

inner join Rss_RssSourceLock as b

on a.SourceId > b.MaxSourceId

order by a.[SourceId]

select @select_count = count(*) from #t

update Rss_RssSourceLock set IsLock = 0,MaxSourceId = MaxSourceId + @select_count

select * from #t commit tran

end

END

1、如果鎖表里顯示沒(méi)有進(jìn)程正在讀取rss源（IsLock = 0），那么就返回從最大的rss源id往后的10個(gè)rss源，否則返回空。
2、用with(READPAST)表示忽略鎖住的行，如果另一個(gè)進(jìn)程正在執(zhí)行update Rss_RssSourceLock的語(yǔ)句，并且在事務(wù)提交前，update語(yǔ)句會(huì)鎖住這些要更新的行，而Rss_RssSourceLock表就一行數(shù) 據(jù)，這時(shí)候select Rss_RssSourceLock表并且忽略被鎖的行肯定是沒(méi)數(shù)據(jù)的，所以本次存儲(chǔ)過(guò)程執(zhí)行會(huì)返回空。
3、begin tran和commit tran保證了即使本次存儲(chǔ)過(guò)程出錯(cuò)，也不會(huì)讓Rss_RssSourceLock表處于IsLock = 1的臟數(shù)據(jù)狀態(tài)，如果處于這種狀態(tài)，后面的進(jìn)程執(zhí)行存儲(chǔ)過(guò)程就永遠(yuǎn)也返回不了數(shù)據(jù)了。
4、因?yàn)橛袝r(shí)候一次選取的記錄可能不夠10條，所以這里用了個(gè)臨時(shí)表來(lái)暫存記錄，再算出來(lái)選取的條數(shù)，最后更新Rss_RssSourceLock表的MaxSourceId字段。但用臨時(shí)表肯定會(huì)增加數(shù)據(jù)庫(kù)的壓力，這里不知道用表變量是不是會(huì)改善性能，暫時(shí)先這樣了。
5、應(yīng)用里調(diào)用這個(gè)存儲(chǔ)過(guò)程，如果返回了數(shù)據(jù)，就進(jìn)行處理，如果沒(méi)返回?cái)?shù)據(jù)，就sleep幾秒才執(zhí)行，直到返回?cái)?shù)據(jù)。

只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。
【推薦】100%開(kāi)源！大型工業(yè)跨平臺(tái)軟件C++源碼提供，建模，組態(tài)！

相關(guān)文章: 兩階段提交主鍵與唯一索引 DB2 Merge語(yǔ)句 LDAP 三十五個(gè)非主流開(kāi)源數(shù)據(jù)庫(kù) MongoDB領(lǐng)銜主演系統(tǒng)臨時(shí)表使用問(wèn)題 WITH HOLD 事務(wù)--<> MINUS EXCEPT OLAP與OLTP的一些基礎(chǔ)知識(shí)

網(wǎng)站導(dǎo)航: 博客園 IT新聞 BlogJava 博問(wèn) Chat2DB 管理

Prayer

C#--多進(jìn)程多線程訪問(wèn)數(shù)據(jù)庫(kù)

日歷

常用鏈接

留言簿(28)

隨筆分類

隨筆檔案

文章分類

UNIX

信用卡

搜索

最新評(píng)論

閱讀排行榜

評(píng)論排行榜