simpleQuery and query should continue after errors

tanner0101 · tanner0101 · commit 650884b8345e · 2019-05-10T17:51:00.000-04:00
diff --git a/Sources/NIOPostgres/Connection/PostgresClient+Query.swift b/Sources/NIOPostgres/Connection/PostgresClient+Query.swift
@@ -39,7 +39,8 @@ private final class PostgresParameterizedQuery: PostgresRequest {
     
     func respond(to message: PostgresMessage) throws -> [PostgresMessage]? {
         if case .error = message.identifier {
-            return nil
+            // we should continue after errors
+            return []
         }
         switch message.identifier {
         case .bindComplete:
diff --git a/Sources/NIOPostgres/Connection/PostgresClient+SimpleQuery.swift b/Sources/NIOPostgres/Connection/PostgresClient+SimpleQuery.swift
@@ -31,7 +31,8 @@ private final class PostgresSimpleQuery: PostgresRequest {
     
     func respond(to message: PostgresMessage) throws -> [PostgresMessage]? {
         if case .error = message.identifier {
-            return nil
+            // we should continue after errors
+            return []
         }
         switch message.identifier {
         case .dataRow:

Original file line number	Diff line number	Diff line change
`@@ -39,7 +39,8 @@ private final class PostgresParameterizedQuery: PostgresRequest {`
`39`	`39`
`40`	`40`	`func respond(to message: PostgresMessage) throws -> [PostgresMessage]? {`
`41`	`41`	`if case .error = message.identifier {`
`42`		`- return nil`
	`42`	`+ // we should continue after errors`
	`43`	`+ return []`
`43`	`44`	`}`
`44`	`45`	`switch message.identifier {`
`45`	`46`	`case .bindComplete:`
Original file line number	Diff line number	Diff line change
`@@ -31,7 +31,8 @@ private final class PostgresSimpleQuery: PostgresRequest {`
`31`	`31`
`32`	`32`	`func respond(to message: PostgresMessage) throws -> [PostgresMessage]? {`
`33`	`33`	`if case .error = message.identifier {`
`34`		`- return nil`
	`34`	`+ // we should continue after errors`
	`35`	`+ return []`
`35`	`36`	`}`
`36`	`37`	`switch message.identifier {`
`37`	`38`	`case .dataRow:`