Jump to content

Warning: mysql_fetch_array() expects parameter 1 to be resource, boolean given in


Recommended Posts

Hi, i need some help with this code..i cant handle it :) Im new in php.

 

I got this error: Warning: mysql_fetch_array() expects parameter 1 to be resource, boolean given in bla bla on line 653

 

 

653 ->  while ($row = mysql_fetch_array($res, MYSQL_ASSOC)) {

 
          $data[] = $row;
 
        }
 
        break;
 
      case "postgres":
 
        if (!$res = @pg_query($this->cnn, $this->sql)) {
 
          $this->log .= "Query execution failed.<br />";
 
          $this->log .= pg_last_error()."<br />";
 
          return false;
 
        }
<?php

 

if (!defined('AFFREE'))

 

{

 

die('You cannot access this page directly!');

 

}

 

class db {

 

  var $cnn_id;

 

  var $db_type;

 

  var $dir;

 

  var $name;

 

  var $filename;

 

  var $fso;

 

  var $sql;

 

  var $cnn;

 

  var $db;

 

  var $ttl;

 

  var $data_ts;

 

  var $server;

 

  var $log;

 

  var $rows_affected;

 

  var $last_id;

 

 

 

  /*

 

  The class constructor. You can set some defaults here if desired.

 

  */

 

  function db($cnn_id=0) {

 

    $this->log = "initialize db() called<br />";

 

    $this->cnn_id = $cnn_id;

 

    $this->dir = "/cache/acache/"; //Default to current dir.

 

    $this->ttl = 0;

 

    $this->data_ts = 0;

 

  }

 

 

 

  /*

 

  connect() method makes the actual server connection and selects a database

 

  only if needed. This saves database connections.  Multiple database types are

 

  supported. Enter your connection credentials in the switch statement below.

 

 

 

  This is a private function, but it is at the top of the class because you need

 

  to enter your connections.

 

  */

 

  function connect() {

 

    $this->log .= "connect() called<br />";

 

    switch($this->cnn_id) {

 

      /*

 

      You can define all the database connections you need in this

 

      switch statement.

 

      */

 

     case 0:

 

        $this->db_type = "mysql";

 

        $this->server = SERVER_NAME;

 

        $user    = USER_NAME;

 

        $pwd      = PASSWORD;

 

        $this->db     = DB_NAME;

 

        break;

 

      case 1:

 

        $this->db_type = "mysql";

 

        $this->server = "";

 

        $user    = "";

 

        $pwd      = "";

 

        $this->db     = "";

 

        break;

 

      case 2:

 

        $this->db_type = "postgres";

 

        $this->server = "";

 

        $user    = "";

 

        $pwd      = "";

 

        $this->db     = "";

 

        break;

 

      case 3:

 

        $this->db_type = "mssql";

 

        $this->server = "";

 

        $user    = "";

 

        $pwd      = "";

 

        $this->db     = "";

 

        break;

 

    }

 

    switch($this->db_type) {

 

      case "mysql":

 

        if (!$this->cnn = mysql_connect($this->server,$user,$pwd )) {

 

          $this->log .= "mysql_connect() failed<br />";

 

          $this->log .= mysql_error()."<br />";

 

          return false;

 

        }

 

        if (!mysql_select_db($this->db,$this->cnn)) {

 

          $this->log .= "Could not select database named ".$this->db."<br />";

 

          $this->log .= mysql_error()."<br />";

 

          return false;

 

        }

 

        break;

 

      case "postgres":

 

        if (!$this->cnn = pg_connect("host=$this->server dbname=$this->dbuser=$user password=$pwd")) {

 

          $this->log .= "pg_connect() failed<br />";

 

          $this->log .= pg_last_error()."<br />";

 

          return false;

 

        }

 

        break;

 

      case "mssql":

 

        if (!$this->cnn = mssql_connect($this->server,$user,$pwd )) {

 

          $this->log .= "mssql_connect() failed<br />";

 

          $this->log .= mssql_error()."<br />";

 

          return false;

 

        }

 

        if (!mssql_select_db($this->db,$this->cnn)) {

 

          $this->log .= "Could not select database named ".$this->db."<br />";

 

          $this->log .= mssql_error()."<br />";

 

          return false;

 

        }

 

        break;

 

    }

 

    return true;

 

  }

 

 

 

  /*

 

  fetch() is used to retrieve a dataaset. fetch() determines whether to use the

 

  cache or not, and queries either the database or the cache file accordingly.

 

  */

 

