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
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
|
<?php
/**
* PHPPgAdmin 6.1.0
*/
namespace PHPPgAdmin\Database\Traits;
/**
* Common trait for operators manipulation.
*/
trait OperatorTrait
{
/**
* Returns a list of all operators in the database.
*
* @return int|\PHPPgAdmin\ADORecordSet
*/
public function getOperators()
{
$c_schema = $this->_schema;
$this->clean($c_schema);
// We stick with the subselects here, as you cannot ORDER BY a regtype
$sql = "
SELECT
po.oid, po.oprname,
(SELECT pg_catalog.format_type(oid, NULL) FROM pg_catalog.pg_type pt WHERE pt.oid=po.oprleft) AS oprleftname,
(SELECT pg_catalog.format_type(oid, NULL) FROM pg_catalog.pg_type pt WHERE pt.oid=po.oprright) AS oprrightname,
po.oprresult::pg_catalog.regtype AS resultname,
pg_catalog.obj_description(po.oid, 'pg_operator') AS oprcomment
FROM
pg_catalog.pg_operator po
WHERE
po.oprnamespace = (SELECT oid FROM pg_catalog.pg_namespace WHERE nspname='{$c_schema}')
ORDER BY
po.oprname, oprleftname, oprrightname
";
return $this->selectSet($sql);
}
/**
* Drops an operator.
*
* @param mixed $operator_oid The OID of the operator to drop
* @param bool $cascade True to cascade drop, false to restrict
*
* @return int|\PHPPgAdmin\ADORecordSet
*/
public function dropOperator($operator_oid, $cascade)
{
// Function comes in with $object as operator OID
$opr = $this->getOperator($operator_oid);
$f_schema = $this->_schema;
$this->fieldClean($f_schema);
$this->fieldClean($opr->fields['oprname']);
$sql = "DROP OPERATOR \"{$f_schema}\".{$opr->fields['oprname']} (";
// Quoting or formatting here???
if (null !== $opr->fields['oprleftname']) {
$sql .= $opr->fields['oprleftname'] . ', ';
} else {
$sql .= 'NONE, ';
}
if (null !== $opr->fields['oprrightname']) {
$sql .= $opr->fields['oprrightname'] . ')';
} else {
$sql .= 'NONE)';
}
if ($cascade) {
$sql .= ' CASCADE';
}
return $this->execute($sql);
}
/**
* Returns all details for a particular operator.
*
* @param mixed $operator_oid The oid of the operator
*
* @return int|\PHPPgAdmin\ADORecordSet
*/
public function getOperator($operator_oid)
{
$this->clean($operator_oid);
$sql = "
SELECT
po.oid, po.oprname,
oprleft::pg_catalog.regtype AS oprleftname,
oprright::pg_catalog.regtype AS oprrightname,
oprresult::pg_catalog.regtype AS resultname,
po.oprcanhash,
oprcanmerge,
oprcom::pg_catalog.regoperator AS oprcom,
oprnegate::pg_catalog.regoperator AS oprnegate,
po.oprcode::pg_catalog.regproc AS oprcode,
po.oprrest::pg_catalog.regproc AS oprrest,
po.oprjoin::pg_catalog.regproc AS oprjoin
FROM
pg_catalog.pg_operator po
WHERE
po.oid='{$operator_oid}'
";
return $this->selectSet($sql);
}
/**
* Gets all opclasses.
*
* @return int|\PHPPgAdmin\ADORecordSet
*/
public function getOpClasses()
{
$c_schema = $this->_schema;
$this->clean($c_schema);
$sql = "
SELECT
pa.amname, po.opcname,
po.opcintype::pg_catalog.regtype AS opcintype,
po.opcdefault,
pg_catalog.obj_description(po.oid, 'pg_opclass') AS opccomment
FROM
pg_catalog.pg_opclass po, pg_catalog.pg_am pa, pg_catalog.pg_namespace pn
WHERE
po.opcmethod=pa.oid
AND po.opcnamespace=pn.oid
AND pn.nspname='{$c_schema}'
ORDER BY 1,2
";
return $this->selectSet($sql);
}
abstract public function fieldClean(&$str);
abstract public function beginTransaction();
abstract public function rollbackTransaction();
abstract public function endTransaction();
abstract public function execute($sql);
abstract public function setComment($obj_type, $obj_name, $table, $comment, $basetype = null);
abstract public function selectSet($sql);
abstract public function clean(&$str);
abstract public function phpBool($parameter);
abstract public function hasCreateTableLikeWithConstraints();
abstract public function hasCreateTableLikeWithIndexes();
abstract public function hasTablespaces();
abstract public function delete($table, $conditions, $schema = '');
abstract public function fieldArrayClean(&$arr);
abstract public function hasCreateFieldWithConstraints();
abstract public function getAttributeNames($table, $atts);
}
|
