File Source for postgresql.php

<?php
/**
* dbscript for PHP 4 & 5 - restful crud framework
* @version 0.1.2 -- 19-Feb-2007
* @author Brian Hendrickson <brian@dbscript.net>
* @link http://dbscript.net/
* @copyright Copyright 2007 Brian Hendrickson
* @license http://www.opensource.org/licenses/mit-license.php MIT License
* @package dbscript
*/
/**
* PostgreSQL
*
* adapter for the PostgreSQL database system
*
* Usage:
* <code>
* $db = new PostgreSQL ( 'hostname', 'database_name', 'username', 'password' );
* </code>
*
* More info...
* {@link http://dbscript.net/postgresql}
*
* @package dbscript
* @author Brian Hendrickson <brian@dbscript.net>
* @access public
* @version 0.1.2
* @todo support array datatypes
*/
class PostgreSQL extends Database {
var $connstr;
var $oid;
function PostgreSQL() {
$this->db_open = false;
$this->models = array();
$this->recordsets = array();
$this->max_blob_length = 6144000; // default max blob file size is 6MB
$this->max_string_length = 1024000; // default max string length is 1MB
$this->datatype_map = array(
'real' => 'float',
'double precision' => 'float',
'int' => 'int',
'integer' => 'int',
'smallint' => 'int',
'bigint' => 'int',
'serial' => 'int',
'serial primary key' => 'int',
'bigserial' => 'int',
'numeric' => 'int',
'text' => 'text',
'char' => 'char',
'varchar' => 'char',
'character' => 'char',
'character varying' => 'char',
'timestamp' => 'time',
'timestamp without time zone' => 'time',
'timestamp with time zone' => 'time',
'time' => 'time',
'time without time zone' => 'time',
'time with time zone' => 'time',
'date' => 'date',
'boolean' => 'bool',
'oid' => 'blob'
);
$func_args = func_get_args();
$argnames = array('host','dbname','user','password','port');
$this->true_values = array('t','true','1',true);
$this->alias_array = array();
for ($i = 0; $i < count($func_args); $i++) {
if (strlen($func_args[$i]) > 0)
$this->connstr .= $argnames[$i] . '=' . $func_args[$i] . ' ';
}
$this->connect();
}
function connect() { // establish a connection to the database
$this->conn = @pg_connect($this->connstr);
if (!$this->conn) {
$this->db_open = false;
trigger_error("error in connect function of class PostgreSQL in postgresql.php".@pg_last_error($this->conn), E_USER_ERROR );
} else {
$this->db_open = true;
}
return $this->db_open;
}
function escape_string($string) {
if (!(strlen($string) > 0)) { return ""; }
$result = @pg_escape_string($string);
if (!$result && !(is_numeric($string)))
trigger_error("error in escape_string in postgresql.php".@pg_last_error($this->conn), E_USER_ERROR );
return $result;
}
function get_result( $sql, $returnfalse = NULL ) { /* run an SQL query */
$request =& request_object();
if (isset($request->params)) {
$request->set_param( 'currentquery', $sql );
trigger_before( 'get_result', $request, $this );
}
$result = @pg_query( $this->conn, $sql );
if (!$result && $returnfalse === NULL)
trigger_error("error in get_result in postgresql.php".@pg_last_error($this->conn)." ".$sql, E_USER_ERROR );
elseif (!$result && $returnfalse)
return true;
else
return $result;
}
function next_primary_key( $table, $pkfield, $sequence_name=NULL ) {
if ($sequence_name == NULL) {
$sql = "SELECT relname FROM pg_class WHERE relkind='S' and substr(relname,1,".strlen($table).")='$table'";
$result = $this->get_result($sql);
if ($this->num_rows($result) > 0) {
$seq = $this->result_value($result,0,"relname");
} else {
return '';
}
} else {
$seq = $sequence_name;
}
$pk_result = $this->get_result("SELECT nextval('$seq')");
if ($this->num_rows($result) > 0)
$pkvalue = $this->result_value( $pk_result, 0, "nextval" );
else
trigger_error("error selecting nexval in next_primary_key in postgresql.php".@pg_last_error($this->conn), E_USER_ERROR );
return $pkvalue;
}
function last_insert_id(&$result,$pkfield,$table) { // returns the id of the most recently modified record
$oid = @pg_last_oid($result);
if (!$oid)
trigger_error(@pg_last_error($this->conn), E_USER_ERROR );
$sql = "SELECT ". $pkfield . " FROM " . $table . " WHERE oid = " . $oid;
$res = $this->get_result($sql);
if (!$res)
trigger_error("error in last_insert_id in postgresql.php".@pg_last_error($this->conn), E_USER_ERROR );
else
return $this->result_value($res,0,$pkfield);
}
function result_value(&$result,$resultindex,$field) { // get a single value from a result set
$return = pg_fetch_result($result,$resultindex,$field);
if (!$return && $return != 0)
trigger_error("error in result_value in postgresql.php".@pg_last_error($this->conn), E_USER_ERROR );
else
return $return;
}
function close() {
$args = func_get_args();
pg_close( $this->conn );
if ( isset( $args[0] ) ) {
if ( strlen($args[0]) > 0 ) {
header( "Location:" . $args[0] );
exit;
}
}
}
function &get_table($table) {
if ( isset( $this->models[$table] ) )
return $this->models[$table];
$data_model = model_path() . classify($table) . '.php';
if (file_exists($data_model))
require_once $data_model;
$this->models[$table] = new PostgreSQLTable( $table, $this );
return $this->models[$table];
}
function &model($model) {
return $this->get_table(tableize($model));
}
function fetch_array( &$result, $row=NULL ) {
if (is_numeric($row))
$this->seek_row( $result, $row );
return pg_fetch_array( $result, $row, PGSQL_ASSOC );
}
function fetch_row( &$result, $row=NULL ) {
if ( ( is_numeric( $row ) ) )
return pg_fetch_row( $result, $row );
return pg_fetch_row( $result );
}
function seek_row(&$result,$row) {
return true;
}
function query_limit($limit,$offset) {
return " LIMIT " . $limit . " OFFSET " . $offset;
}
function blob_value( &$rec, $field, &$value ) {
return $value;
}
function sql_insert_for( &$rec ) {
$sql = "INSERT INTO " . $rec->table . " (";
$comma = '';
$fields = '';
$values = '';
foreach (array_unique($rec->modified_fields) AS $modified_field) {
$datatype = $this->get_mapped_datatype($this->models[$rec->table]->field_array[$modified_field]);
$this->pre_insert( $rec, $modified_field, $datatype );
if ( !( $datatype == 'blob' && ( !(strlen( $rec->attributes[$modified_field] ) > 0 ) ) ) ) {
$fields .= $comma . $modified_field;
$values .= $comma . $this->quoted_insert_value( $rec, $modified_field );;
$comma = ',';
}
}
$sql .= $fields . ") VALUES (" . $values . ")";
return $sql;
}
function sql_update_for( &$rec ) {
$sql = "UPDATE ";
$sql .= $rec->table . ' SET ';
$comma = '';
foreach (array_unique($rec->modified_fields) AS $modified_field) {
$datatype = $this->get_mapped_datatype($this->models[$rec->table]->field_array[$modified_field]);
$this->pre_update( $rec, $modified_field, $datatype );
if ( !( $datatype == 'blob' && ( !(strlen( $rec->attributes[$modified_field] ) > 0 ) ) ) ) {
$sql .= $comma . $this->quoted_update_value( $rec, $modified_field );
$comma = ',';
}
}
$sql .= " WHERE " . $rec->primary_key . "='" . $rec->attributes[$rec->primary_key] . "'";
return $sql;
}
function sql_select_for( &$rec, $id ) {
return "SELECT ".$rec->selecttext." FROM ".$rec->table." WHERE ".$rec->primary_key." = '".$id."'";
}
function sql_delete_for( &$rec ) {
$pkfield = $rec->primary_key;
foreach ($rec->attributes as $key=>$value) {
$datatype = $this->get_mapped_datatype($this->models[$rec->table]->field_array[$key]);
if ($datatype == 'blob' && strlen($rec->attributes[$rec->primary_key]) > 0) {
$oid_result = $this->get_result("select ".$key." from ".$rec->table." where ".$rec->primary_key." = '".$rec->attributes[$rec->primary_key]."'");
$prev_oid = $this->fetch_array($oid_result,0,$key);
if (isset($prev_oid[0]) && $prev_oid[0] > 0)
$result = $this->large_object_delete($prev_oid[0]);
}
}
$sql = 'DELETE FROM ' . $rec->table . ' WHERE ' . $pkfield . ' = ' . $rec->$pkfield;
return $sql;
}
function select_distinct( $field, $table, $orderby ) {
return "SELECT DISTINCT $field, " . $this->models[$table]->primary_key . " FROM $table ORDER BY $orderby DESC";
}
function quoted_update_value( &$rec, $modified_field ) {
return $modified_field . "='" . $this->escape_string($rec->attributes[$modified_field]) . "'";
}
function quoted_insert_value( &$rec, $modified_field ) {
return "'" . $this->escape_string($rec->attributes[$modified_field]) . "'";
}
function pre_insert( &$rec, $modified_field, $datatype ) {
if (isset($this->models[$rec->table]->field_attrs[$modified_field]['required'])) {
if (!(strlen( $rec->attributes[$modified_field] ) > 0))
trigger_error( "$modified_field is a required field", E_USER_ERROR );
}
if (isset($this->models[$rec->table]->field_attrs[$modified_field]['unique'])) {
$result = $this->get_result("select ".$modified_field." from ".$rec->table." where ".$modified_field." = '".$rec->attributes[$modified_field]."'");
if ($this->num_rows($result) > 0)
trigger_error( "$modified_field must be unique!", E_USER_ERROR );
}
if ($datatype == 'time' && !(strlen($rec->attributes[$modified_field]) > 0))
$rec->attributes[$modified_field] = date("Y-m-d H:i:s",strtotime("now"));
if ($datatype == 'blob' && strlen($rec->attributes[$modified_field]) > 0) {
$oid = $this->large_object_create($rec->table,$rec->attributes[$modified_field]);
if ($oid > 0)
$rec->attributes[$modified_field] = $oid;
}
if ($datatype == 'bool') {
if ( in_array( $rec->attributes[$modified_field], $this->true_values, true ) )
$rec->attributes[$modified_field] = "true";
else
$rec->attributes[$modified_field] = "false";
}
if ($modified_field == $rec->primary_key) {
if ( in_array( $rec->attributes[$rec->primary_key], array( '', 0, '0' ), true ))
$rec->attributes[$modified_field] = $this->next_primary_key( $rec->table, $modified_field);
}
}
function pre_update( &$rec, $modified_field, $datatype ) {
if (isset($this->models[$rec->table]->field_attrs[$modified_field]['required'])) {
if (!(strlen( $rec->attributes[$modified_field] ) > 0))
trigger_error( "$modified_field is a required field", E_USER_ERROR );
}
if (isset($this->models[$rec->table]->field_attrs[$modified_field]['unique'])) {
$result = $this->get_result("select ".$modified_field." from ".$rec->table." where ".$modified_field." = '".$rec->attributes[$modified_field]."' and ".$rec->primary_key." != '".$rec->attributes[$rec->primary_key]."'");
if ($this->num_rows($result) > 0)
trigger_error( "$modified_field must be unique!", E_USER_ERROR );
}
if ($datatype == 'blob' && (strlen( $rec->attributes[$modified_field] ) > 0 )) {
$oid_result = $this->get_result("select ".$modified_field." from ".$rec->table." where ".$rec->primary_key." = '".$rec->attributes[$rec->primary_key]."'");
if ($this->num_rows($oid_result) > 0) {
$prev_oid = $this->fetch_array($oid_result);
if (isset($prev_oid[0]) && $prev_oid[0] > 0)
$result = $this->large_object_delete($prev_oid);
}
$oid = $this->large_object_create($rec->table,$rec->attributes[$modified_field]);
if ($oid > 0)
$rec->attributes[$modified_field] = $oid;
}
}
function post_insert( &$rec, &$result ) {
if (!$result) { trigger_error("Sorry, the record could not be saved due to a database error.", E_USER_ERROR ); }
}
function num_rows(&$result) {
return @pg_num_rows($result);
}
function num_fields(&$result) {
return @pg_num_fields($result);
}
function field_name(&$result, $index) {
return @pg_field_name($result, $index);
}
function large_object_create($table,$file) {
$return = false;
$filename = basename($file);
if (!$filename) { trigger_error("Error determining base name of large object file $filename", E_USER_ERROR ); }
$handle = fopen($file,"r");
if (!$handle) { trigger_error("Error opening large object file $file", E_USER_ERROR ); }
$buffer = fread($handle,filesize($file));
if (!$buffer) { trigger_error("Error reading large object file $file", E_USER_ERROR ); }
$result = fclose($handle);
$result = @pg_query($this->conn, "BEGIN");
if (!$result) { trigger_error("error starting l_o_c transaction: ".@pg_last_error($this->conn), E_USER_ERROR ); }
$oid = @pg_lo_create($this->conn);
if (!$oid) { trigger_error("error in pg_l_o_c: ".@pg_last_error($this->conn), E_USER_ERROR ); }
#$result = pg_query($this->conn,"UPDATE $table SET $field = $oid WHERE $pkfield = '$pkvalue'");
#if (!$result) { trigger_error("Error updating file OID", E_USER_ERROR ); }
$handle = @pg_lo_open($this->conn, $oid, "w");
if (!$handle) { trigger_error("error in pg_l_o_o: ".@pg_last_error($this->conn), E_USER_ERROR ); }
$result = @pg_lo_write($handle, $buffer);
if (!$result) { trigger_error("error in l_o_w: ".@pg_last_error($this->conn), E_USER_ERROR ); }
$result = @pg_lo_close($handle);
if (!$result) { trigger_error("error in l_o_close: ".@pg_last_error($this->conn), E_USER_ERROR ); }
$result = @pg_query($this->conn, "COMMIT");
if (!$result) { trigger_error("error committing l_o_c transaction: ".@pg_last_error($this->conn), E_USER_ERROR ); }
else {
$return = $oid;
}
return $return;
}
function large_object_fetch($oid, $return = false) {
//$result = pg_query($this->conn,"SELECT $field FROM $table WHERE $");
//if (!$result) { trigger_error("Error in select file OID", E_USER_ERROR ); }
//$oid = pg_result($result,0,$fieldname);
//if (!$oid) { trigger_error("Error in file OID result", E_USER_ERROR ); }
$result = @pg_query($this->conn,"BEGIN");
if (!$result) { trigger_error("error starting l_o_f transaction: ".@pg_last_error($this->conn), E_USER_ERROR ); }
$handle = @pg_lo_open($this->conn, $oid, "r");
if (!$handle) { trigger_error("error in l_o_f/l_o_o: ".@pg_last_error($this->conn), E_USER_ERROR ); }
if ($return)
$return = @pg_lo_read($handle,$this->max_blob_length);
else
@pg_lo_read_all($handle);
if (!$buffer) { trigger_error("error in l_o_read_all: ".@pg_last_error($this->conn), E_USER_ERROR ); }
$result = @pg_lo_close($handle);
if (!$result) { trigger_error("error in l_o_close: ".@pg_last_error($this->conn), E_USER_ERROR ); }
$result = @pg_query($this->conn,"COMMIT");
if (!$result) { trigger_error("error committing l_o_f transaction: ".@pg_last_error($this->conn), E_USER_ERROR ); }
return $return;
}
function large_object_delete($oid) {
$return = false;
#$result = pg_query($this->conn,"SELECT $field FROM $table WHERE $pkfield = '$pkvalue'");
#if (!$result) { trigger_error("Error in select file OID", E_USER_ERROR ); }
#$oid = pg_result($result,0,$field);
#if (!$oid) { trigger_error("Error in file OID result", E_USER_ERROR ); }
$result = @pg_query($this->conn,"BEGIN");
if (!$result) { trigger_error("error starting l_o_d transaction: ".@pg_last_error($this->conn), E_USER_ERROR ); }
$result = @pg_lo_unlink($this->conn, $oid);
if (!$result) { trigger_error("error in l_o_unlink: ".@pg_last_error($this->conn), E_USER_ERROR ); }
$result = @pg_query($this->conn,"COMMIT");
if (!$result) { trigger_error("error committing l_o_d transaction: ".@pg_last_error($this->conn), E_USER_ERROR ); }
#$result = pg_query($this->conn,"DELETE FROM $table WHERE lo_oid = $oid");
#if (!$result) { trigger_error("Error deleting file OID", E_USER_ERROR ); }
else {
$return = true;
}
return $return;
}
function add_table( $table, $field_array ) {
if (!(count($field_array)>0)) trigger_error( "Error creating table. No fields are defined. Use \$model->auto_field and \$model->text_field etc.", E_USER_ERROR );
$sql = "CREATE TABLE $table (";
$comma = "";
foreach ( $field_array as $field => $data_type ) {
$sql .= "$comma $field $data_type";
$comma = ",";
}
$sql .= ")";
$result = $this->get_result($sql);
}
function add_field( $table, $field, $data_type ) {
$sql = "ALTER TABLE $table ADD COLUMN $field $data_type";
$result = $this->get_result($sql);
}
function has_table($t) {
return in_array( $t, $this->get_tables(), true );
}
function get_tables() {
$tables = array();
#$sql = "SELECT a.relname AS Name FROM pg_class a, pg_user b ";
#$sql .= "WHERE ( relkind = 'r') and relname !~ '^pg_' AND relname !~ '^sql_' ";
#$sql .= "AND relname !~ '^xin[vx][0-9]+' AND b.usesysid = a.relowner ";
#$sql .= "AND NOT (EXISTS (SELECT viewname FROM pg_views WHERE viewname=a.relname))";
$sql = "SELECT tablename AS relname FROM pg_catalog.pg_tables";
$sql .= " WHERE schemaname NOT IN ('pg_catalog', 'information_schema',";
$sql .= " 'pg_toast') ORDER BY tablename";
$result = $this->get_result($sql);
while ($arr = $this->fetch_array($result)) {
foreach($arr as $key=>$value) {
if (strtolower(str_replace( '_', '', $value)) != strtolower(classify($value)) )
$tables[] = $value;
}
}
return $tables;
}
function get_fields($table) {
$datatypes = array();
$fieldindex = array();
$fieldindex[] = "";
#$sql = "SELECT column_name, data_type FROM information_schema.columns ";
#$sql .= "WHERE table_schema = 'public' AND table = '$table'";
$sql = "SELECT a.attname, pg_catalog.format_type(a.atttypid, a.atttypmod)";
$sql .= " as type FROM pg_catalog.pg_attribute a LEFT JOIN";
$sql .= " pg_catalog.pg_attrdef adef ON a.attrelid=adef.adrelid AND";
$sql .= " a.attnum=adef.adnum LEFT JOIN pg_catalog.pg_type t ON";
$sql .= " a.atttypid=t.oid WHERE a.attrelid = (SELECT oid FROM";
$sql .= " pg_catalog.pg_class WHERE relname='$table')";
$sql .= " and a.attname != 'tableoid' and a.attname != 'oid'";
$sql .= " and a.attname != 'xmax' and a.attname != 'xmin'";
$sql .= " and a.attname != 'cmax' and a.attname != 'cmin'";
$sql .= " and a.attname != 'ctid' and a.attname != 'otre'";
$sql .= " and a.attname not ilike '%..%' order by a.attnum ASC";
$result = $this->get_result($sql,true);
if (!$result) return $datatypes;
while ($arr = $this->fetch_array($result)) {
foreach($arr as $key=>$value) {
if ($key == "attname") {
$field = $value;
$fieldindex[] = $value;
} elseif ($key == "type") {
$type = $value;
}
}
$datatypes[$field] = $type;
}
$sql = "SELECT idx.indkey, idx.indisunique, idx.indisprimary";
$sql .= " FROM pg_catalog.pg_class c, pg_catalog.pg_class c2,";
$sql .= " pg_catalog.pg_index idx";
$sql .= " WHERE c.oid = idx.indrelid";
$sql .= " AND idx.indexrelid = c2.oid";
$sql .= " AND c.relname = '$table'";
#$sql .= " AND idx.isprimary = true";
$result = $this->get_result($sql);
while ($row = pg_fetch_row($result)) {
if (!(strstr($row[0], ' ')))
$datatypes[$table."_primary_key"] = $fieldindex[$row[0]];
}
return $datatypes;
}
}
/**
* PostgreSQL Table
*
* data model for a single PostgreSQL table
*
* Usage:
* <code>
* $people = $db->get_table( 'people' );
* </code>
*
* More info...
* {@link http://dbscript.net/postgresqltable}
*
* @package dbscript
* @author Brian Hendrickson <brian@dbscript.net>
* @access public
* @param string $table
* @param object $db
* @version 0.1.2
*/
class PostgreSQLTable extends Model {
function PostgreSQLTable( $table, &$db ) {
$this->table = $table;
$db->models[$table] =& $this;
$this->params = array('resource'=>$table);
$this->access_list = array();
$this->relations = array();
$this->allowed_methods = array( 'get', 'post', 'put', 'delete' );
$this->field_array = $db->get_fields( $this->table );
if ( count( $this->field_array ) > 0 )
$this->exists = true;
else
$this->exists = false;
if (isset($this->field_array[$this->table."_primary_key"])) {
$this->set_primary_key( $this->field_array[$this->table."_primary_key"] );
$this->field_array = drop_array_element($this->field_array,$this->table."_primary_key");
}
if ( class_exists( classify( $table )))
$this->register( classify( $table ) );
}
function auto_field( $field ) {
$this->set_field( $field, "serial primary key" );
$this->set_primary_key( $field );
}
function enum_field( $field, $values ) {
$this->set_field( $field, $values );
}
function float_field( $field ) {
$this->set_field( $field, "double precision" );
}
function bool_field( $field ) {
$this->set_field( $field, "boolean" );
}
function char_field( $field ) {
$args = func_get_args();
if (count($args)>1)
$len = $args[1];
else
$len = "255";
$this->set_field( $field, "varchar($len)" );
}
function date_field( $field ) {
$this->set_field( $field, "date" );
}
function file_field( $field ) {
$this->set_field( $field, "oid" );
}
function int_field( $field ) {
$this->set_field( $field, "int" );
}
function text_field( $field ) {
$this->set_field( $field, "text" );
}
function time_field( $field ) {
$this->set_field( $field, "timestamp with time zone" );
}
function get_query( $id=NULL, $find_by=NULL ) {
$db =& db_object();
trigger_before( 'get_query', $this, $db );
$pkfield = $this->primary_key;
if ($find_by == NULL)
$find_by = $this->primary_key;
$relfields = array();
$relfields = $this->relations;
$table = $this->table;
$fieldstring = '';
$sql = "SELECT " . "\n";
if (!array_key_exists($pkfield,$this->field_array))
$sql .= "$table.$pkfield as \"$table.$pkfield\", " . "\n";
foreach ($this->field_array as $fieldname=>$datatypename) {
if (!(!(strpos($fieldname,".") === false)))
$fieldname = $table . "." . $fieldname;
$fieldstring .= "$fieldname as \"$fieldname\", " . "\n";
}
$leftsql = "";
$first = true;
if (count($relfields) > 0) {
foreach ($relfields as $key=>$val) {
$spl = split("\.",$val["fkey"]);
if (($val["type"] != 'child-many') && isset($db->models[$spl[0]]))
$leftsql .= "(";
}
$skippedrel = false;
foreach ($relfields as $key=>$val) {
$spl = split("\.",$val["fkey"]);
if (($val["type"] == 'child-many') || !(isset($db->models[$spl[0]]))) {
if ($first)
$skippedrel = true;
continue;
}
foreach ($db->models[$spl[0]]->field_array as $fieldname=>$datatypename) {
$fieldstring .= $spl[0].".".$fieldname." as \"".$spl[0].".".$fieldname."\", " . "\n";
}
if ($first)
$leftsql .= $table;
$leftsql .= " left join " . $spl[0] . " on ".$table.".".$val["col"]." = " . $val["fkey"];
$leftsql .= ")";
$first = false;
}
}
$fieldstring = substr($fieldstring,0,-3) . " " . "\n";
$sql .= $fieldstring;
$sql .= "FROM ";
$sql .= $leftsql;
if (!(strlen($leftsql) > 1))
$sql .= $table;
if ($id != NULL)
$sql .= " WHERE $table.$find_by = '$id' ";
if (!(isset($this->orderby)))
$this->orderby = $table . "." . $pkfield;
if (!(isset($this->order)))
$this->order = "DESC";
if (!(isset($this->offset)))
$this->offset = 0;
if (!(isset($this->limit)))
$this->limit = 20;
$sql .= " ORDER BY " . $this->orderby . " ";
$sql .= $this->order . $db->query_limit($this->limit,$this->offset);
if (class_exists(classify($table)))
$this->custom_class = classify($table);
trigger_after( 'get_query', $this, $db );
return $sql;
}
}
?>

Source for file postgresql.php