dddbl.php

Go to the documentation of this file.

<?php

namespace DDDBL;

require_once __DIR__ . '/config.inc.php';

function get() {

  $arrParameter = func_get_args();
  
  if(empty($arrParameter))
    throw new \Exception ("no parameter given for execution");
  
  if(!is_string($arrParameter[0]))
    throw new UnexpectedParameterTypeException('string', $arrParameter[0]);

  # get instance of queue and work with a copy of it
  $objQueue = Singleton::getInstance('\DDDBL\Queue');
  $objQueue = $objQueue->getClone();
  
  return $objQueue->execute($arrParameter);

}

function storeQueryFileContent($strFile) {

  storeDefinitionsFromFileInGroup($strFile, 'Query-Definition');

}

function loadQueryDefinitionsInDir($strDir, $strMatch = '*') {

  walkDirForCallback($strDir, '\DDDBL\storeQueryFileContent', $strMatch);

}

function storeDBFileContent($strFile) {

  $cloAdditionalHandler = function ($objDataObjectPool, $arrDefinition) {
    if(!empty($arrDefinition['DEFAULT'])  && true == (boolean) $arrDefinition['DEFAULT'])
      $objDataObjectPool->add('DEFAULT', $arrDefinition);
  };

  storeDefinitionsFromFileInGroup($strFile, 'Database-Definition', $cloAdditionalHandler);

}

function loadDBDefinitionsInDir($strDir, $strMatch = '*') {

  walkDirForCallback($strDir, '\DDDBL\loadDBDefinitionsInDir', $strMatch);

}

function walkDirForCallback($strPath, $strCallback, $strFilenameMatch) {

  if(!is_string($strPath))
    throw new UnexpectedParameterTypeException('string', $strPath);
  
  if(!is_callable($strCallback))
    throw new UnexpectedParameterTypeException('callable', $strCallback);
    
  if(!is_string($strFilenameMatch))
    throw new UnexpectedParameterTypeException('string', $strFilenameMatch);
  
  if(!is_dir($strPath))
    throw new \Exception ('given path is not an directory: ' . $strPath);
  
  $resDirHandle = opendir($strPath);
  
  if(!is_resource($resDirHandle))
    throw new \Exception ('could not read directory: ' . $strPath);
  
  while($strFile = readdir($resDirHandle))
    if(is_file($strPath.$strFile) && fnmatch($strFilenameMatch, $strFile)) 
      call_user_func_array($strCallback, array($strPath.$strFile));
  
  closedir($resDirHandle);
  
}

function storeDefinitionsFromFileInGroup($strFile, $strGroup, $cloAdditionalHandler = null) {

  if(!is_string($strGroup))
    throw new UnexpectedParameterTypeException('string', $strGroup);
    
  if(!is_null($cloAdditionalHandler) && !is_callable($cloAdditionalHandler))
    throw new UnexpectedParameterTypeException('callable', $cloAdditionalHandler);

  if(!is_file($strFile) || !file_exists($strFile))
    throw new \Exception ("given file is not a file or doesn't exists: $strFile");

  if(!is_readable($strFile))
    throw new \Exception ("given file is not readable: $strFile");

  $arrDefinitions = parse_ini_file($strFile, true);
  
  $objDataObjectPool = new DataObjectPool($strGroup);
  
  foreach($arrDefinitions AS $strDefinitionAlias => $arrDefinition) {
    $objDataObjectPool->add($strDefinitionAlias, $arrDefinition);
    
    if(!is_null($cloAdditionalHandler))
      $cloAdditionalHandler($objDataObjectPool, $arrDefinition);

  }

}