<?php /** * Zend Framework (http://framework.zend.com/) * * @link http://github.com/zendframework/zf2 for the canonical source repository * @copyright Copyright (c) 2005-2016 Zend Technologies USA Inc. (http://www.zend.com) * @license http://framework.zend.com/license/new-bsd New BSD License */ namespace Zend\Db\Adapter; use Interop\Container\ContainerInterface; use Zend\ServiceManager\AbstractFactoryInterface; use Zend\ServiceManager\ServiceLocatorInterface; /** * Database adapter abstract service factory. * * Allows configuring several database instances (such as writer and reader). */ class AdapterAbstractServiceFactory implements AbstractFactoryInterface { /** * @var array */ protected $config; /** * Can we create an adapter by the requested name? * * @param ContainerInterface $container * @param string $requestedName * @return bool */ public function canCreate(ContainerInterface $container, $requestedName) { $config = $this->getConfig($container); if (empty($config)) { return false; } return ( isset($config[$requestedName]) && is_array($config[$requestedName]) && ! empty($config[$requestedName]) ); } /** * Determine if we can create a service with name (SM v2 compatibility) * * @param ServiceLocatorInterface $serviceLocator * @param string $name * @param string $requestedName * @return bool */ public function canCreateServiceWithName(ServiceLocatorInterface $serviceLocator, $name, $requestedName) { return $this->canCreate($serviceLocator, $requestedName); } /** * Create a DB adapter * * @param ContainerInterface $container * @param string $requestedName * @param array $options * @return Adapter */ public function __invoke(ContainerInterface $container, $requestedName, array $options = null) { $config = $this->getConfig($container); return new Adapter($config[$requestedName]); } /** * Create service with name * * @param ServiceLocatorInterface $serviceLocator * @param string $name * @param string $requestedName * @return Adapter */ public function createServiceWithName(ServiceLocatorInterface $serviceLocator, $name, $requestedName) { return $this($serviceLocator, $requestedName); } /** * Get db configuration, if any * * @param ContainerInterface $container * @return array */ protected function getConfig(ContainerInterface $container) { if ($this->config !== null) { return $this->config; } if (! $container->has('config')) { $this->config = []; return $this->config; } $config = $container->get('config'); if (! isset($config['db']) || ! is_array($config['db']) ) { $this->config = []; return $this->config; } $config = $config['db']; if (! isset($config['adapters']) || ! is_array($config['adapters']) ) { $this->config = []; return $this->config; } $this->config = $config['adapters']; return $this->config; } }