Skip to content

Support mongodb+srv connection string in connection test tool #1841

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
alcaeus wants to merge 2 commits into
base: v2.x
Choose a base branch
from
Open

Support mongodb+srv connection string in connection test tool #1841

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
f171efb
Support mongodb+srv connection string in connection test tool
alcaeus Feb 5, 2026
6e0aac0
Apply suggestions from code review
alcaeus Feb 6, 2026
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
46 changes: 43 additions & 3 deletions tools/connect.php
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,15 @@ function getHosts(string $uri): array

$parsed = parse_url($uri);

if (isset($parsed['scheme']) && $parsed['scheme'] !== 'mongodb') {
// TODO: Resolve SRV records (https://github.com/mongodb/specifications/blob/master/source/initial-dns-seedlist-discovery/initial-dns-seedlist-discovery.md)
if (! isset($parsed['scheme'])) {
throw new RuntimeException('URI must contain a scheme');
}

if ($parsed['scheme'] === 'mongodb+srv') {
return getHostsFromSrv($uri);
}

if ($parsed['scheme'] !== 'mongodb') {
throw new RuntimeException('Unsupported scheme: ' . $parsed['scheme']);
}

Expand All @@ -18,6 +25,32 @@ function getHosts(string $uri): array
return explode(',', $hosts);
}

/**
* Resolves SRV records for a MongoDB+SRV URI according to the specification:
* https://github.com/mongodb/specifications/blob/master/source/initial-dns-seedlist-discovery/initial-dns-seedlist-discovery.md
*
* @return list<string> List of host:port strings
*/
function getHostsFromSrv(string $uri): array
{
$parsed = parse_url($uri);
if (! isset($parsed['host'])) {
throw new RuntimeException('SRV URI must contain a host');
}

$srvRecord = '_mongodb._tcp.' . $parsed['host'];

$records = dns_get_record($srvRecord, DNS_SRV);
if ($records === false || count($records) === 0) {
throw new RuntimeException('No SRV records found for ' . $srvRecord);
}

return array_map(
static fn (array $record) => $record['target'] . ':' . ($record['port'] ?? 27017),
$records,
);
}

/** @param resource $stream */
function streamWrite($stream, string $data): int
{
Expand Down Expand Up @@ -127,7 +160,14 @@ function connect(string $host, bool $ssl): void
$uri = $argv[1] ?? 'mongodb://127.0.0.1';
printf("Looking up MongoDB at %s\n", $uri);
$hosts = getHosts($uri);
$ssl = stripos(parse_url($uri, PHP_URL_QUERY) ?? '', 'ssl=true') !== false;

if (str_starts_with($uri, 'mongodb+srv://')) {
// For mongodb+srv, SSL is always true unless explicitly set to false
$ssl = stripos(parse_url($uri, PHP_URL_QUERY) ?? '', 'ssl=false') === false;
} else {
// For other connection strings, SSL is true if indicated
$ssl = stripos(parse_url($uri, PHP_URL_QUERY) ?? '', 'ssl=true') !== false;
}

printf("Found %d host(s) in the URI. Will attempt to connect to each.\n", count($hosts));

Expand Down
Loading