mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-12-01 09:32:32 +01:00
Code Issues Releases Activity

Tailable w/ delete tests

Browse Source
This commit is contained in:
Aaron 2009-03-11 17:19:08 -04:00
parent 3055ab6d1d
commit 1bf6caeb4c
1 changed files with 43 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
dbtests/querytests.cpp
View File

@ -292,6 +292,47 @@ namespace QueryTests {
} }
}; };
class TailableDelete : public ClientBase {
public:
~TailableDelete() {
client().dropCollection( "querytests.TailableDelete" );
}
void run() {
const char *ns = "querytests.TailableDelete";
insert( ns, BSON( "a" << 0 ) );
insert( ns, BSON( "a" << 1 ) );
auto_ptr< DBClientCursor > c = client().query( ns, Query().hint( BSON( "$natural" << 1 ) ), 2, 0, 0, Option_CursorTailable );
c->next();
c->next();
ASSERT( !c->more() );
client().remove( ns, QUERY( "a" << 1 ) );
insert( ns, BSON( "a" << 2 ) );
ASSERT( !c->more() );
ASSERT_EQUALS( 0, c->getCursorId() );
}
};
class TailableInsertDelete : public ClientBase {
public:
~TailableInsertDelete() {
client().dropCollection( "querytests.TailableInsertDelete" );
}
void run() {
const char *ns = "querytests.TailableInsertDelete";
insert( ns, BSON( "a" << 0 ) );
insert( ns, BSON( "a" << 1 ) );
auto_ptr< DBClientCursor > c = client().query( ns, Query().hint( BSON( "$natural" << 1 ) ), 2, 0, 0, Option_CursorTailable );
c->next();
c->next();
ASSERT( !c->more() );
insert( ns, BSON( "a" << 2 ) );
client().remove( ns, QUERY( "a" << 1 ) );
ASSERT( c->more() );
ASSERT_EQUALS( 2, c->next().getIntField( "a" ) );
ASSERT( !c->more() );
}
};
class All : public UnitTest::Suite { class All : public UnitTest::Suite {
public: public:
All() { All() {
@ -311,6 +352,8 @@ namespace QueryTests {
add< ReturnOneOfManyAndTail >(); add< ReturnOneOfManyAndTail >();
add< TailNotAtEnd >(); add< TailNotAtEnd >();
add< EmptyTail >(); add< EmptyTail >();
add< TailableDelete >();
add< TailableInsertDelete >();
} }
}; };