Delphi中實(shí)現(xiàn)多線程同步查詢 (2001年6月8日) 

本站更新  分類:數(shù)據(jù)庫(kù)   作者:賽迪網(wǎng)  推薦:   閱讀次數(shù):222  
(http://www.codesky.net)  

--------------------------------------------------------------------------------

優(yōu)秀的數(shù)據(jù)庫(kù)應(yīng)用應(yīng)當(dāng)充分考慮數(shù)據(jù)庫(kù)訪問(wèn)的速度問(wèn)題。通常可以通過(guò)優(yōu)化數(shù)據(jù)庫(kù)、優(yōu)化 查詢語(yǔ)句、分頁(yè)查詢等途徑收到明顯的效果。即使是這樣，也不可避免地會(huì)在查詢時(shí)閃現(xiàn)一個(gè)帶有 SQL符號(hào)的沙漏，即鼠標(biāo)變成了查詢等待。最可憐的是用戶，他（她）在此時(shí)只能無(wú)奈地等待。遇到急性子的，干脆在此時(shí)嘗試 Windows中的其它應(yīng)用程序，結(jié)果致使你的數(shù)據(jù)庫(kù)應(yīng)用顯示一大片白色的窗口。真是無(wú)奈！

本文將以簡(jiǎn)單的例子告訴你如何實(shí)現(xiàn)線程查詢。還等什么，趕快打開(kāi)Delphi對(duì)照著下面的完整源代碼試試吧。

在查詢時(shí)能夠做別的事情或者取消查詢，這只是基本的線程查詢，在你閱讀了Delphi有關(guān)線程幫助之后能立刻實(shí)現(xiàn)。這里介紹的是多個(gè)線程查詢的同步進(jìn)行。

在Delphi數(shù)據(jù)庫(kù)應(yīng)用中，都有一個(gè)缺省的數(shù)據(jù)庫(kù)會(huì)話 Session。通常情況下，每個(gè)數(shù)據(jù)庫(kù)應(yīng)用中只有這一個(gè)會(huì)話。無(wú)論是查詢函數(shù)修改數(shù)據(jù)，在同一時(shí)間內(nèi)只能進(jìn)行其中的一件事情， 而且進(jìn)行這一件事情的時(shí)候應(yīng)用程序不能響應(yīng)鍵盤、鼠標(biāo)以及其它的 Windows消息。這就是在 窗口區(qū)域會(huì)顯示一片空白的原因所在。當(dāng)然，只要將查詢或數(shù)據(jù)操縱構(gòu)造成線程對(duì)象，情況會(huì)好一些，至少可以接受窗口消息，也可以隨時(shí)終止查詢或數(shù)據(jù)操縱，而不會(huì)在屏幕上顯示出太難看的白色。不過(guò)，這只是解決了問(wèn)題的一部分。假如在進(jìn)行一個(gè)線程查詢的時(shí)候，用戶通過(guò) 按鈕或菜單又發(fā)出了另一個(gè)查詢的命令，這可如何是好，難道終止正在執(zhí)行的數(shù)據(jù)庫(kù)訪問(wèn)嗎？ 解決之道就是：多線程同步查詢。

實(shí)現(xiàn)多線程同步查詢的基本思想是，為每一個(gè)查詢組件（如TQuery組件）創(chuàng)建一個(gè)獨(dú)占的 數(shù)據(jù)庫(kù)會(huì)話，然后各自進(jìn)行數(shù)據(jù)庫(kù)訪問(wèn)。需要特別注意的是，因?yàn)镈elphi中的 VCL組件大多都 不是線程安全的，所以應(yīng)當(dāng)在線程查詢結(jié)束后再將DataSource組件與查詢組件關(guān)聯(lián)，從而顯示 在DBGrid組件中。

下面的例子只實(shí)現(xiàn)了靜態(tài)的線程同步查詢，即線程對(duì)象是固定的，并隨窗體的創(chuàng)建和銷毀 而創(chuàng)建和銷毀。你可以就此進(jìn)行改進(jìn)，為每一個(gè)數(shù)據(jù)查詢或數(shù)據(jù)操縱命令創(chuàng)建一個(gè)單獨(dú)的線程對(duì)象，從而達(dá)到多線程同步查詢的目的。

注意：應(yīng)用程序中的線程不是越多越好，因?yàn)榫€程將嚴(yán)重吞噬CPU資源，盡管看上去并不明顯。謹(jǐn)慎創(chuàng)建和銷毀線程將避免你的應(yīng)用程序?qū)е孪到y(tǒng)資源崩潰。

下面的例子給出了同時(shí)進(jìn)行的兩個(gè)線程查詢。第一次按下按鈕時(shí)，線程開(kāi)始執(zhí)行；以后每次按下按鈕時(shí)，如果線程處于掛起狀態(tài)則繼續(xù)執(zhí)行，否則掛起線程；線程執(zhí)行完畢之后將連接 DataSource，查詢結(jié)果將顯示在相應(yīng)的DBGrid中。

