Symfony/Doctrine:如何使 Doctrine 与 Unix 套接字一起工作?
问题:Symfony/Doctrine:如何使 Doctrine 与 Unix 套接字一起工作? 我正在尝试使用 Unix 套接字连接到 PostgreSQL。我认为只有一种方法可以连接到主机上的数据库,但应用程序在 Docker 中(我遵循不容器化非复制数据库的原则)。我正在使用带有最新 Doctrine 的 Symfony 4。 我用 PDO 对原始 PHP 进行了测试,它可以工作。我不知道如
·
问题:Symfony/Doctrine:如何使 Doctrine 与 Unix 套接字一起工作?
我正在尝试使用 Unix 套接字连接到 PostgreSQL。我认为只有一种方法可以连接到主机上的数据库,但应用程序在 Docker 中(我遵循不容器化非复制数据库的原则)。我正在使用带有最新 Doctrine 的 Symfony 4。
我用 PDO 对原始 PHP 进行了测试,它可以工作。我不知道如何强制 Doctrine 使用 unix 套接字。
<?php
$dbh = new PDO('pgsql:host=/var/run/postgresql;user=xxxx;dbname=zzzz;password=yyyy');
$dbh->setAttribute(PDO::ERRMODE_EXCEPTION, true);
var_dump($dbh->errorInfo());
$stmt = $dbh->query('SELECT 1 as dupa;');
$stmt->execute();
var_dump($stmt->fetchAll());
结果如预期:
www-data@ef0f2269b69a:~/html$ php o.php
array(3) {
[0]=>
string(5) "00000"
[1]=>
NULL
[2]=>
NULL
}
array(1) {
[0]=>
array(2) {
["dupa"]=>
int(1)
[0]=>
int(1)
}
}
问题是我在 Doctrine 中配置的任何内容:
In PDOConnection.php line 27:
[PDOException (7)]
SQLSTATE[08006] [7] could not connect to server: Connection refused
Is the server running on host "localhost" (127.0.0.1) and accepting
TCP/IP connections on port 5432?
could not connect to server: Cannot assign requested address
Is the server running on host "localhost" (::1) and accepting
TCP/IP connections on port 5432?
我试过Doctrine的语法,原始的PDO语法,不知道。我的 pdo_pgsql 是否有可能没有编译 unix 套接字支持?
这是我在 Doctrine 中尝试的数据库 URL:
pdo-pgsql://yyyy:xxxxx@/var/run/postgresql:5432/zzzzz
pgsql:host=/var/run/postgresql;user=xxxx;dbname=zzzz;password=yyyy
解答
在调试了 Doctrine 的驱动程序后,我创建了一个不太优雅的解决方案,但它仍然可以工作,并且可以改进。
我不喜欢在驱动程序本身中访问环境变量,但可能这可以改进。
教义.yaml
doctrine:
dbal:
#driver: %database_driver%
driver_class: App\Infrastructure\Common\Service\PostgreSQLDoctrineDriver
host: %database_host%
port: %database_port%
dbname: %database_name%
user: %database_user%
password: %database_password%
#charset: UTF8
orm:
auto_generate_proxy_classes: %kernel.debug%
auto_mapping: true
PostgreSQLDoctrineDriver.php
<?php declare(strict_types=1);
namespace App\Infrastructure\Common\Service;
use Doctrine\DBAL\DBALException;
use Doctrine\DBAL\Driver\PDOConnection;
use Doctrine\DBAL\Driver\PDOPgSql\Driver;
use \PDO;
use \PDOException;
use function defined;
/**
* Driver that connects through pdo_pgsql
*
* Forked original PostgreSQL driver, extended to have a possibility to pass raw PDO DSN to be
* able to connect via Unix socket
*/
class PostgreSQLDoctrineDriver extends Driver
{
/**
* {@inheritdoc}
*/
public function connect(array $params, $username = null, $password = null, array $driverOptions = [])
{
try {
$pdo = new PDOConnection(
$_SERVER['POSTGRES_DB_PDO_DSN'] ?? '',
$username,
$password,
$driverOptions
);
if (defined('PDO::PGSQL_ATTR_DISABLE_PREPARES')
&& (! isset($driverOptions[PDO::PGSQL_ATTR_DISABLE_PREPARES])
|| $driverOptions[PDO::PGSQL_ATTR_DISABLE_PREPARES] === true
)
) {
$pdo->setAttribute(PDO::PGSQL_ATTR_DISABLE_PREPARES, true);
}
/* defining client_encoding via SET NAMES to avoid inconsistent DSN support
* - the 'client_encoding' connection param only works with postgres >= 9.1
* - passing client_encoding via the 'options' param breaks pgbouncer support
*/
if (isset($params['charset'])) {
$pdo->exec('SET NAMES \'' . $params['charset'] . '\'');
}
return $pdo;
} catch (PDOException $e) {
throw DBALException::driverException($this, $e);
}
}
/**
* {@inheritdoc}
*/
public function getName()
{
return 'pdo_pgsql';
}
}
更多推荐
已为社区贡献19912条内容
所有评论(0)