feat(flux-dsl): supports not operator (#334)

Author: yoobi

CHANGELOG.md

@@ -6,7 +6,6 @@
 
 - see [What is different in RxJava3](https://github.com/ReactiveX/RxJava/wiki/What's-different-in-3.0)
 
- 
 ### Changes in public API
 
   - `WriteService` imports:
@@ -66,7 +65,8 @@ This release also uses new version of InfluxDB OSS API definitions - [oss.yml](h
 1. [#289](https://github.com/influxdata/influxdb-client-java/pull/298): Upgrade `RxJava2` -> `RxJava3`, update outdated dependencies
 1. [#316](https://github.com/influxdata/influxdb-client-java/pull/316): Add `InvocableScriptsApi` to create, update, list, delete and invoke scripts by seamless way
 1. [#315](https://github.com/influxdata/influxdb-client-java/pull/315): Add support for timezones [FluxDSL]
-1. [#317](https://github.com/influxdata/influxdb-client-java/pull/317): Gets HTTP headers from the unsuccessful HTTP reques
+1. [#317](https://github.com/influxdata/influxdb-client-java/pull/317): Gets HTTP headers from the unsuccessful HTTP request
+1. [#334](https://github.com/influxdata/influxdb-client-java/pull/334): Supports not operator [FluxDSL]
 
 ### Bug Fixes
 1. [#313](https://github.com/influxdata/influxdb-client-java/pull/313): Do not deliver `exception` when the consumer is already disposed [influxdb-client-reactive]

flux-dsl/README.md

@@ -240,6 +240,7 @@ Supported Record columns:
 
 Supported Record restrictions:
 - `equal`
+- `not`
 - `notEqual`
 - `less`
 - `greater`

flux-dsl/src/main/java/com/influxdb/query/dsl/functions/restriction/Restrictions.java

@@ -43,6 +43,11 @@ public static Restrictions or(@Nonnull final Restrictions... restrictions) {
         return new Logical("or", restrictions);
     }
 
+    @Nonnull
+    public static Restrictions not(@Nonnull final Restrictions restrictions) {
+        return new Not(restrictions);
+    }
+
     /**
      * Create Record measurement restriction.
      *
@@ -149,4 +154,19 @@ public String toString() {
                     .toString();
         }
     }
+
+    private static class Not extends Restrictions {
+
+        private final Restrictions restriction;
+
+        Not(@Nonnull final Restrictions restrictions) {
+            super();
+            this.restriction = restrictions;
+        }
+
+        @Override
+        public String toString() {
+            return "not " + restriction.toString();
+        }
+    }
 }

flux-dsl/src/test/java/com/influxdb/query/dsl/functions/restriction/RestrictionsTest.java

@@ -64,6 +64,13 @@ void exists() {
         Assertions.assertThat(restrictions.toString()).isEqualTo("exists r[\"_value\"]");
     }
 
+    @Test
+    void not() {
+
+        Restrictions restrictions = Restrictions.not(Restrictions.value().exists());
+        Assertions.assertThat(restrictions.toString()).isEqualTo("not exists r[\"_value\"]");
+    }
+
     @Test
     void emptyLogical() {