mirror of
https://github.com/LBRYFoundation/pool.git
synced 2025-09-30 15:20:36 +00:00
122 lines
No EOL
3.2 KiB
PHP
122 lines
No EOL
3.2 KiB
PHP
<?php
|
|
/**
|
|
* COciCommandBuilder class file.
|
|
*
|
|
* @author Ricardo Grana <rickgrana@yahoo.com.br>
|
|
* @link http://www.yiiframework.com/
|
|
* @copyright Copyright © 2008-2009 Yii Software LLC
|
|
* @license http://www.yiiframework.com/license/
|
|
*/
|
|
|
|
/**
|
|
* COciCommandBuilder provides basic methods to create query commands for tables.
|
|
*
|
|
* @author Ricardo Grana <rickgrana@yahoo.com.br>
|
|
* @version $Id: COciCommandBuilder.php 1281 2009-07-31 21:40:12Z qiang.xue $
|
|
* @package system.db.schema.oci
|
|
* @since 1.0.5
|
|
*/
|
|
class COciCommandBuilder extends CDbCommandBuilder
|
|
{
|
|
/**
|
|
* @var integer the last insertion ID
|
|
*/
|
|
public $returnID;
|
|
|
|
/**
|
|
* Returns the last insertion ID for the specified table.
|
|
* @param mixed the table schema ({@link CDbTableSchema}) 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 CDbTableSchema}) 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 CDbCommand insert command
|
|
*/
|
|
public function createInsertCommand($table,$data)
|
|
{
|
|
$this->ensureTable($table);
|
|
$fields=array();
|
|
$values=array();
|
|
$placeholders=array();
|
|
$i=0;
|
|
foreach($data as $name=>$value)
|
|
{
|
|
if(($column=$table->getColumn($name))!==null && ($value!==null || $column->allowNull))
|
|
{
|
|
$fields[]=$column->rawName;
|
|
if($value instanceof CDbExpression)
|
|
$placeholders[]=$value->expression;
|
|
else
|
|
{
|
|
$placeholders[]=self::PARAM_PREFIX.$i;
|
|
$values[self::PARAM_PREFIX.$i]=$column->typecast($value);
|
|
$i++;
|
|
}
|
|
}
|
|
}
|
|
|
|
$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;
|
|
}
|
|
} |