app/libs/Exception.php app/libs/Message.php @@ -73,13 +73,22 @@ abstract class PhpBURN_Core implements IPhpBurn { return $result; } - public function get() { - + public function get() { } - public function save() { - - } + public function save() { + $fields = array(); + // if query is an insert + $insert = true; + foreach ($this->_mapObj->fields as $field => $infos) { + $fields[$field] = $this->_mapObj->getFieldValue($field); + if ($insert==true && isset($infos['pk']) && $infos['pk']==true && !empty($fields[$field])) { + // query will be an update + $insert = false; + } + } + //execute query. + } public function delete() { @@ -120,4 +129,4 @@ abstract class PhpBURN_Core implements IPhpBurn { } } -?> \ No newline at end of file +?> app/libs/Core.php @@ -1,131 +1,129 @@ -<?php -PhpBurn::load("Dialect.IDialect"); - -class PhpBURN_Dialect_MySQL implements IDialect { - - private $obj = null; - private $connection = null; - private $resultSet; - private $dataSet; - private $mode; - private $pointer; - - function __construct(PhpBurn_Core $obj) { - $this->obj =& $obj; - } - function __destruct() { - unset($this); - } +<?php +PhpBurn::load("Dialect.IDialect"); + +class PhpBURN_Dialect_MySQL implements IDialect { - /* Query Construction */ + private $obj = null; + private $connection = null; + private $resultSet; + private $dataSet; + private $mode; + private $pointer; - public function find($pk = null) { - + function __construct(PhpBurn_Core $obj) { + $this->obj =& $obj; + } + function __destruct() { + unset($this); + } + + /* Query Construction */ + + public function find($pk = null) { + + } + + protected function _prepareSQL($forCount = false, $what = '*') { + $sql = "SELECT %s"; + + return sprintf($sql, ($forCount?'COUNT('.$what.')':$what)); } - protected function _prepareSQL($forCount = false, $what = '*') - { - $sql = "SELECT "; - - + public function setConnection($connection) { + $this->connection =& $connection; + } + + public function getConnection() { + return $this->connection; + } + + public function setMysqlMode($mode = "") { + $this->mode = $mode; - return $sql; - } - - public function setConnection($connection) { - $this->connection =& $connection; - } - - public function getConnection() { - return $this->connection; - } - - public function setMysqlMode($mode = "") { - $this->mode = $mode; - - if (empty($mode)) - $this->setMysqlMode(MYSQL_ASSOC); - } - - public function execute($sql, $mode = "") { - if (!isset($this->connection) && empty($this->connection)) - return false; - $this->setMysqlMode($mode); - $this->resultSet = $this->connection->executeSQL($sql); - while ($row = mysql_fetch_array($this->resultSet, $this->mode)) { - $dataSet[] = $row; - } - $this->setDataSet($dataSet); - $this->setPointer(0); - return true; - } - - public function num_rows() { - if (!isset($this->resultSet) && empty($this->resultSet)) - return 0; - return $this->getConnection()->num_rows($this->resultSet); - } - - public function affected_rows() { - if (!isset($this->resultSet) && empty($this->resultSet)) - return false; - return $this->getConnection()->affected_rows(); - } - - public function moveFirst() { - $this->pointer = 0; - } - - public function moveNext() { - $this->pointer++; - } - - public function movePrev() { - $this->pointer--; - } - - public function moveLast() { - $this->pointer = $this->num_rows() - 1; - } - - public function getLast() { - return $this->num_rows() - 1; - } - - public function fetch_row($rowNumber) { - if (!isset($this->dataSet) && !isset($this->dataSet[$rowNumber])) - return false; - return $this->dataSet[$rowNumber]; - } - - public function fetch() { - $point = $this->getPointer(); - $this->moveNext(); - if ($point > $this->getLast()) { - $this->moveFirst(); - return false; - } - return $this->fetch_row($point); - } - -// @TODO: Create this method - public function getErrorMsg() { - } - - public function getDataSet() { - return $this->dataSet; - } - - public function setDataSet(array $dataSet) { - $this->dataSet = $dataSet; - } - - public function getPointer() { - return $this->pointer; + if (empty($mode)) + $this->setMysqlMode(MYSQL_ASSOC); + } + + public function execute($sql, $mode = "") { + if (!isset($this->connection) && empty($this->connection)) + return false; + $this->setMysqlMode($mode); + $this->resultSet = $this->connection->executeSQL($sql); + while ($row = mysql_fetch_array($this->resultSet, $this->mode)) { + $dataSet[] = $row; + } + $this->setDataSet($dataSet); + $this->setPointer(0); + return true; + } + + public function num_rows() { + if (!isset($this->resultSet) && empty($this->resultSet)) + return 0; + return $this->getConnection()->num_rows($this->resultSet); + } + + public function affected_rows() { + if (!isset($this->resultSet) && empty($this->resultSet)) + return false; + return $this->getConnection()->affected_rows(); + } + + public function moveFirst() { + $this->pointer = 0; + } + + public function moveNext() { + $this->pointer++; + } + + public function movePrev() { + $this->pointer--; + } + + public function moveLast() { + $this->pointer = $this->num_rows() - 1; + } + + public function getLast() { + return $this->num_rows() - 1; + } + + public function fetch_row($rowNumber) { + if (!isset($this->dataSet) && !isset($this->dataSet[$rowNumber])) + return false; + return $this->dataSet[$rowNumber]; + } + + public function fetch() { + $point = $this->getPointer(); + $this->moveNext(); + if ($point > $this->getLast()) { + $this->moveFirst(); + return false; + } + return $this->fetch_row($point); + } + +// @TODO: Create this method + public function getErrorMsg() { + return $this->getConnection()->getErrorMsg(); + } + + public function getDataSet() { + return $this->dataSet; + } + + public function setDataSet(array $dataSet) { + $this->dataSet = $dataSet; + } + + public function getPointer() { + return $this->pointer; + } + + public function setPointer($pointer) { + $this->pointer = $pointer; } - - public function setPointer($pointer) { - $this->pointer = $pointer; - } -} -?> \ No newline at end of file +} +?> app/libs/Dialect/MySQL.php @@ -119,5 +119,5 @@ abstract class PhpBURN { } } -PhpBURN::load('Configuration','Connection', 'IPhpBurn', 'Core', 'Dialect', 'Mapping'); -?> \ No newline at end of file +PhpBURN::load('Configuration','Connection', 'IPhpBurn', 'Core', 'Dialect', 'Mapping','Exception','Message'); +?> app/phpBurn.php 6dc15916cba7577dcc4ded77a067325dbac8a964 673c9e6f6dc76984c21a1bb40b0771e6aa321286 Klederson Bueno klederson@klederson.com http://github.com/klederson/phpburn/commit/4aac0d2619b358543e981dac21aa25457250476a 4aac0d2619b358543e981dac21aa25457250476a 2009-01-26T04:48:32-08:00 2009-01-26T04:48:32-08:00 Several improvements e41466e2b7ffd73ddcc01fbfdc6afbc4beb1ba60 Klederson Bueno klederson@klederson.com