|
@@ -18,6 +18,15 @@ type
|
|
qtExecute=2,
|
|
qtExecute=2,
|
|
qtScript=3);
|
|
qtScript=3);
|
|
|
|
|
|
|
|
+ TQueryActions = (
|
|
|
|
+ qaCommit,
|
|
|
|
+ qaCommitRet,
|
|
|
|
+ qaRollBack,
|
|
|
|
+ qaRollbackRet,
|
|
|
|
+ qaOpen,
|
|
|
|
+ qaDDL,
|
|
|
|
+ qaExec );
|
|
|
|
+
|
|
|
|
|
|
{ TQueryThread }
|
|
{ TQueryThread }
|
|
|
|
|
|
@@ -31,7 +40,7 @@ type
|
|
Error: Boolean;
|
|
Error: Boolean;
|
|
ErrorMsg: string;
|
|
ErrorMsg: string;
|
|
fTerminated: Boolean;
|
|
fTerminated: Boolean;
|
|
- fType: string;
|
|
|
|
|
|
+ fType: TQueryActions;
|
|
fStatement: string;
|
|
fStatement: string;
|
|
property Query: TSQLQuery read fSQLQuery write fSQLQuery;
|
|
property Query: TSQLQuery read fSQLQuery write fSQLQuery;
|
|
property Trans: TSQLTransaction read fTrans write fTrans;
|
|
property Trans: TSQLTransaction read fTrans write fTrans;
|
|
@@ -39,7 +48,7 @@ type
|
|
property Statement: String read fStatement write fStatement;
|
|
property Statement: String read fStatement write fStatement;
|
|
procedure DoJob;
|
|
procedure DoJob;
|
|
procedure Execute; override;
|
|
procedure Execute; override;
|
|
- constructor Create(aType: string);
|
|
|
|
|
|
+ constructor Create(aType: TQueryActions);
|
|
end;
|
|
end;
|
|
|
|
|
|
|
|
|
|
@@ -623,25 +632,25 @@ end;
|
|
procedure TQueryThread.DoJob;
|
|
procedure TQueryThread.DoJob;
|
|
begin
|
|
begin
|
|
try
|
|
try
|
|
- if fType = 'open' then
|
|
|
|
|
|
+ if fType = qaOpen then
|
|
fSQLQuery.Open
|
|
fSQLQuery.Open
|
|
else
|
|
else
|
|
- if fType = 'exec' then
|
|
|
|
|
|
+ if fType = qaExec then
|
|
fSQLQuery.ExecSQL
|
|
fSQLQuery.ExecSQL
|
|
else
|
|
else
|
|
- if fType = 'ddl' then
|
|
|
|
|
|
+ if fType = qaDDL then
|
|
fConnection.ExecuteDirect(fStatement)
|
|
fConnection.ExecuteDirect(fStatement)
|
|
else
|
|
else
|
|
- if fType = 'commit' then
|
|
|
|
|
|
+ if fType = qaCommit then
|
|
fTrans.Commit
|
|
fTrans.Commit
|
|
else
|
|
else
|
|
- if fType = 'commitret' then
|
|
|
|
|
|
+ if fType = qaCommitRet then
|
|
fTrans.CommitRetaining
|
|
fTrans.CommitRetaining
|
|
else
|
|
else
|
|
- if fType = 'rollback' then
|
|
|
|
|
|
+ if fType = qaRollBack then
|
|
fTrans.Rollback
|
|
fTrans.Rollback
|
|
else
|
|
else
|
|
- if fType = 'rollbackret' then
|
|
|
|
|
|
+ if fType = qaRollbackRet then
|
|
fTrans.RollbackRetaining;
|
|
fTrans.RollbackRetaining;
|
|
|
|
|
|
Error:= False;
|
|
Error:= False;
|
|
@@ -681,7 +690,7 @@ end;
|
|
|
|
|
|
{ Create query thread }
|
|
{ Create query thread }
|
|
|
|
|
|
-constructor TQueryThread.Create(aType: string);
|
|
|
|
|
|
+constructor TQueryThread.Create(aType: TQueryActions);
|
|
begin
|
|
begin
|
|
inherited Create(True);
|
|
inherited Create(True);
|
|
fType:= aType;
|
|
fType:= aType;
|
|
@@ -727,7 +736,7 @@ var
|
|
begin
|
|
begin
|
|
RemoveControls;
|
|
RemoveControls;
|
|
ATab:= CreateResultTab(2, SqlQuery, SqlScript, meResult);
|
|
ATab:= CreateResultTab(2, SqlQuery, SqlScript, meResult);
|
|
- QT:= TQueryThread.Create('commit');
|
|
|
|
|
|
+ QT:= TQueryThread.Create(qaCommit);
|
|
try
|
|
try
|
|
QT.Trans:= SqlTrans;
|
|
QT.Trans:= SqlTrans;
|
|
ATab.ImageIndex:= 6;
|
|
ATab.ImageIndex:= 6;
|
|
@@ -769,7 +778,7 @@ procedure TfmQueryWindow.tbCommitRetainingClick(Sender: TObject);
|
|
var
|
|
var
|
|
QT: TQueryThread;
|
|
QT: TQueryThread;
|
|
begin
|
|
begin
|
|
- QT:= TQueryThread.Create('commitret');
|
|
|
|
|
|
+ QT:= TQueryThread.Create(qaCommitRet);
|
|
try
|
|
try
|
|
QT.Trans:= SqlTrans;
|
|
QT.Trans:= SqlTrans;
|
|
|
|
|
|
@@ -852,7 +861,7 @@ var
|
|
begin
|
|
begin
|
|
RemoveControls;
|
|
RemoveControls;
|
|
ATab:= CreateResultTab(2, SqlQuery, SqlScript, meResult);
|
|
ATab:= CreateResultTab(2, SqlQuery, SqlScript, meResult);
|
|
- QT:= TQueryThread.Create('rollback');
|
|
|
|
|
|
+ QT:= TQueryThread.Create(qaRollBack);
|
|
try
|
|
try
|
|
QT.Trans:= SqlTrans;
|
|
QT.Trans:= SqlTrans;
|
|
ATab.ImageIndex:= 6;
|
|
ATab.ImageIndex:= 6;
|
|
@@ -890,7 +899,7 @@ procedure TfmQueryWindow.tbRollbackRetainingClick(Sender: TObject);
|
|
var
|
|
var
|
|
QT: TQueryThread;
|
|
QT: TQueryThread;
|
|
begin
|
|
begin
|
|
- QT:= TQueryThread.Create('rollbackret');
|
|
|
|
|
|
+ QT:= TQueryThread.Create(qaRollbackRet);
|
|
try
|
|
try
|
|
QT.Trans:= SqlTrans;
|
|
QT.Trans:= SqlTrans;
|
|
|
|
|
|
@@ -1182,7 +1191,7 @@ begin
|
|
fSQLQuery.SQL.Text:= fQueryPart;
|
|
fSQLQuery.SQL.Text:= fQueryPart;
|
|
|
|
|
|
// Create thread to open dataset
|
|
// Create thread to open dataset
|
|
- fQT:= TQueryThread.Create('open');
|
|
|
|
|
|
+ fQT:= TQueryThread.Create(qaOpen);
|
|
fQT.Query:= fSqlQuery;
|
|
fQT.Query:= fSqlQuery;
|
|
// fQT.OnTerminate:= @ThreadTerminated;
|
|
// fQT.OnTerminate:= @ThreadTerminated;
|
|
faText:= fTab.Caption;
|
|
faText:= fTab.Caption;
|
|
@@ -1235,7 +1244,7 @@ begin
|
|
if IsDDL then
|
|
if IsDDL then
|
|
begin
|
|
begin
|
|
// Execute the statement in thread
|
|
// Execute the statement in thread
|
|
- fQT:= TQueryThread.Create('ddl');
|
|
|
|
|
|
+ fQT:= TQueryThread.Create(qaDDL);
|
|
fQT.Connection:= ibConnection;
|
|
fQT.Connection:= ibConnection;
|
|
fQT.Statement:= fQueryPart;
|
|
fQT.Statement:= fQueryPart;
|
|
fQT.Resume;
|
|
fQT.Resume;
|
|
@@ -1268,7 +1277,7 @@ begin
|
|
fSQLQuery.SQL.Text:= fQueryPart;
|
|
fSQLQuery.SQL.Text:= fQueryPart;
|
|
|
|
|
|
// Execute the statement in thread
|
|
// Execute the statement in thread
|
|
- fQT:= TQueryThread.Create('exec');
|
|
|
|
|
|
+ fQT:= TQueryThread.Create(qaExec);
|
|
try
|
|
try
|
|
fQT.Query:= fSqlQuery;
|
|
fQT.Query:= fSqlQuery;
|
|
fQT.Resume;
|
|
fQT.Resume;
|