* * metadata() contributed by Adelino Monteiro * * ------------------------------------------------------------------------ * * This is not part of phpGroupWare, but is used by phpGroupWare. * * http://www.phpgroupware.org/ * * ------------------------------------------------------------------------ * * This program is free software; you can redistribute it and/or modify it * * under the terms of the GNU Lesser General Public License as published * * by the Free Software Foundation; either version 2.1 of the License, or * * 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) { if($GLOBALS['phpgw_info']['server']['db_persistent']) { $this->Link_ID = sybase_pconnect($this->Host,$this->User,$this->Password); } else { $this->Link_ID = sybase_connect($this->Host,$this->User,$this->Password); } } if(!$this->Link_ID) { $this->halt('Link-ID == false, '.($GLOBALS['phpgw_info']['server']['db_persistent']?'p':'')..'connect 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."); } } ?>