• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            Prayer

            在一般中尋求卓越
            posts - 1256, comments - 190, trackbacks - 0, articles - 0
              C++博客 :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理

            如何讓多進程多線程訪問數據庫

            Posted on 2008-08-26 15:12 Prayer 閱讀(582) 評論(0)  編輯 收藏 引用 所屬分類: 數據庫,SQLDB2

            如何讓多進程多線程訪問數據庫,而不會選擇相同的數據,這在設計分布式程序的時候經常用到,多臺機器的多個進程,每個進程都有多個線程,每個線程要從數據庫里取數據來處理,要實現不能漏取數據,也不能重復取數據,這里給出答案

            創建一個數據表,如下,一個自增列,一個表示rss鏈接地址先放1w條數據再創建一個鎖表,一個字段表示是否已經鎖定的資源,另一個表示已經讀取的rss源的最大id初始化數據下面我們要設計一個存儲過程,讓這個存儲過程每次返回10個rss源,知道返回所有的rss源,要求無遺漏,無重復返回。如下1、如果鎖表里顯示沒有進程正在讀取rss源(IsLock = 0),那么就返回從最大的rss源id往后的10個rss源,否則返回空。

              2、用with(READPAST)表示忽略鎖住的行,如果另一個進程正在執行update Rss_RssSourceLock的語句,并且在事務提交前,update語句會鎖住這些要更新的行,而Rss_RssSourceLock表就一行數據,這時候select Rss_RssSourceLock表并且忽略被鎖的行肯定是沒數據的,所以本次存儲過程執行會返回空。


              3、begin tran和commit tran保證了即使本次存儲過程出錯,也不會讓Rss_RssSourceLock表處于IsLock = 1的臟數據狀態,如果處于這種狀態,后面的進程執行存儲過程就永遠也返回不了數據了。

              4、因為有時候一次選取的記錄可能不夠10條,所以這里用了個臨時表來暫存記錄,再算出來選取的條數,最后更新Rss_RssSourceLock表的MaxSourceId字段。但用臨時表肯定會增加數據庫的壓力,這里不知道用表變量是不是會改善性能,暫時先這樣了。

             

              5、應用里調用這個存儲過程,如果返回了數據,就進行處理,如果沒返回數據,就sleep幾秒才執行,直到返回數據。

              CREATE TABLE [dbo].[Rss_RssSources](


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

             

               [Link] [varchar](1024) NOT NULL

              ) ON [PRIMARY]

             

              declare @i int

              set @i = 1

              while @i <10000

              begin


              select @i = @i +1

              insert into [Rss_RssSources] values(newid())

              end

              create table Rss_RssSourceLock

              (

             

              IsLock bit,

              MaxSourceId int


              )


            insert into Rss_RssSourceLock values (0,0)
            CREATE PROCEDURE [dbo].[USP_GetRssSources]

             

              AS

             

              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


             

            伊人久久大香线蕉综合热线| 9999国产精品欧美久久久久久| 亚洲国产成人精品女人久久久 | 亚洲综合精品香蕉久久网| 久久亚洲精品人成综合网| 久久精品免费观看| 亚洲国产成人精品久久久国产成人一区二区三区综 | 99久久精品免费看国产免费| 久久香综合精品久久伊人| 久久香蕉一级毛片| 无码8090精品久久一区| 狠狠色婷婷久久一区二区三区| 久久久久综合中文字幕| 久久99精品国产麻豆| 日日狠狠久久偷偷色综合96蜜桃| 久久发布国产伦子伦精品| 日本国产精品久久| 国产韩国精品一区二区三区久久 | 亚洲欧美日韩中文久久| 精品久久久久久国产三级| 99re这里只有精品热久久| 国产精品久久久久久久久久影院 | 久久99精品国产麻豆宅宅| 久久精品国产精品亚洲| 精品久久久无码人妻中文字幕豆芽| 久久亚洲国产精品123区| 国产高潮国产高潮久久久91| 狠狠色丁香婷婷综合久久来| 77777亚洲午夜久久多喷| 久久久久亚洲精品日久生情 | 亚洲国产精品成人久久蜜臀| 久久97久久97精品免视看秋霞| 久久亚洲精品中文字幕三区| 97久久久精品综合88久久| 久久综合给合久久狠狠狠97色| 久久久亚洲AV波多野结衣| 国产A级毛片久久久精品毛片| 欧美伊人久久大香线蕉综合| 区亚洲欧美一级久久精品亚洲精品成人网久久久久 | 欧美精品丝袜久久久中文字幕 | 天天久久狠狠色综合|