Code examples for connection to a non-sharded Yandex StoreDoc cluster

Written by

Updated at September 25, 2025

Go
Java
Node.js
PHP
Python

Go

Before connecting, install the following dependencies:

sudo apt update && sudo apt install --yes golang git && \
go get go.mongodb.org/mongo-driver/mongo

Connecting with SSL

Connecting without SSL

connect.go

package main

import (
      "fmt"
      "strings"
      "context"
      "go.mongodb.org/mongo-driver/mongo"
      "go.mongodb.org/mongo-driver/mongo/options"
)

func main() {

      const DB_RS = "<replica_set_name>"
      const DB_NAME = "<DB_name>"
      DB_HOSTS := []string {"<Yandex_StoreDoc_host_1_FQDN>:27018",
                            ...,
                            "<Yandex_StoreDoc_host_N_FQDN>:27018"}
      const DB_USER = "<DB_username>"
      const DB_PASS = "<DB_user_password>"

      const CACERT = "/home/<home_directory>/.mongodb/root.crt"

      url := fmt.Sprintf("mongodb://%s:%s@%s/%s?replicaSet=%s&tls=true&tlsCaFile=%s",
              DB_USER,
              DB_PASS,
              strings.Join(DB_HOSTS, ","),
              DB_NAME,
              DB_RS,
              CACERT)

      conn, err := mongo.Connect(context.Background(), options.Client().ApplyURI(url))
      if err != nil {
              panic(err)
      }

      defer conn.Disconnect(context.Background())

      fmt.Println(conn.Database(DB_NAME).Name())
}

connect.go

package main

import (
      "fmt"
      "strings"
      "context"
      "go.mongodb.org/mongo-driver/mongo"
      "go.mongodb.org/mongo-driver/mongo/options"
)

func main() {

      const DB_RS = "<replica_set_name>"
      const DB_NAME = "<DB_name>"
      DB_HOSTS := []string {"<Yandex_StoreDoc_host_1_FQDN>:27018",
                            ...,
                            "<Yandex_StoreDoc_host_N_FQDN>:27018"}
      const DB_USER = "<DB_username>"
      const DB_PASS = "<DB_user_password>"

      url := fmt.Sprintf("mongodb://%s:%s@%s/%s?replicaSet=%s&tls=false",
              DB_USER,
              DB_PASS,
              strings.Join(DB_HOSTS, ","),
              DB_NAME,
              DB_RS)

      conn, err := mongo.Connect(context.Background(), options.Client().ApplyURI(url))
      if err != nil {
              panic(err)
      }

      defer conn.Disconnect(context.Background())

      fmt.Println(conn.Database(DB_NAME).Name())
}

To learn how to get host FQDN, see this guide.

Connecting:

go run connect.go

Java

Before connecting:

Install the dependencies:

sudo apt update && sudo apt install --yes default-jdk maven

Add the SSL certificate to the Java trusted certificate store (Java Key Store) so that the Yandex StoreDoc driver can use this certificate for secure connections to the cluster hosts. Set a password in the -storepass parameter for storage protection:
```
cd ~/.mongodb && \
sudo keytool -importcert \
             -alias YandexCA -file root.crt \
             -keystore ssl -storepass <password> \
             --noprompt
```
Where storepass is your certificate store password, a minimum of 6 characters.

Create a directory for the Maven project:

cd ~/ && \
mkdir --parents project/src/java/com/example && \
cd ~/project

Create a configuration file for Maven:

pom.xml

<?xml version="1.0" encoding="utf-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">

  <modelVersion>4.0.0</modelVersion>
  <groupId>com.example</groupId>
  <artifactId>app</artifactId>
  <packaging>jar</packaging>
  <version>0.1.0</version>
  <properties>
    <maven.compiler.source>1.8</maven.compiler.source>
    <maven.compiler.target>1.8</maven.compiler.target>
  </properties>
  <dependencies>
    <dependency>
      <groupId>org.mongodb</groupId>
      <artifactId>mongodb-driver-sync</artifactId>
      <version>4.1.0</version>
    </dependency>
    <dependency>
      <groupId>org.slf4j</groupId>
      <artifactId>slf4j-simple</artifactId>
      <version>1.7.30</version>
    </dependency>
  </dependencies>
  <build>
    <finalName>${project.artifactId}-${project.version}</finalName>
    <sourceDirectory>src</sourceDirectory>
    <resources>
      <resource>
        <directory>src</directory>
      </resource>
    </resources>
    <plugins>
      <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-assembly-plugin</artifactId>
        <executions>
          <execution>
            <goals>
              <goal>attached</goal>
            </goals>
            <phase>package</phase>
            <configuration>
              <descriptorRefs>
                <descriptorRef>
                jar-with-dependencies</descriptorRef>
              </descriptorRefs>
              <archive>
                <manifest>
                  <mainClass>com.example.App</mainClass>
                </manifest>
              </archive>
            </configuration>
          </execution>
        </executions>
      </plugin>
      <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-jar-plugin</artifactId>
        <version>3.1.0</version>
        <configuration>
          <archive>
            <manifest>
              <mainClass>com.example.App</mainClass>
            </manifest>
          </archive>
        </configuration>
      </plugin>
    </plugins>
  </build>
