實例講解如何讓多進程多線程訪問數據庫

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

創建一個數據表,如下,一個自增列,一個表示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

詳細講解Oracle數據庫後台進程的具體功能
DBWR進程:該進程執行將緩沖區寫入數據文件,是負責緩沖存儲區管理的一個Oracle後台進程。當緩沖區中的一緩沖區被修改,它被標志爲“弄髒”,DBWR的主要任務是將“弄髒”的緩沖區寫入磁盤,使緩沖區保持“幹淨”。由...查看完整版>>詳細講解Oracle數據庫後台進程的具體功能
 
講解jython訪問Oracle數據庫的具體步驟
需要的准備工作: 下載 http://jaist.dl.sourceforge.net/sourceforge/zxjdbc/zxJDBC-2.1.tar.gz http://jaist.dl.sourceforge.net/sourceforge/jython/jython_installer-2.2.1.jar 根據自己的jdk版本下載對應的ojdb...查看完整版>>講解jython訪問Oracle數據庫的具體步驟
 
講解jython訪問MySQL數據庫的具體步驟
准備工作如下: 下載 http://jaist.dl.sourceforge.net/sourceforge/zxjdbc/zxJDBC-2.1.tar.gz http://jaist.dl.sourceforge.net/sourceforge/jython/jython_installer-2.2.1.jar http://mmmysql.sourceforge.net/di...查看完整版>>講解jython訪問MySQL數據庫的具體步驟
 
詳細講解Oracle數據庫後台進程的具體功能
閱讀提示:DBWR進程:該進程執行將緩沖區寫入數據文件,是負責緩沖存儲區管理的一個Oracle後台進程。當緩沖區中的一緩沖區被修改,它被標志爲“弄髒”,DBWR的主要任務是將“弄髒”的緩沖區寫入...查看完整版>>詳細講解Oracle數據庫後台進程的具體功能
 
實例講解兩台SQL Server數據同步解決方案
複制的概念   複制是將一組數據從一個數據源拷貝到多個數據源的技術,是將一份數據發布到多個存儲站點上的有效方式。使用複制技術,用戶可以將一份數據發布到多台服務器上,從而使不同的服務器用戶都可以在權限的許...查看完整版>>實例講解兩台SQL Server數據同步解決方案
 
實例講解如何刪除Oracle 10g的垃圾表
經常使用Oracle數據庫10g,大家可以發現以前刪除的表在數據庫中出現了特別多的垃圾表,如下例: BINjR8PK5HhrrgMK8KmgQ9nw==這一類的表通常無法刪除,並且無法用"delete"刪除,這種情況的出現, 一般不會影響正常的使...查看完整版>>實例講解如何刪除Oracle 10g的垃圾表
 
(原創)CE MAPI實例講解 --- 如何獲取收件人信息(六)
接下來開始講講如何獲取聯系人信息,它與設置信息比較相近,以下舉例說明: IMAPITable* pTable = NULL; //通過GetRecipientTable獲取聯系人信息列表 pMsg->GetRecipientTable( NULL, &pTable ...查看完整版>>(原創)CE MAPI實例講解 --- 如何獲取收件人信息(六)
 
Linux下如何限制訪問apache的每個用戶的浏覽進程?
最近發現有一個IP開了幾十個線程在訪問我們的服務器(好像用了webzip的軟件),弄得服務器好慢,想限制卻不知怎麽做,請高手指點。 擋泥板 回複于:2003-10-15 14:50:09 我的apache是1.3.26的 zhangweibo 回複于:20...查看完整版>>Linux下如何限制訪問apache的每個用戶的浏覽進程?
 
訪問Oracle數據庫時如何限制繞過漏洞
導 讀 Oracle 9.2.0.0到10.2.0.3版本答應在基表中僅有SELECT權限的用戶通過特制的視圖插入/更新/刪除數據,成功利用這個漏洞的低權限用戶可以通過創建特制的視圖導致插入、更新和刪除數據。 受影響系統: Oracle Dat...查看完整版>>訪問Oracle數據庫時如何限制繞過漏洞
 
 
回到王朝網路移動版首頁