X-Git-Url: https://git.saurik.com/redis.git/blobdiff_plain/621d5c1985a211662409976d7b49645cad55ea4e..2069d06a0bb88acf17153e2ece1ffb857d11645d:/redis-cli.c diff --git a/redis-cli.c b/redis-cli.c index cac22c9b..03755efa 100644 --- a/redis-cli.c +++ b/redis-cli.c @@ -1,6 +1,6 @@ /* Redis CLI (command line interface) * - * Copyright (c) 2006-2009, Salvatore Sanfilippo + * Copyright (c) 2009-2010, Salvatore Sanfilippo * All rights reserved. * * Redistribution and use in source and binary forms, with or without @@ -51,6 +51,7 @@ static struct config { int hostport; long repeat; int dbnum; + int interactive; } config; struct redisCommand { @@ -63,6 +64,8 @@ static struct redisCommand cmdTable[] = { {"get",2,REDIS_CMD_INLINE}, {"set",3,REDIS_CMD_BULK}, {"setnx",3,REDIS_CMD_BULK}, + {"append",3,REDIS_CMD_BULK}, + {"substr",4,REDIS_CMD_INLINE}, {"del",-2,REDIS_CMD_INLINE}, {"exists",2,REDIS_CMD_INLINE}, {"incr",2,REDIS_CMD_INLINE}, @@ -98,8 +101,13 @@ static struct redisCommand cmdTable[] = { {"zincrby",4,REDIS_CMD_BULK}, {"zrem",3,REDIS_CMD_BULK}, {"zremrangebyscore",4,REDIS_CMD_INLINE}, + {"zmerge",-3,REDIS_CMD_INLINE}, + {"zmergeweighed",-4,REDIS_CMD_INLINE}, {"zrange",-4,REDIS_CMD_INLINE}, + {"zrank",3,REDIS_CMD_BULK}, + {"zrevrank",3,REDIS_CMD_BULK}, {"zrangebyscore",-4,REDIS_CMD_INLINE}, + {"zcount",4,REDIS_CMD_INLINE}, {"zrevrange",-4,REDIS_CMD_INLINE}, {"zcard",2,REDIS_CMD_INLINE}, {"zscore",3,REDIS_CMD_BULK}, @@ -135,6 +143,16 @@ static struct redisCommand cmdTable[] = { {"mset",-3,REDIS_CMD_MULTIBULK}, {"msetnx",-3,REDIS_CMD_MULTIBULK}, {"monitor",1,REDIS_CMD_INLINE}, + {"multi",1,REDIS_CMD_INLINE}, + {"exec",1,REDIS_CMD_INLINE}, + {"discard",1,REDIS_CMD_INLINE}, + {"hset",4,REDIS_CMD_MULTIBULK}, + {"hget",3,REDIS_CMD_BULK}, + {"hdel",3,REDIS_CMD_BULK}, + {"hlen",2,REDIS_CMD_INLINE}, + {"hkeys",2,REDIS_CMD_INLINE}, + {"hvals",2,REDIS_CMD_INLINE}, + {"hgetall",2,REDIS_CMD_INLINE}, {NULL,0,0} }; @@ -152,14 +170,16 @@ static struct redisCommand *lookupCommand(char *name) { static int cliConnect(void) { char err[ANET_ERR_LEN]; - int fd; + static int fd = ANET_ERR; - fd = anetTcpConnect(err,config.hostip,config.hostport); if (fd == ANET_ERR) { - fprintf(stderr,"Connect: %s\n",err); - return -1; + fd = anetTcpConnect(err,config.hostip,config.hostport); + if (fd == ANET_ERR) { + fprintf(stderr, "Could not connect to Redis at %s:%d: %s", config.hostip, config.hostport, err); + return -1; + } + anetTcpNoDelay(NULL,fd); } - anetTcpNoDelay(NULL,fd); return fd; } @@ -264,8 +284,7 @@ static int cliReadReply(int fd) { } } -static int selectDb(int fd) -{ +static int selectDb(int fd) { int retval; sds cmd; char type; @@ -280,8 +299,7 @@ static int selectDb(int fd) if (type <= 0 || type != '+') return 1; retval = cliReadSingleLineReply(fd,1); if (retval) { - close(fd); - return retval; + return retval; } return 0; } @@ -311,7 +329,7 @@ static int cliSendCommand(int argc, char **argv) { fprintf(stderr,"Error setting DB num\n"); return 1; } - + while(config.repeat--) { /* Build the command to send */ cmd = sdsempty(); @@ -348,11 +366,9 @@ static int cliSendCommand(int argc, char **argv) { retval = cliReadReply(fd); if (retval) { - close(fd); return retval; } } - close(fd); return 0; } @@ -361,7 +377,7 @@ static int parseOptions(int argc, char **argv) { for (i = 1; i < argc; i++) { int lastarg = i==argc-1; - + if (!strcmp(argv[i],"-h") && !lastarg) { char *ip = zmalloc(32); if (anetResolve(NULL,argv[i+1],ip) == ANET_ERR) { @@ -381,6 +397,8 @@ static int parseOptions(int argc, char **argv) { } else if (!strcmp(argv[i],"-n") && !lastarg) { config.dbnum = atoi(argv[i+1]); i++; + } else if (!strcmp(argv[i],"-i")) { + config.interactive = 1; } else { break; } @@ -406,17 +424,68 @@ static sds readArgFromStdin(void) { } static void usage() { - fprintf(stderr, "usage: redis-cli [-h host] [-p port] [-r repeat_times] [-n db_num] cmd arg1 arg2 arg3 ... argN\n"); + fprintf(stderr, "usage: redis-cli [-h host] [-p port] [-r repeat_times] [-n db_num] [-i] cmd arg1 arg2 arg3 ... argN\n"); fprintf(stderr, "usage: echo \"argN\" | redis-cli [-h host] [-p port] [-r repeat_times] [-n db_num] cmd arg1 arg2 ... arg(N-1)\n"); fprintf(stderr, "\nIf a pipe from standard input is detected this data is used as last argument.\n\n"); fprintf(stderr, "example: cat /etc/passwd | redis-cli set my_passwd\n"); fprintf(stderr, "example: redis-cli get my_passwd\n"); fprintf(stderr, "example: redis-cli -r 100 lpush mylist x\n"); + fprintf(stderr, "\nRun in interactive mode: redis-cli -i or just don't pass any command\n"); exit(1); } +/* Turn the plain C strings into Sds strings */ +static char **convertToSds(int count, char** args) { + int j; + char **sds = zmalloc(sizeof(char*)*count+1); + + for(j = 0; j < count; j++) + sds[j] = sdsnew(args[j]); + + return sds; +} + +static char *prompt(char *line, int size) { + char *retval; + + do { + printf(">> "); + retval = fgets(line, size, stdin); + } while (retval && *line == '\n'); + line[strlen(line) - 1] = '\0'; + + return retval; +} + +static void repl() { + int size = 4096, max = size >> 1, argc; + char buffer[size]; + char *line = buffer; + char **ap, *args[max]; + + while (prompt(line, size)) { + argc = 0; + + for (ap = args; (*ap = strsep(&line, " \t")) != NULL;) { + if (**ap != '\0') { + if (argc >= max) break; + if (strcasecmp(*ap,"quit") == 0 || strcasecmp(*ap,"exit") == 0) + exit(0); + ap++; + argc++; + } + } + + config.repeat = 1; + cliSendCommand(argc, convertToSds(argc, args)); + line = buffer; + } + + exit(0); +} + int main(int argc, char **argv) { - int firstarg, j; + int firstarg; char **argvcopy; struct redisCommand *rc; @@ -424,25 +493,23 @@ int main(int argc, char **argv) { config.hostport = 6379; config.repeat = 1; config.dbnum = 0; + config.interactive = 0; firstarg = parseOptions(argc,argv); argc -= firstarg; argv += firstarg; - - /* Turn the plain C strings into Sds strings */ - argvcopy = zmalloc(sizeof(char*)*argc+1); - for(j = 0; j < argc; j++) - argvcopy[j] = sdsnew(argv[j]); - if (argc < 1) usage(); + if (argc == 0 || config.interactive == 1) repl(); + + argvcopy = convertToSds(argc, argv); /* Read the last argument from stdandard input if needed */ if ((rc = lookupCommand(argv[0])) != NULL) { - if (rc->arity > 0 && argc == rc->arity-1) { - sds lastarg = readArgFromStdin(); - argvcopy[argc] = lastarg; - argc++; - } + if (rc->arity > 0 && argc == rc->arity-1) { + sds lastarg = readArgFromStdin(); + argvcopy[argc] = lastarg; + argc++; + } } return cliSendCommand(argc, argvcopy);