diff --git a/lib/couchbase-orm/relation.rb b/lib/couchbase-orm/relation.rb
index 006b831..fc49511 100644
--- a/lib/couchbase-orm/relation.rb
+++ b/lib/couchbase-orm/relation.rb
@@ -113,7 +113,7 @@ def [](*args)
             def delete_all
                 CouchbaseOrm::logger.debug{ "Delete all: #{self}" }
                 ids = query.to_a
-                CouchbaseOrm::Connection.bucket.default_collection.remove_multi(ids) unless ids.empty?
+                @model.bucket.default_collection.remove_multi(ids) unless ids.empty?
             end
 
             def where(string_cond=nil, **conds)