MatrixDAL.inc

<?php
require_once dirname(__FILE__).'/../DAL/DAL.inc';

class MatrixDAL extends DAL
{


    function __construct()
    {
        parent::__construct();

    }//end constructor


    public static function getQuery($systemid, $queryid, $params=Array(), $bindValues=TRUE)
    {
        // Work out the class and method name to call.
        $class    = $systemid.'Queries';
        $function = 'prepare'.$queryid.'Query';

        self::requireQueryClass($systemid);

        // Should we include the class here?
        if (method_exists($class, $function) === FALSE) {
            // Query not found. Throw DALException exception?
            throw new DALException('Could not load query '.$queryid.' in system '.$systemid);
        } else {
            return call_user_func(array($class, $function), $params, $bindValues);
        }

    }//end getQuery()




    public static function executeGrouped($systemid, $queryid, $params=Array())
    {
        $query = self::getQuery($systemid, $queryid, $params);
        return self::getGrouped($query);

    }//end executeGrouped()


    public static function executeGroupedAssoc($systemid, $queryid, $params=Array())
    {
        $query = self::getQuery($systemid, $queryid, $params);
        return self::getGroupedAssoc($query);

    }//end executeGrouped()


    public static function executeAssoc($systemid, $queryid, $col=NULL, $params=Array())
    {
        if ((func_num_args() === 3) && is_array($col)) {
            $params = $col;
            $col    = NULL;
        }
        $query = self::getQuery($systemid, $queryid, $params);
        $res   = self::getAssoc($query, $col);

        return $res;

    }//end executeAssoc()


    public static function executeAll($systemid, $queryid, $params=Array())
    {
        $query = self::getQuery($systemid, $queryid, $params);
        return self::getAll($query);

    }//end executeAll()


    public static function executeOne($systemid, $queryid, $params=Array())
    {
        $query  = self::getQuery($systemid, $queryid, $params);
        $result = self::getOne($query);

        // Oracle returns resourceid for LOB fields.
        // If result is a resource then retreive its contents.
        if (is_resource($result) === TRUE) {
            $result = stream_get_contents($result);
        }

        return $result;

    }//end executeOne()


    public static function executeQuery($systemid, $queryid=NULL, $params=Array())
    {
        $query = NULL;
        if (($systemid instanceof Query) === TRUE) {
            self::_startQueryTimer($systemid);
            $dalQuery = $systemid;
            $query    = $dalQuery->prepare();
        } else if ($queryid === NULL) {
            throw new DALException('No queryid provided for executeQuery.');
        } else {
            $dalQuery = self::getQuery($systemid, $queryid, $params);
            self::_startQueryTimer($dalQuery);
            $query    = $dalQuery->prepare();
        }

        try {
            self::execPdoQuery($query);
        } catch (PDOException $e) {
            throw new DALException($e->getMessage());
        }

        if (self::getDbType() == 'oci') {
            // OCI:
            $dalQuery->releaseLobs();
            $rows = oci_num_rows($query);
        } else {
            $rows = (int)$query->rowCount();
        }

        // DB2 returns -1 rows if no rows were affected.
        if ($rows === -1) {
            $rows = 0;
        }

        self::_endQueryTimer();

        return $rows;

    }//end executeQuery()



    public static function preparePdoQuery($sql)
    {
        $dbh = self::getDb();
        $db_type = self::getDbType();

        if ($db_type === 'oci') {
            // OCI:
            $query = oci_parse($dbh, $sql);
        } else {
            $query = $dbh->prepare($sql);
        }

        return $query;

    }//end preparePdoQuery()


    public static function bindValueToPdo($query, $name, $value, $dataType=NULL)
    {
        $dbh = self::getDb();
        $db_type = self::getDbType();

        if ($db_type === 'oci') {
            // OCI:
            // LOB handling needs a descriptor to be created.
            if ($dataType == 'PDO::PARAM_LOB') {
                $lob = oci_new_descriptor($dbh);
                $lob->write($value);
                $ret_val = oci_bind_by_name($query, ':'.$name, $lob, SQLT_CLOB);
            } else {
                $ret_val = oci_bind_by_name($query, ':'.$name, $value);
            }
            if ($ret_val === FALSE) {
                $oci_error = oci_error($query);
                throw new Exception('Unable to bind variable "'.$name.'" to query: '.$oci_error['code'].' '.$oci_error['message']);
            }
        } else {
            if ($dataType === NULL) {
                $query->bindValue(':'.$name, $value);
            } else {
                $query->bindValue(':'.$name, $value, $dataType);
            }
        }

    }//end bindValueToPdo()


    public static function bindValueToPdoByRef($query, $name, &$value, $dataType=NULL, $maxLength=NULL)
    {
        $dbh = self::getDb();
        $db_type = self::getDbType();

        if ($db_type === 'oci') {
            // OCI:
            // LOB handling needs a descriptor to be created.
            if ($dataType == 'PDO::PARAM_LOB') {
                $lob = oci_new_descriptor($dbh);
                $lob->write($value);
                $ret_val = oci_bind_by_name($query, ':'.$name, $lob, SQLT_CLOB);
            } else {
                if ($dataType & PDO::PARAM_INPUT_OUTPUT) {
                    $ret_val = oci_bind_by_name($query, ':'.$name, $value, $maxLength);
                } else {
                    $ret_val = oci_bind_by_name($query, ':'.$name, $value);
                }
                if (!$ret_val) {
                    $oci_error = oci_error($query);
                    throw new DALException('Unable to bind Oracle variable by reference: '.$oci_error['code'].' '.$oci_error['message']);
                }
            }
        } else {
            if ($dataType === NULL) {
                $query->bindValue(':'.$name, $value);
            } else {
                $query->bindValue(':'.$name, $value, $dataType, $maxLength);
            }
        }

    }//end bindValueToPdoByRef()


    public static function bindValuesToPdo($query, $name, $value)
    {

    }//end bindValuesToPdo()


    protected static function _getPdoDataType($systemId, $table, $column, $dataType=NULL)
    {
        if ($dataType === NULL) {
            return 'PDO::PARAM_STR';
        //    $dataType = self::getTableColumnTypes($systemId, $table, $column);
        }

        switch (strtoupper($dataType)) {
            case 'NUMERIC':
            case 'DECIMAL':
            case 'INTEGER':
            case 'SMALLINT':
            case 'REAL':
            case 'DOUBLE PRECISION':
            case 'FLOAT':
                $pdoType = 'PDO::PARAM_INT';
            break;
            case 'BOOLEAN':
                $pdoType = 'PDO::PARAM_BOOL';
            break;
            default:
                $pdoType = 'PDO::PARAM_STR';
        }

        return $pdoType;

    }//end _getPdoDataType()


    public static function quote($value)
    {
        $quoted_value = NULL;
        if (self::getDbType() == 'oci') {
            // We don't have PDO to help us here
            $quoted_value = '\''.str_replace('\'', '\'\'', $value).'\'';
        } else {
            $db = self::getDb();
            $quoted_value = $db->quote($value);
            if ($quoted_value === FALSE) {
                // If PDO won't quote it for us...
                $quoted_value = '\''.str_replace('\'', '\'\'', $value).'\'';
            }
        }

        return $quoted_value;

    }//end quote()


}
?>