mirror of
https://github.com/HeidiSQL/HeidiSQL.git
synced 2025-08-15 02:54:07 +08:00
Organize repository into standard trunk/branches/tags structure.
This commit is contained in:
rosenfield
288
extra/QueryThreadExample/Main.pas
Normal file
288
extra/QueryThreadExample/Main.pas
Normal file
@ -0,0 +1,288 @@
|
||||
unit Main;
|
||||
|
||||
interface
|
||||
|
||||
uses
|
||||
Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
|
||||
Dialogs, StdCtrls, MysqlQueryThread, ComCtrls, ExtCtrls, MysqlQuery, Grids,
|
||||
DBGrids, DB;
|
||||
|
||||
type
|
||||
TForm1 = class(TForm)
|
||||
Panel2: TPanel;
|
||||
Label1: TLabel;
|
||||
Label2: TLabel;
|
||||
Label3: TLabel;
|
||||
Label5: TLabel;
|
||||
Label6: TLabel;
|
||||
Button1: TButton;
|
||||
Edit1: TEdit;
|
||||
edHost: TEdit;
|
||||
edPort: TEdit;
|
||||
edUser: TEdit;
|
||||
edPass: TEdit;
|
||||
edDatabase: TEdit;
|
||||
Label4: TLabel;
|
||||
Panel3: TPanel;
|
||||
bnKillThread: TButton;
|
||||
Label7: TLabel;
|
||||
Panel1: TPanel;
|
||||
Panel4: TPanel;
|
||||
lvResult: TListView;
|
||||
Panel5: TPanel;
|
||||
Splitter1: TSplitter;
|
||||
pnResultset: TPanel;
|
||||
DBGrid1: TDBGrid;
|
||||
DataSource1: TDataSource;
|
||||
Button2: TButton;
|
||||
Button3: TButton;
|
||||
procedure FormDestroy(Sender: TObject);
|
||||
procedure FormCreate(Sender: TObject);
|
||||
procedure Button3Click(Sender: TObject);
|
||||
procedure lvResultSelectItem(Sender: TObject; Item: TListItem;
|
||||
Selected: Boolean);
|
||||
procedure bnKillThreadClick(Sender: TObject);
|
||||
procedure Button1Click(Sender: TObject);
|
||||
private
|
||||
procedure HandleWMCopyData(var msg: TWMCopyData); message WM_COPYDATA;
|
||||
function FindListItemByMysqlQueryObject(AObject: Pointer): Integer;
|
||||
function AssembleConnParams () : TOpenConnProf;
|
||||
function AddListItem(AMysqlQuery : Pointer; ACaption : String) : TListItem;
|
||||
public
|
||||
procedure LogMsg (AMsg : String);
|
||||
procedure HandleQueryNotification(ASender : TMysqlQuery; AEvent : Integer);
|
||||
procedure HandleQueryNotificationMsg(var AMessage : TMessage); message WM_MYSQL_THREAD_NOTIFY;
|
||||
end;
|
||||
|
||||
var
|
||||
Form1: TForm1;
|
||||
|
||||
implementation
|
||||
|
||||
uses synchronization, communication, threading;
|
||||
|
||||
{$R *.dfm}
|
||||
|
||||
procedure TForm1.Button1Click(Sender: TObject);
|
||||
var
|
||||
cp : TOpenConnProf;
|
||||
mq : TMysqlQuery;
|
||||
begin
|
||||
cp := AssembleConnParams();
|
||||
mq := ExecMysqlStatementAsync(Edit1.Text,cp,HandleQueryNotification,Handle);
|
||||
end;
|
||||
|
||||
procedure TForm1.Button3Click(Sender: TObject);
|
||||
var
|
||||
cp : TOpenConnProf;
|
||||
mq : TMysqlQuery;
|
||||
begin
|
||||
cp := AssembleConnParams();
|
||||
mq := ExecMysqlStatementBlocking(Edit1.Text,cp,Handle);
|
||||
end;
|
||||
|
||||
function TForm1.AddListItem(AMysqlQuery: Pointer; ACaption: String): TListItem;
|
||||
begin
|
||||
Result := lvResult.Items.Add();
|
||||
Result.Data := AMysqlQuery;
|
||||
Result.Caption := ACaption;
|
||||
Result.SubItems.Add('');
|
||||
Result.SubItems.Add('');
|
||||
Result.SubItems.Add('');
|
||||
Result.SubItems.Add('');
|
||||
Result.SubItems.Add('');
|
||||
end;
|
||||
|
||||
function TForm1.AssembleConnParams: TOpenConnProf;
|
||||
begin
|
||||
ZeroMemory(@Result,SizeOf(Result));
|
||||
Result.MysqlParams.Host := edHost.Text;
|
||||
Result.MysqlParams.Database := edDatabase.Text;
|
||||
Result.MysqlParams.Protocol := 'mysql';
|
||||
Result.MysqlParams.User := edUser.Text;
|
||||
Result.MysqlParams.Pass := edPass.Text;
|
||||
Result.MysqlParams.Port := StrToIntDef(edPort.Text,3306);
|
||||
end;
|
||||
|
||||
procedure TForm1.bnKillThreadClick(Sender: TObject);
|
||||
var
|
||||
cp : TOpenConnProf;
|
||||
mq : TMysqlQuery;
|
||||
li : TListItem;
|
||||
begin
|
||||
li := lvResult.Selected;
|
||||
|
||||
if li<>nil then
|
||||
if li.Data <> nil then
|
||||
begin
|
||||
mq := li.Data;
|
||||
|
||||
if mq.ConnectionID<>0 then
|
||||
begin
|
||||
cp := AssembleConnParams();
|
||||
ExecMysqlStatementAsync (Format('KILL %d;',[mq.ConnectionID]),cp,HandleQueryNotification);
|
||||
end;
|
||||
end;
|
||||
|
||||
end;
|
||||
|
||||
function TForm1.FindListItemByMysqlQueryObject(AObject : Pointer): Integer;
|
||||
var
|
||||
i : Integer;
|
||||
begin
|
||||
Result := -1;
|
||||
|
||||
if lvResult.Items.Count > 0 then
|
||||
for i := 0 to lvResult.Items.Count - 1 do
|
||||
if lvResult.Items[i].Data = AObject then
|
||||
begin
|
||||
Result := i;
|
||||
Break;
|
||||
end;
|
||||
|
||||
end;
|
||||
|
||||
procedure TForm1.FormCreate(Sender: TObject);
|
||||
begin
|
||||
InitializeSync(Form1.Handle);
|
||||
SetWindowName (Caption);
|
||||
SetWindowConnected (True);
|
||||
end;
|
||||
|
||||
procedure TForm1.FormDestroy(Sender: TObject);
|
||||
begin
|
||||
DeInitializeSync();
|
||||
end;
|
||||
|
||||
procedure TForm1.HandleQueryNotification(ASender : TMysqlQuery; AEvent : Integer);
|
||||
var
|
||||
li : TListItem;
|
||||
idx : Integer;
|
||||
begin
|
||||
idx := FindListItemByMysqlQueryObject (ASender);
|
||||
|
||||
if (idx<>-1) or (AEvent=MQE_INITED) then
|
||||
begin
|
||||
if idx=-1 then
|
||||
li := AddListItem(ASender,'?')
|
||||
else
|
||||
li := lvResult.Items[idx];
|
||||
|
||||
case AEvent of
|
||||
MQE_INITED:
|
||||
begin
|
||||
li.Caption := IntToStr(ASender.ThreadID);
|
||||
li.SubItems[0] := '?';
|
||||
li.SubItems[1] := 'INIT';
|
||||
li.SubItems[2] := ASender.Sql;
|
||||
end;
|
||||
MQE_STARTED:
|
||||
begin
|
||||
li.SubItems[0] := IntToStr(ASender.ConnectionID);
|
||||
li.SubItems[1] := 'STARTED';
|
||||
end;
|
||||
MQE_FINISHED:
|
||||
begin
|
||||
li.SubItems[1] := 'FINISHED';
|
||||
end;
|
||||
MQE_FREED:
|
||||
begin
|
||||
li.SubItems[1] := 'IDLE';
|
||||
end;
|
||||
|
||||
end;
|
||||
|
||||
li.SubItems[3] := Format('[%d] %s',[ASender.Result,ASender.Comment]);
|
||||
end;
|
||||
|
||||
end;
|
||||
|
||||
procedure TForm1.HandleQueryNotificationMsg(var AMessage: TMessage);
|
||||
var
|
||||
idx : Integer;
|
||||
li : TListItem;
|
||||
mq : TMysqlQuery;
|
||||
begin
|
||||
//ShowMessageFmt('thread notification winmessage: wp=%d lp=%d qry=%s',[AMessage.WParam,AMessage.LParam,TMysqlQuery(Pointer(AMessage.WParam)).Sql]);
|
||||
|
||||
idx := FindListItemByMysqlQueryObject (Pointer(AMessage.WParam));
|
||||
if (idx<>-1) or (AMessage.LParam=MQE_INITED) then
|
||||
begin
|
||||
mq := TMysqlQuery(Pointer(AMessage.WParam));
|
||||
|
||||
if idx=-1 then
|
||||
li := AddListItem(mq,'?')
|
||||
else
|
||||
li := lvResult.Items[idx];
|
||||
|
||||
li.SubItems[1] := IntToStr(AMessage.LParam);
|
||||
|
||||
|
||||
case AMessage.LParam of
|
||||
MQE_INITED:
|
||||
li.Caption := IntToStr(mq.ThreadID);
|
||||
MQE_STARTED:;
|
||||
MQE_FINISHED:;
|
||||
MQE_FREED:;
|
||||
end;
|
||||
|
||||
|
||||
end;
|
||||
end;
|
||||
|
||||
procedure TForm1.LogMsg(AMsg: String);
|
||||
begin
|
||||
end;
|
||||
|
||||
procedure TForm1.lvResultSelectItem(Sender: TObject; Item: TListItem;
|
||||
Selected: Boolean);
|
||||
var
|
||||
mq : TMysqlQuery;
|
||||
begin
|
||||
bnKillThread.Enabled := Selected;
|
||||
Datasource1.DataSet := nil;
|
||||
|
||||
if lvResult.Selected<>nil then
|
||||
if lvResult.Selected.Data <> nil then
|
||||
begin
|
||||
mq := TMysqlQuery(lvResult.Selected.Data);
|
||||
if mq.HasResultset then
|
||||
begin
|
||||
DataSource1.Dataset := mq.MysqlDataset;
|
||||
// Enable free button
|
||||
end;
|
||||
|
||||
end;
|
||||
|
||||
|
||||
end;
|
||||
|
||||
|
||||
procedure TForm1.HandleWMCopyData(var msg: TWMCopyData);
|
||||
var
|
||||
method: DWORD;
|
||||
cp : TOpenConnProf;
|
||||
mq : TMysqlQuery;
|
||||
begin
|
||||
|
||||
// extract info from message
|
||||
method := msg.CopyDataStruct^.dwData;
|
||||
|
||||
// display
|
||||
//DebugWrite(Format('WM_COPYDATA received; method=%d',[method]));
|
||||
|
||||
if method in [CMD_EXECUTEQUERY_NORESULTS,CMD_EXECUTEQUERY_RESULTS] then
|
||||
begin
|
||||
//DebugWrite('Query: '+GetQueryFromMsg(msg));
|
||||
|
||||
cp := AssembleConnParams();
|
||||
mq := ExecMysqlStatementBlocking(GetQueryFromMsg(msg),cp,Handle); //HandleQueryNotification
|
||||
end;
|
||||
|
||||
|
||||
// release
|
||||
//ReleaseRemoteCaller(ERR_UNSPECIFIED);
|
||||
end;
|
||||
|
||||
|
||||
end.
|
||||
Reference in New Issue
Block a user