diff --git a/src/index.js b/src/index.js
index 4423999..2b59541 100644
--- a/src/index.js
+++ b/src/index.js
@@ -59,7 +59,12 @@ module.exports = function(conn, options){
       return err;
     }
 
-    await next();
-    db.pool.end();
+		try {
+			await next();
+			db.pool.end();
+		}catch(err){
+			db.pool.end();
+			throw err;
+		}
   }
 }