[arrow-adbc] branch main updated: fix(go/adbc/driver/flightsql): properly map error codes (#509)

[lidavidm]

This is an automated email from the ASF dual-hosted git repository.

lidavidm pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-adbc.git


The following commit(s) were added to refs/heads/main by this push:
     new a1acf0b  fix(go/adbc/driver/flightsql): properly map error codes (#509)
a1acf0b is described below

commit a1acf0be13ed541b17dc21f99664b97d1137ea1a
Author: David Li <li.david...@gmail.com>
AuthorDate: Mon Mar 13 12:40:15 2023 -0400

    fix(go/adbc/driver/flightsql): properly map error codes (#509)
    
    Fixes #508.
---
 go/adbc/driver/flightsql/utils.go | 34 ++++++++++++++++++++++------------
 1 file changed, 22 insertions(+), 12 deletions(-)

diff --git a/go/adbc/driver/flightsql/utils.go 
b/go/adbc/driver/flightsql/utils.go
index 6ffd253..4f1f165 100644
--- a/go/adbc/driver/flightsql/utils.go
+++ b/go/adbc/driver/flightsql/utils.go
@@ -36,24 +36,34 @@ func adbcFromFlightStatus(err error) error {
                adbcCode = adbc.StatusCancelled
        case codes.Unknown:
                adbcCode = adbc.StatusUnknown
-       case codes.Internal:
-               adbcCode = adbc.StatusInternal
        case codes.InvalidArgument:
                adbcCode = adbc.StatusInvalidArgument
-       case codes.AlreadyExists:
-               adbcCode = adbc.StatusAlreadyExists
+       case codes.DeadlineExceeded:
+               adbcCode = adbc.StatusTimeout
        case codes.NotFound:
                adbcCode = adbc.StatusNotFound
-       case codes.Unauthenticated:
-               adbcCode = adbc.StatusUnauthenticated
-       case codes.Unavailable:
-               adbcCode = adbc.StatusIO
-       case codes.Unimplemented:
-               adbcCode = adbc.StatusNotImplemented
+       case codes.AlreadyExists:
+               adbcCode = adbc.StatusAlreadyExists
        case codes.PermissionDenied:
                adbcCode = adbc.StatusUnauthorized
-       case codes.DeadlineExceeded:
-               adbcCode = adbc.StatusTimeout
+       case codes.ResourceExhausted:
+               adbcCode = adbc.StatusInternal
+       case codes.FailedPrecondition:
+               adbcCode = adbc.StatusUnknown
+       case codes.Aborted:
+               adbcCode = adbc.StatusUnknown
+       case codes.OutOfRange:
+               adbcCode = adbc.StatusUnknown
+       case codes.Unimplemented:
+               adbcCode = adbc.StatusNotImplemented
+       case codes.Internal:
+               adbcCode = adbc.StatusInternal
+       case codes.Unavailable:
+               adbcCode = adbc.StatusIO
+       case codes.DataLoss:
+               adbcCode = adbc.StatusIO
+       case codes.Unauthenticated:
+               adbcCode = adbc.StatusUnauthenticated
        default:
                adbcCode = adbc.StatusUnknown
        }