Commits

Liam Staskawicz committed cd6b3c8

* format fields correctly for query - still needs testing

  • Participants
  • Parent commits e0c1391

Comments (0)

Files changed (1)

     return (opts["admin"] == true) ? "admin.${coll.name}" : coll.fullName
   }
   
+  private [Str:Int]? fieldsForQuery(Str[] fields)
+  {
+    if(fields.isEmpty) return null
+    m := Str:Int[:]
+    fields.each |val| { m[val] = 1 }
+    return m
+  }
+  
   private Void doQuery(Int numToRetrieve)
   {
     b := Buf() { endian = Endian.little }
     b.writeI4(numToRetrieve)                    // num to return
     Bson.write(b.out, selector)                 // query object
     if(opts.containsKey("fields"))              // optional fieldReturnSelector
-      Bson.write(b.out, opts["fields"])
+      Bson.write(b.out, fieldsForQuery(opts["fields"]))
     
     s := coll.db.connection.getSocket()
     reqID := coll.db.connection.sendMsg(s.out, b.flip, MongoOp.QUERY)