?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
- finally removed sql_numrows
[phpbb.git] / phpBB / includes / db / mssql.php
blob19bc3709d67f9193bccd3ba71b67bd3cc6304faa
1 <?php
2 /**
3 *
4 * @package dbal
5 * @version $Id$
6 * @copyright (c) 2005 phpBB Group
7 * @license http://opensource.org/licenses/gpl-license.php GNU Public License
8 *
9 */
10
11 /**
12 */
13 if (!defined('IN_PHPBB'))
14 {
15 exit;
16 }
17
18 /**
19 * @ignore
20 */
21 if (!defined('SQL_LAYER'))
22 {
23
24 define('SQL_LAYER', 'mssql');
25 include_once($phpbb_root_path . 'includes/db/dbal.' . $phpEx);
26
27 /**
28 * MSSQL Database Abstraction Layer
29 * Minimum Requirement is MSSQL 2000+
30 * @package dbal
31 */
32 class dbal_mssql extends dbal
33 {
34 /**
35 * Connect to server
36 */
37 function sql_connect($sqlserver, $sqluser, $sqlpassword, $database, $port = false, $persistency = false)
38 {
39 $this->persistency = $persistency;
40 $this->user = $sqluser;
41 $this->server = $sqlserver . (($port) ? ':' . $port : '');
42 $this->dbname = $database;
43
44 $this->db_connect_id = ($this->persistency) ? @mssql_pconnect($this->server, $this->user, $sqlpassword) : @mssql_connect($this->server, $this->user, $sqlpassword);
45
46 if ($this->db_connect_id && $this->dbname != '')
47 {
48 if (!@mssql_select_db($this->dbname, $this->db_connect_id))
49 {
50 @mssql_close($this->db_connect_id);
51 return false;
52 }
53 }
54
55 return ($this->db_connect_id) ? $this->db_connect_id : $this->sql_error('');
56 }
57
58 /**
59 * Version information about used database
60 */
61 function sql_server_info()
62 {
63 $result_id = @mssql_query("SELECT SERVERPROPERTY('productversion'), SERVERPROPERTY('productlevel'), SERVERPROPERTY('edition')", $this->db_connect_id);
64
65 $row = false;
66 if ($result_id)
67 {
68 $row = @mssql_fetch_assoc($result_id);
69 @mssql_free_result($result_id);
70 }
71
72 if ($row)
73 {
74 return 'MSSQL<br />' . implode(' ', $row);
75 }
76
77 return 'MSSQL';
78 }
79
80 /**
81 * SQL Transaction
82 * @access private
83 */
84 function _sql_transaction($status = 'begin')
85 {
86 switch ($status)
87 {
88 case 'begin':
89 return @mssql_query('BEGIN TRANSACTION', $this->db_connect_id);
90 break;
91
92 case 'commit':
93 return @mssql_query('commit', $this->db_connect_id);
94 break;
95
96 case 'rollback':
97 return @mssql_query('ROLLBACK', $this->db_connect_id);
98 break;
99 }
100
101 return true;
102 }
103
104 /**
105 * Base query method
106 *
107 * @param string $query Contains the SQL query which shall be executed
108 * @param int $cache_ttl Either 0 to avoid caching or the time in seconds which the result shall be kept in cache
109 * @return mixed When casted to bool the returned value returns true on success and false on failure
110 *
111 * @access public
112 */
113 function sql_query($query = '', $cache_ttl = 0)
114 {
115 if ($query != '')
116 {
117 global $cache;
118
119 // EXPLAIN only in extra debug mode
120 if (defined('DEBUG_EXTRA'))
121 {
122 $this->sql_report('start', $query);
123 }
124
125 // For now, MSSQL has no real UTF-8 support
126 $query = utf8_decode($query);
127
128 $this->query_result = ($cache_ttl && method_exists($cache, 'sql_load')) ? $cache->sql_load($query) : false;
129 $this->sql_add_num_queries($this->query_result);
130
131 if ($this->query_result === false)
132 {
133 if (($this->query_result = @mssql_query($query, $this->db_connect_id)) === false)
134 {
135 $this->sql_error($query);
136 }
137
138 if (defined('DEBUG_EXTRA'))
139 {
140 $this->sql_report('stop', $query);
141 }
142
143 if ($cache_ttl && method_exists($cache, 'sql_save'))
144 {
145 $this->open_queries[(int) $this->query_result] = $this->query_result;
146 $cache->sql_save($query, $this->query_result, $cache_ttl);
147 }
148 else if (strpos($query, 'SELECT') === 0 && $this->query_result)
149 {
150 $this->open_queries[(int) $this->query_result] = $this->query_result;
151 }
152 }
153 else if (defined('DEBUG_EXTRA'))
154 {
155 $this->sql_report('fromcache', $query);
156 }
157 }
158 else
159 {
160 return false;
161 }
162
163 return ($this->query_result) ? $this->query_result : false;
164 }
165
166 /**
167 * Build LIMIT query
168 */
169 function sql_query_limit($query, $total, $offset = 0, $cache_ttl = 0)
170 {
171 if ($query != '')
172 {
173 $this->query_result = false;
174
175 // Since TOP is only returning a set number of rows we won't need it if total is set to 0 (return all rows)
176 if ($total)
177 {
178 // We need to grab the total number of rows + the offset number of rows to get the correct result
179 if (strpos($query, 'SELECT DISTINCT') === 0)
180 {
181 $query = 'SELECT DISTINCT TOP ' . ($total + $offset) . ' ' . substr($query, 15);
182 }
183 else
184 {
185 $query = 'SELECT TOP ' . ($total + $offset) . ' ' . substr($query, 6);
186 }
187 }
188
189 $result = $this->sql_query($query, $cache_ttl);
190
191 // Seek by $offset rows
192 if ($offset)
193 {
194 $this->sql_rowseek($offset, $result);
195 }
196
197 return $result;
198 }
199 else
200 {
201 return false;
202 }
203 }
204
205 /**
206 * Return number of affected rows
207 */
208 function sql_affectedrows()
209 {
210 return ($this->db_connect_id) ? @mssql_rows_affected($this->db_connect_id) : false;
211 }
212
213 /**
214 * Fetch current row
215 */
216 function sql_fetchrow($query_id = false)
217 {
218 global $cache;
219
220 if ($query_id === false)
221 {
222 $query_id = $this->query_result;
223 }
224
225 if (isset($cache->sql_rowset[$query_id]))
226 {
227 return $cache->sql_fetchrow($query_id);
228 }
229
230 if ($query_id === false)
231 {
232 return false;
233 }
234
235 $row = @mssql_fetch_assoc($query_id);
236
237 // I hope i am able to remove this later... hopefully only a PHP or MSSQL bug
238 if ($row)
239 {
240 foreach ($row as $key => $value)
241 {
242 $row[$key] = ($value === ' ') ? '' : $value;
243 }
244 }
245
246 return $row;
247 }
248
249 /**
250 * Seek to given row number
251 * rownum is zero-based
252 */
253 function sql_rowseek($rownum, $query_id = false)
254 {
255 global $cache;
256
257 if ($query_id === false)
258 {
259 $query_id = $this->query_result;
260 }
261
262 if (isset($cache->sql_rowset[$query_id]))
263 {
264 return $cache->sql_rowseek($rownum, $query_id);
265 }
266
267 return ($query_id !== false) ? @mssql_data_seek($query_id, $rownum) : false;
268 }
269
270 /**
271 * Get last inserted id after insert statement
272 */
273 function sql_nextid()
274 {
275 $result_id = @mssql_query('SELECT @@IDENTITY', $this->db_connect_id);
276 if ($result_id)
277 {
278 if ($row = @mssql_fetch_assoc($result_id))
279 {
280 @mssql_free_result($result_id);
281 return $row['computed'];
282 }
283 @mssql_free_result($result_id);
284 }
285
286 return false;
287 }
288
289 /**
290 * Free sql result
291 */
292 function sql_freeresult($query_id = false)
293 {
294 global $cache;
295
296 if ($query_id === false)
297 {
298 $query_id = $this->query_result;
299 }
300
301 if (isset($cache->sql_rowset[$query_id]))
302 {
303 return $cache->sql_freeresult($query_id);
304 }
305
306 if (isset($this->open_queries[$query_id]))
307 {
308 unset($this->open_queries[$query_id]);
309 return @mssql_free_result($query_id);
310 }
311
312 return false;
313 }
314
315 /**
316 * Escape string used in sql query
317 */
318 function sql_escape($msg)
319 {
320 return str_replace("'", "''", $msg);
321 }
322
323 /**
324 * return sql error array
325 * @access private
326 */
327 function _sql_error()
328 {
329 $error = array(
330 'message' => @mssql_get_last_message($this->db_connect_id),
331 'code' => ''
332 );
333
334 // Get error code number
335 $result_id = @mssql_query('SELECT @@ERROR as code', $this->db_connect_id);
336 if ($result_id)
337 {
338 $row = @mssql_fetch_assoc($result_id);
339 $error['code'] = $row['code'];
340 @mssql_free_result($result_id);
341 }
342
343 // Get full error message if possible
344 $sql = 'SELECT CAST(description as varchar(255)) as message
345 FROM master.dbo.sysmessages
346 WHERE error = ' . $error['code'];
347 $result_id = @mssql_query($sql);
348
349 if ($result_id)
350 {
351 $row = @mssql_fetch_assoc($result_id);
352 if (!empty($row['message']))
353 {
354 $error['message'] .= '<br />' . $row['message'];
355 }
356 @mssql_free_result($result_id);
357 }
358
359 return $error;
360 }
361
362 /**
363 * Build db-specific query data
364 * @access private
365 */
366 function _sql_custom_build($stage, $data)
367 {
368 return $data;
369 }
370
371 /**
372 * Close sql connection
373 * @access private
374 */
375 function _sql_close()
376 {
377 return @mssql_close($this->db_connect_id);
378 }
379
380 /**
381 * Build db-specific report
382 * @access private
383 */
384 function _sql_report($mode, $query = '')
385 {
386 switch ($mode)
387 {
388 case 'start':
389 $explain_query = $query;
390 if (preg_match('/UPDATE ([a-z0-9_]+).*?WHERE(.*)/s', $query, $m))
391 {
392 $explain_query = 'SELECT * FROM ' . $m[1] . ' WHERE ' . $m[2];
393 }
394 else if (preg_match('/DELETE FROM ([a-z0-9_]+).*?WHERE(.*)/s', $query, $m))
395 {
396 $explain_query = 'SELECT * FROM ' . $m[1] . ' WHERE ' . $m[2];
397 }
398
399 if (preg_match('/^SELECT/', $explain_query))
400 {
401 $html_table = false;
402 @mssql_query("SET SHOWPLAN_TEXT ON;", $this->db_connect_id);
403 if ($result = @mssql_query($explain_query, $this->db_connect_id))
404 {
405 @mssql_next_result($result);
406 while ($row = @mssql_fetch_row($result))
407 {
408 $html_table = $this->sql_report('add_select_row', $query, $html_table, $row);
409 }
410 }
411 @mssql_query("SET SHOWPLAN_TEXT OFF;", $this->db_connect_id);
412 @mssql_free_result($result);
413
414 if ($html_table)
415 {
416 $this->html_hold .= '</table>';
417 }
418 }
419 break;
420
421 case 'fromcache':
422 $endtime = explode(' ', microtime());
423 $endtime = $endtime[0] + $endtime[1];
424
425 $result = @mssql_query($query, $this->db_connect_id);
426 while ($void = @mssql_fetch_assoc($result))
427 {
428 // Take the time spent on parsing rows into account
429 }
430 @mssql_free_result($result);
431
432 $splittime = explode(' ', microtime());
433 $splittime = $splittime[0] + $splittime[1];
434
435 $this->sql_report('record_fromcache', $query, $endtime, $splittime);
436
437 break;
438 }
439 }
440
441 }
442
443 } // if ... define
444
445 ?>
phpbb is a php-based BBS (buletin board system)