<?php
/**
 * ADOdb Lite Extend Module for Mysqlt
 * 
 */

eval('class mssqlpo_extend_EXTENDER extends '. $last_module . '_ADOConnection { }');

class mssqlpo_extend_ADOConnection extends mssqlpo_extend_EXTENDER
{
	function &GetAssoc($sql, $inputarr=false, $force_array = false, $first2cols = false)
	{
		$data = false;
		$result =& $this->Execute($sql, $inputarr);
		if ($result) {
			$data =& $result->GetAssoc($force_array, $first2cols);
			$result->Close();
		}
		return $data;
	}

	/**
	 * Generates a sequence id and stores it in $this->genID;
	 * GenID is only available if $this->hasGenID = true;
	 *
	 * @param seqname		name of sequence to use
	 * @param startID		if sequence does not exist, start at this ID
	 * @return		0 if not supported, otherwise a sequence id
	 */
	var $genID = 0;

	function GenID($seqname='adodbseq', $startID=1)
	{
		$this->Execute('BEGIN TRANSACTION adodbseq');
		$result = $this->Execute("update $seq with (tablock,holdlock) set id = id + 1");
		if (!$result) {
			$this->Execute("create table $seq (id float(53))");
			$result = $this->Execute("insert into $seq with (tablock,holdlock) values($start)");
			if (!$result) {
				$this->Execute('ROLLBACK TRANSACTION adodbseq');
				return false;
			}
			$this->Execute('COMMIT TRANSACTION adodbseq'); 
			return $start;
		}
		$num = $this->GetOne("select id from $seq");
		$this->Execute('COMMIT TRANSACTION adodbseq'); 
		return $num;
	}

	function CreateSequence($seqname='adodbseq',$startID=1)
	{
		return false;
	}

	function DropSequence($seqname='adodbseq')
	{
		return false;
	}

}

eval('class mssqlpo_extend_resultset_EXTENDER extends '. $last_module . '_ResultSet { }');

class mssqlpo_extend_ResultSet extends mssqlpo_extend_resultset_EXTENDER
{
	function &GetAssoc($force_array = false, $first2cols = false) 
	{
		$results = false;
		
		if ($this->_numOfFields > 1) {
			$numIndex = isset($this->fields[0]);
			$results = array();
			if (!$first2cols && ($this->_numOfFields > 2 || $force_array)) {
				if ($numIndex) {
					while (!$this->EOF) {
						$results[trim($this->fields[0])] = array_slice($this->fields, 1);
						$this->MoveNext();
					}
				} else {
					while (!$this->EOF) {
						$results[trim(reset($this->fields))] = array_slice($this->fields, 1);
						$this->MoveNext();
					}
				}
			} else {
				if ($numIndex) {
					while (!$this->EOF) {
						$results[trim(($this->fields[0]))] = $this->fields[1];
						$this->MoveNext();
					}
				} else {
					while (!$this->EOF) {
						$v1 = trim(reset($this->fields));
						$v2 = ''.next($this->fields); 
						$results[$v1] = $v2;
						$this->MoveNext();
					}
				}
			}
		}
		return $results; 
	}

	function PO_RecordCount($table="", $condition="")
	{
		$lnumrows = $this->_numOfRows;
		if($lnumrows == -1 && $this->connectionId)
		{
			if($table)
			{
				if ($condition)
					$condition = " WHERE " . $condition; 
				$resultrows = &$this->connectionId->Execute("SELECT COUNT(*) FROM $table $condition");
				if ($resultrows)
					$lnumrows = reset($resultrows->fields);
			}
		}
		return $lnumrows;
	}

	function CurrentRow()
	{
		return $this->_currentRow;
	}

	function AbsolutePosition()
	{
		return $this->_currentRow;
	}

	function NextRecordSet()
	{
		if (!mssql_next_result($this->resultId)) return false;
		$this->_inited = false;
		$this->bind = false;
		$this->_currentRow = -1;
		$this->_numOfRows = @mssql_num_rows($this->resultId);
		$this->_numOfFields = @mssql_num_fields($this->resultId);
		if ($this->_numOfRows != 0 && $this->_numOfFields) {
			$this->_currentRow = 0;
			$this->_fetch();
		} else {
			$this->EOF = true;
		}
		return true;
	}

}
?>