Allow dropping of specific series from specific DBs

Author: cantino

lib/influxdb/query/series.rb

@@ -1,8 +1,12 @@
 module InfluxDB
   module Query
     module Series # :nodoc:
-      def delete_series(name)
-        execute("DROP SERIES FROM #{name}", db: config.database)
+      def delete_series(name, where: nil, db: config.database)
+        if where
+          execute("DROP SERIES FROM \"#{name}\" WHERE #{where}", db: db)
+        else
+          execute("DROP SERIES FROM \"#{name}\"", db: db)
+        end
       end
 
       def list_series

spec/influxdb/cases/query_series_spec.rb

@@ -49,16 +49,32 @@
   end
 
   describe "#delete_series" do
-    let(:name) { "events" }
-    let(:query) { "DROP SERIES FROM #{name}" }
+    describe "without a where clause" do
+      let(:name) { "events" }
+      let(:query) { "DROP SERIES FROM \"#{name}\"" }
 
-    before do
-      stub_request(:get, "http://influxdb.test:9999/query")
-        .with(query: { u: "username", p: "password", q: query, db: "database" })
+      before do
+        stub_request(:get, "http://influxdb.test:9999/query")
+          .with(query: { u: "username", p: "password", q: query, db: "database" })
+      end
+
+      it "should GET to remove a database" do
+        expect(subject.delete_series(name)).to be_a(Net::HTTPOK)
+      end
     end
 
-    it "should GET to remove a database" do
-      expect(subject.delete_series(name)).to be_a(Net::HTTPOK)
+    describe "with a where clause" do
+      let(:name) { "events" }
+      let(:query) { "DROP SERIES FROM \"#{name}\" WHERE \"tag\"='value'" }
+
+      before do
+        stub_request(:get, "http://influxdb.test:9999/query")
+          .with(query: { u: "username", p: "password", q: query, db: "database" })
+      end
+
+      it "should GET to remove a database" do
+        expect(subject.delete_series(name, where: "\"tag\"='value'")).to be_a(Net::HTTPOK)
+      end
     end
   end
 end