Rev Author Line No. Line
130 kaklik 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,v 1.19.2.3 2005/05/06 20:50:10 acydburn Exp $
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 ?>