Source/carbon/database/drivers/mssql/mssql_driver.php

   1 <?php
   2 /*------------------------------------------------------------
   3 *  CarbonPHP framework (C) Tom Bell
   4 *  http://tombell.org.uk
   5 *------------------------------------------------------------*/
   6
   7 if (!defined('CARBON_PATH'))
   8 {
   9         exit('Direct script access is not allowed.');
  10 }
  11
  12 class Carbon_Database_mssql_driver extends Carbon_Database
  13 {
  14         public function database_connect()
  15         {
  16                 return @mssql_connect($this->hostname, $this->username, $this->password);
  17         }
  18
  19         public function database_pconnect()
  20         {
  21                 return @mssql_pconnect($this->hostname, $this->username, $this->password);
  22         }
  23
  24         public function database_select()
  25         {
  26                 return @mssql_select_db($this->database, $this->conn_id);
  27         }
  28
  29         public function database_version()
  30         {
  31                 return "SELECT @@VERSION AS ver";
  32         }
  33
  34         public function database_execute($sql)
  35         {
  36                 $sql = $this->database_prep_query($sql);
  37                 return @mssql_query($sql, $this->conn_id);
  38         }
  39
  40         public function database_prep_query($sql)
  41         {
  42                 return $sql;
  43         }
  44
  45         public function trans_begin($test_mode = false)
  46         {
  47                 if (!$this->trans_enabled)
  48                 {
  49                         return true;
  50                 }
  51
  52                 if ($this->_trans_depth > 0)
  53                 {
  54                         return true;
  55                 }
  56
  57                 $this->_trans_failure = ($test_mode === true) ? true : false;
  58                 $this->simple_query('BEGIN TRAN');
  59                 return true;
  60         }
  61
  62         public function trans_commit()
  63         {
  64                 if (!$this->trans_enabled)
  65                 {
  66                         return true;
  67                 }
  68
  69                 if ($this->_trans_depth > 0)
  70                 {
  71                         return true;
  72                 }
  73
  74                 $this->simple_query('COMMIT TRAN');
  75                 return true;
  76         }
  77
  78         public function trans_rollback()
  79         {
  80                 if (!$this->trans_enabled)
  81                 {
  82                         return true;
  83                 }
  84
  85                 if ($this->_trans_depth > 0)
  86                 {
  87                         return true;
  88                 }
  89
  90                 $this->simple_query('ROLLBACK TRAN');
  91                 return true;
  92         }
  93
  94         public function escape_string($string)
  95         {
  96                 return str_replace("'", "''", $string);
  97         }
  98
  99         public function affected_rows()
 100         {
 101                 return @mssql_row_affected($this->conn_id);
 102         }
 103
 104         public function insert_id()
 105         {
 106                 $ver = self::database_parse_major_version($this->database_version());
 107                 $sql = ($ver >= 8 ? "SELECT SCOPE_IDENTITY() AS last_id" : "SELECT @@IDENTITY AS last_id");
 108                 $query = $this->query($sql);
 109                 $row = $query->row();
 110                 return $row->last_id;
 111         }
 112
 113         private function database_parse_major_version($version)
 114         {
 115                 preg_match('/([0-9]+)\.([0-9]+)\.([0-9]+)/', $version, $ver_info);
 116                 return $ver_info[1];
 117         }
 118
 119         public function count_all($table = '')
 120         {
 121                 if ($table == '')
 122                 {
 123                         return '0';
 124                 }
 125
 126                 $query = $this->query('SELECT COUNT(*) AS numrows FROM ' . $this->dbprefix . $table);
 127
 128                 if ($query->num_rows() == 0)
 129                 {
 130                         return '0';
 131                 }
 132
 133                 $row = $query->row();
 134                 return $row->numrows;
 135         }
 136
 137         public function database_list_tables()
 138         {
 139                 return 'SELECT name FROM sysobjects WHERE type = \'U\' ORDER BY name';
 140         }
 141
 142         public function database_list_columns($table = '')
 143         {
 144                 return "SELECT * FROM INFORMATION_SCHEMA.Columns WHERE TABLE_NAME = '" . $this->database_escape_table($table) . "'";
 145         }
 146
 147         public function database_field_data($table)
 148         {
 149                 'SELECT TOP 1 * FROM ' . $this->database_escape_table($table);
 150         }
 151
 152         public function database_error_message()
 153         {
 154                 return '';
 155         }
 156
 157         public function database_error_number()
 158         {
 159                 return '';
 160         }
 161
 162         public function database_escape_table($table)
 163         {
 164                 return $table;
 165         }
 166
 167         public function database_insert($table, $keys, $values)
 168         {
 169                 return "INSERT INTO " . $this->database_escape_table($table) . " (" . implode(', ', $keys) . ") VALUES (" . implode(', ', $values) . ")";
 170         }
 171
 172         public function database_update($table, $values, $where)
 173         {
 174                 foreach($values as $key => $val)
 175                 {
 176                         $valstr[] = $key . " = " . $val;
 177                 }
 178
 179                 return "UPDATE " . $this->database_escape_table($table) . " SET " . implode(', ', $valstr) . " WHERE " . implode(" ", $where);
 180         }
 181
 182         public function database_delete($table, $where)
 183         {
 184                 return "DELETE FROM " . $this->database_escape_table($table) . " WHERE " . implode(" ", $where);
 185         }
 186
 187         public function database_limit($sql, $limit, $offset)
 188         {
 189                 $i = $limit + $offset;
 190                 return preg_replace('/(^\SELECT (DISTINCT)?)/i', '\\1 TOP ' . $i . ' ' . $sql);
 191         }
 192
 193         public function database_close($conn_id)
 194         {
 195                 @mssql_close($conn_id);
 196         }
 197 }
 198
 199 ?>