diff --git a/application/tables/ImportsourceHookTable.php b/application/tables/ImportsourceHookTable.php
index 4f3c4065..557e7dbd 100644
--- a/application/tables/ImportsourceHookTable.php
+++ b/application/tables/ImportsourceHookTable.php
@@ -90,6 +90,7 @@ class ImportsourceHookTable extends QuickTable
             }
             $obj = new $mod->provider_class;
             $obj->setSettings($mod->getSettings());
+            $obj->setDb($this->source->getConnection());
             $propertyModifiers[$mod->property_name][] = $obj;
             
         }
diff --git a/library/Director/Hook/PropertyModifierHook.php b/library/Director/Hook/PropertyModifierHook.php
index d8cc4b96..4fc41965 100644
--- a/library/Director/Hook/PropertyModifierHook.php
+++ b/library/Director/Hook/PropertyModifierHook.php
@@ -9,6 +9,8 @@ abstract class PropertyModifierHook
 {
     protected $settings = array();
 
+    private $db;
+
     public function getName()
     {
         $parts = explode('\\', get_class($this));
@@ -24,9 +26,9 @@ abstract class PropertyModifierHook
         return $class;
     }
 
-    public static function loadById($property_id, Db $db)
+    public static function loadById($property_id, Db $connection)
     {
-        $db = $db->getDbAdapter();
+        $db = $connection->getDbAdapter();
         $modifier = $db->fetchRow(
             $db->select()->from(
                 'import_row_modifier',
@@ -43,10 +45,22 @@ abstract class PropertyModifierHook
 
         $obj = new $modifier->provider_class;
         $obj->setSettings($settings);
+        $obj->setDb($db);
 
         return $obj;
     }
 
+    public function setDb(Db $db)
+    {
+        $this->db = $db;
+        return $this;
+    }
+
+    public function getDb()
+    {
+        return $this->db;
+    }
+
     public function setSettings($settings)
     {
         $this->settings = $settings;
diff --git a/library/Director/Import/Import.php b/library/Director/Import/Import.php
index fdbf7800..eff138f5 100644
--- a/library/Director/Import/Import.php
+++ b/library/Director/Import/Import.php
@@ -232,6 +232,7 @@ class Import
             }
             $obj = new $mod->provider_class;
             $obj->setSettings($mod->getSettings());
+            $obj->setDb($this->connection);
             $propertyModifiers[$mod->property_name][] = $obj;
         }