</project>

Current versions of Maven dependencies:

Connecting with SSL

Connecting without SSL

src/java/com/example/App.java

package com.example;

import java.util.*;
import com.mongodb.*;
import com.mongodb.client.*;

public class App {
  public static void main(String[] args) {

    System.setProperty("javax.net.ssl.trustStore", "/home/<home_directory>/.mongodb/YATrustStore");
    System.setProperty("javax.net.ssl.trustStorePassword", "<certificate_store_password>");

    final Integer DB_PORT = 27018;

    List DB_HOSTS = new ArrayList<ServerAddress>();
    DB_HOSTS.add(new ServerAddress("<Yandex_StoreDoc_host_1_FQDN>", DB_PORT));
    ...,
    DB_HOSTS.add(new ServerAddress("<Yandex_StoreDoc_host_N_FQDN>", DB_PORT));

    final String DB_NAME = "<DB_name>";
    final String DB_USER = "<DB_username>";
    final String DB_PASS = "<DB_user_password>";

    MongoClient conn = MongoClients.create(
        MongoClientSettings.builder()
              .applyToClusterSettings(builder -> builder.hosts(DB_HOSTS))
              .applyToSslSettings(builder -> builder.enabled(true))
              .credential(MongoCredential.createCredential(DB_USER, DB_NAME, DB_PASS.toCharArray()))
              .build());

    System.out.println(conn.getDatabase(DB_NAME).getName());

    conn.close();
  }
}

src/java/com/example/App.java

package com.example;

import java.util.*;
import com.mongodb.*;
import com.mongodb.client.*;

public class App {
  public static void main(String[] args) {

    final Integer DB_PORT = 27018;

    List DB_HOSTS = new ArrayList<ServerAddress>();
    DB_HOSTS.add(new ServerAddress("<Yandex_StoreDoc_host_1_FQDN>", DB_PORT));
    ...,
    DB_HOSTS.add(new ServerAddress("<Yandex_StoreDoc_host_N_FQDN>", DB_PORT));

    final String DB_NAME = "<DB_name>";
    final String DB_USER = "<DB_username>";
    final String DB_PASS = "<DB_user_password>";

    MongoClient conn = MongoClients.create(
        MongoClientSettings.builder()
              .applyToClusterSettings(builder -> builder.hosts(DB_HOSTS))
              .credential(MongoCredential.createCredential(DB_USER, DB_NAME, DB_PASS.toCharArray()))
              .build());

    System.out.println(conn.getDatabase(DB_NAME).getName());

    conn.close();
  }
}

To learn how to get host FQDN, see this guide.

Connecting:

mvn clean package && \
    java -jar target/app-0.1.0-jar-with-dependencies.jar

Node.js

Before connecting, install the required dependencies:

sudo apt update && sudo apt install --yes nodejs npm && \
npm install mongodb

Connecting with SSL

Connecting without SSL

app.js

const util = require('util');
const MongoClient = require('mongodb').MongoClient;

const DB_RS = '<replica_set_name>'
const DB_NAME = '<DB_name>'
const DB_HOSTS = ['<Yandex_StoreDoc_host_1_FQDN>:27018',
                  ...,
                  '<Yandex_StoreDoc_host_N_FQDN>:27018']
const DB_USER  = '<DB_username>'
const DB_PASS  = '<DB_user_password>'
const CACERT   = '/home/<home_directory>/.mongodb/root.crt'

const url = util.format('mongodb://%s:%s@%s/', DB_USER, DB_PASS, DB_HOSTS.join(','))

const options = {
  useNewUrlParser: true,
  useUnifiedTopology: true,
  tls: true,
  tlsCAFile: CACERT,
  replicaSet: DB_RS,
  authSource: DB_NAME
}

MongoClient.connect(url, options, function(err, conn) {
  if (conn.isConnected()) {
    const db = conn.db(DB_NAME)
    console.log(db.databaseName)
  }

  conn.close()
})

app.js

const util = require('util');
const MongoClient = require('mongodb').MongoClient;

const DB_RS = '<replica_set_name>'
const DB_NAME = '<DB_name>'
const DB_HOSTS = ['<Yandex_StoreDoc_host_1_FQDN>:27018',
                  ...
                  '<Yandex_StoreDoc_host_N_FQDN>:27018']
const DB_USER  = '<DB_username>'
const DB_PASS  = '<DB_user_password>'

const url = util.format('mongodb://%s:%s@%s/', DB_USER, DB_PASS, DB_HOSTS.join(','))

const options = {
  useNewUrlParser: true,
  useUnifiedTopology: true,
  replicaSet: DB_RS,
  authSource: DB_NAME
}

MongoClient.connect(url, options, function(err, conn) {
  if (conn.isConnected()) {
    const db = conn.db(DB_NAME)
    console.log(db.databaseName)
  }

  conn.close()
})

