diff --git a/src/feat/agencies/emu/database.py b/src/feat/agencies/emu/database.py
index <HASH>..<HASH> 100644
--- a/src/feat/agencies/emu/database.py
+++ b/src/feat/agencies/emu/database.py
@@ -157,6 +157,9 @@ class Database(common.ConnectionManager, log.LogProxy, ChangeListener,
             d.addCallback(self._perform_reduce, factory)
         return d
 
+    def disconnect(self):
+        pass
+
     ### private
 
     def _matches_filter(self, tup, **filter_options):
diff --git a/src/feat/agencies/net/agency.py b/src/feat/agencies/net/agency.py
index <HASH>..<HASH> 100644
--- a/src/feat/agencies/net/agency.py
+++ b/src/feat/agencies/net/agency.py
@@ -416,6 +416,8 @@ class Agency(agency.Agency):
             d.addCallback(defer.drop_param, self._gateway.cleanup)
         if self._journaler:
             d.addCallback(defer.drop_param, self._journaler.close)
+        if self._database:
+            d.addCallback(defer.drop_param, self._database.disconnect)
         if self._broker:
             d.addCallback(defer.drop_param, self._broker.disconnect)
         return d
Disconnect the DB when terminating the agency