TYPO3 Core

<?php

/***************************************************************

/**

* PHP SQL engine

* EXPERIMENTAL!

*

*

* 104: class t3lib_sqlengine extends t3lib_sqlparser

*

*

*

*

*

*

*

* 829: class t3lib_sqlengine_resultobj

*

* TOTAL FUNCTIONS: 27

* (This index is automatically created/updated by the extension "extdeveval")

*/

/**

* PHP SQL engine / server

* Basically this is trying to emulation SQL record selection by PHP, thus allowing SQL queries into alternative data storages managed by PHP.

class t3lib_sqlengine extends t3lib_sqlparser {

// array with data records: [table name][num.index] = records

// Internal, SQL Status vars:

/**

* Constrcutor

*/

*

* @return void

*/

$this->errorStatus = '';

$this->lastInsertedId = 0;

$this->lastAffectedRows = 0;

* @param array $fInfo Field configuration data

* @return mixed The processed input value

*/

$options = $this->parseFieldDef($fInfo['Type']);

case 'int':

case 'smallint':

case 'tinyint':

case 'mediumint':

$value = intval($value);

}

break;

case 'double':

break;

case 'varchar':

case 'char':

break;

case 'text':

case 'blob':

break;

case 'tinytext':

case 'tinyblob':

break;

case 'mediumtext':

case 'mediumblob':

break;

}

}

/********************************

*

* SQL queries

* @param array Field values as key=>value pairs.

* @return boolean TRUE on success and FALSE on failure (error is set internally)

*/

// Initialize

$this->resetStatusVars();

$this->readDataSource($table);

// If data source is set:

// Looking for unique keys:

$saveArray = array();

// Field name:

$fN = $fInfo['Field'];

// Set value:

$saveArray[$fN] = isset($fields_values[$fN]) ? $fields_values[$fN] : $options['Default'];

// Process value:

$this->processAccordingToConfig($saveArray[$fN], $fInfo);

// If an auto increment field is found, find the largest current uid:

// Get all UIDs:

$uidArray = array();

$uidArray[] = $r[$fN];

}

// If current value is blank or already in array, we create a new:

// Update "last inserted id":

$this->lastInsertedId = $saveArray[$fN];

$this->saveDataSource($table);

return TRUE;

return FALSE;

}

* @param array Field values as key=>value pairs.

* @return boolean TRUE on success and FALSE on failure (error is set internally)

*/

// Initialize:

$this->resetStatusVars();

$this->readDataSource($table);

// If anything is there:

// Parse WHERE clause:

$where = $this->parseWhereClause($where);

// Field information

// Traverse fields to update:

}

// Do query, returns array with keys to the data array of the result:

// Set "last affected rows":

$this->lastAffectedRows = count($itemKeys);

// Update rows:

// Traverse result set here:

// Traverse fields to update:

$this->data[$table][$dataArrayKey][$fName] = $fValue;

}

}

$this->saveDataSource($table);

}

return TRUE;

return FALSE;

}

* @param string WHERE clause

* @return boolean TRUE on success and FALSE on failure (error is set internally)

*/

// Initialize:

$this->resetStatusVars();

$this->readDataSource($table);

// If anything is there:

// Parse WHERE clause:

$where = $this->parseWhereClause($where);

// Do query, returns array with keys to the data array of the result:

// Set "last affected rows":

$this->lastAffectedRows = count($itemKeys);

// Remove rows:

// Traverse result set:

unset($this->data[$table][$dataArrayKey]);

}

}

return TRUE;

return FALSE;

}

* @param string Optional LIMIT value ([begin,]max), if none, supply blank string.

* @return object Returns result object, but if errors, returns false

*/

// Initialize:

$this->resetStatusVars();

// Create result object

$sqlObj = t3lib_div::makeInstance('t3lib_sqlengine_resultobj');

// Get table list:

$tableArray = $this->parseFromTables($from_table);

$this->readDataSource($table);

// If anything is there:

