diff --git a/.gitattributes b/.gitattributes
index ab3de7cf3e..892b19a8a1 100644
--- a/.gitattributes
+++ b/.gitattributes
@@ -2350,6 +2350,7 @@ components/sqldb/languages/sqlstringspropertyeditordlg.ru.po svneol=native#text/
 components/sqldb/languages/sqlstringspropertyeditordlg.uk.po svneol=native#text/plain
 components/sqldb/languages/sqlstringspropertyeditordlg.zh_CN.po svneol=native#text/plain
 components/sqldb/lib/README.txt svneol=native#text/plain
+components/sqldb/pqteventmonitor.pas svneol=native#text/plain
 components/sqldb/registersqldb.lrs svneol=native#text/pascal
 components/sqldb/registersqldb.pas svneol=native#text/pascal
 components/sqldb/sqldblaz.lpk svneol=native#text/pascal
diff --git a/components/sqldb/pqteventmonitor.pas b/components/sqldb/pqteventmonitor.pas
new file mode 100644
index 0000000000..85a2b42a4e
--- /dev/null
+++ b/components/sqldb/pqteventmonitor.pas
@@ -0,0 +1,79 @@
+unit PQTEventMonitor;
+
+{$mode objfpc}{$H+}
+
+interface
+
+uses
+  Classes,PQEventMonitor,ExtCtrls;
+
+
+type
+
+  { TPQTEventMonitor }
+
+  TPQTEventMonitor=class(TPQEventMonitor)
+  private
+    Fpoll: integer;
+    Timer:TTimer;
+    function GetPollInterval: integer;
+    procedure OnTimer(Sender: TObject);
+    procedure SetPollInterval(AValue: integer);
+  public
+    constructor Create(AOwner: TComponent); override;
+    destructor Destroy; override;
+    procedure RegisterEvents; override;
+    procedure UnRegisterEvents; override;
+  published
+    property PollInterval:integer read GetPollInterval write SetPollInterval default 500;
+  end;
+
+implementation
+
+
+{ TPQTEventMonitor }
+
+procedure TPQTEventMonitor.SetPollInterval(AValue: integer);
+begin
+  if Timer.Interval=AValue then Exit;
+  Timer.Interval:=AValue;
+end;
+
+function TPQTEventMonitor.GetPollInterval: integer;
+begin
+  result:=Timer.Interval;
+end;
+
+procedure TPQTEventMonitor.OnTimer(Sender: TObject);
+begin
+  Poll;
+end;
+
+constructor TPQTEventMonitor.Create(AOwner: TComponent);
+begin
+  inherited Create(AOwner);
+  Timer:=TTImer.Create(self);
+  Timer.Interval:=500;
+  Timer.Enabled:=false;
+  Timer.OnTimer:=@OnTimer;
+end;
+
+destructor TPQTEventMonitor.Destroy;
+begin
+  inherited Destroy;
+end;
+
+procedure TPQTEventMonitor.RegisterEvents;
+begin
+  inherited RegisterEvents;
+  Timer.Enabled:=true;
+end;
+
+procedure TPQTEventMonitor.UnRegisterEvents;
+begin
+  Timer.Enabled:=false;
+  inherited UnRegisterEvents;
+end;
+
+end.
+