DataConnector_pdo_oci.php

<?php
 
namespace ceLTIc\LTI\DataConnector;
 
class DataConnector_pdo_oci extends DataConnector_pdo
{
 
    private static $sequence = array();
 
    public function __construct($db, $dbTableNamePrefix = '')
    {
        parent::__construct($db, $dbTableNamePrefix);
        $this->dateFormat = 'd-M-Y';
        $db->setAttribute(\PDO::ATTR_STRINGIFY_FETCHES, true);
        if (empty(self::$sequence)) {
            $n = strlen($this->dbTableNamePrefix) + 6;
            $sql = 'SELECT TABLE_NAME, DATA_DEFAULT FROM USER_TAB_COLUMNS ' .
                "WHERE (TABLE_NAME LIKE UPPER('{$this->dbTableNamePrefix}lti2_%')) AND (COLUMN_NAME = UPPER(CONCAT(SUBSTR(TABLE_NAME, {$n}), '_pk')))";
            $query = $this->db->prepare($sql);
            if ($this->executeQuery($sql, $query)) {
                $row = $query->fetchAll(\PDO::FETCH_ASSOC);
                foreach ($row as $entry) {
                    self::$sequence[substr($entry['TABLE_NAME'], strlen($this->dbTableNamePrefix))] = str_replace('nextval',
                        'currval', $entry['DATA_DEFAULT']);
                }
            }
        }
    }
 
###
###    PROTECTED METHODS
###
 
    protected function getLastInsertId($tableName)
    {
        $pk = 0;
        $sql = 'SELECT ' . self::$sequence[strtoupper($tableName)] . ' FROM dual';
        $query = $this->db->prepare($sql);
        if ($this->executeQuery($sql, $query)) {
            $row = $query->fetch(\PDO::FETCH_ASSOC);
            $pk = intval(array_values($row)[0]);
        }
        return $pk;
    }
 
}