To learn how to get host FQDN, see this guide.

Connecting:

node app.js

PHP

Before connecting, install the required dependencies:

sudo apt update && sudo apt install --yes php php-mongodb

Connecting with SSL

Connecting without SSL

connect.php

<?php
  $DB_RS    = '<replica_set_name>';
  $DB_NAME  = '<DB_name>';
  $DB_HOSTS = '<Yandex_StoreDoc_host_1_FQDN>:27018,...,<Yandex_StoreDoc_host_N_FQDN>:27018';
  $DB_USER  = '<DB_username>';
  $DB_PASS  = '<DB_user_password>';
  $CACERT   = '/home/<home_directory>/.mongodb/root.crt';

  $uri = sprintf(
      'mongodb://%s:%s@%s/%s?replicaSet=%s',
      $DB_USER,
      $DB_PASS,
      $DB_HOSTS,
      $DB_NAME,
      $DB_RS
  );

  $conn = new \MongoDB\Driver\Manager($uri, ["tls" => "true", "tlsCAFile" => $CACERT], []);
  $command = new MongoDB\Driver\Command(array("ping" => 1));

  try {
      $cursor = $conn->executeCommand($DB_NAME, $command);
        $response = $cursor->toArray()[0];
  } catch(MongoDB\Driver\Exception $ex) {
      echo "$ex->getMessage()";
      exit;
  }

  var_dump($response);
?>

connect.php

<?php
  $DB_RS    = '<replica_set_name>';
  $DB_NAME  = '<DB_name>';
  $DB_HOSTS = '<Yandex_StoreDoc_host_1_FQDN>:27018,...,<Yandex_StoreDoc_host_N_FQDN>:27018';
  $DB_USER  = '<DB_username>';
  $DB_PASS  = '<DB_user_password>';

  $uri = sprintf(
      'mongodb://%s:%s@%s/%s?replicaSet=%s',
      $DB_USER,
      $DB_PASS,
      $DB_HOSTS,
      $DB_NAME,
      $DB_RS
  );

  $conn = new \MongoDB\Driver\Manager($uri);
  $command = new MongoDB\Driver\Command(array("ping" => 1));

  try {
      $cursor = $conn->executeCommand($DB_NAME, $command);
      $response = $cursor->toArray()[0];
  } catch(MongoDB\Driver\Exception $ex) {
      echo "$ex->getMessage()";
      exit;
  }

  var_dump($response);
?>

To learn how to get host FQDN, see this guide.

Connecting:

php connect.php

Python

Before connecting, install the required dependencies:

sudo apt update && sudo apt install --yes python3 python3-pip && \
pip3 install pyMongo

To find out the name of a replica set, connect to the database via MongoDB Shell and run this command:

rs.status().set

Connecting with SSL

Connecting without SSL

connect.py

import ssl
import pymongo
from urllib.parse import quote_plus as quote

CACERT = '/home/<home_directory>/.mongodb/root.crt'
DB_RS = '<replica_set_name>'
DB_NAME = '<DB_name>'
DB_HOSTS =','.join([
      '<Yandex_StoreDoc_host_1_FQDN>:27018',
      ...,
      '<Yandex_StoreDoc_host_N_FQDN>:27018'
    ])
DB_USER = '<DB_username>'
DB_PASS = '<DB_user_password>'

url = 'mongodb://{user}:{pw}@{hosts}/?replicaSet={rs}&authSource={auth_src}'.format(
          user=quote(DB_USER),
          pw=quote(DB_PASS),
          rs=DB_RS,
          hosts=DB_HOSTS,
          auth_src=DB_NAME)

conn = pymongo.MongoClient(
    url,
    tls=True,
    tlsCAFile=CACERT)

db = conn[DB_NAME]
print(db.name)

conn.close()

connect.py

import ssl
import pymongo
from urllib.parse import quote_plus as quote

DB_RS = '<replica_set_name>'
DB_NAME = '<DB_name>'
DB_HOSTS =','.join([
      '<Yandex_StoreDoc_host_1_FQDN>:27018',
      ...,
      '<Yandex_StoreDoc_host_N_FQDN>:27018'
    ])
DB_USER = '<DB_username>'
DB_PASS = '<DB_user_password>'

url = 'mongodb://{user}:{pw}@{hosts}/?replicaSet={rs}&authSource={auth_src}'.format(
          user=quote(DB_USER),
          pw=quote(DB_PASS),
          rs=DB_RS,
          hosts=DB_HOSTS,
          auth_src=DB_NAME)

conn = pymongo.MongoClient(url)

db = conn[DB_NAME]
print(db.name)

conn.close()

To learn how to get host FQDN, see this guide.

Connecting:

python3 connect.py

Code examples for connection to a non-sharded Yandex StoreDoc cluster

GoGo

JavaJava

Node.jsNode.js

PHPPHP

PythonPython

Was the article helpful?

Go

Java

Node.js

PHP

Python