Java 11

.gitignore

@@ -6,3 +6,4 @@ target/
 *.iml
 src/test/java/com/github/pgasync/impl/Heroku.java
 .repository/
+.gradle

README.md

@@ -45,7 +45,7 @@ db.queryRows("select unnest('{ hello, world }'::text[] as message)")
 
 ### Creating a Db
 
-Db is a connection pool that is created with [`com.github.pgasync.ConnectionPoolBuilder`](https://github.com/alaisi/postgres-async-driver/blob/master/src/main/java/com/github/pgasync/ConnectionPoolBuilder.java)
+Db is a connection pool that is created with [`ConnectionPoolBuilder`](https://github.com/alaisi/postgres-async-driver/blob/master/src/main/java/com/github/pgasync/ConnectionPoolBuilder.java)
 
 ```java
 Db db = new ConnectionPoolBuilder()
@@ -66,7 +66,7 @@ Prepared statements use native PostgreSQL syntax `$index`. Supported parameter t
 
 ```java
 db.querySet("insert into message(id, body) values($1, $2)", 123, "hello")
-    .subscribe(result -> out.printf("Inserted %d rows", result.updatedRows() ));
+    .subscribe(result -> out.printf("Inserted %d rows", result.affectedRows() ));
 ```
 
 ### Transactions
@@ -87,7 +87,7 @@ db.begin()
 
 ### Custom data types
 
-Support for additional data types requires registering converters to [`com.github.pgasync.ConnectionPoolBuilder`](https://github.com/alaisi/postgres-async-driver/blob/master/src/main/java/com/github/pgasync/ConnectionPoolBuilder.java)
+Support for additional data types requires registering converters to [`ConnectionPoolBuilder`](https://github.com/alaisi/postgres-async-driver/blob/master/src/main/java/com/github/pgasync/ConnectionPoolBuilder.java)
 
 ```java
 class JsonConverter implements Converter<example.Json> {

TODO.md

@@ -0,0 +1,21 @@
+## Refactoring
+* Add arguments checks to most core methods.
+
+## Tests
+* Connection pool failed connections
+* Connection pool abandoned waiters
++ Make tests for all message flow scenarios.
++ Errors while validation query processing while getting connection in two cases (pool and plain connectible)
++ Errors while authentication
++ Errors while simple query process
++ Errors while extended query process
++ Multiple result sets test
++ Connection pool statements eviction and duplicated statements
++ Termination process test
++ Prepared statement eviction test
++ Auto rollback transaction review
++ Ssl interaction test
++ Notifications test
++ Transactions general test
++ Connection pool general test
++ Queries pipelining vs errors test

pom.xml

@@ -14,7 +14,6 @@
 
     <name>postgres-async-driver</name>
     <description>Asynchronous PostgreSQL Java driver</description>
-
     <url>https://github.com/alaisi/postgres-async-driver</url>
     <inceptionYear>2014</inceptionYear>
     <developers>
@@ -40,19 +39,14 @@
         <url>https://github.com/alaisi/postgres-async-driver/issues</url>
     </issueManagement>
 
-    <prerequisites>
-        <maven>3.3</maven>
-    </prerequisites>
-
     <build>
         <plugins>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-compiler-plugin</artifactId>
-                <version>3.5.1</version>
+                <version>3.8.0</version>
                 <configuration>
-                    <source>1.8</source>
-                    <target>1.8</target>
+                    <release>11</release>
                 </configuration>
             </plugin>
             <plugin>
@@ -72,13 +66,15 @@
         <dependency>
             <groupId>io.netty</groupId>
             <artifactId>netty-handler</artifactId>
-            <version>4.1.11.Final</version>
+            <version>4.1.33.Final</version>
         </dependency>
+        <!-- https://mvnrepository.com/artifact/javax.xml.bind/jaxb-api -->
         <dependency>
-            <groupId>io.reactivex</groupId>
-            <artifactId>rxjava</artifactId>
-            <version>1.3.0</version>
+            <groupId>javax.xml.bind</groupId>
+            <artifactId>jaxb-api</artifactId>
+            <version>2.3.1</version>
         </dependency>
+
         <dependency>
             <groupId>com.google.code.findbugs</groupId>
             <artifactId>annotations</artifactId>
@@ -95,7 +91,7 @@
         <dependency>
             <groupId>ru.yandex.qatools.embed</groupId>
             <artifactId>postgresql-embedded</artifactId>
-            <version>2.1</version>
+            <version>2.10</version>
             <scope>test</scope>
         </dependency>
     </dependencies>

src/main/java/com/github/pgasync/impl/Oid.java → src/main/java/com/github/pgasync/Oid.java

@@ -12,7 +12,7 @@
  * limitations under the License.
  */
 
-package com.github.pgasync.impl;
+package com.github.pgasync;
 
 /**
  * Object identifiers, copied from org.postgresql.core.Oid.
@@ -87,6 +87,10 @@ public enum Oid {
         this.id = id;
     }
 
+    public int getId() {
+        return id;
+    }
+
     public static Oid valueOfId(int id) {
         for (Oid oid : values()) {
             if (oid.id == id) {

src/main/java/com/github/pgasync/impl/PgColumn.java → src/main/java/com/github/pgasync/PgColumn.java

@@ -12,22 +12,34 @@
  * limitations under the License.
  */
 
-package com.github.pgasync.impl;
+package com.github.pgasync;
 
 /**
  * Column index/type pair.
  *
  * @author Antti Laisi
  */
-class PgColumn{
+public class PgColumn {
 
-    final int index;
-    final String name;
-    final Oid type;
+    private final int index;
+    private final String name;
+    private final Oid type;
 
-    public PgColumn(int index, String name, Oid type){
+    public PgColumn(int index, String name, Oid type) {
         this.index = index;
         this.name = name;
         this.type = type;
     }
+
+    public Oid getType() {
+        return type;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public int at() {
+        return index;
+    }
 }