1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
<?php
/**
* TOciCommandBuilder 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/
*/
prado::using('System.Testing.Data.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.Testing.Data.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;
}
}
|
