Vergara_Tech/mongodb
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

add find command: simpler to use then query for most uses

Browse source
This commit is contained in:
Scott R. Parish 2010-01-16 18:54:26 -06:00
parent 20f68b706c
commit 344c6bb975
1 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
Database/MongoDB.hs
View file

@ -3,6 +3,7 @@ module Database.MongoDB
connect, connectOnPort, conClose, connect, connectOnPort, conClose,
delete, insert, insertMany, query, remove, update, delete, insert, insertMany, query, remove, update,
nextDoc, finish, nextDoc, finish,
find,
Collection, FieldSelector, NumToSkip, NumToReturn, RequestID, Selector, Collection, FieldSelector, NumToSkip, NumToReturn, RequestID, Selector,
Opcode(..), Opcode(..),
QueryOpt(..), QueryOpt(..),
@ -15,7 +16,7 @@ import Data.Binary
import Data.Binary.Get import Data.Binary.Get
import Data.Binary.Put import Data.Binary.Put
import Data.Bits import Data.Bits
import Data.ByteString.Char8 import Data.ByteString.Char8 hiding (find)
import qualified Data.ByteString.Lazy as L import qualified Data.ByteString.Lazy as L
import qualified Data.ByteString.Lazy.UTF8 as L8 import qualified Data.ByteString.Lazy.UTF8 as L8
import Data.Int import Data.Int
@ -147,6 +148,11 @@ insertMany c col docs = do
L.hPut (cHandle c) msg L.hPut (cHandle c) msg
return reqID return reqID
{- | Open a cursor to find documents. If you need full functionality,
see 'query' -}
find :: Connection -> Collection -> Selector -> IO Cursor
find c col sel = query c col [] 0 0 sel Nothing
query :: Connection -> Collection -> [QueryOpt] -> NumToSkip -> NumToReturn -> query :: Connection -> Collection -> [QueryOpt] -> NumToSkip -> NumToReturn ->
Selector -> Maybe FieldSelector -> IO Cursor Selector -> Maybe FieldSelector -> IO Cursor
query c col opts skip ret sel fsel = do query c col opts skip ret sel fsel = do
@ -228,6 +234,8 @@ getReply h = do
return $ (Reply respFlags cursorID startFrom numReturned) return $ (Reply respFlags cursorID startFrom numReturned)
{- | Return one document or Nothing if there are no more.
Automatically closes the curosr when last document is read -}
nextDoc :: Cursor -> IO (Maybe BSONObject) nextDoc :: Cursor -> IO (Maybe BSONObject)
nextDoc cur = do nextDoc cur = do
closed <- readIORef $ curClosed cur closed <- readIORef $ curClosed cur