unit Unit1;

interface

uses
  Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
  Dialogs, StdCtrls,inifiles, FIBQuery, pFIBQuery,FIBDatabase,  pFIBDatabase,
  ExtCtrls, tlhelp32, XPMan , wcthread, wlog ;

type
  TForm1 = class(TForm)
    Button1: TButton;
    Memo1: TMemo;
    Timer1: TTimer;
    Button2: TButton;
    XPManifest1: TXPManifest;
    WCThread1: TWCThread;
    procedure Button1Click(Sender: TObject);
  private
    { Private declarations }

  public
    { Public declarations }
  end;

      TMyThread = class(TThread)
    	private
        		Fpath1, Fpath2,Fkind,Flog,Fexe,Fuser: string;
        		db3 :   TpFIBDatabase;
        		trans3 : TpFIBTransaction;
        		query3:   TpFIBQuery;
      protected
        		procedure CreateConnection;
        		procedure CloseConnection;
    	public
        		constructor Create(CreateSuspended: Boolean; var Apath1, Apath2, Akind,Alog,Aexe,Auser : string);
        		destructor Destroy; override;
        		procedure Execute; override;
    	end;


var
    Form1: TForm1;



implementation

{$R *.dfm}

procedure TMyThread.CreateConnection;

begin
    // подключаемся, настраиваем транзакцию и т.п
    // логируем через wlog
     PostToLog('Create connection');
     db3:=TpFIBDatabase.Create(nil);
     trans3:= TpFIBTransaction.Create(nil);
     query3:= TpFIBQuery.Create(nil);
     db3.connectparams.Username:='SYSDBA';
     db3.connectparams.Password:='masterkey';
     db3.DatabaseName:='d:\fdbase\fb_log_database.fdb';
     db3.AutoReconnect := False;
     db3.DefaultUpdateTransaction:=trans3;
     db3.LibraryName:= 'fbclient.dll';
     trans3.DefaultDatabase:=db3;
     query3.Database:=db3;
     query3.Transaction:=trans3;
     db3.connected:=True;
end;

procedure TMyThread.CloseConnection;
begin
    db3.connected:=False;
    db3.Close;
    PostToLog('Close connection');
end;

constructor TMyThread.Create(CreateSuspended: Boolean;  var Apath1, Apath2,Akind,Alog,Aexe,Auser: string);
begin
  	inherited Create(CreateSuspended);
  	CreateConnection;
  	Fpath1:= Apath1;
  	Fpath2:= Apath2;
  	Fkind:= Akind;
  	Flog:=Alog;
  	Fexe:=Aexe;
  	Fuser:=Auser;
end;

destructor TMyThread.Destroy;
begin
		CloseConnection;
    inherited Destroy;
end;

procedure TMyThread.Execute;
begin
    // делаем что нужно
					 	PostToLog(Format('%d Start execute', [Handle]));
            query3.SQL.Clear;
            query3.SQL.Add('insert into IMPORT_EXISTS_LOG (WRITE_TIME,KIND,USER_ID) values (current_timestamp,:KIND,:USER_ID)');
            trans3.StartTransaction;
         		query3.ParamByName('KIND').Value:= Fkind;
            query3.ParamByName('USER_ID').Value:= Fuser;
            query3.ExecQuery();
            trans3.Commit;
            query3.Close;
            freeandnil(trans3);
            freeandnil(query3);
            freeandnil(db3);
            CloseConnection;
            PostToLog(Format('%d End execute', [Handle]));
end;




procedure TForm1.Button1Click(Sender: TObject);
var
    i: integer;
    fini: TIniFile;
    sections: TStringList;
    tpath1
    ,tpath2
    ,tpath3
    , tkind
    , tlog
    , texe
    ,tuser: string;
    MyThread: TMyThread;
begin
    memo1.Lines.Clear;
    sections := TStringList.Create;
    try
      fini:=TIniFile.Create(ExtractFilePath(Application.ExeName)+'init.ini');
      tpath3 := ExtractFilepath(Application.ExeName);
      fini.ReadSections(sections);
      //ïðîõîäèì ïî íàñòðîéêàì, ïîëó÷àåì ïóòè
      for i:= 0 to pred(sections.Count) do
      begin
        tpath1:=  fini.ReadString(sections[i],'source','');
        tpath2:=  fini.ReadString(sections[i],'target','');
        tkind:=  fini.ReadString(sections[i],'kind','');
        tlog:=  fini.ReadString(sections[i],'log','');
        texe:=  fini.ReadString(sections[i],'exe','');
        tuser:=  fini.ReadString(sections[i],'user','');
        memo1.Lines.Add(tpath1);
        memo1.Lines.Add(tpath2);
        memo1.Lines.Add(tkind);
         memo1.Lines.Add(tlog);
         memo1.Lines.Add(texe);
         memo1.Lines.Add(tuser);
        MyThread:= TMyThread.Create(true, tpath1,tpath2,tkind,tlog,texe,tuser);
      end;
    finally
      FreeAndNil(sections);
    end;
end;


end.

procedure TMyThread.Execute;
begin
    // делаем что нужно
					 	PostToLog(Format('%d Start execute', [Handle]));
            query3.SQL.Clear;
            query3.SQL.Add('insert into IMPORT_EXISTS_LOG (WRITE_TIME,KIND,USER_ID) values (current_timestamp,:KIND,:USER_ID)');
            trans3.StartTransaction;
         		query3.ParamByName('KIND').Value:= Fkind;
            query3.ParamByName('USER_ID').Value:= Fuser;
            query3.ExecQuery();
            trans3.Commit;
            query3.Close;
            freeandnil(trans3);
            freeandnil(query3);
            freeandnil(db3);
            try
            CloseConnection;
            PostToLog(Format('%d End execute', [Handle]));
            except
            showmessage('проверка');
            end;
end;