Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 8 additions & 8 deletions tests/Provider/QueryBuilderProvider.php
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ public static function buildCondition(): array
];

$buildCondition['and-subquery'][1] = <<<SQL
([[expired]]='0') AND ((SELECT count(*) > 1 FROM [[queue]]))
([[expired]] = '0') AND ((SELECT count(*) > 1 FROM [[queue]]))
SQL;

return $buildCondition;
Expand Down Expand Up @@ -124,7 +124,7 @@ public static function insert(): array
SQL;

$insert['carry passed params (query)'][3] = <<<SQL
INSERT INTO "customer" ("email", "name", "address", "is_active", "related_id") SELECT "email", "name", "address", "is_active", "related_id" FROM "customer" WHERE ("email"=:qp1) AND ("name"=:qp2) AND ("address"=:qp3) AND ("is_active"='0') AND ("related_id" IS NULL) AND ("col"=CONCAT(:phFoo, :phBar))
INSERT INTO "customer" ("email", "name", "address", "is_active", "related_id") SELECT "email", "name", "address", "is_active", "related_id" FROM "customer" WHERE ("email" = :qp1) AND ("name" = :qp2) AND ("address" = :qp3) AND ("is_active" = '0') AND ("related_id" IS NULL) AND ("col" = CONCAT(:phFoo, :phBar))
SQL;

return $insert;
Expand Down Expand Up @@ -156,20 +156,20 @@ public static function upsert(): array
],
'query' => [
3 => <<<SQL
MERGE INTO "T_upsert" USING (WITH USER_SQL AS (SELECT "email", 2 AS "status" FROM "customer" WHERE "name"=:qp0), PAGINATION AS (SELECT USER_SQL.*, rownum as rowNumId FROM USER_SQL)
MERGE INTO "T_upsert" USING (WITH USER_SQL AS (SELECT "email", 2 AS "status" FROM "customer" WHERE "name" = :qp0), PAGINATION AS (SELECT USER_SQL.*, rownum as rowNumId FROM USER_SQL)
SELECT * FROM PAGINATION WHERE rownum <= 1) "EXCLUDED" ON ("T_upsert"."email"="EXCLUDED"."email") WHEN MATCHED THEN UPDATE SET "status"="EXCLUDED"."status" WHEN NOT MATCHED THEN INSERT ("email", "status") VALUES ("EXCLUDED"."email", "EXCLUDED"."status")
SQL,
],
'query with update part' => [
2 => ['address' => 'foo {{city}}', 'status' => 2, 'orders' => new Expression('"T_upsert"."orders" + 1')],
3 => <<<SQL
MERGE INTO "T_upsert" USING (WITH USER_SQL AS (SELECT "email", 2 AS "status" FROM "customer" WHERE "name"=:qp0), PAGINATION AS (SELECT USER_SQL.*, rownum as rowNumId FROM USER_SQL)
MERGE INTO "T_upsert" USING (WITH USER_SQL AS (SELECT "email", 2 AS "status" FROM "customer" WHERE "name" = :qp0), PAGINATION AS (SELECT USER_SQL.*, rownum as rowNumId FROM USER_SQL)
SELECT * FROM PAGINATION WHERE rownum <= 1) "EXCLUDED" ON ("T_upsert"."email"="EXCLUDED"."email") WHEN MATCHED THEN UPDATE SET "address"=:qp1, "status"=:qp2, "orders"="T_upsert"."orders" + 1 WHEN NOT MATCHED THEN INSERT ("email", "status") VALUES ("EXCLUDED"."email", "EXCLUDED"."status")
SQL,
],
'query without update part' => [
3 => <<<SQL
MERGE INTO "T_upsert" USING (WITH USER_SQL AS (SELECT "email", 2 AS "status" FROM "customer" WHERE "name"=:qp0), PAGINATION AS (SELECT USER_SQL.*, rownum as rowNumId FROM USER_SQL)
MERGE INTO "T_upsert" USING (WITH USER_SQL AS (SELECT "email", 2 AS "status" FROM "customer" WHERE "name" = :qp0), PAGINATION AS (SELECT USER_SQL.*, rownum as rowNumId FROM USER_SQL)
SELECT * FROM PAGINATION WHERE rownum <= 1) "EXCLUDED" ON ("T_upsert"."email"="EXCLUDED"."email") WHEN NOT MATCHED THEN INSERT ("email", "status") VALUES ("EXCLUDED"."email", "EXCLUDED"."status")
SQL,
],
Expand Down Expand Up @@ -437,16 +437,16 @@ public static function caseExpressionBuilder(): array
[':qp0' => $param],
3,
];
$data['without case expression'][1] = 'CASE WHEN "column_name" = :qp0 THEN :qp1'
. ' WHEN "column_name" = 2 THEN (SELECT :pv2 FROM DUAL) END';
$data['without case expression'][1] = 'CASE WHEN "column_name" = 1 THEN :qp0'
. ' WHEN "column_name" = 2 THEN (SELECT :pv1 FROM DUAL) END';

return $data;
}

public static function delete(): array
{
$values = parent::delete();
$values['base'][2] = 'DELETE FROM "user" WHERE ("is_enabled"=\'0\') AND ("power"=WRONG_POWER())';
$values['base'][2] = 'DELETE FROM "user" WHERE ("is_enabled" = \'0\') AND ("power" = WRONG_POWER())';
return $values;
}
}