_res/_libs/models/foo/footdoa.class.php

   1 <?php
   2 /**
   3  * the query compiler/executer object
   4  * @package ts_models
   5  * @author Marius Orcsik <marius@habarnam.ro>
   6  * @version 0.0.1
   7  */
   8 abstract class fooTdoA {
   9         /**
  10          * @var fooSqlDriverA
  11          */
  12         private $oConnection;
  13
  14         /**
  15          * @param fooSqlDriverA $oConnection
  16          * @return void
  17          */
  18         public function setConnection (fooSqlDriverA $oConnection) {
  19                 $this->oConnection = $oConnection;
  20         }
  21
  22         /**
  23          * @return fooSqlDriverA
  24          */
  25         public function getConnection () {
  26                 if (!self::isValidConnection($this->oConnection))
  27                         throw new fooInvalidTypeException ('Could not establish a valid DB connection - current resource type [' . get_class ($this->oConnection) . ']');
  28                 return $this->oConnection;
  29         }
  30
  31         /**
  32          * Outputs the SQL necessary for creating the table
  33          * @return string
  34          */
  35         public function outputCreateSQL (fooEntityA $oInc) {
  36                 $sRet = $this->getConnection()->_CREATE ($oInc->getName()) . "\n";
  37                 $sRet .= ' ( ' . "\n";
  38
  39                 /* @var $oColumn fooFieldA */
  40                 foreach ($oInc->getMembers () as $oColumn) {
  41                         $sRet .= "\t" . $oColumn->getName() . ' ' . $oColumn->getDefinition() ;
  42                         $sRet .= ', ' . "\n";
  43                 }
  44
  45                 $aIndexes = $oInc->getIndexes(true);
  46                 if (is_array ($aIndexes)) {
  47                         foreach ($aIndexes as $oIndex) {
  48                                 // this needs to be replaced with connection functionality : something like getConstraint (type, columns)
  49                                 $sRet .=  "\t" . $oIndex->getDefinition() . ", \n"; //getType() . ' KEY ' . $oIndex->getName() . '  (' . $oIndex->getIndexComponents(). '), ' . "\n";
  50                         }
  51                 }
  52
  53                 $sRet = substr( $sRet, 0, -3);
  54
  55                 $sRet.= "\n" . ' ) ';
  56
  57                 if ($this->oConnection->getType() == 'mysql') {
  58                         $sRet.= ' ENGINE ' . $this->getConnection()->getEngine();
  59                 }
  60
  61                 return $sRet;
  62         }
  63
  64         static public function isValidConnection ($oConnection) {
  65                 return sqlFactory::validType ($oConnection->getType());
  66         }
  67 }