Kotlin coroutine support for MongoDB built on top of the official Reactive Streams Java Driver

Marc Knaup

Last update: Oct 3, 2022

Related tags

Overview

fluid-mongo

Kotlin coroutine support for MongoDB built on top of the official MongoDB Reactive Streams Java Driver.

Installation

build.gradle.kts:

dependencies {
    implementation("io.fluidsonic.mongo:fluid-mongo:1.4.0")
}

Example

import io.fluidsonic.mongo.MongoClients
import org.bson.Document


suspend fun main() {
    val collection = MongoClients.create()
        .getDatabase("test")
        .getCollection("test")

    collection.insertOne(mapOf("hello" to "world"))    // suspending call
    collection.insertOne(mapOf("it's" to "so easy!"))  // suspending call

    collection.find().collect { document ->  // Kotlin Flow
        println(document)
    }
}

Output:

Document{{_id=5bb6b56f9cfa62686b5afc87, hello=world}}
Document{{_id=5bb6b56f9cfa62686b5afc88, it's=so easy!}}

License

Apache 2.0

You might also like...

A project to learn about Reactive Microservices experimenting with architectures and patterns

7 Feb 21, 2022

Event-driven application uses React, reactive Spring Boot WebFlux, R2DBC, MySQL and Liquibase

Product delivery Event-driven application uses React, reactive Spring Boot WebFlux, R2DBC, MySQL and Liquibase Status: IN PROGRESS if [[ "" != `docker

2 Aug 17, 2022

New Relic Kotlin Instrumentation for Kotlin Coroutine. It successfully handles thread changes in suspend states.

new-relic-kotlin-coroutine New Relic Kotlin Instrumentation for Kotlin Coroutine. It successfully handles thread changes in suspend states. Usage 1- U

7 Nov 17, 2022

Saga pattern implementation in Kotlin build in top of Kotlin's Coroutines.

Module Saga Website can be found here Add in build.gradle.kts repositories { mavenCentral() } dependencies { implementation("io.github.nomisr

50 Dec 30, 2022

Android Multi Theme Switch Library ,use kotlin language ,coroutine ,and so on ...

Magic Mistletoe Android多主题（换肤）切换框架背景时隔四年，在网易换肤之前的思路下，做了几点改进，现在完全通过反射创建View，并且在SkinLoadManager中提供一个configCustomAttrs以支持自定义View的属性插队替换摈弃了之前的AsyncTask

18 Jun 17, 2022

R2DBC Sharding Example with Kotlin Coroutine

R2DBC Sharding Example with Kotlin Coroutine A minimal sharding example with R2DBC and coroutine, where user table is divided into 2 different shards.

0 Oct 4, 2021

Kreds - a thread-safe, idiomatic, coroutine based Redis client written in 100% Kotlin

Kreds Kreds is a thread-safe, idiomatic, coroutine based Redis client written in 100% Kotlin. Why Kreds? Kreds is designed to be EASY to use. Kreds ha

117 Dec 23, 2022

Demonstration of Object Pool Design Pattern using Kotlin language and Coroutine

Object Pool Design Pattern with Kotlin Demonstration of Thread Safe Object Pool Design Pattern using Kotlin language and Coroutine. Abstract The objec

7 Apr 12, 2022

Mobile client for official Nextcloud News App written as Kotlin Multiplatform Project

Newsout Android and iOS mobile client for Nextcloud news App. The Android client is already available to download in the Play Store. F-Droid and Apple

118 Oct 3, 2022

Comments

No action.

Hello, i try insert some document and timeout code with println -> https://imgur.com/a/Qangnia

Exception -> Exception in thread "main" com.mongodb.MongoTimeoutException: Timed out after 30000 ms while waiting for a server that matches WritableServerSelector. Client view of cluster state is {type=UNKNOWN, servers=[{address=xxxxx:xxx, type=UNKNOWN, state=CONNECTING, exception={com.mongodb.MongoSocketOpenException: Exception opening socket}, caused by {java.io.IOException: The remote computer refused the network connection }}] at com.mongodb.internal.connection.BaseCluster.createTimeoutException(BaseCluster.java:407) at com.mongodb.internal.connection.BaseCluster.handleServerSelectionRequest(BaseCluster.java:311) at com.mongodb.internal.connection.BaseCluster.access$800(BaseCluster.java:62) at com.mongodb.internal.connection.BaseCluster$WaitQueueHandler.run(BaseCluster.java:478) at java.lang.Thread.run(Thread.java:748)

opened by TheMajster 3
Callback-based MongoDB Async Java Driver is deprecated since v3.9

I was about to start using KMongo on a new project when I decided to check some documentation on the underlying client and noticed it's deprecated since MongoDB Async/Reactive Java Driver v3.9 (now on 3.11). Here's my source: https://mongodb.github.io/mongo-java-driver/3.11/driver-async/#what-s-new-in-3-9 Maybe this lib should change to wrapping reactive streams?

opened by Tmpod 2
where are the tests?

Hello! I see no automatic tests in the repo.

Do the tests exist? If so, where can I find them? If I want to contribute, how do I test the project.

Thank you!

opened by voddan 1

Releases(1.5.0)

1.5.0(Feb 5, 2022)
Kotlin 1.6.10

kotlinx-coroutines 1.6.0

mongodb-driver 4.4.1

Source code(tar.gz)
Source code(zip)
1.4.0(Aug 6, 2021)
Kotlin 1.5.21

kotlinx-coroutines 1.5.1

mongodb-driver 4.3.1

Source code(tar.gz)
Source code(zip)
1.3.0(May 27, 2021)
Kotlin 1.5.10

kotlinx-coroutines 1.5.0

mongodb-driver 4.2.3

Source code(tar.gz)
Source code(zip)
1.1.3(Oct 15, 2020)
Made sure that all execution happens on Dispatchers.IO

Updated to MongoDB Reactive Streams Java Driver 4.1.1

Updated to Kotlin 1.4.10

Source code(tar.gz)
Source code(zip)
1.1.0(Jul 29, 2020)
Kotlin 1.4.0-rc

Source code(tar.gz)
Source code(zip)
1.0.1(May 29, 2020)
Added .empty() to all Flows

Updated kotlin-* to 1.3.72

Updated kotlinx-coroutines-* to 3.0.7

Updated mongodb-driver-* to 4.0.3

Source code(tar.gz)
Source code(zip)
1.0.0(Mar 6, 2020)

🎉 with Kotlin 1.3.70 and MongoDB Reactive Streams Java Driver 4.0.0
Source code(tar.gz)
Source code(zip)
1.0.0-beta.2(Oct 20, 2019)
Use KClass instead of Class

Source code(tar.gz)
Source code(zip)
1.0.0-beta.1(Oct 19, 2019)
Migrated to Reactive Streams driver and Kotlin Flows

Source code(tar.gz)
Source code(zip)
0.9.11(Oct 19, 2019)
Gradle group ID and Kotlin package changed to io.fluidsonic.mongo.

Source code(tar.gz)
Source code(zip)
0.9.10(Oct 15, 2019)
Updated mongodb-driver-async to 3.11.1

Updated kotlin-coroutines-core to 1.3.2

Source code(tar.gz)
Source code(zip)

Owner

Marc Knaup

❤️ tech / startups / crypto / travel

GitHub

An android app using Mongodb for logistics tracking system.

DeliveryGo An android application for logistics tracking. Used technology Kotlin: In this project kotlin is used to code the full application on Andro

1 Mar 5, 2022

Template to accelerate the creation of new apps using Spring Boot 3, MongoDB & GraphQL.

1 Feb 13, 2022

User Authentication ( Compose Ktor Server MongoDB)

Utilising Security in android for Authentication and Authorization for Android I would be using mongo db to perform all basic operations no need for f

0 May 2, 2022

A sample skeleton backend app built using Spring Boot kotlin, Expedia Kotlin Graphql, Reactive Web that can be deployed to Google App Engine Flexible environmennt

spring-kotlin-gql-gae This is a sample skeleton of a backend app that was built using: Spring Boot(Kotlin) Reactive Web Sprinng Data R2DBC with MYSQL

7 Sep 17, 2022

Kotlin coroutine support for MongoDB built on top of the official Reactive Streams Java Driver

Related tags

Overview

fluid-mongo

Installation

Example

License

You might also like...

A project to learn about Reactive Microservices experimenting with architectures and patterns

Event-driven application uses React, reactive Spring Boot WebFlux, R2DBC, MySQL and Liquibase

New Relic Kotlin Instrumentation for Kotlin Coroutine. It successfully handles thread changes in suspend states.

Saga pattern implementation in Kotlin build in top of Kotlin's Coroutines.

Android Multi Theme Switch Library ,use kotlin language ,coroutine ,and so on ...

R2DBC Sharding Example with Kotlin Coroutine

Kreds - a thread-safe, idiomatic, coroutine based Redis client written in 100% Kotlin

Demonstration of Object Pool Design Pattern using Kotlin language and Coroutine

Mobile client for official Nextcloud News App written as Kotlin Multiplatform Project

Comments

No action.

Callback-based MongoDB Async Java Driver is deprecated since v3.9

where are the tests?

Releases(1.5.0)

1.5.0(Feb 5, 2022)

1.4.0(Aug 6, 2021)

1.3.0(May 27, 2021)

1.1.3(Oct 15, 2020)

1.1.0(Jul 29, 2020)

1.0.1(May 29, 2020)

1.0.0(Mar 6, 2020)

1.0.0-beta.2(Oct 20, 2019)

1.0.0-beta.1(Oct 19, 2019)

0.9.11(Oct 19, 2019)

0.9.10(Oct 15, 2019)

Owner

Marc Knaup

An android app using Mongodb for logistics tracking system.

Template to accelerate the creation of new apps using Spring Boot 3, MongoDB & GraphQL.

User Authentication ( Compose Ktor Server MongoDB)

A sample skeleton backend app built using Spring Boot kotlin, Expedia Kotlin Graphql, Reactive Web that can be deployed to Google App Engine Flexible environmennt

This repository contains event driven redis app uses redis streams

Kafka Streams Processor to unwrap CØSMOS blocks into CØSMOS transactions

Spring-graphql-getting-started - Spring for GraphQL provides support for Spring applications built on GraphQL Java

Reactive setup with Spring WebFlux , Kotlin, Postgres and Spring Data R2DBC

Showcase project of Functional Reactive Programming on Android, using RxJava.

My personal template for a Spring Boot REST reactive webapp