yiisoft /
db-sqlite
| Total Complexity | 75 |
| Total Lines | 620 |
| Duplicated Lines | 0 % |
| Changes | 0 | ||
Complex classes like QueryBuilder often do a lot of different things. To break such a class down, we need to identify a cohesive component within that class. A common approach to find such a component is to look for fields/methods that share the same prefixes, or suffixes.
Once you have determined the fields that belong together, you can apply the Extract Class refactoring. If the component makes sense as a sub-class, Extract Subclass is also a candidate, and is often faster.
While breaking up the class, it is a good idea to analyze how other classes use QueryBuilder, and based on these observations, apply Extract Interface, too.
| 1 | <?php |
||
| 25 | class QueryBuilder extends BaseQueryBuilder |
||
| 26 | { |
||
| 27 | /** |
||
| 28 | * @var array mapping from abstract column types (keys) to physical column types (values). |
||
| 29 | */ |
||
| 30 | public array $typeMap = [ |
||
| 31 | Schema::TYPE_PK => 'integer PRIMARY KEY AUTOINCREMENT NOT NULL', |
||
| 32 | Schema::TYPE_UPK => 'integer UNSIGNED PRIMARY KEY AUTOINCREMENT NOT NULL', |
||
| 33 | Schema::TYPE_BIGPK => 'integer PRIMARY KEY AUTOINCREMENT NOT NULL', |
||
| 34 | Schema::TYPE_UBIGPK => 'integer UNSIGNED PRIMARY KEY AUTOINCREMENT NOT NULL', |
||
| 35 | Schema::TYPE_CHAR => 'char(1)', |
||
| 36 | Schema::TYPE_STRING => 'varchar(255)', |
||
| 37 | Schema::TYPE_TEXT => 'text', |
||
| 38 | Schema::TYPE_TINYINT => 'tinyint', |
||
| 39 | Schema::TYPE_SMALLINT => 'smallint', |
||
| 40 | Schema::TYPE_INTEGER => 'integer', |
||
| 41 | Schema::TYPE_BIGINT => 'bigint', |
||
| 42 | Schema::TYPE_FLOAT => 'float', |
||
| 43 | Schema::TYPE_DOUBLE => 'double', |
||
| 44 | Schema::TYPE_DECIMAL => 'decimal(10,0)', |
||
| 45 | Schema::TYPE_DATETIME => 'datetime', |
||
| 46 | Schema::TYPE_TIMESTAMP => 'timestamp', |
||
| 47 | Schema::TYPE_TIME => 'time', |
||
| 48 | Schema::TYPE_DATE => 'date', |
||
| 49 | Schema::TYPE_BINARY => 'blob', |
||
| 50 | Schema::TYPE_BOOLEAN => 'boolean', |
||
| 51 | Schema::TYPE_MONEY => 'decimal(19,4)', |
||
| 52 | ]; |
||
| 53 | |||
| 54 | |||
| 55 | /** |
||
| 56 | * {@inheritdoc} |
||
| 57 | */ |
||
| 58 | protected function defaultExpressionBuilders(): array |
||
| 59 | { |
||
| 60 | return array_merge(parent::defaultExpressionBuilders(), [ |
||
| 61 | LikeCondition::class => LikeConditionBuilder::class, |
||
| 62 | InCondition::class => InConditionBuilder::class, |
||
| 63 | ]); |
||
| 64 | } |
||
| 65 | |||
| 66 | /** |
||
| 67 | * Generates a batch INSERT SQL statement. |
||
| 68 | * |
||
| 69 | * For example, |
||
| 70 | * |
||
| 71 | * ```php |
||
| 72 | * $connection->createCommand()->batchInsert('user', ['name', 'age'], [ |
||
| 73 | * ['Tom', 30], |
||
| 74 | * ['Jane', 20], |
||
| 75 | * ['Linda', 25], |
||
| 76 | * ])->execute(); |
||
| 77 | * ``` |
||
| 78 | * |
||
| 79 | * Note that the values in each row must match the corresponding column names. |
||
| 80 | * |
||
| 81 | * @param string $table the table that new rows will be inserted into. |
||
| 82 | * @param array $columns the column names |
||
| 83 | * @param array|\Generator $rows the rows to be batch inserted into the table |
||
| 84 | * |
||
| 85 | * @return string the batch INSERT SQL statement |
||
| 86 | */ |
||
| 87 | public function batchInsert(string $table, array $columns, $rows, array &$params = []): string |
||
| 88 | { |
||
| 89 | if (empty($rows)) { |
||
| 90 | return ''; |
||
| 91 | } |
||
| 92 | |||
| 93 | // SQLite supports batch insert natively since 3.7.11 |
||
| 94 | // http://www.sqlite.org/releaselog/3_7_11.html |
||
| 95 | $this->db->open(); // ensure pdo is not null |
||
|
|
|||
| 96 | |||
| 97 | if (version_compare($this->db->getServerVersion(), '3.7.11', '>=')) { |
||
| 98 | return parent::batchInsert($table, $columns, $rows, $params); |
||
| 99 | } |
||
| 100 | |||
| 101 | $schema = $this->db->getSchema(); |
||
| 102 | |||
| 103 | if (($tableSchema = $schema->getTableSchema($table)) !== null) { |
||
| 104 | $columnSchemas = $tableSchema->columns; |
||
| 105 | } else { |
||
| 106 | $columnSchemas = []; |
||
| 107 | } |
||
| 108 | |||
| 109 | $values = []; |
||
| 110 | |||
| 111 | foreach ($rows as $row) { |
||
| 112 | $vs = []; |
||
| 113 | foreach ($row as $i => $value) { |
||
| 114 | if (isset($columnSchemas[$columns[$i]])) { |
||
| 115 | $value = $columnSchemas[$columns[$i]]->dbTypecast($value); |
||
| 116 | } |
||
| 117 | if (is_string($value)) { |
||
| 118 | $value = $schema->quoteValue($value); |
||
| 119 | } elseif (is_float($value)) { |
||
| 120 | // ensure type cast always has . as decimal separator in all locales |
||
| 121 | $value = StringHelper::floatToString($value); |
||
| 122 | } elseif ($value === false) { |
||
| 123 | $value = 0; |
||
| 124 | } elseif ($value === null) { |
||
| 125 | $value = 'NULL'; |
||
| 126 | } elseif ($value instanceof ExpressionInterface) { |
||
| 127 | $value = $this->buildExpression($value, $params); |
||
| 128 | } |
||
| 129 | $vs[] = $value; |
||
| 130 | } |
||
| 131 | $values[] = implode(', ', $vs); |
||
| 132 | } |
||
| 133 | |||
| 134 | if (empty($values)) { |
||
| 135 | return ''; |
||
| 136 | } |
||
| 137 | |||
| 138 | foreach ($columns as $i => $name) { |
||
| 139 | $columns[$i] = $schema->quoteColumnName($name); |
||
| 140 | } |
||
| 141 | |||
| 142 | return 'INSERT INTO ' . $schema->quoteTableName($table) |
||
| 143 | . ' (' . implode(', ', $columns) . ') SELECT ' . implode(' UNION SELECT ', $values); |
||
| 144 | } |
||
| 145 | |||
| 146 | /** |
||
| 147 | * Creates a SQL statement for resetting the sequence value of a table's primary key. |
||
| 148 | * |
||
| 149 | * The sequence will be reset such that the primary key of the next new row inserted will have the specified value |
||
| 150 | * or 1. |
||
| 151 | * |
||
| 152 | * @param string $tableName the name of the table whose primary key sequence will be reset |
||
| 153 | * @param mixed $value the value for the primary key of the next new row inserted. If this is not set, the next new |
||
| 154 | * row's primary key will have a value 1. |
||
| 155 | * |
||
| 156 | * @throws InvalidArgumentException if the table does not exist or there is no sequence associated with the table. |
||
| 157 | * |
||
| 158 | * @return string the SQL statement for resetting sequence |
||
| 159 | */ |
||
| 160 | public function resetSequence(string $tableName, $value = null): string |
||
| 161 | { |
||
| 162 | $db = $this->db; |
||
| 163 | |||
| 164 | $table = $db->getTableSchema($tableName); |
||
| 165 | |||
| 166 | if ($table !== null && $table->sequenceName !== null) { |
||
| 167 | $tableName = $db->quoteTableName($tableName); |
||
| 168 | if ($value === null) { |
||
| 169 | $key = $this->db->quoteColumnName(reset($table->primaryKey)); |
||
| 170 | $value = $this->db->useMaster(function (Connection $db) use ($key, $tableName) { |
||
| 171 | return $db->createCommand("SELECT MAX($key) FROM $tableName")->queryScalar(); |
||
| 172 | }); |
||
| 173 | } else { |
||
| 174 | $value = (int) $value - 1; |
||
| 175 | } |
||
| 176 | |||
| 177 | return "UPDATE sqlite_sequence SET seq='$value' WHERE name='{$table->name}'"; |
||
| 178 | } elseif ($table === null) { |
||
| 179 | throw new InvalidArgumentException("Table not found: $tableName"); |
||
| 180 | } |
||
| 181 | |||
| 182 | throw new InvalidArgumentException("There is not sequence associated with table '$tableName'.'"); |
||
| 183 | } |
||
| 184 | |||
| 185 | /** |
||
| 186 | * Enables or disables integrity check. |
||
| 187 | * |
||
| 188 | * @param bool $check whether to turn on or off the integrity check. |
||
| 189 | * @param string $schema the schema of the tables. Meaningless for SQLite. |
||
| 190 | * @param string $table the table name. Meaningless for SQLite. |
||
| 191 | * |
||
| 192 | * @throws NotSupportedException this is not supported by SQLite |
||
| 193 | * |
||
| 194 | * @return string the SQL statement for checking integrity |
||
| 195 | */ |
||
| 196 | public function checkIntegrity(string $schema = '', string $table = '', bool $check = true): string |
||
| 197 | { |
||
| 198 | return 'PRAGMA foreign_keys=' . (int) $check; |
||
| 199 | } |
||
| 200 | |||
| 201 | /** |
||
| 202 | * Builds a SQL statement for truncating a DB table. |
||
| 203 | * |
||
| 204 | * @param string $table the table to be truncated. The name will be properly quoted by the method. |
||
| 205 | * |
||
| 206 | * @return string the SQL statement for truncating a DB table. |
||
| 207 | */ |
||
| 208 | public function truncateTable(string $table): string |
||
| 209 | { |
||
| 210 | return 'DELETE FROM ' . $this->db->quoteTableName($table); |
||
| 211 | } |
||
| 212 | |||
| 213 | /** |
||
| 214 | * Builds a SQL statement for dropping an index. |
||
| 215 | * |
||
| 216 | * @param string $name the name of the index to be dropped. The name will be properly quoted by the method. |
||
| 217 | * @param string $table the table whose index is to be dropped. The name will be properly quoted by the method. |
||
| 218 | * |
||
| 219 | * @return string the SQL statement for dropping an index. |
||
| 220 | */ |
||
| 221 | public function dropIndex(string $name, string $table): string |
||
| 222 | { |
||
| 223 | return 'DROP INDEX ' . $this->db->quoteTableName($name); |
||
| 224 | } |
||
| 225 | |||
| 226 | /** |
||
| 227 | * Builds a SQL statement for dropping a DB column. |
||
| 228 | * |
||
| 229 | * @param string $table the table whose column is to be dropped. The name will be properly quoted by the method. |
||
| 230 | * @param string $column the name of the column to be dropped. The name will be properly quoted by the method. |
||
| 231 | * |
||
| 232 | * @throws NotSupportedException this is not supported by SQLite |
||
| 233 | * |
||
| 234 | * @return string the SQL statement for dropping a DB column. |
||
| 235 | */ |
||
| 236 | public function dropColumn(string $table, string $column): string |
||
| 237 | { |
||
| 238 | throw new NotSupportedException(__METHOD__ . ' is not supported by SQLite.'); |
||
| 239 | } |
||
| 240 | |||
| 241 | /** |
||
| 242 | * Builds a SQL statement for renaming a column. |
||
| 243 | * |
||
| 244 | * @param string $table the table whose column is to be renamed. The name will be properly quoted by the method. |
||
| 245 | * @param string $oldName the old name of the column. The name will be properly quoted by the method. |
||
| 246 | * @param string $newName the new name of the column. The name will be properly quoted by the method. |
||
| 247 | * |
||
| 248 | * @throws NotSupportedException this is not supported by SQLite |
||
| 249 | * |
||
| 250 | * @return string the SQL statement for renaming a DB column. |
||
| 251 | */ |
||
| 252 | public function renameColumn(string $table, string $oldName, string $newName): string |
||
| 253 | { |
||
| 254 | throw new NotSupportedException(__METHOD__ . ' is not supported by SQLite.'); |
||
| 255 | } |
||
| 256 | |||
| 257 | /** |
||
| 258 | * Builds a SQL statement for adding a foreign key constraint to an existing table. |
||
| 259 | * The method will properly quote the table and column names. |
||
| 260 | * @param string $name the name of the foreign key constraint. |
||
| 261 | * @param string $table the table that the foreign key constraint will be added to. |
||
| 262 | * @param string|array $columns the name of the column to that the constraint will be added on. |
||
| 263 | * If there are multiple columns, separate them with commas or use an array to represent them. |
||
| 264 | * @param string $refTable the table that the foreign key references to. |
||
| 265 | * @param string|array $refColumns the name of the column that the foreign key references to. |
||
| 266 | * If there are multiple columns, separate them with commas or use an array to represent them. |
||
| 267 | * @param string $delete the ON DELETE option. Most DBMS support these options: |
||
| 268 | * RESTRICT, CASCADE, NO ACTION, SET DEFAULT, SET NULL |
||
| 269 | * @param string $update the ON UPDATE option. Most DBMS support these options: |
||
| 270 | * RESTRICT, CASCADE, NO ACTION, SET DEFAULT, SET NULL |
||
| 271 | * |
||
| 272 | * @throws NotSupportedException this is not supported by SQLite |
||
| 273 | * |
||
| 274 | * @return string the SQL statement for adding a foreign key constraint to an existing table. |
||
| 275 | */ |
||
| 276 | public function addForeignKey( |
||
| 277 | string $name, |
||
| 278 | string $table, |
||
| 279 | $columns, |
||
| 280 | string $refTable, |
||
| 281 | $refColumns, |
||
| 282 | ?string $delete = null, |
||
| 283 | ?string $update = null |
||
| 284 | ): string { |
||
| 285 | throw new NotSupportedException(__METHOD__ . ' is not supported by SQLite.'); |
||
| 286 | } |
||
| 287 | |||
| 288 | /** |
||
| 289 | * Builds a SQL statement for dropping a foreign key constraint. |
||
| 290 | * @param string $name the name of the foreign key constraint to be dropped. The name will be properly quoted |
||
| 291 | * by the method. |
||
| 292 | * @param string $table the table whose foreign is to be dropped. The name will be properly quoted by the method. |
||
| 293 | * |
||
| 294 | * @throws NotSupportedException this is not supported by SQLite |
||
| 295 | * |
||
| 296 | * @return string the SQL statement for dropping a foreign key constraint. |
||
| 297 | */ |
||
| 298 | public function dropForeignKey(string $name, string $table): string |
||
| 299 | { |
||
| 300 | throw new NotSupportedException(__METHOD__ . ' is not supported by SQLite.'); |
||
| 301 | } |
||
| 302 | |||
| 303 | /** |
||
| 304 | * Builds a SQL statement for renaming a DB table. |
||
| 305 | * |
||
| 306 | * @param string $table the table to be renamed. The name will be properly quoted by the method. |
||
| 307 | * @param string $newName the new table name. The name will be properly quoted by the method. |
||
| 308 | * |
||
| 309 | * @return string the SQL statement for renaming a DB table. |
||
| 310 | */ |
||
| 311 | public function renameTable(string $table, string $newName): string |
||
| 312 | { |
||
| 313 | return 'ALTER TABLE ' . $this->db->quoteTableName($table) . ' RENAME TO ' . $this->db->quoteTableName($newName); |
||
| 314 | } |
||
| 315 | |||
| 316 | /** |
||
| 317 | * Builds a SQL statement for changing the definition of a column. |
||
| 318 | * @param string $table the table whose column is to be changed. The table name will be properly quoted by the |
||
| 319 | * method. |
||
| 320 | * @param string $column the name of the column to be changed. The name will be properly quoted by the method. |
||
| 321 | * @param string $type the new column type. The [[getColumnType()]] method will be invoked to convert abstract |
||
| 322 | * column type (if any) into the physical one. Anything that is not recognized as abstract type will be kept |
||
| 323 | * in the generated SQL. For example, 'string' will be turned into 'varchar(255)', while 'string not null' |
||
| 324 | * will become 'varchar(255) not null'. |
||
| 325 | * |
||
| 326 | * @throws NotSupportedException this is not supported by SQLite |
||
| 327 | * |
||
| 328 | * @return string the SQL statement for changing the definition of a column. |
||
| 329 | */ |
||
| 330 | public function alterColumn(string $table, string $column, string $type): string |
||
| 331 | { |
||
| 332 | throw new NotSupportedException(__METHOD__ . ' is not supported by SQLite.'); |
||
| 333 | } |
||
| 334 | |||
| 335 | /** |
||
| 336 | * Builds a SQL statement for adding a primary key constraint to an existing table. |
||
| 337 | * |
||
| 338 | * @param string $name the name of the primary key constraint. |
||
| 339 | * @param string $table the table that the primary key constraint will be added to. |
||
| 340 | * @param string|array $columns comma separated string or array of columns that the primary key will consist of. |
||
| 341 | * |
||
| 342 | * @throws NotSupportedException this is not supported by SQLite |
||
| 343 | * |
||
| 344 | * @return string the SQL statement for adding a primary key constraint to an existing table. |
||
| 345 | */ |
||
| 346 | public function addPrimaryKey(string $name, string $table, $columns): string |
||
| 347 | { |
||
| 348 | throw new NotSupportedException(__METHOD__ . ' is not supported by SQLite.'); |
||
| 349 | } |
||
| 350 | |||
| 351 | /** |
||
| 352 | * Builds a SQL statement for removing a primary key constraint to an existing table. |
||
| 353 | * |
||
| 354 | * @param string $name the name of the primary key constraint to be removed. |
||
| 355 | * @param string $table the table that the primary key constraint will be removed from. |
||
| 356 | * |
||
| 357 | * @throws NotSupportedException this is not supported by SQLite |
||
| 358 | * |
||
| 359 | * @return string the SQL statement for removing a primary key constraint from an existing table. |
||
| 360 | */ |
||
| 361 | public function dropPrimaryKey(string $name, string $table): string |
||
| 362 | { |
||
| 363 | throw new NotSupportedException(__METHOD__ . ' is not supported by SQLite.'); |
||
| 364 | } |
||
| 365 | |||
| 366 | /** |
||
| 367 | * {@inheritdoc} |
||
| 368 | * |
||
| 369 | * @throws NotSupportedException this is not supported by SQLite. |
||
| 370 | */ |
||
| 371 | public function addUnique(string $name, string $table, $columns): string |
||
| 372 | { |
||
| 373 | throw new NotSupportedException(__METHOD__ . ' is not supported by SQLite.'); |
||
| 374 | } |
||
| 375 | |||
| 376 | /** |
||
| 377 | * {@inheritdoc} |
||
| 378 | * |
||
| 379 | * @throws NotSupportedException this is not supported by SQLite. |
||
| 380 | */ |
||
| 381 | public function dropUnique(string $name, string $table): string |
||
| 382 | { |
||
| 383 | throw new NotSupportedException(__METHOD__ . ' is not supported by SQLite.'); |
||
| 384 | } |
||
| 385 | |||
| 386 | /** |
||
| 387 | * {@inheritdoc} |
||
| 388 | * |
||
| 389 | * @throws NotSupportedException this is not supported by SQLite. |
||
| 390 | */ |
||
| 391 | public function addCheck(string $name, string $table, string $expression): string |
||
| 392 | { |
||
| 393 | throw new NotSupportedException(__METHOD__ . ' is not supported by SQLite.'); |
||
| 394 | } |
||
| 395 | |||
| 396 | /** |
||
| 397 | * {@inheritdoc} |
||
| 398 | * |
||
| 399 | * @throws NotSupportedException this is not supported by SQLite. |
||
| 400 | */ |
||
| 401 | public function dropCheck(string $name, string $table): string |
||
| 402 | { |
||
| 403 | throw new NotSupportedException(__METHOD__ . ' is not supported by SQLite.'); |
||
| 404 | } |
||
| 405 | |||
| 406 | /** |
||
| 407 | * {@inheritdoc} |
||
| 408 | * |
||
| 409 | * @throws NotSupportedException this is not supported by SQLite. |
||
| 410 | */ |
||
| 411 | public function addDefaultValue(string $name, string $table, string $column, $value): string |
||
| 412 | { |
||
| 413 | throw new NotSupportedException(__METHOD__ . ' is not supported by SQLite.'); |
||
| 414 | } |
||
| 415 | |||
| 416 | /** |
||
| 417 | * {@inheritdoc} |
||
| 418 | * |
||
| 419 | * @throws NotSupportedException this is not supported by SQLite. |
||
| 420 | */ |
||
| 421 | public function dropDefaultValue(string $name, string $table): string |
||
| 422 | { |
||
| 423 | throw new NotSupportedException(__METHOD__ . ' is not supported by SQLite.'); |
||
| 424 | } |
||
| 425 | |||
| 426 | /** |
||
| 427 | * {@inheritdoc} |
||
| 428 | * |
||
| 429 | * @throws NotSupportedException |
||
| 430 | */ |
||
| 431 | public function addCommentOnColumn(string $table, string $column, string $comment): string |
||
| 432 | { |
||
| 433 | throw new NotSupportedException(__METHOD__ . ' is not supported by SQLite.'); |
||
| 434 | } |
||
| 435 | |||
| 436 | /** |
||
| 437 | * {@inheritdoc} |
||
| 438 | * |
||
| 439 | * @throws NotSupportedException |
||
| 440 | */ |
||
| 441 | public function addCommentOnTable(string $table, string $comment): string |
||
| 444 | } |
||
| 445 | |||
| 446 | /** |
||
| 447 | * {@inheritdoc} |
||
| 448 | * |
||
| 449 | * @throws NotSupportedException |
||
| 450 | */ |
||
| 451 | public function dropCommentFromColumn(string $table, string $column): string |
||
| 452 | { |
||
| 453 | throw new NotSupportedException(__METHOD__ . ' is not supported by SQLite.'); |
||
| 454 | } |
||
| 455 | |||
| 456 | /** |
||
| 457 | * {@inheritdoc} |
||
| 458 | * |
||
| 459 | * @throws NotSupportedException |
||
| 460 | */ |
||
| 461 | public function dropCommentFromTable(string $table): string |
||
| 462 | { |
||
| 463 | throw new NotSupportedException(__METHOD__ . ' is not supported by SQLite.'); |
||
| 464 | } |
||
| 465 | |||
| 466 | /** |
||
| 467 | * {@inheritdoc} |
||
| 468 | */ |
||
| 469 | public function buildLimit($limit, $offset): string |
||
| 470 | { |
||
| 471 | $sql = ''; |
||
| 472 | |||
| 473 | if ($this->hasLimit($limit)) { |
||
| 474 | $sql = 'LIMIT ' . $limit; |
||
| 475 | if ($this->hasOffset($offset)) { |
||
| 476 | $sql .= ' OFFSET ' . $offset; |
||
| 477 | } |
||
| 478 | } elseif ($this->hasOffset($offset)) { |
||
| 479 | // limit is not optional in SQLite |
||
| 480 | // http://www.sqlite.org/syntaxdiagrams.html#select-stmt |
||
| 481 | $sql = "LIMIT 9223372036854775807 OFFSET $offset"; // 2^63-1 |
||
| 482 | } |
||
| 483 | |||
| 484 | return $sql; |
||
| 485 | } |
||
| 486 | |||
| 487 | /** |
||
| 488 | * {@inheritdoc} |
||
| 489 | */ |
||
| 490 | public function build(Query $query, array $params = []): array |
||
| 491 | { |
||
| 492 | $query = $query->prepare($this); |
||
| 493 | |||
| 494 | $params = empty($params) ? $query->params : array_merge($params, $query->params); |
||
| 495 | |||
| 496 | $clauses = [ |
||
| 497 | $this->buildSelect($query->select, $params, $query->distinct, $query->selectOption), |
||
| 498 | $this->buildFrom($query->from, $params), |
||
| 499 | $this->buildJoin($query->join, $params), |
||
| 500 | $this->buildWhere($query->where, $params), |
||
| 501 | $this->buildGroupBy($query->groupBy), |
||
| 502 | $this->buildHaving($query->having, $params), |
||
| 503 | ]; |
||
| 504 | |||
| 505 | $sql = implode($this->separator, array_filter($clauses)); |
||
| 506 | $sql = $this->buildOrderByAndLimit($sql, $query->orderBy, $query->limit, $query->offset); |
||
| 507 | |||
| 508 | if (!empty($query->orderBy)) { |
||
| 509 | foreach ($query->orderBy as $expression) { |
||
| 510 | if ($expression instanceof ExpressionInterface) { |
||
| 511 | $this->buildExpression($expression, $params); |
||
| 512 | } |
||
| 513 | } |
||
| 514 | } |
||
| 515 | |||
| 516 | if (!empty($query->groupBy)) { |
||
| 517 | foreach ($query->groupBy as $expression) { |
||
| 518 | if ($expression instanceof ExpressionInterface) { |
||
| 519 | $this->buildExpression($expression, $params); |
||
| 520 | } |
||
| 521 | } |
||
| 522 | } |
||
| 523 | |||
| 524 | $union = $this->buildUnion($query->union, $params); |
||
| 525 | |||
| 526 | if ($union !== '') { |
||
| 527 | $sql = "$sql{$this->separator}$union"; |
||
| 528 | } |
||
| 529 | |||
| 530 | $with = $this->buildWithQueries($query->withQueries, $params); |
||
| 531 | |||
| 532 | if ($with !== '') { |
||
| 533 | $sql = "$with{$this->separator}$sql"; |
||
| 534 | } |
||
| 535 | |||
| 536 | return [$sql, $params]; |
||
| 537 | } |
||
| 538 | |||
| 539 | public function createIndex(string $name, string $table, $columns, bool $unique = false): string |
||
| 540 | { |
||
| 541 | $sql = ($unique ? 'CREATE UNIQUE INDEX ' : 'CREATE INDEX ') |
||
| 542 | . $this->db->quoteTableName($name) . ' ON ' |
||
| 543 | . $this->db->quoteTableName($table) |
||
| 544 | . ' (' . $this->buildColumns($columns) . ')'; |
||
| 545 | |||
| 546 | $sql = preg_replace_callback( |
||
| 547 | '/(`.*`) ON ({{(%?)([\w\-]+)}\}\.{{((%?)[\w\-]+)\\}\\})|(`.*`) ON ({{(%?)([\w\-]+)\.([\w\-]+)\\}\\})/', |
||
| 548 | static function ($matches) { |
||
| 549 | if (!empty($matches[1])) { |
||
| 550 | return $matches[4].".".$matches[1] |
||
| 551 | . ' ON {{' .$matches[3].$matches[5] . '}}'; |
||
| 552 | } |
||
| 553 | |||
| 554 | if (!empty($matches[7])) { |
||
| 555 | return $matches[10]. '.' .$matches[7] |
||
| 556 | . ' ON {{' .$matches[9].$matches[11] . '}}'; |
||
| 557 | } |
||
| 558 | }, |
||
| 559 | $sql |
||
| 560 | ); |
||
| 561 | |||
| 562 | return $sql; |
||
| 563 | } |
||
| 564 | |||
| 565 | /** |
||
| 566 | * @param array $unions |
||
| 567 | * @param array $params the binding parameters to be populated |
||
| 568 | * |
||
| 569 | * @return string the UNION clause built from {@see Query::$union}. |
||
| 570 | */ |
||
| 571 | public function buildUnion(array $unions, array &$params): string |
||
| 589 | } |
||
| 590 | |||
| 591 | /** |
||
| 592 | * {@inheritdoc} |
||
| 593 | * @see https://stackoverflow.com/questions/15277373/sqlite-upsert-update-or-insert/15277374#15277374 |
||
| 594 | */ |
||
| 595 | public function upsert(string $table, $insertColumns, $updateColumns, array &$params): string |
||
| 645 | } |
||
| 646 | } |
||
| 647 |
Loading history...
This check looks for calls to methods that do not seem to exist on a given type. It looks for the method on the type itself as well as in inherited classes or implemented interfaces.
This is most likely a typographical error or the method has been renamed.