* * metadata() contributed by Adelino Monteiro * * ------------------------------------------------------------------------ * * This file is not part of the phpGroupWare API * * ------------------------------------------------------------------------ * * This program is free software; you can redistribute it and/or modify it * * under the terms of the GNU General Public License as published by the * * Free Software Foundation; either version 2 of the License, or (at your * * option) any later version. * \**************************************************************************/ /* $Id$ */ class db { var $Host = ""; var $Database = ""; var $User = ""; var $Password = ""; var $Link_ID = 0; var $Query_ID = 0; var $Record = array(); var $Row; var $Auto_Free = 0; ## Set this to 1 for automatic sybase_free_result() function connect() { if ( 0 == $this->Link_ID ) { $this->Link_ID=sybase_pconnect($this->Host,$this->User,$this->Password); if (!$this->Link_ID) { $this->halt("Link-ID == false, pconnect failed"); } if(!sybase_select_db($this->Database, $this->Link_ID)) { $this->halt("cannot use database ".$this->Database); } } } function query($Query_String) { $this->connect(); # printf("Debug: query = %s
\n", $Query_String); $this->Query_ID = sybase_query($Query_String,$this->Link_ID); $this->Row = 0; if (!$this->Query_ID) { $this->halt("Invalid SQL: ".$Query_String); } return $this->Query_ID; } function next_record() { $this->Record = sybase_fetch_array($this->Query_ID); $this->Row += 1; $stat = is_array($this->Record); if (!$stat && $this->Auto_Free) { sybase_free_result($this->Query_ID); $this->Query_ID = 0; } return $stat; } function seek($pos) { $status = sybase_data_seek($this->Query_ID, $pos); if ($status) $this->Row = $pos; return; } function metadata($table) { $count = 0; $id = 0; $res = array(); $this->connect(); $result = $this->query("exec sp_columns $table"); if ($result < 0) { $this->Errno = 1; $this->Error = "Metadata query failed"; $this->halt("Metadata query failed."); } $count = sybase_num_rows($result); for ($i=0; $i<$count; $i++) { $res[$i]["table"] = $table ; $res[$i]["name"] = sybase_result ($result, $i, "COLUMN_NAME"); $res[$i]["type"] = sybase_result ($result, $i, "TYPE_NAME"); $res[$i]["len"] = sybase_result ($result, $i, "LENGTH"); $res[$i]["position"] = sybase_result ($result, $i, "ORDINAL_POSITION"); $res[$i]["flags"] = sybase_result ($result, $i, "REMARKS"); } } function affected_rows() { return sybase_affected_rows($this->Query_ID); } function num_rows() { return sybase_num_rows($this->Query_ID); } function num_fields() { return sybase_num_fields($this->Query_ID); } function nf() { return $this->num_rows(); } function np() { print $this->num_rows(); } function f($Name) { return $this->Record[$Name]; } function p($Name) { print $this->Record[$Name]; } function halt($msg) { printf("Database error: %s
\n", $msg); printf("Sybase Error
\n"); die("Session halted."); } } ?>