1<?php
2// This file is part of Moodle - http://moodle.org/
3//
4// Moodle is free software: you can redistribute it and/or modify
5// it under the terms of the GNU General Public License as published by
6// the Free Software Foundation, either version 3 of the License, or
7// (at your option) any later version.
8//
9// Moodle is distributed in the hope that it will be useful,
10// but WITHOUT ANY WARRANTY; without even the implied warranty of
11// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
12// GNU General Public License for more details.
13//
14// You should have received a copy of the GNU General Public License
15// along with Moodle.  If not, see <http://www.gnu.org/licenses/>.
16
17/**
18 * Oracle specific recordset.
19 *
20 * @package    core_dml
21 * @copyright  2008 Petr Skoda (http://skodak.org)
22 * @license    http://www.gnu.org/copyleft/gpl.html GNU GPL v3 or later
23 */
24
25defined('MOODLE_INTERNAL') || die();
26
27require_once(__DIR__.'/moodle_recordset.php');
28
29class oci_native_moodle_recordset extends moodle_recordset {
30
31    protected $stmt;
32    protected $current;
33
34    public function __construct($stmt) {
35        $this->stmt  = $stmt;
36        $this->current = $this->fetch_next();
37    }
38
39    public function __destruct() {
40        $this->close();
41    }
42
43    private function fetch_next() {
44        if (!$this->stmt) {
45            return false;
46        }
47        if (!$row = oci_fetch_array($this->stmt, OCI_ASSOC + OCI_RETURN_NULLS + OCI_RETURN_LOBS)) {
48            oci_free_statement($this->stmt);
49            $this->stmt = null;
50            return false;
51        }
52
53        $row = array_change_key_case($row, CASE_LOWER);
54        unset($row['oracle_rownum']);
55        array_walk($row, array('oci_native_moodle_database', 'onespace2empty'));
56        return $row;
57    }
58
59    public function current() {
60        return (object)$this->current;
61    }
62
63    public function key() {
64        // return first column value as key
65        if (!$this->current) {
66            return false;
67        }
68        $key = reset($this->current);
69        return $key;
70    }
71
72    public function next() {
73        $this->current = $this->fetch_next();
74    }
75
76    public function valid() {
77        return !empty($this->current);
78    }
79
80    public function close() {
81        if ($this->stmt) {
82            oci_free_statement($this->stmt);
83            $this->stmt  = null;
84        }
85        $this->current = null;
86    }
87}
88