summaryrefslogtreecommitdiff
path: root/framework/Db/Schema/oci/TOciCommandBuilder.php
diff options
context:
space:
mode:
authorrojaro <>2009-07-13 14:02:17 +0000
committerrojaro <>2009-07-13 14:02:17 +0000
commit78af2b4630ccde4b03659a259f739f83ae0de9ec (patch)
treef1a27cc2dbe77682143ae8243eee91187e66c6fe /framework/Db/Schema/oci/TOciCommandBuilder.php
parentb4b2c7e5e2eadd48b344538823dcf5645939ba44 (diff)
- ActiveRecord Port from Yii ... not perfect but works ^^
Diffstat (limited to 'framework/Db/Schema/oci/TOciCommandBuilder.php')
-rwxr-xr-xframework/Db/Schema/oci/TOciCommandBuilder.php122
1 files changed, 122 insertions, 0 deletions
diff --git a/framework/Db/Schema/oci/TOciCommandBuilder.php b/framework/Db/Schema/oci/TOciCommandBuilder.php
new file mode 100755
index 00000000..807b7271
--- /dev/null
+++ b/framework/Db/Schema/oci/TOciCommandBuilder.php
@@ -0,0 +1,122 @@
+<?php
+/**
+ * TOciCommandBuilder class file.
+ *
+ * @author Ricardo Grana <rickgrana@yahoo.com.br>
+ * @link http://www.yiiframework.com/
+ * @copyright Copyright &copy; 2008-2009 Yii Software LLC
+ * @license http://www.yiiframework.com/license/
+ */
+
+prado::using('System.Db.Schema.TDbCommandBuilder');
+
+/**
+ * TOciCommandBuilder provides basic methods to create query commands for tables.
+ *
+ * @author Ricardo Grana <rickgrana@yahoo.com.br>
+ * @version $Id: TOciCommandBuilder.php 2679 2009-06-15 07:49:42Z Christophe.Boulain $
+ * @package System.Db.Schema.oci
+ * @since 1.0.5
+ */
+class TOciCommandBuilder extends TDbCommandBuilder
+{
+ /**
+ * @var integer the last insertion ID
+ */
+ public $returnID;
+
+ /**
+ * Returns the last insertion ID for the specified table.
+ * @param mixed the table schema ({@link TDbTableSchema}) or the table name (string).
+ * @return mixed last insertion id. Null is returned if no sequence name.
+ */
+ public function getLastInsertID($table)
+ {
+ return $this->returnID;
+ }
+
+ /**
+ * Alters the SQL to apply LIMIT and OFFSET.
+ * Default implementation is applicable for PostgreSQL, MySQL and SQLite.
+ * @param string SQL query string without LIMIT and OFFSET.
+ * @param integer maximum number of rows, -1 to ignore limit.
+ * @param integer row offset, -1 to ignore offset.
+ * @return string SQL with LIMIT and OFFSET
+ */
+ public function applyLimit($sql,$limit,$offset)
+ {
+ if (($limit < 0) and ($offset < 0)) return $sql;
+
+ $filters = array();
+ if($offset>0){
+ $filters[] = 'rowNumId >= '.(int)$offset;
+ }
+
+ if($limit>=0){
+ $filters[]= 'rownum <= '.(int)$limit;
+ }
+
+ if (count($filters) > 0){
+ $filter = implode(' and ', $filters);
+ $filter= " WHERE ".$filter;
+ }else{
+ $filter = '';
+ }
+
+
+ $sql = <<<EOD
+ WITH USER_SQL AS ({$sql}),
+ PAGINATION AS (SELECT USER_SQL.*, rownum as rowNumId FROM USER_SQL)
+ SELECT *
+ FROM PAGINATION
+ {$filter}
+EOD;
+
+ return $sql;
+ }
+
+ /**
+ * Creates an INSERT command.
+ * @param mixed the table schema ({@link TDbTableSchema}) or the table name (string).
+ * @param array data to be inserted (column name=>column value). If a key is not a valid column name, the corresponding value will be ignored.
+ * @return TDbCommand insert command
+ */
+ public function createInsertCommand($table,$data)
+ {
+ $this->ensureTable($table);
+ $fields=array();
+ $values=array();
+ $placeholders=array();
+ foreach($data as $name=>$value)
+ {
+ if(($column=$table->getColumn($name))!==null && ($value!==null || $column->allowNull))
+ {
+ $fields[]=$column->rawName;
+ if($value instanceof TDbExpression)
+ $placeholders[]=(string)$value;
+ else
+ {
+ $placeholders[]=':'.$name;
+ $values[':'.$name]=$column->typecast($value);
+ }
+ }
+ }
+
+ $sql="INSERT INTO {$table->rawName} (".implode(', ',$fields).') VALUES ('.implode(', ',$placeholders).')';
+
+ if(is_string($table->primaryKey))
+ {
+ $sql.=" RETURNING ".$table->primaryKey." INTO :RETURN_ID";
+ $command=$this->getDbConnection()->createCommand($sql);
+ $command->bindParam(':RETURN_ID', $this->returnID, PDO::PARAM_INT, 12);
+ $table->sequenceName='RETURN_ID';
+ }
+ else
+ $command=$this->getDbConnection()->createCommand($sql);
+
+ foreach($values as $name=>$value)
+ $command->bindValue($name,$value);
+
+ return $command;
+ }
+}