Skip to content

Instantly share code, notes, and snippets.

@rozza
rozza / MongoClientConnectionExample.kt
Created March 30, 2023 14:00
Kotlin coroutine driver with server api example of connecting to the database
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
rozza / MongoClientConnectionExample.kt
Created March 30, 2023 13:58
Kotlin coroutine simple example of connecting to the database
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
rozza / MongoClientConnectionExample.kt
Last active March 30, 2023 13:57
Kotlin sync simple example of connecting to the database
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
rozza / MongoClientConnectionExample.kt
Last active March 30, 2023 13:57
Kotlin sync with server api example of connecting to the database
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() {
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 {
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
rozza / JavadocFilter.java
Created March 7, 2019 15:43 — forked from benjchristensen/JavadocFilter.java
Doclet for filtering public classes from Javadoc
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;
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
rozza / DocumentToBinary.java
Created September 22, 2015 09:35
Example of static helpers to convert to and from InputStreams
package example;
import org.bson.BsonBinaryReader;
import org.bson.BsonBinaryWriter;
import org.bson.Document;
import org.bson.codecs.Codec;
import org.bson.codecs.DecoderContext;
import org.bson.codecs.DocumentCodec;
import org.bson.codecs.EncoderContext;
import org.bson.io.BasicOutputBuffer;
@rozza
rozza / SomeAbstractClass.java
Created July 11, 2014 11:24
Abstract class with a static member that can't be called
package org.example;
public abstract class SomeAbstractClass {
SomeAbstractClass(){}
/**
* The name of the SomeAbstractClass instance.
*
* @return the name