rdbc-io / rdbc-pgsql Goto Github PK

View Code? Open in Web Editor NEW

22.0 9.0 2.0 697 KB

Asynchronous PostgreSQL driver for Scala and Java

Home Page: http://rdbc.io

License: Apache License 2.0

Scala 97.85% CSS 0.14% Java 1.86% JavaScript 0.15%

postgresql driver asynchronous reactive database back-pressure rdbc non-blocking scala java

rdbc-pgsql's Issues

Implement operation cancellation

Check for write errors when writing (out.write future)

Implement SSL support

Connection validation is broken for closed connections

validate method now returns IllegalSessionStateException if connection is already closed. It should return ConnectionValidationException in this case. It should still return IllegalSessionStateException if connection is in use though

Investigate if the non-blocking property holds

Investigate the code whether it really is non-blocking and possibly fix it.

Optimize non-select operations

In non-select operations like non-returning inserts, deletes, updates there are many optimizations available:

don't set up a publisher (stream)
don't do describe, do parse & bind & execute together
something else?

Fix error cause returned by PG during md5 auth

Implement streamParams

NettyPgConnectionFactory can't create more than one connection

Allow Options as statement parameters

Allow setting SQL null values as Nones and not null SQL values as Somes.

Make PgConnectionFactory completely configurable

Fix TODO, don't fill config props, this should be the other way around

Implement PgStatement.bindByIdx

Documentation should link to the examples repository

Fix TODOs in StatusMessage

Fix TODOs in DataRowPublisher

Inserts/Selects/Updates/Deletes can't be deallocated

Insert doesnt implement Statement where deallocate method is. This should change I think. Insert should also have streamParams method.

Create cross tests with JDBC pgsql driver

Create a PoC of netty transport

Return Warnings to clients in PG

Fix TODOs in PgBindable

General clean up

Generally clean up all the code, deal with code duplication, too long methods etc.

Support NotificationResponse message

This issue is only about not crashing on unknown NotificationResponse backend message, not about Postgres' LISTEN/NOTIFY mechanism support.

When PgSession gets "closed" msg, mark PgConnection as closed and reject requests with error

Handle EmptyQueryResponse in QueryingExtended

Investigate spurious test fails - race conditions?

[info] - stochastic_spec103_mustSignalOnMethodsSequentially *** FAILED ***
[info]   java.util.concurrent.TimeoutException: Futures timed out after [10 seconds]
[info]   at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:223)
[info]   at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:227)
[info]   at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:190)
[info]   at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
[info]   at scala.concurrent.Await$.result(package.scala:190)
[info]   at io.rdbc.test.package$AwaitableOps.get(package.scala:26)
[info]   at io.rdbc.test.RowPublisherVerification.createPublisher(RowPublisherVerification.scala:63)
[info]   at org.reactivestreams.tck.PublisherVerification.activePublisherTest(PublisherVerification.java:1091)
[info]   at org.reactivestreams.tck.PublisherVerification$5.apply(PublisherVerification.java:244)
[info]   at org.reactivestreams.tck.PublisherVerification$5.apply(PublisherVerification.java:241)

Handle SyncError in PgSession

Remove DescribedDataRow

DescribedDataRow is not needed, see how extended querying makes queries without described data row. DescribedDataRow shouldn't be used for simple queries.

Extract what's possible from pgsql-akka to pgsql-core.

Introduce a stmt cache threshold and cache eviction

Fix TODOs in PgRowPublisher

PgParametrizedStatement: parameter and return value formats

Decide whether returning DB values should always be in binary format, if so, make appropriate changes to PgParametrizedStatement.

Use binary parameters at first attempt and textual as a fallback. Investigate whether PG supports textual for all possible datatypes. Make it possible for a pg type converter to implement only textual or only binary format