  function fetch($sql="",$ttl=0,$name="") {

 

    $this->log .= "---------------------------------<br />fetch() called<br />";

 

    $this->rows_affected = 0;

 

    if (!$sql) {

 

      $this->log .= "OOPS: You need to pass a SQL statement!<br />";

 

      return false;

 

    }

 

    $this->sql = $sql;

 

    $this->ttl = $ttl;

 

    $this->name = $name;

 

    $this->log .= "SQL: ".$this->sql."<br />";

 

    $data = "";

 

    if ($this->ttl == "0") {

 

      return $data = $this->getFromDB();

 

    } else {

 

      if (strlen(trim($this->name)) == 0) { $this->name = MD5($this->sql); }

 

      $this->filename = $this->dir."db_".$this->name;

 

      $this->log .= "Filename: ".$this->filename."<br />";

 

      $this->getFile_ts();

 

      if ($this->ttl == "daily") {

 

        if (date('Y-m-d',$this->data_ts) != date('Y-m-d',time())) {

 

          $this->log .= "cache has expired<br />";

 

          if (!$data = $this->getFromDB()) { return false; }

 

          if (!$this->saveToCache($data)) { return false; }

 

          return $data;

 

        } else {

 

          return $data = $this->getFromCache();

 

        }

 

      } else {

 

        if ((time() - $this->data_ts) >= $this->ttl) {

 

          $this->log .= "cache has expired<br />";

 

          if (!$data = $this->getFromDB()) { return false; }

 

          if (!$this->saveToCache($data)) { return false; }

 

          return $data;

 

        } else {

 

          return $data = $this->getFromCache();

 

        }

 

      }

 

    }

 

  }

 

 

 

  /*

 

  Use exec() to execute INSERT, UPDATE, DELETE statements.

 

  */

 

  function exec($sql="") {

 

    $this->log .= "---------------------------------<br />exec() called<br />";

 

    $this->rows_affected = 0;

 

    if (!$sql) {

 

      $this->log .= "OOPS: You need to pass a SQL statement!<br />";

 

      return false;

 

    }

 

    $this->sql = $sql;

 

    $this->log .= "SQL: ".$this->sql."<br />";

 

    if (!$this->cnn) { if (!$this->connect()) { return false; } }

 

    switch($this->db_type) {

 

      case "mysql":

 

        if (!$res = @mysql_query($this->sql, $this->cnn)) {

 

          $this->log .= "Query execution failed.<br />";

 

          $this->log .= mysql_error()."<br />";

 

          return false;

 

        }

 

        break;

 

      case "postgres":

 

        if (!$res = @pg_query($this->cnn, $this->sql)) {

 

          $this->log .= "Query execution failed.<br />";

 

          $this->log .= pg_last_error()."<br />";

 

          return false;

 

        }

 

        break;

 

      case "mssql":

 

        if (!$res = @mssql_query($this->sql, $this->cnn)) {

 

          $this->log .= "Query execution failed.<br />";

 

          $this->log .= mssql_error()."<br />";

 

          return false;

 

        }

 

        break;

 

    }

 

 

 

    /*

 

    Set last_id property (only applicable for INSERTS), and return

 

    number of rows affected by INSERT, UPDATE, DELETE.

 

    */

 

    switch($this->db_type) {

 

      case "mysql":

 

        $this->last_id = mysql_insert_id();

 

        $this->rows_affected = mysql_affected_rows($this->cnn);

 

        $this->log .= $this->rows_affected." rows affected<br />";

 

        return $this->rows_affected;

 

      case "postgres":

 

        $this->last_id = pg_last_oid($res);

 

        $this->rows_affected = pg_affected_rows($res);

 

        $this->log .= $this->rows_affected." rows affected<br />";

 

        return $this->rows_affected;

 

      case "mssql":

 

        $this->last_id = @mssql_result(@mysql_query("select SCOPE_IDENTITY()"),0,0);

 

        $this->rows_affected = mssql_rows_affected($this->cnn);

 

        $this->log .= $this->rows_affected." rows affected<br />";

 

        return $this->rows_affected;

 

    }

 

  }

 

 

 

  /*

 

  fmt() is a helper function for formatting SQL statement strings.

 

  For strings values, it will escape embedded single ticks, replace emptry

 

  strings with 'NULL', and properly wrap the value in quotes. For numeric types,

 

  it will replace empty values with zero.

 

      val : value to format

 

      dtype : 0 = string, 1 = numeric

 

  */

 

  function fmt($val,$dtype) {

 

    switch($dtype) {

 

      case 0:

 

        if(! $val && $val != "0") {

 

          $tmp = "null";

 

        } else {

 

          $tmp = "'".str_replace("'","''",$val)."'";

 

        }

 

        break;

 

      case 1:

 

        if(! $val) {

 

          $tmp = "0";

 

        } else {

 

          $tmp = $val;

 

        }

 

        break;

 

    }

 

    return $tmp;

 

  }

 

 

 

  /*

 

  fmt2() is the same as fmt() except it inserts a comma at the beginning

 

  of the return value and a space at the end. Useful in building SQL statements

 

  with multiple values.

 

  */

 

  function fmt2($val,$dtype) {

 

    switch($dtype) {

 

      case 0:

 

        if(! $val && $val != "0") {

 

          $tmp = ",null ";

 

        } else {

 

          $tmp = ",'".str_replace("'","''",$val)."' ";

 

        }

 

        break;

 

      case 1:

 

        if(! $val) {

 

          $tmp = ",0";

 

        } else {

 

          $tmp = ",".$val." ";

 

        }

 

        break;

 

    }

 

    return $tmp;

 

  }

 

 

 

