~desarrollokumbia/kumbia/ActiveRecord

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
<?php
/**
 * KumbiaPHP web & app Framework
 *
 * LICENSE
 *
 * This source file is subject to the new BSD license that is bundled
 * with this package in the file LICENSE.txt.
 * It is also available through the world-wide-web at this URL:
 * http://wiki.kumbiaphp.com/Licencia
 * If you did not receive a copy of the license and are unable to
 * obtain it through the world-wide-web, please send an email
 * to license@kumbiaphp.com so we can send you a copy immediately.
 *
 * Resultado de una consulta con ActiveRecord
 * 
 * @category   Kumbia
 * @package    Db 
 * @copyright  Copyright (c) 2005-2010 KumbiaPHP Team (http://www.kumbiaphp.com)
 * @license    http://wiki.kumbiaphp.com/Licencia     New BSD License
 */
class ResultSet implements Iterator
{
    /**
     * Resultado de la consulta
     *
     * @var resource
     */
    protected $_result;
    /**
     * 
     */
    private $_position = 0;
    /**
     * Constructor
     *
     */
    public function __construct ($result)
    {
        $this->_result = $result;
    }
    /**
     * fetch Array
     * 
     * @return Array
     */
    public function fetchArray ()
    {
        return $this->_result->fetchAll(PDO::FETCH_ASSOC);
    }
    /**
     * Fetch Object
     * 
     * @param string Class
     * @return Array
     */
    public function fetchObject ($class = 'stdClass')
    {
        return $this->_result->fetchObject($class);
    }
    /**
     * Fetch All
     * 
     * @param int Fetch
     * @return ResultSet
     */
    public function fetchAll($fetch=PDO::FETCH_OBJ)
    {
        return $this->_result->fetchAll($fetch);
    }
    /**
     * Cantidad de filas afectadas por la sentencia
     * 
     * @return int
     */
    public function affectRows ()
    {
        return $this->_result->rowCount();
    }
    /**
     * reset result set pointer 
     * (implementation required by 'rewind()' method in Iterator interface)
     */
    public function rewind ()
    {
        $this->_pointer = 0;
    }
    /**
     * get current row set in result set 
     * (implementation required by 'current()' method in Iterator interface)
     */
    public function current ()
    {
        if (! $this->valid()) {
            throw new KumbiaException('Unable to retrieve current row.');
        }
        return $this->fetchObject();
    }
    /**
     * Obtiene la posiciĆ³n actual del Puntero 
     * 
     */
    public function key ()
    {
        return $this->_pointer;
    }
    /**
     * Mueve el puntero a la siguiente posiciĆ³n 
     * 
     */
    public function next ()
    {
        ++ $this->_pointer;
    }
    /**
     * Determina si el puntero del ResultSet es valido 
     * 
     */
    public function valid ()
    {
        return $this->_pointer < $this->_result->rowCount();
    }
}