diff --git a/src/warden-server/lib/WardenCommon.pm b/src/warden-server/lib/WardenCommon.pm
index 6aff81ee5f30ae3a16a612953303d83a55ddde8c..cd56daf937a13f31e3222429c137989c00fa95ff 100755
--- a/src/warden-server/lib/WardenCommon.pm
+++ b/src/warden-server/lib/WardenCommon.pm
@@ -106,4 +106,18 @@ sub loadConf
 } # End of loadConf
 
 
+#-------------------------------------------------------------------------------
+# connectDB - connect to database and create DB handler
+#-------------------------------------------------------------------------------
+sub connectDB
+{
+  my $db_name	= shift;
+  my $db_host	= shift;
+  my $db_user	= shift;
+  my $db_pass	= shift;
+
+  my $dbh = DBI->connect("DBI:mysql:database=$db_name;host=$db_host",$db_user, $db_pass, {RaiseError => 1, mysql_auto_reconnect => 1}) || die "Could not connect to database '$db_name': $DBI::errstr";
+  return $dbh;
+} # End of connectDB
+
 1;