Package redis.clients.jedis

Examples of redis.clients.jedis.Jedis.del()

141
142
143
144
145
146
147
148
149
150
151
      keys = jedis.keys("fromurl:*");
      for (String key : keys) {
         String urlKey = jedis.get(key);
         if (jedis.keys("fromkey:" + urlKey).isEmpty()) {
            deletedKeys.add(key);
            jedis.del("count:" + urlKey);
            jedis.del("fromkey:" + urlKey);
            jedis.del(key);
         }
      }
      renderJSON(deletedKeys);
View Full Code Here
142
143
144
145
146
147
148
149
150
151
152
      for (String key : keys) {
         String urlKey = jedis.get(key);
         if (jedis.keys("fromkey:" + urlKey).isEmpty()) {
            deletedKeys.add(key);
            jedis.del("count:" + urlKey);
            jedis.del("fromkey:" + urlKey);
            jedis.del(key);
         }
      }
      renderJSON(deletedKeys);
   }
View Full Code Here
143
144
145
146
147
148
149
150
151
152
153
         String urlKey = jedis.get(key);
         if (jedis.keys("fromkey:" + urlKey).isEmpty()) {
            deletedKeys.add(key);
            jedis.del("count:" + urlKey);
            jedis.del("fromkey:" + urlKey);
            jedis.del(key);
         }
      }
      renderJSON(deletedKeys);
   }
View Full Code Here
159
160
161
162
163
164
165
166
167
168
169
                    String jsonState = jedis.get( ref.identity() );
                    if( notFound( jsonState ) )
                    {
                        throw new EntityNotFoundException( ref );
                    }
                    jedis.del( ref.identity() );
                }
            } );
        }
        finally
        {
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
    @Override
    public void resetDuplicateCheck(Task task) {
        Jedis jedis = pool.getResource();
        try {
            jedis.del(getSetKey(task));
        } finally {
            pool.returnResource(jedis);
        }
    }
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
    public static void cleanDB() {
        Jedis jedis = emometer.EmoMeter.getPool().getResource();
        try {
            int id = Integer.parseInt(jedis.get("ids:emotion"));
            for (int i = 1; i <= id; i++) {
                jedis.del("emotion:"+i);
            }
            jedis.del("ids:emotion");
        } catch (Exception e) {
            e.printStackTrace();
        }finally{
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
        try {
            int id = Integer.parseInt(jedis.get("ids:emotion"));
            for (int i = 1; i <= id; i++) {
                jedis.del("emotion:"+i);
            }
            jedis.del("ids:emotion");
        } catch (Exception e) {
            e.printStackTrace();
        }finally{
            emometer.EmoMeter.getPool().returnResource(jedis);
        }
View Full Code Here
135
136
137
138
139
140
141
142
143
144
145
            for (String key : keys) {
              ks.add(key.getBytes());
            }
          }
          // 清除缓存
          jedis.del(ks.toArray(new byte[0][0]));
        }
      } finally {
        jedisPool.returnResource(jedis);
      }
    }
View Full Code Here
123
124
125
126
127
128
129
130
131
132
133
                            return new RpcResult();
                        } else if (delete.equals(invocation.getMethodName())) {
                            if (invocation.getArguments().length != 1) {
                                throw new IllegalArgumentException("The redis delete method arguments mismatch, must only one arguments. interface: " + type.getName() + ", method: " + invocation.getMethodName() + ", url: " + url);
                            }
                            resource.del(String.valueOf(invocation.getArguments()[0]).getBytes());
                            return new RpcResult();
                        } else {
                            throw new UnsupportedOperationException("Unsupported method " + invocation.getMethodName() + " in redis service.");
                        }
                    }
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
    @Override
    public boolean remove(String key) {
        Jedis jedis = null;
        try {
            jedis = getJedis();
            jedis.del(SerializationUtils.serialize(key));
        } finally {
            returnJedis(jedis);
        }
        return false;
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.