generic-library/poco
1
0
Fork 0
mirror of https://github.com/pocoproject/poco.git synced 2025-04-17 07:13:27 +02:00
Code Issues Projects Releases Wiki Activity

added support for additional commands (exists, expire, ping, multi, exec, discard)

Browse Source
This commit is contained in:
Günter Obiltschnig 2019-06-22 14:44:01 +02:00
parent d5ab10cc10
commit 5cfd767239
2 changed files with 32 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
Redis/include/Poco/Redis/Client.h
View File

@ -116,6 +116,9 @@ public:
void disconnect();
/// Disconnects from the Redis server.
bool isConnected() const;
/// Returns true iff the Client is connected to a Redis server.
template<typename T>
T execute(const Array& command)
/// Sends the Redis Command to the server. It gets the reply
@ -130,7 +133,7 @@ public:
/// Array and void. When the reply is an Error, it will throw
/// a RedisException.
{
T result;
T result = T();
writeCommand(command, true);
readReply(result);
return result;

44
Redis/src/Client.cpp
View File

@ -22,39 +22,39 @@ namespace Poco {
namespace Redis {
Client::Client():
_address(),
_socket(),
_input(0),
Client::Client():
_address(),
_socket(),
_input(0),
_output(0)
{
}
Client::Client(const std::string& hostAndPort):
_address(hostAndPort),
_socket(),
_input(0),
_address(hostAndPort),
_socket(),
_input(0),
_output(0)
{
connect();
}
Client::Client(const std::string& host, int port):
_address(host, port),
_socket(),
_input(0),
Client::Client(const std::string& host, int port):
_address(host, port),
_socket(),
_input(0),
_output(0)
{
connect();
}
Client::Client(const Net::SocketAddress& addrs):
_address(addrs),
_socket(),
_input(0),
Client::Client(const Net::SocketAddress& addrs):
_address(addrs),
_socket(),
_input(0),
_output(0)
{
connect();
@ -73,7 +73,7 @@ void Client::connect()
poco_assert(! _input);
poco_assert(! _output);
_socket.connect(_address);
_socket = Net::StreamSocket(_address);
_input = new RedisInputStream(_socket);
_output = new RedisOutputStream(_socket);
}
@ -105,6 +105,7 @@ void Client::connect(const Timespan& timeout)
poco_assert(! _input);
poco_assert(! _output);
_socket = Net::StreamSocket();
_socket.connect(_address, timeout);
_input = new RedisInputStream(_socket);
_output = new RedisOutputStream(_socket);
@ -144,6 +145,12 @@ void Client::disconnect()
}
bool Client::isConnected() const
{
return _input != 0;
}
void Client::writeCommand(const Array& command, bool doFlush)
{
poco_assert(_output);
@ -160,6 +167,11 @@ RedisType::Ptr Client::readReply()
poco_assert(_input);
int c = _input->get();
if (c == -1)
{
disconnect();
throw RedisException("Lost connection to Redis server");
}
RedisType::Ptr result = RedisType::createRedisType(c);
if (result.isNull())
{