mirror of
https://github.com/pocoproject/poco.git
synced 2024-12-18 12:19:30 +01:00
add testLPop
This commit is contained in:
parent
b66751a919
commit
b7bdbf89f0
@ -378,6 +378,79 @@ void RedisTest::testPing()
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void RedisTest::testLPop()
|
||||||
|
{
|
||||||
|
if (!_connected)
|
||||||
|
{
|
||||||
|
std::cout << "Not connected, test skipped." << std::endl;
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Make sure the list is not there yet ...
|
||||||
|
Command delCommand = Command::del("mylist");
|
||||||
|
try
|
||||||
|
{
|
||||||
|
_redis.execute<Poco::Int64>(delCommand);
|
||||||
|
}
|
||||||
|
catch(RedisException& e)
|
||||||
|
{
|
||||||
|
fail(e.message());
|
||||||
|
}
|
||||||
|
catch(Poco::BadCastException& e)
|
||||||
|
{
|
||||||
|
fail(e.message());
|
||||||
|
}
|
||||||
|
|
||||||
|
try
|
||||||
|
{
|
||||||
|
Command rpush = Command::rpush("mylist", "one");
|
||||||
|
Poco::Int64 result = _redis.execute<Poco::Int64>(rpush);
|
||||||
|
assert(result == 1);
|
||||||
|
|
||||||
|
rpush = Command::rpush("mylist", "two");
|
||||||
|
result = _redis.execute<Poco::Int64>(rpush);
|
||||||
|
assert(result == 2);
|
||||||
|
|
||||||
|
rpush = Command::rpush("mylist", "three");
|
||||||
|
result = _redis.execute<Poco::Int64>(rpush);
|
||||||
|
assert(result == 3);
|
||||||
|
}
|
||||||
|
catch(RedisException &e)
|
||||||
|
{
|
||||||
|
fail(e.message());
|
||||||
|
}
|
||||||
|
|
||||||
|
Command lpop = Command::lpop("mylist");
|
||||||
|
try
|
||||||
|
{
|
||||||
|
BulkString result = _redis.execute<BulkString>(lpop);
|
||||||
|
assert(result.value().compare("one") == 0);
|
||||||
|
}
|
||||||
|
catch(RedisException &e)
|
||||||
|
{
|
||||||
|
fail(e.message());
|
||||||
|
}
|
||||||
|
|
||||||
|
Command lrange = Command::lrange("mylist");
|
||||||
|
try
|
||||||
|
{
|
||||||
|
Array result = _redis.execute<Array>(lrange);
|
||||||
|
|
||||||
|
assert(result.size() == 2);
|
||||||
|
assert(result.get<BulkString>(0).value().compare("two") == 0);
|
||||||
|
assert(result.get<BulkString>(1).value().compare("three") == 0);
|
||||||
|
}
|
||||||
|
catch(RedisException &e)
|
||||||
|
{
|
||||||
|
fail(e.message());
|
||||||
|
}
|
||||||
|
catch(Poco::NullValueException &e)
|
||||||
|
{
|
||||||
|
fail(e.message());
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
void RedisTest::testMSet()
|
void RedisTest::testMSet()
|
||||||
{
|
{
|
||||||
if (!_connected)
|
if (!_connected)
|
||||||
@ -1043,6 +1116,7 @@ CppUnit::Test* RedisTest::suite()
|
|||||||
CppUnit_addTest(pSuite, RedisTest, testLIndex);
|
CppUnit_addTest(pSuite, RedisTest, testLIndex);
|
||||||
CppUnit_addTest(pSuite, RedisTest, testLInsert);
|
CppUnit_addTest(pSuite, RedisTest, testLInsert);
|
||||||
CppUnit_addTest(pSuite, RedisTest, testLRem);
|
CppUnit_addTest(pSuite, RedisTest, testLRem);
|
||||||
|
CppUnit_addTest(pSuite, RedisTest, testLPop);
|
||||||
CppUnit_addTest(pSuite, RedisTest, testMulti);
|
CppUnit_addTest(pSuite, RedisTest, testMulti);
|
||||||
|
|
||||||
CppUnit_addTest(pSuite, RedisTest, testPubSub);
|
CppUnit_addTest(pSuite, RedisTest, testPubSub);
|
||||||
|
@ -44,6 +44,7 @@ public:
|
|||||||
void testRPush();
|
void testRPush();
|
||||||
void testLIndex();
|
void testLIndex();
|
||||||
void testLInsert();
|
void testLInsert();
|
||||||
|
void testLPop();
|
||||||
void testLRem();
|
void testLRem();
|
||||||
void testMulti();
|
void testMulti();
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user