--- /dev/null
+<?php
+
+class IPF_ORM_Middleware extends IPF_Middleware
+{
+ function processRequest($request)
+ {
+ $pdo = $this->container['db']->getWrappedConnection();
+ IPF_ORM_Manager::getInstance()->setConnection($pdo);
+ return false;
+ }
+}
return IPF_ORM_Manager::getInstance()->getCurrentConnection();
}
+ public function setConnection(PDO $pdo)
+ {
+ $this->_connection = new IPF_ORM_Connection_Mysql($this, $pdo);
+ }
+
public function getCurrentConnection()
{
- if (!$this->_connection) {
- $pdo = \PFF\Container::databaseConnection();
- $this->_connection = new IPF_ORM_Connection_Mysql($this, $pdo);
- }
return $this->_connection;
}