php的mssql数据库连接类实例

这篇文章主要介绍了php的mssql数据库连接类,以一个类实例的形式演示了PHP实现针对mssql数据库的各种常用操作方法,包括对数据库的连接与增删改查等操作,非常具有实用价值,需要的朋友可以参考下

本文实例讲述了php的mssql数据库连接类实例代码,分享给大家供大家参考。

具体实现代码如下:

class DB_Sql { 
  var $Host     = ""; 
  var $Database = ""; 
  var $User     = ""; 
  var $Password = ""; 
  var $Link_ID  = 0; 
  var $Query_ID = 0; 
  var $Record   = array(); 
  var $Row      = 0; 
   
  var $Errno    = 0; 
  var $Error    = ""; 
  var $Auto_Free = 0;     ## set this to 1 to automatically free results 
   
  function DB_Sql($query = "") { 
      $this->query($query); 
  } 
  function connect() { 
    if ( 0 == $this->Link_ID ) { 
      $this->Link_ID=mssql_connect($this->Host, $this->User, $this->Password); 
      if (!$this->Link_ID) 
        $this->halt("Link-ID == false, mssql_pconnect failed"); 
      else 
          @mssql_select_db($this->Database, $this->Link_ID); 
    } 
  } 
  function free_result(){ 
      mssql_free_result($this->Query_ID); 
      $this->Query_ID = 0; 
  } 
   
  function query($Query_String)  
  { 
     
    /* No empty queries, please, since PHP4 chokes on them. */ 
    if ($Query_String == "") 
      /* The empty query string is passed on from the constructor, 
       * when calling the class without a query, e.g. in situations 
       * like these: '$db = new DB_Sql_Subclass;' 
       */ 
      return 0; 
      if (!$this->Link_ID) 
        $this->connect(); 
     
#   printf("<br>Debug: query = %s<br> ", $Query_String); 
 
 $this->Query_ID = mssql_query($Query_String, $this->Link_ID); 
    $this->Row = 0; 
    if (!$this->Query_ID) { 
      $this->Errno = 1; 
      $this->Error = "General Error (The MSSQL interface cannot return detailed error messages)."; 
      $this->halt("Invalid SQL: ".$Query_String); 
    } 
    return $this->Query_ID; 
  } 
   
  function next_record() { 
       
    if ($this->Record = mssql_fetch_row($this->Query_ID)) { 
      // add to Record[<key>] 
      $count = mssql_num_fields($this->Query_ID); 
      for ($i=0; $i<$count; $i++){ 
          $fieldinfo = mssql_fetch_field($this->Query_ID,$i); 
        $this->Record[strtolower($fieldinfo->name)] = $this->Record[$i]; 
      } 
      $this->Row += 1; 
      $stat = 1; 
    } else { 
      if ($this->Auto_Free) { 
            $this->free_result(); 
          } 
      $stat = 0; 
    } 
    return $stat; 
  } 
   
  function seek($pos) { 
        mssql_data_seek($this->Query_ID,$pos); 
      $this->Row = $pos; 
  } 
  function metadata($table) { 
    $count = 0; 
    $id    = 0; 
    $res   = array(); 
    $this->connect(); 
    $id = mssql_query("select * from $table", $this->Link_ID); 
    if (!$id) { 
      $this->Errno = 1; 
      $this->Error = "General Error (The MSSQL interface cannot return detailed error messages)."; 
      $this->halt("Metadata query failed."); 
    } 
    $count = mssql_num_fields($id); 
     
    for ($i=0; $i<$count; $i++) { 
        $info = mssql_fetch_field($id, $i); 
      $res[$i]["table"] = $table; 
      $res[$i]["name"]  = $info["name"]; 
      $res[$i]["len"]   = $info["max_length"]; 
      $res[$i]["flags"] = $info["numeric"]; 
    } 
    $this->free_result(); 
    return $res; 
  } 
   
  function affected_rows() { 
// Not a supported function in PHP3/4.  Chris Johnson, 16May2001. 
//    return mssql_affected_rows($this->Query_ID); 
    $rsRows = mssql_query("Select @@rowcount as rows", $this->Link_ID); 
    if ($rsRows) {        
       return mssql_result($rsRows, 0, "rows"); 
    } 
  } 
   
  function num_rows() { 
    return mssql_num_rows($this->Query_ID); 
  } 
   
  function num_fields() { 
    return mssql_num_fields($this->Query_ID); 
  } 
  function nf() { 
    return $this->num_rows(); 
  } 
   
  function np() { 
    print $this->num_rows(); 
  } 
   
  function f($Field_Name) { 
    return $this->Record[strtolower($Field_Name)]; 
  }
   
  function p($Field_Name) { 
    print $this->f($Field_Name); 
  } 
   
  function halt($msg) { 
    printf("</td></tr></table><b>Database error:</b> %s<br> ", $msg); 
    printf("<b>MSSQL Error</b>: %s (%s)<br> ", 
      $this->Errno, 
      $this->Error); 
    die("Session halted."); 
  } 
}

希望本文所述对大家的PHP程序设计有所帮助。