Merge pull request #474 from influxdata/remove-unsupported-influxdb-c…

…hecks Remove code which checks for unsupported influxdb versions
influxdata · Jul 23, 2018 · 0aac8f0 · 0aac8f0
2 parents c57c09d + b1844b2
commit 0aac8f0
Showing 1 changed file with 0 additions and 8 deletions.
diff --git a/src/main/java/org/influxdb/impl/InfluxDBImpl.java b/src/main/java/org/influxdb/impl/InfluxDBImpl.java
@@ -481,11 +481,6 @@ public void onFailure(final Call<QueryResult> call, final Throwable throwable) {
    */
   @Override
     public void query(final Query query, final int chunkSize, final Consumer<QueryResult> consumer) {
-
-        if (version().startsWith("0.") || version().startsWith("1.0")) {
-            throw new UnsupportedOperationException("chunking not supported");
-        }
-
         Call<ResponseBody> call = null;
         if (query instanceof BoundParameterQuery) {
             BoundParameterQuery boundParameterQuery = (BoundParameterQuery) query;
@@ -556,9 +551,6 @@ public QueryResult query(final Query query, final TimeUnit timeUnit) {
   public void createDatabase(final String name) {
     Preconditions.checkNonEmptyString(name, "name");
     String createDatabaseQueryString = String.format("CREATE DATABASE \"%s\"", name);
-    if (this.version().startsWith("0.")) {
-      createDatabaseQueryString = String.format("CREATE DATABASE IF NOT EXISTS \"%s\"", name);
-    }
     execute(this.influxDBService.postQuery(this.username, this.password, Query.encode(createDatabaseQueryString)));
   }