@@ -26,7 +26,7 @@ resulting errors see [this section.](#synchronous-writes)
2626``` java
2727InfluxDB influxDB = InfluxDBFactory . connect(" http://172.17.0.2:8086" , " root" , " root" );
2828String dbName = " aTimeSeries" ;
29- influxDB. query(new Query (" CREATE DATABASE " + dbName, " " ));
29+ influxDB. query(new Query (" CREATE DATABASE " + dbName));
3030influxDB. setDatabase(dbName);
3131String rpName = " aRetentionPolicy" ;
3232influxDB. createRetentionPolicy(rpName, dbName, " 30d" , " 30m" , 2 , true );
@@ -50,7 +50,7 @@ influxDB.write(Point.measurement("disk")
5050Query query = new Query (" SELECT idle FROM cpu" , dbName);
5151influxDB. query(query);
5252influxDB. dropRetentionPolicy(rpName, dbName);
53- influxDB. deleteDatabase( dbName);
53+ influxDB. query( new Query ( " DROP DATABASE " + dbName) );
5454influxDB. close();
5555```
5656
@@ -86,7 +86,7 @@ If your points are written into different databases and retention policies, the
8686``` java
8787InfluxDB influxDB = InfluxDBFactory . connect(" http://172.17.0.2:8086" , " root" , " root" );
8888String dbName = " aTimeSeries" ;
89- influxDB. query(new Query (" CREATE DATABASE " + dbName, " " ));
89+ influxDB. query(new Query (" CREATE DATABASE " + dbName));
9090String rpName = " aRetentionPolicy" ;
9191influxDB. createRetentionPolicy(rpName, dbName, " 30d" , " 30m" , 2 , true );
9292
@@ -110,7 +110,7 @@ influxDB.write(dbName, rpName, point2);
110110Query query = new Query (" SELECT idle FROM cpu" , dbName);
111111influxDB. query(query);
112112influxDB. dropRetentionPolicy(rpName, dbName);
113- influxDB. deleteDatabase( dbName);
113+ influxDB. query( new Query ( " DROP DATABASE " + dbName) );
114114influxDB. close();
115115```
116116
@@ -121,7 +121,7 @@ If you want to write the data points immediately to InfluxDB (and handle the err
121121``` java
122122InfluxDB influxDB = InfluxDBFactory . connect(" http://172.17.0.2:8086" , " root" , " root" );
123123String dbName = " aTimeSeries" ;
124- influxDB. query(new Query (" CREATE DATABASE " + dbName, " " ));
124+ influxDB. query(new Query (" CREATE DATABASE " + dbName));
125125String rpName = " aRetentionPolicy" ;
126126influxDB. createRetentionPolicy(rpName, dbName, " 30d" , " 30m" , 2 , true );
127127
@@ -148,7 +148,7 @@ influxDB.write(batchPoints);
148148Query query = new Query (" SELECT idle FROM cpu" , dbName);
149149influxDB. query(query);
150150influxDB. dropRetentionPolicy(rpName, dbName);
151- influxDB. deleteDatabase( dbName);
151+ influxDB. query( new Query ( " DROP DATABASE " + dbName) );
152152```
153153
154154#### Try-with-resources
0 commit comments