$orig_field = reset($orig_fields);
$after = "FIRST";
foreach ($_POST["fields"] as $key => $field) {
- $type_field = (isset($types[$field["type"]]) ? $field : $referencable_primary[$foreign_keys[$field["type"]]]);
+ $foreign_key = $foreign_keys[$field["type"]];
+ $type_field = (isset($foreign_key) ? $referencable_primary[$foreign_key] : $field); //! can collide with user defined type
if ($field["field"] != "") {
- if ($type_field) {
- if (!$field["has_default"]) {
- $field["default"] = null;
- }
- $default = eregi_replace(" *on update CURRENT_TIMESTAMP", "", $field["default"]);
- if ($default != $field["default"]) { // preg_replace $count is available since PHP 5.1.0
- $field["on_update"] = "CURRENT_TIMESTAMP";
- $field["default"] = $default;
- }
- if ($key == $_POST["auto_increment_col"]) {
- $field["auto_increment"] = true;
- }
- $process_field = process_field($field, $type_field);
- if ($process_field != process_field($orig_field, $orig_field)) {
- $fields[] = array($field["orig"], $process_field, $after);
- }
- if (!isset($types[$field["type"]])) {
- $foreign[] = ($TABLE != "" ? "ADD " : " ") . "FOREIGN KEY (" . idf_escape($field["field"]) . ") REFERENCES " . idf_escape($foreign_keys[$field["type"]]) . " (" . idf_escape($type_field["field"]) . ")";
- }
+ if (!$field["has_default"]) {
+ $field["default"] = null;
+ }
+ $default = eregi_replace(" *on update CURRENT_TIMESTAMP", "", $field["default"]);
+ if ($default != $field["default"]) { // preg_replace $count is available since PHP 5.1.0
+ $field["on_update"] = "CURRENT_TIMESTAMP";
+ $field["default"] = $default;
+ }
+ if ($key == $_POST["auto_increment_col"]) {
+ $field["auto_increment"] = true;
+ }
+ $process_field = process_field($field, $type_field);
+ if ($process_field != process_field($orig_field, $orig_field)) {
+ $fields[] = array($field["orig"], $process_field, $after);
+ }
+ if (isset($foreign_key)) {
+ $foreign[] = ($TABLE != "" ? "ADD" : " ") . " FOREIGN KEY (" . idf_escape($field["field"]) . ") REFERENCES " . idf_escape($foreign_key) . " (" . idf_escape($type_field["field"]) . ")";
}
$after = "AFTER " . idf_escape($field["field"]);
} elseif ($field["orig"] != "") {
function table_status($name = "") {
global $connection;
$return = array();
- $result = $connection->query("SELECT relname AS \"Name\", CASE relkind WHEN 'r' THEN '' ELSE 'view' END AS \"Engine\", pg_relation_size(oid) AS \"Data_length\", pg_total_relation_size(oid) - pg_relation_size(oid) AS \"Index_length\", pg_catalog.obj_description(oid, 'pg_class') AS \"Comment\"
-FROM pg_catalog.pg_class
+ $result = $connection->query("SELECT relname AS \"Name\", CASE relkind WHEN 'r' THEN '' ELSE 'view' END AS \"Engine\", pg_relation_size(oid) AS \"Data_length\", pg_total_relation_size(oid) - pg_relation_size(oid) AS \"Index_length\", obj_description(oid, 'pg_class') AS \"Comment\"
+FROM pg_class
WHERE relkind IN ('r','v')
AND relnamespace = (SELECT oid FROM pg_namespace WHERE nspname = current_schema())"
. ($name != "" ? " AND relname = " . $connection->quote($name) : "")
function fields($table) {
global $connection;
$return = array();
- $table_oid = $connection->result("SELECT oid FROM pg_class WHERE relname = " . $connection->quote($table));
- $result = $connection->query("SELECT *, col_description($table_oid, ordinal_position) AS comment FROM information_schema.columns WHERE table_name = " . $connection->quote($table) . " ORDER BY ordinal_position");
+ $result = $connection->query("SELECT a.attname AS field, format_type(a.atttypid, a.atttypmod) AS full_type, d.adsrc AS default, a.attnotnull, col_description(c.oid, a.attnum) AS comment
+FROM pg_class c
+JOIN pg_namespace n ON c.relnamespace = n.oid
+JOIN pg_attribute a ON c.oid = a.attrelid
+LEFT JOIN pg_attrdef d ON c.oid = d.adrelid AND a.attnum = d.adnum
+WHERE c.relname = " . $connection->quote($table) . "
+AND n.nspname = current_schema()
+AND a.attnum > 0
+ORDER BY a.attnum");
if ($result) {
while ($row = $result->fetch_assoc()) {
- $length = $row["character_maximum_length"];
- $return[$row["column_name"]] = array(
- "field" => $row["column_name"],
- "full_type" => $row["data_type"] . ($length ? "($length)" : ""),
- "type" => $row["data_type"],
- "length" => $length,
- "default" => $row["column_default"],
- "null" => ($row["is_nullable"] == "YES"),
- "auto_increment" => eregi("^nextval\\(", $row["column_default"]),
- "collation" => $row["collation_name"],
- "privileges" => array("insert" => 1, "select" => 1, "update" => 1), //! is_updatable
- "primary" => false, //!
- "comment" => $row["comment"],
- );
+ //! collation, primary
+ ereg('(.*)(\\((.*)\\))?', $row["full_type"], $match);
+ list(, $row["type"], , $row["length"]) = $match;
+ $row["full_type"] = $row["type"] . ($row["length"] ? "($row[length])" : "");
+ $row["null"] = ($row["attnotnull"] == "f");
+ $row["auto_increment"] = eregi("^nextval\\(", $row["default"]);
+ $row["privileges"] = array("insert" => 1, "select" => 1, "update" => 1);
+ $return[$row["field"]] = $row;
}
}
return $return;
}
function set_schema($schema) {
- global $connection;
+ global $connection, $types, $structured_types;
+ foreach (get_vals("SELECT typname
+FROM pg_type
+WHERE typnamespace = (SELECT oid FROM pg_namespace WHERE nspname = " . $connection->quote($schema) . ")
+AND typtype IN ('b','d','e')
+AND typelem = 0"
+ ) as $type) { //! get types from current_schemas('t')
+ if (!isset($types[$type])) {
+ $types[$type] = 0;
+ $structured_types[lang('User types')][] = $type;
+ }
+ }
return $connection->query("SET search_path TO " . idf_escape($schema));
}
lang('Binary') => array("bit" => 0, "bit varying" => 0, "bytea" => 0),
lang('Network') => array("cidr" => 43, "inet" => 43, "macaddr" => 17, "txid_snapshot" => 0),
lang('Geometry') => array("box" => 0, "circle" => 0, "line" => 0, "lseg" => 0, "path" => 0, "point" => 0, "polygon" => 0),
- ) as $key => $val) {
+ ) as $key => $val) { //! can be retrieved from pg_type
$types += $val;
$structured_types[$key] = array_keys($val);
}
projects / adminer.git / commitdiff