// Parse WHERE clause:

$where = $this->parseWhereClause($where_clause);

// Do query, returns array with keys to the data array of the result:

// Finally, read the result rows into this variable:

// Reset and return result:

reset($sqlObj->result);

return $sqlObj;

return FALSE;

}

* @param string Query to execute

* @return object Result object or false if error

*/

$res = t3lib_div::makeInstance('t3lib_sqlengine_resultobj');

$res->result = array();

return $res;

*

* @return string Error message, if any

*/

return $this->errorStatus;

}

* @param string Input String

* @return string String, with quotes escaped

*/

return addslashes($str);

}

/**************************************

*

* SQL admin functions

* @return array Tables in an array (tablename is in both key and value)

* @todo Should return table details in value! see t3lib_db::admin_get_tables()

*/

$whichTables = array();

return $whichTables;

}

* @param string Table name

* @return array Field information in an associative array with fieldname => field row

*/

$output = array();

return $output;

}

* @param string Table name

* @return array Key information in a numeric array

*/

$output = array();

return $output;

}

* @param string Query to execute

* @return pointer Result pointer

*/

return $this->sql_query($query);

}

/********************************

*

* Data Source I/O

* @return void

* @todo Table locking tools?

*/

$this->data[$table] = array();

}

* @return void

* @todo Table locking tools?

*/

debug($this->data[$table]);

}

/********************************

*

* SQL engine functions (PHP simulation of SQL) - still experimental

* @param array Where clause parsed into array

* @return array Array of keys pointing to result rows in $this->data[$table]

*/

$output = array();

// All keys:

$OR_index = 0;

$OR_index++;

}

}

$output = array_merge($output, $uidKeys);

}

$output = array_unique($output);

* @return void Data array passed by reference

* @see selectFromData()

*/

unset($itemKeys[$kk]);

}

}

$itemKeys = array_intersect($itemKeys, $subSelKeys);

}

} else {

$mod = strtoupper($config['modifier']);

case 'NOTLIKE':

case 'LIKE':

$like_value = strtolower($config['value'][0]);

$wildCard_begin = TRUE;

}

$wildCard_end = TRUE;

}

break;

case 'NOTIN':

case 'IN':

$in_valueArray = array();

}

break;

}

$field_value = $this->data[$table][$v][$config['field']];

// Calculate it:

}

// Compare it:

case '<=':

$bool = $field_value <= $config['value'][0];

break;

$bool = $field_value > $config['value'][0];

break;

case '=':

break;

case '!=':

break;

case 'NOTIN':

case 'IN':

break;

case 'NOTLIKE':

case 'LIKE':

$bool = TRUE;

} else {

}

break;

default:

$bool = $field_value ? TRUE : FALSE;

}

// General negation:

// Modify?

case 'NOT':

case '!':

$bool = !$bool;

}

// Action:

unset($itemKeys[$kk]);

}

}

* @param string Fieldlist (commaseparated)

* @return array Result array with "rows"

*/

$output = array();

$output[$kValue] = $this->data[$table][$kValue];

} else {

$output[$kValue][$fieldName] = $this->data[$table][$kValue][$fieldName];

}

}

}

/*************************

*

* Debugging

* @param array Result set array (array of rows)

* @return string HTML table

*/

$fields = array_keys(current($array));

<td>IDX</td>';

}

}

/**

*

* @return integer

*/

return count($this->result);

}

*

* @return array Associative array

*/

$row = current($this->result);

next($this->result);

return $row;

*

* @return array Numerical array

*/

$resultRow = $this->sql_fetch_assoc();

$numArray = array();

}

return $numArray;

}

* @param integer Position pointer.

* @return boolean Returns true on success

*/

reset($this->result);

next($this->result);

}

return TRUE;

*

* @return string Blank string, not supported (it seems)

*/

return '';

}

}

include_once($TYPO3_CONF_VARS[TYPO3_MODE]['XCLASS']['t3lib/class.t3lib_sqlengine.php']);

}