diff --git a/src/ORM/Entity.php b/src/ORM/Entity.php index cf3b7f8..2de3bbf 100755 --- a/src/ORM/Entity.php +++ b/src/ORM/Entity.php @@ -4,17 +4,17 @@ namespace ORM; abstract class Entity { - const tableName = ''; - const connectionName = 'default'; - const softdelete = false; + const _tableName = ''; + const _connectionName = 'default'; + const _softdelete = false; const _ignore = Array( 'classname', '_properties', '_ignore', - 'connectionName', - 'timestamps', - 'softdelete', - 'tableName', + '_connectionName', + '_timestamps', + '_softdelete', + '_tableName', '_idPolice' ); const _properties = Array(); @@ -28,7 +28,7 @@ abstract class Entity { const _idPolice = Array(); function __construct() { - if (isset($this->timestamps) && $this->timestamps) { + if (isset($this->_timestamps) && $this->_timestamps) { $this->created_at = date('Y-m-d h:m:s'); $this->updated_at = date('Y-m-d h:m:s'); } @@ -71,7 +71,7 @@ abstract class Entity { private function update() { //First check if the record exist. If not, we might have a idPolice - if (!DBInstance::queryOne("SELECT id FROM {" . static::tableName . "} WHERE id = ?", Array($this->id))) { + if (!DBInstance::queryOne("SELECT id FROM {" . static::_tableName . "} WHERE id = ?", Array($this->id))) { $this->create(); return; } @@ -92,8 +92,8 @@ abstract class Entity { $update_string = rtrim($update_string, ', '); - $sql = "UPDATE {" . static::tableName . "} SET $update_string WHERE id = :_update_id"; - DBInstance::execute($sql, $update_data, static::connectionName); + $sql = "UPDATE {" . static::_tableName . "} SET $update_string WHERE id = :_update_id"; + DBInstance::execute($sql, $update_data, static::_connectionName); } private function create() { @@ -101,7 +101,7 @@ abstract class Entity { //Manual and empty don't need special treatments if (!empty(static::_idPolice) && static::_idPolice['type'] != 'manual') { //Get the actual max value of the key - $maxVal = DBInstance::queryOne("SELECT max(id) as id FROM {" . static::tableName . "}"); + $maxVal = DBInstance::queryOne("SELECT max(id) as id FROM {" . static::_tableName . "}"); $maxVal = ($maxVal) ? $maxVal : 0; // If the next val is smaller than the minumum value @@ -141,9 +141,9 @@ abstract class Entity { $first_argument = rtrim($first_argument, ', '); $second_argument = rtrim($second_argument, ', '); - $sql = "INSERT INTO {" . static::tableName . "} ($first_argument) VALUES ($second_argument)"; + $sql = "INSERT INTO {" . static::_tableName . "} ($first_argument) VALUES ($second_argument)"; - DBInstance::execute($sql, $insert_data, static::connectionName); + DBInstance::execute($sql, $insert_data, static::_connectionName); // If there is a id pollice applied, do not get the inserted id if ( empty(static::_idPolice) ){ $this->id = DBInstance::lastInsert(); @@ -151,7 +151,7 @@ abstract class Entity { } public function delete() { - if (isset($this->softdelete) && $this->softdelete) { + if (isset($this->_softdelete) && $this->_softdelete) { $this->deleted_at = date('Y-m-d h:m:s'); $this->update(); return; @@ -164,14 +164,14 @@ abstract class Entity { return; } - $sql = "SELECT * FROM {" . static::tableName . "} WHERE id = ?"; + $sql = "SELECT * FROM {" . static::_tableName . "} WHERE id = ?"; - $this->fill(DBInstance::queryPrepare($sql, Array($id), static::connectionName)[0]); + $this->fill(DBInstance::queryPrepare($sql, Array($id), static::_connectionName)[0]); } public function purge() { - $sql = "DELETE FROM {" . static::tableName . "} WHERE id = :id"; - DBInstance::execute($sql, Array('id' => $this->id), static::connectionName); + $sql = "DELETE FROM {" . static::_tableName . "} WHERE id = :id"; + DBInstance::execute($sql, Array('id' => $this->id), static::_connectionName); } private function fill($data) { @@ -206,13 +206,13 @@ abstract class Entity { $limits_sql .= "$key $value "; } - if (static::softdelete && !$trashed) { - $sql = "SELECT $criteria FROM {" . static::tableName . "} WHERE deleted_at is null $limits_sql"; + if (static::_softdelete && !$trashed) { + $sql = "SELECT $criteria FROM {" . static::_tableName . "} WHERE deleted_at is null $limits_sql"; } else { - $sql = "SELECT $criteria FROM {" . static::tableName . "} $limits_sql"; + $sql = "SELECT $criteria FROM {" . static::_tableName . "} $limits_sql"; } - $results = DBInstance::query($sql, Array(), static::connectionName); + $results = DBInstance::query($sql, Array(), static::_connectionName); $objects = Array(); foreach ($results as $value) { @@ -258,13 +258,13 @@ abstract class Entity { $criteria_data[] = $criteria[1]; } } - if (static::softdelete && !$trashed) { - $sql = "SELECT COUNT(*) FROM {" . static::tableName . "} $criteria_sql AND deleted_at is null"; + if (static::_softdelete && !$trashed) { + $sql = "SELECT COUNT(*) FROM {" . static::_tableName . "} $criteria_sql AND deleted_at is null"; } else { - $sql = "SELECT COUNT(*) FROM {" . static::tableName . "} $criteria_sql"; + $sql = "SELECT COUNT(*) FROM {" . static::_tableName . "} $criteria_sql"; } - $results = DBInstance::queryOne($sql, $criteria_data, static::connectionName); + $results = DBInstance::queryOne($sql, $criteria_data, static::_connectionName); return $results->count; } @@ -317,13 +317,13 @@ abstract class Entity { $limits_sql .= "$key $value "; } - if (static::softdelete && !$trashed) { - $sql = "SELECT $select_sql FROM {" . static::tableName . "} $criteria_sql AND deleted_at is null $limits_sql"; + if (static::_softdelete && !$trashed) { + $sql = "SELECT $select_sql FROM {" . static::_tableName . "} $criteria_sql AND deleted_at is null $limits_sql"; } else { - $sql = "SELECT $select_sql FROM {" . static::tableName . "} $criteria_sql $limits_sql"; + $sql = "SELECT $select_sql FROM {" . static::_tableName . "} $criteria_sql $limits_sql"; } - $results = DBInstance::query($sql, $criteria_data, static::connectionName); + $results = DBInstance::query($sql, $criteria_data, static::_connectionName); $objects = Array(); foreach ($results as $value) { @@ -376,13 +376,13 @@ abstract class Entity { } $select_sql = rtrim($select_sql, ', '); - if (static::softdelete && !$trashed) { - $sql = "SELECT $select_sql FROM {" . static::tableName . "} $criteria_sql AND deleted_at is null $limits_sql"; + if (static::_softdelete && !$trashed) { + $sql = "SELECT $select_sql FROM {" . static::_tableName . "} $criteria_sql AND deleted_at is null $limits_sql"; } else { - $sql = "SELECT $select_sql FROM {" . static::tableName . "} $criteria_sql $limits_sql"; + $sql = "SELECT $select_sql FROM {" . static::_tableName . "} $criteria_sql $limits_sql"; } - $results = DBInstance::query($sql, Array(), static::connectionName); + $results = DBInstance::query($sql, Array(), static::_connectionName); $objects = Array(); foreach ($results as $value) { @@ -489,7 +489,7 @@ abstract class Entity { } $sql = "SELECT $remote_in_pivot FROM {$pivot_table} WHERE $local_in_pivot = $this->id $limits_sql"; - $relations = DBInstance::query($sql, Array(), static::connectionName); + $relations = DBInstance::query($sql, Array(), static::_connectionName); $ids = Array(); foreach ($relations as $relation) { $ids[] = $relation->$remote_in_pivot; @@ -528,7 +528,7 @@ abstract class Entity { } $sql = "SELECT * FROM $pivot_table WHERE $local_in_pivot = $this->id $limits_sql"; - $relations = DBInstance::query($sql, Array(), static::connectionName); + $relations = DBInstance::query($sql, Array(), static::_connectionName); $objects = Array(); if (empty($relations)) { diff --git a/src/index.php b/src/index.php index 7e6c34a..6681beb 100644 --- a/src/index.php +++ b/src/index.php @@ -30,7 +30,7 @@ class Estado extends Entity { class Estado_ extends Entity { - const tableName = 'estado_novo'; + const _tableName = 'estado_novo'; const _idPolice = Array( 'type' => 'nextval', 'min' => 500/*, @@ -122,6 +122,8 @@ Connections::addConnection($conn); //var_dump( DBInstance::queryOne('SELECT max(id) as id FROM {estado}')); +var_dump(Estado_::findAll()); + $a = new Estado_(); $a->nome = 'Estado 1'; $a->save();