| [ Index ] |
PHP Cross Reference of Unnamed Project |
[Summary view] [Print] [Text view]
1 <?php 2 /*************************************************************************** 3 * postgres7.php 4 * ------------------- 5 * begin : Saturday, Feb 13, 2001 6 * copyright : (C) 2001 The phpBB Group 7 * email : supportphpbb.com 8 * 9 * $Id: postgres7.php 5142 2005-05-06 20:50:13Z acydburn $ 10 * 11 ***************************************************************************/ 12 13 /*************************************************************************** 14 * 15 * This program is free software; you can redistribute it and/or modify 16 * it under the terms of the GNU General Public License as published by 17 * the Free Software Foundation; either version 2 of the License, or 18 * (at your option) any later version. 19 * 20 ***************************************************************************/ 21 22 if(!defined("SQL_LAYER")) 23 { 24 25 define("SQL_LAYER","postgresql"); 26 27 class sql_db 28 { 29 30 var $db_connect_id; 31 var $query_result; 32 var $in_transaction = 0; 33 var $row = array(); 34 var $rowset = array(); 35 var $rownum = array(); 36 var $num_queries = 0; 37 38 // 39 // Constructor 40 // 41 function sql_db($sqlserver, $sqluser, $sqlpassword, $database, $persistency = true) 42 { 43 $this->connect_string = ""; 44 45 if( $sqluser ) 46 { 47 $this->connect_string .= "user=$sqluser "; 48 } 49 50 if( $sqlpassword ) 51 { 52 $this->connect_string .= "password=$sqlpassword "; 53 } 54 55 if( $sqlserver ) 56 { 57 if( ereg(":", $sqlserver) ) 58 { 59 list($sqlserver, $sqlport) = split(":", $sqlserver); 60 $this->connect_string .= "host=$sqlserver port=$sqlport "; 61 } 62 else 63 { 64 if( $sqlserver != "localhost" ) 65 { 66 $this->connect_string .= "host=$sqlserver "; 67 } 68 } 69 } 70 71 if( $database ) 72 { 73 $this->dbname = $database; 74 $this->connect_string .= "dbname=$database"; 75 } 76 77 $this->persistency = $persistency; 78 79 $this->db_connect_id = ( $this->persistency ) ? pg_pconnect($this->connect_string) : pg_connect($this->connect_string); 80 81 return ( $this->db_connect_id ) ? $this->db_connect_id : false; 82 } 83 84 // 85 // Other base methods 86 // 87 function sql_close() 88 { 89 if( $this->db_connect_id ) 90 { 91 // 92 // Commit any remaining transactions 93 // 94 if( $this->in_transaction ) 95 { 96 @pg_exec($this->db_connect_id, "COMMIT"); 97 } 98 99 if( $this->query_result ) 100 { 101 @pg_freeresult($this->query_result); 102 } 103 104 return @pg_close($this->db_connect_id); 105 } 106 else 107 { 108 return false; 109 } 110 } 111 112 // 113 // Query method 114 // 115 function sql_query($query = "", $transaction = false) 116 { 117 // 118 // Remove any pre-existing queries 119 // 120 unset($this->query_result); 121 if( $query != "" ) 122 { 123 $this->num_queries++; 124 125 $query = preg_replace("/LIMIT ([0-9]+),([ 0-9]+)/", "LIMIT \\2 OFFSET \\1", $query); 126 127 if( $transaction == BEGIN_TRANSACTION && !$this->in_transaction ) 128 { 129 $this->in_transaction = TRUE; 130 131 if( !@pg_exec($this->db_connect_id, "BEGIN") ) 132 { 133 return false; 134 } 135 } 136 137 $this->query_result = @pg_exec($this->db_connect_id, $query); 138 if( $this->query_result ) 139 { 140 if( $transaction == END_TRANSACTION ) 141 { 142 $this->in_transaction = FALSE; 143 144 if( !@pg_exec($this->db_connect_id, "COMMIT") ) 145 { 146 @pg_exec($this->db_connect_id, "ROLLBACK"); 147 return false; 148 } 149 } 150 151 $this->last_query_text[$this->query_result] = $query; 152 $this->rownum[$this->query_result] = 0; 153 154 unset($this->row[$this->query_result]); 155 unset($this->rowset[$this->query_result]); 156 157 return $this->query_result; 158 } 159 else 160 { 161 if( $this->in_transaction ) 162 { 163 @pg_exec($this->db_connect_id, "ROLLBACK"); 164 } 165 $this->in_transaction = FALSE; 166 167 return false; 168 } 169 } 170 else 171 { 172 if( $transaction == END_TRANSACTION && $this->in_transaction ) 173 { 174 $this->in_transaction = FALSE; 175 176 if( !@pg_exec($this->db_connect_id, "COMMIT") ) 177 { 178 @pg_exec($this->db_connect_id, "ROLLBACK"); 179 return false; 180 } 181 } 182 183 return true; 184 } 185 } 186 187 // 188 // Other query methods 189 // 190 function sql_numrows($query_id = 0) 191 { 192 if( !$query_id ) 193 { 194 $query_id = $this->query_result; 195 } 196 197 return ( $query_id ) ? @pg_numrows($query_id) : false; 198 } 199 200 function sql_numfields($query_id = 0) 201 { 202 if( !$query_id ) 203 { 204 $query_id = $this->query_result; 205 } 206 207 return ( $query_id ) ? @pg_numfields($query_id) : false; 208 } 209 210 function sql_fieldname($offset, $query_id = 0) 211 { 212 if( !$query_id ) 213 { 214 $query_id = $this->query_result; 215 } 216 217 return ( $query_id ) ? @pg_fieldname($query_id, $offset) : false; 218 } 219 220 function sql_fieldtype($offset, $query_id = 0) 221 { 222 if( !$query_id ) 223 { 224 $query_id = $this->query_result; 225 } 226 227 return ( $query_id ) ? @pg_fieldtype($query_id, $offset) : false; 228 } 229 230 function sql_fetchrow($query_id = 0) 231 { 232 if( !$query_id ) 233 { 234 $query_id = $this->query_result; 235 } 236 237 if($query_id) 238 { 239 $this->row = @pg_fetch_array($query_id, $this->rownum[$query_id]); 240 241 if( $this->row ) 242 { 243 $this->rownum[$query_id]++; 244 return $this->row; 245 } 246 } 247 248 return false; 249 } 250 251 function sql_fetchrowset($query_id = 0) 252 { 253 if( !$query_id ) 254 { 255 $query_id = $this->query_result; 256 } 257 258 if( $query_id ) 259 { 260 unset($this->rowset[$query_id]); 261 unset($this->row[$query_id]); 262 $this->rownum[$query_id] = 0; 263 264 while( $this->rowset = @pg_fetch_array($query_id, $this->rownum[$query_id], PGSQL_ASSOC) ) 265 { 266 $result[] = $this->rowset; 267 $this->rownum[$query_id]++; 268 } 269 270 return $result; 271 } 272 273 return false; 274 } 275 276 function sql_fetchfield($field, $row_offset=-1, $query_id = 0) 277 { 278 if( !$query_id ) 279 { 280 $query_id = $this->query_result; 281 } 282 283 if( $query_id ) 284 { 285 if( $row_offset != -1 ) 286 { 287 $this->row = @pg_fetch_array($query_id, $row_offset, PGSQL_ASSOC); 288 } 289 else 290 { 291 if( $this->rownum[$query_id] ) 292 { 293 $this->row = @pg_fetch_array($query_id, $this->rownum[$query_id]-1, PGSQL_ASSOC); 294 } 295 else 296 { 297 $this->row = @pg_fetch_array($query_id, $this->rownum[$query_id], PGSQL_ASSOC); 298 299 if( $this->row ) 300 { 301 $this->rownum[$query_id]++; 302 } 303 } 304 } 305 306 return $this->row[$field]; 307 } 308 309 return false; 310 } 311 312 function sql_rowseek($offset, $query_id = 0) 313 { 314 315 if(!$query_id) 316 { 317 $query_id = $this->query_result; 318 } 319 320 if( $query_id ) 321 { 322 if( $offset > -1 ) 323 { 324 $this->rownum[$query_id] = $offset; 325 return true; 326 } 327 else 328 { 329 return false; 330 } 331 } 332 333 return false; 334 } 335 336 function sql_nextid() 337 { 338 $query_id = $this->query_result; 339 340 if($query_id && $this->last_query_text[$query_id] != "") 341 { 342 if( preg_match("/^INSERT[\t\n ]+INTO[\t\n ]+([a-z0-9\_\-]+)/is", $this->last_query_text[$query_id], $tablename) ) 343 { 344 $query = "SELECT currval('" . $tablename[1] . "_id_seq') AS last_value"; 345 $temp_q_id = @pg_exec($this->db_connect_id, $query); 346 if( !$temp_q_id ) 347 { 348 return false; 349 } 350 351 $temp_result = @pg_fetch_array($temp_q_id, 0, PGSQL_ASSOC); 352 353 return ( $temp_result ) ? $temp_result['last_value'] : false; 354 } 355 } 356 357 return false; 358 } 359 360 function sql_affectedrows($query_id = 0) 361 { 362 if( !$query_id ) 363 { 364 $query_id = $this->query_result; 365 } 366 367 return ( $query_id ) ? @pg_cmdtuples($query_id) : false; 368 } 369 370 function sql_freeresult($query_id = 0) 371 { 372 if( !$query_id ) 373 { 374 $query_id = $this->query_result; 375 } 376 377 return ( $query_id ) ? @pg_freeresult($query_id) : false; 378 } 379 380 function sql_error($query_id = 0) 381 { 382 if( !$query_id ) 383 { 384 $query_id = $this->query_result; 385 } 386 387 $result['message'] = @pg_errormessage($this->db_connect_id); 388 $result['code'] = -1; 389 390 return $result; 391 } 392 393 } // class ... db_sql 394 395 } // if ... defined 396 397 ?>
title
Description
Body
title
Description
Body
title
Description
Body
title
Body
| Generated: Mon Jan 14 19:21:40 2013 | Cross-referenced by PHPXref 0.7.1 |