@@ 123-142 (lines=20) @@ | ||
120 | return substr($sql, 0, -1); |
|
121 | } |
|
122 | ||
123 | protected function processSELECT($parsed) |
|
124 | { |
|
125 | $sql = ''; |
|
126 | foreach ($parsed as $k => $v) { |
|
127 | $len = strlen($sql); |
|
128 | $sql .= $this->processColRef($v); |
|
129 | $sql .= $this->processSelectExpression($v); |
|
130 | $sql .= $this->processFunction($v); |
|
131 | $sql .= $this->processConstant($v); |
|
132 | ||
133 | if ($len == strlen($sql)) { |
|
134 | throw new UnableToCreateSQLException('SELECT', $k, $v, 'expr_type'); |
|
135 | } |
|
136 | ||
137 | $sql .= ','; |
|
138 | } |
|
139 | $sql = substr($sql, 0, -1); |
|
140 | ||
141 | return 'SELECT '.$sql; |
|
142 | } |
|
143 | ||
144 | protected function processFROM($parsed) |
|
145 | { |
|
@@ 144-161 (lines=18) @@ | ||
141 | return 'SELECT '.$sql; |
|
142 | } |
|
143 | ||
144 | protected function processFROM($parsed) |
|
145 | { |
|
146 | $sql = ''; |
|
147 | foreach ($parsed as $k => $v) { |
|
148 | $len = strlen($sql); |
|
149 | $sql .= $this->processTable($v, $k); |
|
150 | $sql .= $this->processTableExpression($v, $k); |
|
151 | $sql .= $this->processSubquery($v, $k); |
|
152 | ||
153 | if ($len == strlen($sql)) { |
|
154 | throw new UnableToCreateSQLException('FROM', $k, $v, 'expr_type'); |
|
155 | } |
|
156 | ||
157 | $sql .= ' '; |
|
158 | } |
|
159 | ||
160 | return 'FROM '.substr($sql, 0, -1); |
|
161 | } |
|
162 | ||
163 | protected function processORDER($parsed) |
|
164 | { |