diff --git a/tests/_data/assets/schemas/pgsql.sql b/tests/_data/assets/schemas/pgsql.sql index f39ce6a79bf..de38cb0ebbe 100644 --- a/tests/_data/assets/schemas/pgsql.sql +++ b/tests/_data/assets/schemas/pgsql.sql @@ -14,8 +14,6 @@ create table co_invoices inv_created_at timestamp ); -alter table co_invoices owner to postgres; - create index co_invoices_inv_created_at_index on co_invoices (inv_created_at); @@ -39,8 +37,6 @@ create table co_orders ord_name varchar(70) ); -alter table public.co_orders owner to postgres; - drop table if exists private.co_orders_x_products; @@ -52,8 +48,6 @@ create table private.co_orders_x_products oxp_quantity int not null ); -alter table private.co_orders_x_products owner to postgres; - drop table if exists co_products; @@ -66,8 +60,6 @@ create table co_products prd_name varchar(70) ); -alter table public.co_products owner to postgres; - diff --git a/tests/_data/fixtures/Migrations/InvoicesMigration.php b/tests/_data/fixtures/Migrations/InvoicesMigration.php index d44d44f51f2..414d76c399d 100644 --- a/tests/_data/fixtures/Migrations/InvoicesMigration.php +++ b/tests/_data/fixtures/Migrations/InvoicesMigration.php @@ -46,10 +46,9 @@ public function insert( insert into co_invoices ( inv_id, inv_cst_id, inv_status_flag, inv_title, inv_total, inv_created_at ) values ( - {$id}, {$custId}, {$status}, "{$title}", {$total}, "{$now}" + {$id}, {$custId}, {$status}, '{$title}', {$total}, '{$now}' ) SQL; - return $this->connection->exec($sql); } @@ -135,9 +134,6 @@ protected function getSqlPgsql(): array ); ", " -alter table co_invoices owner to postgres; - ", - " create index co_invoices_inv_created_at_index on co_invoices (inv_created_at); ", diff --git a/tests/_data/fixtures/Migrations/OrdersMigration.php b/tests/_data/fixtures/Migrations/OrdersMigration.php index 4322b997bc8..ba1acd459b5 100644 --- a/tests/_data/fixtures/Migrations/OrdersMigration.php +++ b/tests/_data/fixtures/Migrations/OrdersMigration.php @@ -78,9 +78,6 @@ protected function getSqlPgsql(): array primary key, ord_name varchar(70) ); - ", - " -alter table public.co_orders owner to postgres; " ]; } diff --git a/tests/_data/fixtures/Migrations/OrdersProductsMigration.php b/tests/_data/fixtures/Migrations/OrdersProductsMigration.php index 5592525df6b..8067f12b3f7 100644 --- a/tests/_data/fixtures/Migrations/OrdersProductsMigration.php +++ b/tests/_data/fixtures/Migrations/OrdersProductsMigration.php @@ -80,9 +80,6 @@ protected function getSqlPgsql(): array oxp_prd_id int not null, oxp_quantity int not null ); - ", - " -alter table private.co_orders_x_products owner to postgres; " ]; } diff --git a/tests/_data/fixtures/Migrations/ProductsMigration.php b/tests/_data/fixtures/Migrations/ProductsMigration.php index 401fbf2f7a1..9ab3ac05345 100644 --- a/tests/_data/fixtures/Migrations/ProductsMigration.php +++ b/tests/_data/fixtures/Migrations/ProductsMigration.php @@ -78,9 +78,6 @@ protected function getSqlPgsql(): array primary key, prd_name varchar(70) ); - ", - " -alter table public.co_products owner to postgres; " ]; } diff --git a/tests/_data/fixtures/Traits/DiTrait.php b/tests/_data/fixtures/Traits/DiTrait.php index 3e2112b7f34..56bd58d0d94 100644 --- a/tests/_data/fixtures/Traits/DiTrait.php +++ b/tests/_data/fixtures/Traits/DiTrait.php @@ -99,7 +99,7 @@ protected function newDbConnection(string $driver): AdapterInterface break; case 'pgsql': $options = getOptionsPostgresql(); - $service = 'postgresql'; + $driver = 'postgresql'; break; case 'sqlite': $options = getOptionsSqlite(); diff --git a/tests/_envs/pgsql.yml b/tests/_envs/pgsql.yml index 859c7018e9d..9122daeb201 100644 --- a/tests/_envs/pgsql.yml +++ b/tests/_envs/pgsql.yml @@ -11,11 +11,4 @@ modules: reconnect: true waitlock: 10 initial_queries: - - 'DROP SCHEMA public CASCADE;' - - 'DROP SCHEMA private CASCADE;' - - 'CREATE SCHEMA public;' - - 'CREATE SCHEMA private;' - - 'REVOKE ALL ON SCHEMA public FROM PUBLIC;' - - 'REVOKE ALL ON SCHEMA public FROM %DATA_POSTGRES_USER%;' - - 'GRANT ALL ON SCHEMA public TO %DATA_POSTGRES_USER%;' - - 'GRANT ALL ON SCHEMA public TO public;' + - 'CREATE SCHEMA IF NOT EXISTS private;' diff --git a/tests/database/Db/Adapter/Pdo/QueryCest.php b/tests/database/Db/Adapter/Pdo/QueryCest.php index 23470245d3b..a8b158688c7 100644 --- a/tests/database/Db/Adapter/Pdo/QueryCest.php +++ b/tests/database/Db/Adapter/Pdo/QueryCest.php @@ -38,12 +38,13 @@ public function _before(DatabaseTester $I) * @author Phalcon Team * @since 2020-02-22 * + * @group pgsql * @group mysql * @group sqlite */ public function dbAdapterPdoQuery(DatabaseTester $I) { - $I->wantToTest('Db\Adapter\Pdo\Mysql - query()'); + $I->wantToTest('Db\Adapter\Pdo - query()'); $connection = $I->getConnection(); $db = $this->container->get('db'); diff --git a/tests/database/Mvc/Model/Criteria/JoinCest.php b/tests/database/Mvc/Model/Criteria/JoinCest.php index 8c79b049ac4..146f81a04ac 100644 --- a/tests/database/Mvc/Model/Criteria/JoinCest.php +++ b/tests/database/Mvc/Model/Criteria/JoinCest.php @@ -21,6 +21,7 @@ use Phalcon\Test\Models\Invoices; use Phalcon\Test\Models\Orders; use Phalcon\Test\Models\Products; +use Phalcon\Mvc\Model\Resultset\Simple; /** * Class JoinCest @@ -74,6 +75,7 @@ public function mvcModelCriteriaJoin(DatabaseTester $I) * @since 2020-02-06 * * @group mysql + * @group pgsql */ public function mvcModelCriteriaJoinManyToManyMultipleSchema(DatabaseTester $I) { @@ -92,13 +94,12 @@ public function mvcModelCriteriaJoinManyToManyMultipleSchema(DatabaseTester $I) $builder->from(Orders::class); $builder->join(Products::class); - $expected = 'SELECT `co_orders`.`ord_id`, `co_orders`.`ord_name` ' - . 'FROM `co_orders` ' - . 'INNER JOIN `private`.`co_orders_x_products` ' - . 'ON `co_orders`.`ord_id` = `co_orders_x_products`.`oxp_ord_id` ' - . 'INNER JOIN `co_products` ON `co_orders_x_products`.`oxp_prd_id` = `co_products`.`prd_id`'; - $actual = $builder->getQuery()->getSql(); + $expected = 'private'; + $query = $builder->getQuery(); + $request = $query->getSql(); - $I->assertEquals($expected, $actual['sql']); + $I->assertContains($expected, $request['sql']); + + $I->assertInstanceOf(Simple::class, $query->execute()); } }