{ 這里的多線程同步查詢演示程序僅包括一個(gè)工程文件和一個(gè)單元文件 }
{ 窗體中放置的組件有： }
{ 兩個(gè)Session組件 }
{ 兩個(gè)Database組件 }
{ 兩個(gè)Query組件 }
{ 兩個(gè)DataSource組件 }
{ 兩個(gè)DBGrid組件 }
{ 一個(gè)Button組件 }
{ 除非特別說(shuō)明，否則上述各組件的屬性都取默認(rèn)值（見(jiàn)各組件注釋） }
{ 對(duì)于Database組件，就和一般設(shè)置一樣，有一個(gè)正確的連接即可 }
{ 對(duì)于Query 組件，需要在各自的屬性 SQL中添加一些查詢語(yǔ)句，為了 }
{ 看得更清除，建議不要在兩個(gè)Query 組件中填寫相同的查詢語(yǔ)句。 }

unit Unit1;

interface

uses
Windows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs,
Db, DBTables, Grids, DBGrids, StdCtrls;

type
TForm1 = class(TForm)
Session1: TSession; { 屬性SessionName填寫為S1 }
Database1: TDatabase; { 屬性SessionName選擇為S1 }
Query1: TQuery;{ 屬性Database選擇為Database1；屬性SessionName選擇為S1 }
DataSource1: TDataSource; { 屬性DataSet設(shè)置為空 }
DBGrid1: TDBGrid; { 屬性DataSource選擇為DataSource1 }
Session2: TSession; { 屬性SessionName填寫為S2 }
Database2: TDatabase; { 屬性SessionName選擇為S2 }
Query2: TQuery;{ 屬性Database選擇為Database2；屬性SessionName選擇為S2 }
DataSource2: TDataSource; { 屬性DataSet設(shè)置為空 }
DBGrid2: TDBGrid; { 屬性DataSource選擇為DataSource2 }
BtnGoPause: TButton; { 用于執(zhí)行和掛起線程 }
procedure FormCreate(Sender: TObject); { 創(chuàng)建窗體時(shí)創(chuàng)建線程對(duì)象 }
procedure FormDestroy(Sender: TObject); { 銷毀窗體時(shí)銷毀線程對(duì)象 }
procedure BtnGoPauseClick(Sender: TObject); { 執(zhí)行線程和掛起線程 }
private
public
end;

TThreadQuery = class(TThread) { 聲明線程類 }
private
FQuery: TQuery; { 線程中的查詢組件 }
FDataSource: TDataSource; { 與查詢組件相關(guān)的數(shù)據(jù)感知組件 }
procedure ConnectDataSource;{ 連接數(shù)據(jù)查詢組件和數(shù)據(jù)感知組件的方法 }
protected
procedure Execute; override;{ 執(zhí)行線程的方法 }
public
constructor Create(Query: TQuery;
DataSource: TDataSource); virtual; { 線程構(gòu)造器 }
end;

var
Form1: TForm1;
Q1, { 線程查詢對(duì)象1 }
Q2: TThreadQuery; { 線程查詢對(duì)象2 }

implementation

{$R *.DFM}

{ TThreadQuery類的實(shí)現(xiàn) }

{ 連接數(shù)據(jù)查詢組件和數(shù)據(jù)感知組件}
procedure TThreadQuery.ConnectDataSource;
begin
FDataSource.DataSet := FQuery;{ 該方法在查詢結(jié)束后才調(diào)用 }
end;

procedure TThreadQuery.Execute;{ 執(zhí)行線程的方法 }
begin
try
FQuery.Open; { 打開(kāi)查詢 }
Synchronize(ConnectDataSource);{ 線程同步 }
except
ShowMessage('Query Error'); { 線程異常 }
end;
end;

{ 線程查詢類的構(gòu)造器 }
constructor TThreadQuery.Create(Query: TQuery; DataSource: TDataSource);
begin
FQuery := Query;
FDataSource := DataSource;
inherited Create(True);
FreeOnTerminate := False;
end;

{ 創(chuàng)建窗體時(shí)創(chuàng)建線程查詢對(duì)象 }
procedure TForm1.FormCreate(Sender: TObject);
begin
Q1 := TThreadQuery.Create(Query1, DataSource1);
Q2 := TThreadQuery.Create(Query2, DataSource2);
end;

{ 銷毀窗體時(shí)銷毀線程查詢對(duì)象 }
procedure TForm1.FormDestroy(Sender: TObject);
begin
Q1.Terminate; { 銷毀之前終止線程執(zhí)行 }
Q1.Destroy;
Q2.Terminate; { 銷毀之前終止線程執(zhí)行 }
Q2.Destroy;
end;

{ 開(kāi)始線程、繼續(xù)執(zhí)行線程、掛起線程 }
procedure TForm1.BtnGoPauseClick(Sender: TObject);
begin
if Q1.Suspended then Q1.Resume else Q1.Suspend;
if Q2.Suspended then Q2.Resume else Q2.Suspend;
end;

end.