Home | Classes | Modules | Annotated | Functions | Files

MSSQLResultSet.php

Go to the documentation of this file.

<?php
/*
 *  $Id: MSSQLResultSet.php,v 1.1 2004/05/03 16:19:39 micha Exp $
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *
 * This software consists of voluntary contributions made by many individuals
 * and is licensed under the LGPL. For more information please see
 * <http://creole.phpdb.org>.
 */

require_once 'creole/ResultSet.php';
require_once 'creole/common/ResultSetCommon.php';

class MSSQLResultSet extends ResultSetCommon
{    
  var $offset = 0;
  
  var $limit = 0;   
  
  function _setOffset($offset)
  {
    $this->offset = $offset;
    if ($offset > 0) {
      $this->seek(0);  // 0 becomes $offset by seek() method
    }
  }
  
  function _setLimit($limit)
  {
    $this->limit = $limit;
  }
  
  function seek($rownum)
  {
    // support emulated OFFSET
    $actual = $rownum + $this->offset;
    
    if (($this->limit > 0 && $rownum >= $this->limit) || $rownum < 0) {
      // have to check for rownum < 0, because mssql_seek() won't
      // complain if the $actual is valid.
      return false;
    }
            
    // MSSQL rows start w/ 0, but this works, because we are
    // looking to move the position _before_ the next desired position
    if (!@mssql_data_seek($this->result, $actual)) {
      return false;
    }

    $this->cursorPos = $rownum;
    return true;
  }
  
  function next()
  {
    // support emulated LIMIT
    if ( $this->limit > 0 && ($this->cursorPos >= $this->limit) ) {
      if (($e = $this->afterLast()) !== true) {
        return $e;
      }
      return false;
    }
    
    $this->fields = mssql_fetch_array($this->result, $this->fetchmode);        
            
    if (!$this->fields) {
      if ($errmsg = mssql_get_last_message()) {
        return new SQLException(CREOLE_ERROR, "Error fetching result", $errmsg);
      } else {
        // We've advanced beyond end of recordset.
        if (($e = $this->afterLast()) !== true) {
          return $e;
        }
        return false;
      }          
    }
    
    if (!$this->ignoreAssocCase) {
      $this->fields = array_change_key_case($this->fields, CASE_LOWER);
    }
    
    // Advance cursor position
    $this->cursorPos++;
    return true;
  }
  
  function getRecordCount()
  {
    $rows = @mssql_num_rows($this->result);
    if ($rows === null) {
      return new SQLException(CREOLE_ERROR, 'Error getting record count', mssql_get_last_message());
    }
    // adjust count based on emulated LIMIT/OFFSET
    $rows -= $this->offset;
    return ($this->limit > 0 && $rows > $this->limit ? $this->limit : $rows);
  }

  function close()
  {
    $ret = @mssql_free_result($this->result);
    $this->result = false;
    $this->fields = array();
    $this->limit = 0;
    $this->offset = 0;        
  }   

}

---

This file is part of the Creole[php4] library.