generic-library/poco
1
0
Fork 0
mirror of https://github.com/pocoproject/poco.git synced 2025-10-27 11:06:50 +01:00
Code Issues Projects Releases Wiki Activity

Add rpoplpush

Browse Source
This commit is contained in:
fbraem
2015-11-14 18:36:48 +01:00
parent df452c610f
commit f3dd36ac70
4 changed files with 105 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
Redis/include/Poco/Redis/Command.h
View File

@@ -105,6 +105,9 @@ public:
static Command rpop(const std::string& list);
/// Returns a RPOP command
static Command rpoplpush(const std::string& sourceList, const std::string& destinationList);
/// Returns a RPOPLPUSH command
static Command rpush(const std::string& list, const std::string& value, bool create = true);
/// Returns a RPUSH or RPUSHX (when create is false) command

8
Redis/src/Command.cpp
View File

@@ -236,6 +236,14 @@ Command Command::rpop(const std::string& list)
return cmd;
}
Command Command::rpoplpush(const std::string& sourceList, const std::string& destinationList)
{
Command cmd("RPOPLPUSH");
cmd << sourceList << destinationList;
return cmd;
}
Command Command::rpush(const std::string& list, const std::string& value, bool create)
{

93
Redis/testsuite/src/RedisTest.cpp
View File

@@ -827,6 +827,98 @@ void RedisTest::testRPop()
}
void RedisTest::testRPoplPush()
{
if (!_connected)
{
std::cout << "Not connected, test skipped." << std::endl;
return;
}
// Make sure the lists are not there yet ...
std::vector<std::string> lists;
lists.push_back("mylist");
lists.push_back("myotherlist");
Command delCommand = Command::del(lists);
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 rpoplpush = Command::rpoplpush("mylist", "myotherlist");
try
{
BulkString result = _redis.execute<BulkString>(rpoplpush);
assert(result.value().compare("three") == 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("one") == 0);
assert(result.get<BulkString>(1).value().compare("two") == 0);
}
catch(RedisException &e)
{
fail(e.message());
}
catch(Poco::NullValueException &e)
{
fail(e.message());
}
lrange = Command::lrange("myotherlist");
try
{
Array result = _redis.execute<Array>(lrange);
assert(result.size() == 1);
assert(result.get<BulkString>(0).value().compare("three") == 0);
}
catch(RedisException &e)
{
fail(e.message());
}
catch(Poco::NullValueException &e)
{
fail(e.message());
}
}
void RedisTest::testRPush()
{
if (!_connected)
@@ -1338,6 +1430,7 @@ CppUnit::Test* RedisTest::suite()
CppUnit_addTest(pSuite, RedisTest, testMSetWithMap);
CppUnit_addTest(pSuite, RedisTest, testStrlen);
CppUnit_addTest(pSuite, RedisTest, testRPush);
CppUnit_addTest(pSuite, RedisTest, testRPoplPush);
CppUnit_addTest(pSuite, RedisTest, testLIndex);
CppUnit_addTest(pSuite, RedisTest, testLInsert);
CppUnit_addTest(pSuite, RedisTest, testLRem);

1
Redis/testsuite/src/RedisTest.h
View File

@@ -52,6 +52,7 @@ public:
void testPubSub();
void testRPop();
void testRPoplPush();
void testPipeliningWithSendCommands();
void testPipeliningWithWriteCommand();