rozza

import org.bson.Document
import com.mongodb.ConnectionString
import com.mongodb.MongoClientSettings
import com.mongodb.ServerApi
import com.mongodb.ServerApiVersion
import com.mongodb.kotlin.client.coroutine.MongoClient
import kotlinx.coroutines.runBlocking

object MongoClientConnectionExample {

rozza

import com.mongodb.kotlin.client.coroutine.MongoClient
import kotlinx.coroutines.runBlocking
import org.bson.Document

object MongoClientConnectionExample {

    fun main() {
        // Replace the placeholders with your credentials and hostname
        val connectionString = "mongodb+srv://<username>:<password>@<svrHostName>";

rozza

import com.mongodb.kotlin.client.MongoClient
import org.bson.Document

object MongoClientConnectionExample {

    fun main() {
        // Replace the placeholders with your credentials and hostname
        val connectionString = "mongodb+srv://<username>:<password>@<svrHostName>";
        
        // Create a new client and connect to the server

rozza

import org.bson.Document
import com.mongodb.ConnectionString
import com.mongodb.MongoClientSettings
import com.mongodb.ServerApi
import com.mongodb.ServerApiVersion
import com.mongodb.kotlin.client.MongoClient

object MongoClientConnectionExample {

    fun main() {

rozza

import com.mongodb.{ServerApi, ServerApiVersion}
import org.mongodb.scala.{ConnectionString, MongoClient, MongoClientSettings}
import org.mongodb.scala.bson.Document

import scala.concurrent.Await
import scala.concurrent.duration.DurationInt
import scala.util.Using

object MongoClientConnectionExample {

rozza

import org.mongodb.scala.MongoClient
import org.mongodb.scala.bson.Document

import scala.concurrent.Await
import scala.concurrent.duration.DurationInt
import scala.util.Using

object MongoClientConnectionExample {

  def main(args: Array[String]): Unit = {

rozza

        MongoClientSettings expected = MongoClientSettings.builder()
            .applyToClusterSettings(new Block<ClusterSettings.Builder>() {
            @Override
            void apply(final ClusterSettings.Builder builder) {
                builder.hosts([new ServerAddress('host1', 1), new ServerAddress('host2', 2)])
                        .mode(ClusterConnectionMode.MULTIPLE)
                        .requiredReplicaSetName('test')
                        .serverSelectionTimeout(25000, TimeUnit.MILLISECONDS)
                        .maxWaitQueueSize(10 * 7) // maxPoolSize * waitQueueMultiple
                        .localThreshold(30, TimeUnit.MILLISECONDS)

rozza

import unittest
from mongoengine import *


class Test(unittest.TestCase):

    def setUp(self):
        conn = connect(db='mongoenginetest')

    def create_old_data(self):

rozza

from django.contrib.auth import SESSION_KEY, BACKEND_SESSION_KEY, load_backend
from users.models import AnonymousUser

def get_user(request):
    try:
        user_id = request.session[SESSION_KEY]
        backend_path = request.session[BACKEND_SESSION_KEY]
        backend = load_backend(backend_path)
        user = backend.get_user(user_id) or AnonymousUser()
    except KeyError:

rozza

import java.lang.reflect.Array;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.util.ArrayList;
import java.util.List;

import com.sun.javadoc.Doc;
import com.sun.javadoc.DocErrorReporter;