diff --git a/command.go b/command.go index a7ea6ab..6664eca 100644 --- a/command.go +++ b/command.go @@ -235,7 +235,7 @@ func (srv *Server) handleSimpleQuery(ctx context.Context, reader *buffer.Reader, statement, _, columns, err := srv.parse(ctx, query) if err != nil { - return err + return ErrorCode(writer, err) } if err != nil {