  /*

 

  dump() produces an HTML table of the data. It is useful for debugging.

 

  This is also a good example of how to work with the data array.

 

  */

 

  function dump($data) {

 

    $this->log .= "dump() called<br />";

 

    if (!$data) {

 

      $this->log .= "dump(): no rows exist<br />";

 

      return false;

 

    }

 

    echo "<style>table.dump { font-family:Arial; font-size:8pt; }</style>";

 

    echo "<table class=\"dump\" border=\"1\" cellpadding=\"1\" cellspacing=\"0\">\n";

 

    echo "<tr>";

 

    echo "<th>#</th>";

 

    foreach($data[0] as $key=>$val) {

 

      echo "<th><b>";

 

      echo $key;

 

      echo "</b></th>";

 

    }

 

    echo "</tr>\n";

 

    $row_cnt = 0;

 

    foreach($data as $row) {

 

      $row_cnt++;

 

      echo "<tr align='center'>";

 

      echo "<td>".$row_cnt."</td>";

 

      foreach($row as $val) {

 

        echo "<td>";

 

        echo $val;

 

        echo "</td>";

 

      }

 

      echo"</tr>\n";

 

    }

 

    echo "</table>\n";

 

  }

 

 

 

  /*

 

  PRIVATE FUNCTIONS BELOW THIS POINT

 

  ------------------------------------------------------------------------------

 

  */

 

 

 

  function getFromDB() {

 

    $this->log .= "getFromDB() called<br />";

 

    if (!$this->cnn) {

 

      if (!$this->connect()) {

 

        $this->log .= "Database connection failed.<br />";

 

        return false;

 

      }

 

    }

 

    switch($this->db_type) {

 

      case "mysql":

 

        if (!$res = @mysql_query($this->sql, $this->cnn)) {

 

          $this->log .= "Query execution failed.<br />";

 

          $this->log .= mysql_error()."<br />";

 

          return false;

 

        }

 

        while ($row = mysql_fetch_array($res, MYSQL_ASSOC)) {

 

          $data[] = $row;

 

        }

 

        break;

 

      case "postgres":

 

        if (!$res = @pg_query($this->cnn, $this->sql)) {

 

          $this->log .= "Query execution failed.<br />";

 

          $this->log .= pg_last_error()."<br />";

 

          return false;

 

        }

 

        if (!$data = @pg_fetch_all($res)) {

 

          $this->log .= "getFromDB() failed<br />";

 

          return false;

 

        }

 

        break;

 

      case "mssql":

 

        if (!$res = @mssql_query($this->sql, $this->cnn)) {

 

          $this->log .= "Query execution failed.<br />";

 

          $this->log .= mssql_error()."<br />";

 

          return false;

 

        }

 

        while ($row = mssql_fetch_array($res)) {

 

          $data[] = $row;

 

        }

 

        break;

 

    }

 

    return $data;

 

  }

 

 

 

  function getFromCache() {

 

    $this->log .= "getFromCache() called<br />";

 

    if (!$x = @file_get_contents($this->filename)) {

 

      $this->log .= "Could not read ".$this->filename."<br />";

 

      return false;

 

    }

 

    if (!$data = unserialize($x)) {

 

      $this->log .= "getFromCache() failed<br />";

 

      return false;

 

    }

 

    return $data;

 

  }

 

 

 

  function saveToCache($data) {

 

    $this->log .= "saveToCache() called<br />";

 

    //create file pointer

 

    if (!$fp=@fopen($this->filename,"w")) {

 

      $this->log .= "Could not open ".$this->filename."<br />";

 

      return false;

 

    }

 

    //write to file

 

    if (!@fwrite($fp,serialize($data))) {

 

      $this->log .= "Could not write to ".$this->filename."<br />";

 

      fclose($fp);

 

      return false;

 

    }

 

    //close file pointer

 

    fclose($fp);

 

    return true;

 

  }

 

 

 

  function getFile_ts() {

 

    $this->log .= "getFile_ts() called<br />";

 

    if (!file_exists($this->filename)) {

 

      $this->data_ts = 0;

 

      $this->log .= $this->filename." does not exist<br />";

 

      return false;

 

    }

 

    $this->data_ts = filemtime($this->filename);

 

    return true;

 

  }

 

 

 

}

 

 

 

 

 

 

 

?>
This thread is more than a year old. Please don't revive it unless you have something important to add.

Join the conversation

You can post now and register later. If you have an account, sign in now to post with your account.

Guest
Reply to this topic...

×   Pasted as rich text.   Restore formatting

  Only 75 emoji are allowed.

×   Your link has been automatically embedded.   Display as a link instead

×   Your previous content has been restored.   Clear editor

×   You cannot paste images directly. Upload or insert images from URL.

×
×
  • Create New...

Important Information

We have placed cookies on your device to help make this website better. You can adjust your cookie settings, otherwise we'll assume you're okay to continue.