TABLE_NAME)) $this->TABLE_NAME = strtolower(get_called_class()); $this->connect(); $this->fields['created'] = array('type'=>'date', 'label' => 'Date de création'); $this->fields['updated'] = array('type'=>'date', 'label' => 'Date de modification'); $this->fields['updater'] = array('type'=>'text', 'label' => 'Modificateur'); $this->fields['creator'] = array('type'=>'text', 'label' => 'Créateur'); $this->joins = array(); $this->created = time(); $this->fieldMapping = $this->field_mapping($this->fields); global $myUser; if(is_object($myUser) && $myUser->login!='') $this->creator = $myUser->login; } public function field_mapping($fields = array()){ $fieldMapping = array(); $fieldTypes = FieldType::available(); foreach($fields as $field => $type) { if(!is_array($type)) $type = array('type'=>$type,'column'=>$field); if(!isset($type['column'])) $type['column'] = $field; if(isset($type['link'])) $this->links[$type['column']] = $type['link']; $type['fieldtype'] = $type['type']; //conversion des field type en sql type if(isset($fieldTypes[$type['type']])) $type['type'] = $fieldTypes[$type['type']]->sqlType; $fieldMapping[$field] = $type; } return $fieldMapping; } //Connexion à la base public function connect() { $this->pdo = Database::instance($this->baseUid); global $databases_credentials; $this->connector = $databases_credentials[$this->baseUid]['connector']; } public function __toString() { foreach ($this->toArray() as $key => $value) echo $key.' : '.$value.','.PHP_EOL; } public function __sleep() { return array_keys($this->toArray()); } public function __wakeup() { $this->connect(); } //Comparaison de deux instances d'une même entité, retourne les champs ayant changés uniquement public static function compare($obj1,$obj2,$ignore=array()){ $class = get_called_class(); $compare = array(); foreach ($obj1->fields as $field => $type) { if($field == 'updated' || $field == 'updater' || in_array($field, $ignore)) continue; if($obj1->$field != $obj2->$field){ if($type=='int' && (($obj1->$field==0 && $obj2->$field =='') || ($obj2->$field=='' && $obj1->$field ==0)) ) continue; $compare[] = array('field'=>$field,'value1'=>$obj1->$field,'value2'=>$obj2->$field); } } return $compare; } public static function fields($onlyKeys = true){ $class = get_called_class(); $instance = new $class(); if($onlyKeys) return array_keys($instance->fields); return $instance->fieldMapping; } public function toArray($decoded=false) { $fields = array(); foreach ($this->fields as $field => $type) { $fields[$field] = $decoded ? html_entity_decode($this->$field) : $this->$field; } return $fields; } public function toText() { $text = array(); foreach ($this->fields as $field => $type) { $value = is_object($this->$field) ? '[object]' : $this->$field; $text[]= $field.' = '.$value; } return implode(', ',$text); } public function fromArray($array) { foreach ($array as $field => $value) { $this->$field = $value; } } public function closeDatabase() { // $this->close(); } //Libellé human readable de l'entité public static function entityLabel() { $class = get_called_class(); $instance = new $class(); return !empty($instance->entityLabel) ? $instance->entityLabel : $class; } public static function tableName($escapeName = false,$instance = null) { global $databases_credentials; $class = get_called_class(); if(!isset($instance)) $instance = new $class(); $prefix = isset($databases_credentials[$instance->baseUid]['prefix']) ? $databases_credentials[$instance->baseUid]['prefix'] : ''; $connector = $instance->connector; return $escapeName ? $connector::table_escape.$prefix.$instance->TABLE_NAME.$connector::table_escape : $prefix.$instance->TABLE_NAME; } // GESTION SQL /** * Verifie l'existence de la table en base de donnée. * @category manipulation SQL * @param créé la table si elle n'existe pas * @return true si la table existe, false dans le cas contraire */ public static function checkTable($autocreate = false) { $class = get_called_class(); $instance = new $class(); $query = 'SELECT count(*) as numRows FROM sqlite_master WHERE type="table" AND name=?'; $statement = $instance->customQuery($query, array($class::tableName(false,$instance))); if ($statement != false) { $statement = $statement->fetchArray(); if ($statement['numRows'] == 1) $return = true; } if ($autocreate && !$return) self::create(); return $return; } public static function install($classDirectory) { foreach (glob($classDirectory.SLASH.'*.class.php') as $file) { $infos = explode('.', basename($file)); $class = array_shift($infos); require_once($classDirectory.SLASH.$class.'.class.php'); $reflection = new ReflectionClass($class); if (!class_exists($class) || !method_exists($class, 'create') || $class == get_class() || $reflection->isAbstract()) continue; $class::create(); } } public static function uninstall($classDirectory) { foreach (glob($classDirectory.SLASH.'*.class.php') as $file) { $infos = explode('.', basename($file)); $class = array_shift($infos); require_once($classDirectory.SLASH.$class.'.class.php'); $reflection = new ReflectionClass($class); if (!class_exists($class) || !method_exists($class, 'drop') || $class == get_class() || $reflection->isAbstract()) continue; $class::drop(); } } /** * Methode de vidage de l'entité. * @category manipulation SQL * @return Aucun retour */ public static function truncate() { $class = get_called_class(); $instance = new $class(); $connector = $instance->connector; $sql = $connector::truncate(); $query = Entity::render($sql,array( 'table' => $class::tableName(false,$instance), 'fieldMapping' => $instance->fieldMapping )); $instance->customQuery($query); } /** * Methode de creation de l'entité. * @category manipulation SQL * @return Aucun retour */ public static function create() { $class = get_called_class(); $instance = new $class(); $fields = array(); $connector = $instance->connector; $types = $connector::types(); $fieldMapping = $instance->field_mapping($instance->fields); foreach ($instance->fields(false) as $slug => $field) $fields[$slug] = isset($types[$field['type']]) ? $types[$field['type']] : $types['default']; $sql = $connector::create(); $query = Entity::render($sql,array( 'table' => $class::tableName(false,$instance), 'fields' => $fields, 'fieldMapping' => $instance->fieldMapping )); $instance->customQuery($query); if(isset($instance->indexes)) $instance->index($instance->indexes); } public static function drop() { $class = get_called_class(); $instance = new $class(); $connector = $instance->connector; $sql = $connector::drop(); $query = Entity::render($sql,array( 'table' => $class::tableName(false,$instance), 'fieldMapping' => $instance->fieldMapping )); $instance->customQuery($query); if(isset($instance->indexes)) $instance->index($instance->indexes,false); } /** * Methode d'insertion ou de modifications d'elements de l'entité. * @category manipulation SQL * @param Aucun * @return Aucun retour */ public function save() { global $myUser; $this->updated = time(); if(is_object($myUser) && $myUser->login!='') $this->updater = $myUser->login; //update if (isset($this->id) && $this->id > 0) { $fields = array(); foreach ($this->fields as $field => $type) $fields[$field] = $this->{$field}; self::change($fields,array('id'=>$this->id)); //insert } else { $connector = $this->connector; $data = array(); $fields = array(); $i = 0; foreach ($this->fields as $field => $type) { if((is_array($type) && $type['type'] == 'key') || $type == 'key') continue; $data[':'.$i] = $this->{$field}; if((is_array($type) && $type['type'] == 'boolean') || $type == 'boolean') $data[':'.$i] = $data[':'.$i] ? 1 : 0; $fields[$field] = ':'.$i; $i++; } $sql = $connector::insert(); $query = self::render($sql,array( 'table' => $this->tableName(false,$this), 'fields' => $fields, 'fieldMapping' => $this->fieldMapping )); $this->customQuery($query, $data); } $this->id = !isset($this->id) || !is_numeric($this->id) ? $this->pdo->lastInsertId() : $this->id; } /** * Methode d'insertion massive de l'entité. * @category manipulation SQL * @param $entities tableau des entité a inserer (update non géré) * @param $maxLines grouper par requete de $maxLines maximum * @return Aucun retour */ public static function saveAll($entities,$maxLines = 300) { global $myUser; if(empty($entities)) return; $reference = $entities[0]; $connector = $reference->connector; $sql_head = $connector::insert_head(); $sql_body = $connector::insert_body(); $time = time(); $login = is_object($myUser) && $myUser->login!='' ? $myUser->login : ''; //sépare en requetes groupées de $maxLines lignes max $entities_groups = array_chunk($entities, $maxLines); $tableName = $reference->tableName(false,$reference); foreach ($entities_groups as $entities_group) { $end = count($entities_group)-1; $data = array(); foreach($entities_group as $u=>$entity){ $entity->updated = $time; $entity->updater = $login; $fields = array(); $i = 0; foreach ($entity->fields as $field => $type) { if ($type == 'key') continue; $data[':'.$u.'a'.$i] = $type!='boolean' ? $entity->{$field} : ($entity->{$field} ? 1:0); $fields[$field] = ':'.$u.'a'.$i; $i++; } if($u==0){ $query = self::render($sql_head,array( 'table' => $tableName, 'fields' => $fields, 'fieldMapping' => $reference->fieldMapping )); } $query .= self::render($sql_body,array( 'table' => $entity->tableName(false,$entity), 'fields' => $fields, 'fieldMapping' => $entity->fieldMapping )); if($u!=$end) $query .= ','; } $reference->customQuery($query, $data); } } /** * Méthode de modification d'éléments de l'entité. * @category manipulation SQL * @param $colonnes=>$valeurs * @param $colonnes (WHERE) =>$valeurs (WHERE) * @return Aucun retour */ public static function change($columns, $columns2 = array()) { $class = get_called_class(); $instance = new $class(); $connector = $instance->connector; $fields = array(); $i = 0; $values = array(); foreach ($columns as $field => $value) { $values[':'.$i] = $value; $fields[$field] = ':'.$i; $i++; } $filters = array(); foreach($columns2 as $key=>$value){ $filter = array( 'operator' => '=', 'field' => $key, 'postoperator' => '' ); if(strpos($key,':')!==false){ $infos = explode(':',$key); $filter['operator'] = $infos[1]; $filter['field'] = $infos[0]; } $fieldInfos = $instance->fieldMapping[$filter['field']]; $filter['type'] = $fieldInfos['type']; $filter['column'] = $fieldInfos['column']; $connector::processField($filter,$value,$values,$i); $filters[] = $filter; } $data = array( 'table' => $class::tableName(false,$instance), 'fields' => $fields, 'filter' => !isset($filters) || count($filters) == 0 ? null: $filters, 'fieldMapping' => $instance->fieldMapping ); $sql = $connector::update(); $sql = Entity::render($sql,$data); $instance->customQuery($sql, $values); } /** * Méthode de selection de tous les elements de l'entité. * @category manipulation SQL * @param $ordre=null * @param $limite=null * @return > $Entity */ public static function populate($order = null, $limit = null,$selColumn = array('*'),$joins = 0) { $results = self::loadAll(array(), $order, $limit,$selColumn,$joins); return $results; } /** * Méthode de selection multiple d'elements de l'entité. * @category manipulation SQL * @param $colonnes (WHERE) * @param $valeurs (WHERE) * @param $ordre=null * @param $limite=null * @param $operation="=" definis le type d'operateur pour la requete select * @return > $Entity */ public static function loadAll($columns = array(), $order = null, $limit = null, $selColumn = array('*'), $joins = 0) { $class = get_called_class(); $instance = new $class(); $connector = $instance->connector; $values = array(); $i=0; $filters = array(); foreach($columns as $key=>$value){ $filter = array( 'operator' => '=', 'field' => $key, 'postoperator' => '' ); if(strpos($key,':')!==false){ $infos = explode(':',$key); $filter['operator'] = $infos[1]; $filter['field'] = $infos[0]; } $fieldInfos = $instance->fieldMapping[$filter['field']]; $filter['type'] = $fieldInfos['type']; $filter['column'] = $fieldInfos['column']; $connector::processField($filter,$value,$values,$i); $filters[] = $filter; } if(!empty($order)){ foreach ($order as $key=>$clause) { foreach ($instance->fieldMapping as $attribute => $infos) { $order[$key] = str_replace( $attribute,$infos['column'],$order[$key]); } } } $tableName = $class::tableName(false,$instance); $data = array( 'table' => $tableName, 'selected' => $selColumn, 'limit' => !isset($limit) || count($limit) == 0 ? null: $limit, 'orderby' => !isset($order) || count($order) == 0 ? null: $order, 'filter' => !isset($filters) || count($filters) == 0 ? null: $filters, 'fieldMapping' => $instance->fieldMapping ); $data['joins'] = array(); if($joins!=0){ foreach ($data['selected'] as $k=>$column) $data['selected'][$k] = $tableName.'.'.$column; $data = self::recursiveJoining($instance,$data,$joins); } $sql = $connector::select(); $sql = Entity::render($sql,$data); return $instance->customQuery($sql, $values, true, $joins); } /** * Méthode privée de gestion du join récursif sur les objets liés * @category manipulation SQL * @param $instance $instance de départ * @param $data Tableau de construction de la requete via render() * @param $iterations Nombre d'iteration réecurive maximum * @return $data */ private static function recursiveJoining($instance,$data,$iterations,$joinInstanceAlias=''){ if($iterations==0) return $data; $iterations--; if(isset($instance->links)){ $instanceTable = $instance::tableName(); foreach ($instance->links as $field => $className) { $className = str_replace('.class.php','',basename($className)); $linkTable = $className::tableName(); $field2 = 'id'; $classField = explode('.',$className); if(isset($classField[1])) list($className,$field2) = $classField; $alias = substr($linkTable,0,3).'_'.$field; $joinInstance = new $className(); foreach ($joinInstance->fields as $key=>$type) $data['selected'][] = $alias.'.'.$key.' as '.$linkTable.'_join_'.$key; $joinTable1 = $instanceTable; if(!empty($joinInstanceAlias)) $joinTable1 = $joinInstanceAlias; $data['joins'][] = array( 'jointable1' => $joinTable1, 'jointable2' => $linkTable, 'jointableAlias' => $alias, 'field1' => $field, 'field2' => $field2 ); $data = self::recursiveJoining($joinInstance,$data,$iterations,$alias); } } return $data; } /** * Methode de comptage des éléments de l'entité. * @category manipulation SQL * @return nombre de ligne dans l'entité' */ public static function rowCount($columns = array()) { $values = array(); $class = get_called_class(); $instance = new $class(); $connector = $instance->connector; $i=0; $values = array(); $filters = array(); foreach($columns as $key=>$value){ $filter = array( 'operator' => '=', 'field' => $key, 'postoperator' => '' ); if(strpos($key,':')!==false){ $infos = explode(':',$key); $filter['operator'] = $infos[1]; $filter['field'] = $infos[0]; } $fieldInfos = $instance->fieldMapping[$filter['field']]; $filter['type'] = $fieldInfos['type']; $filter['column'] = $fieldInfos['column']; $connector::processField($filter,$value,$values,$i); $filters[] = $filter; } $data = array( 'table' => $class::tableName(false,$instance), 'selected' => 'id' , 'filter' => count($filters) == 0 ? null: $filters, 'fieldMapping' => $instance->fieldMapping ); $sql = $connector::count(); $execQuery = $instance->customQuery(Entity::render($sql,$data), $values); $row = $execQuery->fetch(); return $row['number']; } public static function loadAllOnlyColumn($selColumn, $columns, $order = null, $limit = null) { $objects = self::loadAll($columns, $order, $limit, $selColumn); if (count($objects) == 0) $objects = array(); return $objects; } /** * Méthode de selection unique d'élements de l'entité. * * @category manipulation SQL * * @param $colonnes (WHERE) * @param $valeurs (WHERE) * @param $operation="=" definis le type d'operateur pour la requete select * * @return $Entity ou false si aucun objet n'est trouvé en base */ public static function load($columns = array(),$joins =0) { $objects = self::loadAll($columns, null, array('1'),array('*'),$joins); if (!isset($objects[0])) $objects[0] = false; return $objects[0]; } /** * Méthode de selection unique d'élements de l'entité. * @param $colonnes (WHERE) * @param $valeurs (WHERE) * @param $operation="=" definis le type d'operateur pour la requete select * @return $Entity ou false si aucun objet n'est trouvé en base */ public static function getById($id,$joins =0 ) { return self::load(array('id' => $id),$joins); } //parsing des templates sql de cnnecteurs avec les filtres/columns/data... public static function render($sql,$data=array()) { //loop $sql = preg_replace_callback('/{{\:([^\/\:\?}]*)}}(.*?){{\/\:[^\/\:\?}]*}}/',function($matches) use ($data) { $tag = $matches[1]; $sqlTpl = $matches[2]; $sql = ''; if(isset($data[$tag])){ $i = 0; $values = $data[$tag]; if($tag =='joins'){ //joins foreach($values as $join){ $occurence = $sqlTpl; foreach($join as $key=>$value){ $occurence = str_replace(array('{{'.$key.'}}'),array($value),$occurence); } $sql.= $occurence; } }else if($tag =='filter'){ //filters foreach($values as $key=>$value){ $i++; $last = $i == count($values); $operator = $value['operator']; $postoperator = $value['postoperator']; $key = $value['column']; $occurence = str_replace(array('{{key}}','{{value}}','{{operator}}','{{postoperator}}'),array($key, $value['tag'], $operator, $postoperator), $sqlTpl); $occurence = preg_replace_callback('/{{\;}}(.*?){{\/\;}}/',function($matches) use ($last){ return $last? '': $matches[1]; },$occurence); $sql.= $occurence; } } else { //Autre boucles foreach($values as $key=>$value){ $i++; $last = $i == count($values); $operator = isset($data['operator']) ? $data['operator'][0] : '='; $postoperator = isset($data['postoperator']) ? $data['postoperator'][0] : ''; if(strpos($key,':')!==false){ $infos = explode(':',$key); $key = $infos[0]; $operator = $infos[1]; if($operator=='IN' || $operator=='NOT IN'){ $operator = $operator.'('; $postoperator = ')'; } } $occurence = str_replace(array('{{key}}','{{value}}','{{operator}}','{{postoperator}}'),array($key,$value,$operator,$postoperator),$sqlTpl); $occurence = preg_replace_callback('/{{\;}}(.*?){{\/\;}}/',function($matches) use ($last){ return $last? '': $matches[1]; },$occurence); $sql.= $occurence; } } return $sql; } return ''; },$sql); //conditions $sql = preg_replace_callback('/{{\?([^\/\:\?}]*)}}(.*?){{\/\?[^\/\:\?}]*}}/',function($matches) use ($data) { $key = $matches[1]; $sql = $matches[2]; return !isset($data[$key]) || (is_array($data[$key]) && count($data[$key])==0) ?'':$sql; },$sql); //simple vars $sql = preg_replace_callback('/{{([^\/\:\;\?}]*)}}/',function($matches) use ($data) { $key = $matches[1]; return isset($data[$key])?$data[$key]:''; },$sql); return $sql; } /** * Methode de définition de l'éxistence d'un moins un des éléments spécifiés en base. * * @category manipulation SQL * @return existe (true) ou non (false) */ public static function exist($columns = array()) { $result = self::rowCount($columns); return $result != 0; } public static function deleteById($id) { self::delete(array('id' => $id)); } /** * Méthode de Suppression d'elements de l'entité. * @category manipulation SQL * @param $colonnes (WHERE) * @param $valeurs (WHERE) * @param $operation="=" definis le type d'operateur pour la requete select * @return Aucun retour */ public static function delete($columns, $limit = array()) { $values = array(); $class = get_called_class(); $instance = new $class(); $connector = $instance->connector; $i=0; $values = array(); $filters = array(); foreach($columns as $key=>$value){ $filter = array( 'operator' => '=', 'field' => $key, 'postoperator' => '' ); if(strpos($key,':')!==false){ $infos = explode(':',$key); $filter['operator'] = $infos[1]; $filter['field'] = $infos[0]; } $fieldInfos = $instance->fieldMapping[$filter['field']]; $filter['type'] = $fieldInfos['type']; $filter['column'] = $fieldInfos['column']; $connector::processField($filter,$value,$values,$i); $filters[] = $filter; } $data = array( 'table' => $class::tableName(false,$instance), 'limit' => count($limit) == 0 ? null: $limit, 'filter' => count($filters) == 0 ? null: $filters, 'fieldMapping' => $instance->fieldMapping ); $sql = $connector::delete(); return $instance->customQuery(Entity::render($sql,$data), $values); } /** * Méthode d'indexation de la ou les colonnes ciblées * nb : il est possible d'appeller automatiquement cette méthode sur les classes entity lors du create * si la classe contient l'attribut $this->indexes = array(...); * @category manipulation SQL * @param | $colonne(s) * @param Mode (true : ajout, false : suppression) * @return Aucun retour */ public static function index($columns,$mode = true){ if(!is_array($columns)) $columns = array($columns); $columns = array_filter($columns); $class = get_called_class(); $instance = new $class(); $connector = $instance->connector; $tableName = $class::tableName(false,$instance); foreach($columns as $column){ if(!is_array($column)) $column = array($column); $data = array( 'table' => $tableName, 'column' => '`'.implode('`,`',$column).'`', 'index_name' => $tableName.'_'.implode('_',$column), 'fieldMapping' => $instance->fieldMapping ); $results = $class::staticQuery(Entity::render($connector::count_index(),$data)); $exists = $results->fetch(); if($mode){ if($exists['exists'] != 1) $class::staticQuery(Entity::render($connector::create_index(),$data)); }else{ if($exists['exists'] > 0) $class::staticQuery(Entity::render($connector::drop_index(),$data)); } } } //Génération d'une pagination public static function paginate($itemPerPage,$currentPage,&$query,$data,$alias=''){ $class = get_called_class(); $instance = new $class(); $keys = array_keys($instance->fields, 'key'); $key = count($keys) == 1 ? $keys[0] : 'id'; $tableName = $class::tableName(false,$instance); $queryNumber = $query; $queryNumber = preg_replace("/(?fetch(); $number = $queryNumber[0]; $pageNumber = $number / $itemPerPage; if($currentPage >= $pageNumber) $currentPage = 0; $limit = ' LIMIT '.($currentPage*$itemPerPage).','.$itemPerPage; $query .= $limit; return array( 'pages' => $pageNumber, 'current' => $currentPage, 'total' => $number ); } public static function provide($parameter = 'id',$join=0){ global $_; $class = get_called_class(); return !empty($_[$parameter]) ? $class::getById($_[$parameter],$join) : new $class(); } // L'alias utilisé pour la colonne du join doit avoir la syntaxe [table]_join_[field] // Ex : address_join_street public static function staticQuery($query, $data = array(), $fill = false,$joins = 0) { $class = get_called_class(); $instance = new $class(); return $instance->customQuery($query, $data, $fill,$joins); } public function customQuery($query, $data = array(), $fill = false,$joins = 0) { $query = str_replace('{{table}}', $this->tableName(true,$this), $query); $mapping = $this->fieldMapping; $query = preg_replace_callback('/{{([^}]*)}}/si', function($match) use ($mapping){ return isset($mapping[$match[1]]) && isset($mapping[$match[1]]['column']) ? $mapping[$match[1]]['column'] : $match[0]; }, $query); try{ if(BASE_DEBUG) self::logFile($query.' :: '.json_encode($data, JSON_UNESCAPED_UNICODE),debug_backtrace()); $results = $this->pdo->prepare($query); $results->execute($data); if (!$results) throw new Exception(json_encode($this->pdo->errorInfo())); }catch(Exception $e){ Log::put("[SQL ERROR] - Erreur : ".$e->getMessage().' - Requete : '.$query.' - Données : '.json_encode($data, JSON_UNESCAPED_UNICODE)); if(BASE_DEBUG) self::logFile( "Erreur : ".$e->getMessage()); throw $e; } if (!$fill) return $results; $class = get_class($this); $objects = array(); $results = $results->fetchAll(PDO::FETCH_ASSOC); foreach ($results as $queryReturn) { $object = new $class(); foreach ($this->fields as $field => $type) { $dbField = $field; if(is_array($type)){ if(isset($type['column'])) $dbField = $type['column']; $type = $type['type']; } if (isset($queryReturn[$dbField])) { $object->{$field} = $queryReturn[$dbField]; unset($queryReturn[$dbField]); } } if($joins>0) $object = self::recursiveJoiningFill($object,$queryReturn,$joins); foreach ($queryReturn as $key => $value) { if(!is_numeric($key)) $object->foreignColumns[$key] = $value; } $objects[] = $object; unset($object); } return $objects == null ? array() : $objects; } //Récuperation d'une/plusieurs colonne non référencée dans l'objet mais récuperée dans une requete static query public function foreign($key=null){ if(!isset($key)) return $this->foreignColumns; return isset($this->foreignColumns[$key]) ? $this->foreignColumns[$key] : ''; } //Renvois une chaine de selecteur sql devant être join //ex : Client::joinString('cli') --> cli.id client_join_id,cli.label client_join_label ... public static function joinString($prefix = ''){ $class = get_called_class(); $instance = new $class(); $tableName = $class::tableName(false,$instance); $columns = array(); foreach($instance->fields() as $field) $columns[] = $prefix.'.'.$field.' '.$tableName.'_join_'.$field.' '; return implode(', ',$columns); } private static function recursiveJoiningFill($object,$queryReturn,$iterations){ if($iterations == 0) return $object; $iterations--; if(isset($object->links)){ foreach ($object->links as $link=>$classLink) { $classLink = str_replace('.class.php','',basename($classLink)); $classField = explode('.',$classLink); if(isset($classField[1])) $classLink = $classField[0]; $instanceLink = new $classLink(); $tableName = $classLink::tableName(false,$instanceLink); foreach ($instanceLink->fields as $field => $type) if(isset($queryReturn[$tableName.'_join_'.$field])) $instanceLink->{$field} = $queryReturn[$tableName.'_join_'.$field]; $instanceLink = self::recursiveJoiningFill($instanceLink,$queryReturn,$iterations); $object->joins[$link] = $instanceLink; } } return $object; } /** * Récupere l'objet join ex : $contact->join("adress")->street; --> récupere l'attribut street de la class Adress dont l'id est spécifié dans la colonne adress de la class Contact * Nb : cette méthode ne fonctionne que si vous avez placé le parametre joins > 0 dans la méthode LoadALl * Nb : cette méthode ne fonctionne que si vous avez précisé le lien entre Contact et Adress dans la classe Contact via : protected $links = array( 'address' => 'Address' ); * * @category manipulation SQL * * @param $colonnes (WHERE) * @param $valeurs (WHERE) * @param $operation="=" definis le type d'operateur pour la requete select * * @return Aucun retour */ public function join($field){ return isset($this->joins[$field])?$this->joins[$field]:''; } public static function logFile($msg,$backtrace=null){ if(strpos(ROOT_URL, '127.0.0.1') === false && strpos(ROOT_URL, 'dev.local') === false && strpos(ROOT_URL, 'localhost') === false ) return; file_put_contents(__DIR__.SLASH.'..'.SLASH.'sql.debug.sql', date('H:i:s').' | '.$msg.PHP_EOL,FILE_APPEND); //A décommenter pour obtenir la stacktrace d'un appel sql dans le fichier sql.debug.sql //if(isset($backtrace)) file_put_contents(__DIR__.SLASH.'..'.SLASH.'sql.debug.sql', json_encode($backtrace,JSON_PRETTY_PRINT).PHP_EOL,FILE_APPEND); } public static function log_executed_query($string, $data) { $indexed = $data==array_values($data); foreach($data as $k=>$v) { if(is_string($v)) $v="'$v'"; if($indexed) $string=preg_replace('/\?/',$v,$string,1); else $string=str_replace(":$k",$v,$string); } self::logFile($string); } }