Package redis.clients.jedis

Class Transaction

java.lang.Object

redis.clients.jedis.Queable

redis.clients.jedis.TransactionBase

redis.clients.jedis.Transaction

All Implemented Interfaces:

Closeable, AutoCloseable, BloomFilterPipelineCommands, CountMinSketchPipelineCommands, CuckooFilterPipelineCommands, RedisBloomPipelineCommands, TDigestSketchPipelineCommands, TopKFilterPipelineCommands, BitPipelineBinaryCommands, BitPipelineCommands, FunctionPipelineBinaryCommands, FunctionPipelineCommands, GeoPipelineBinaryCommands, GeoPipelineCommands, HashPipelineBinaryCommands, HashPipelineCommands, HyperLogLogPipelineBinaryCommands, HyperLogLogPipelineCommands, KeyPipelineBinaryCommands, KeyPipelineCommands, ListPipelineBinaryCommands, ListPipelineCommands, PipelineBinaryCommands, PipelineCommands, RedisModulePipelineCommands, SampleBinaryKeyedPipelineCommands, SampleKeyedPipelineCommands, ScriptingKeyPipelineBinaryCommands, ScriptingKeyPipelineCommands, SetPipelineBinaryCommands, SetPipelineCommands, SortedSetPipelineBinaryCommands, SortedSetPipelineCommands, StreamPipelineBinaryCommands, StreamPipelineCommands, StringPipelineBinaryCommands, StringPipelineCommands, RedisGraphPipelineCommands, RedisJsonPipelineCommands, RediSearchPipelineCommands, RedisTimeSeriesPipelineCommands

public class Transaction
extends TransactionBase

A pipeline based transaction.

Field Summary

Fields

Modifier and Type	Field	Description
private final Jedis	jedis

Fields inherited from class redis.clients.jedis.TransactionBase

connection

Constructor Summary

Constructors

Constructor	Description
Transaction(Connection connection)	Creates a new transaction.
Transaction(Connection connection, boolean doMulti)	Creates a new transaction.
Transaction(Connection connection, boolean doMulti, boolean closeConnection)	Creates a new transaction.
Transaction(Jedis jedis)

Method Summary

Modifier and Type	Method	Description
final String	discard()
final List<Object>	exec()
protected final void	processAppendStatus()
protected final void	processMultiResponse()
protected final void	processPipelinedResponses()

Methods inherited from class redis.clients.jedis.TransactionBase

append, append, appendCommand, bfAdd, bfCard, bfExists, bfInfo, bfInsert, bfInsert, bfLoadChunk, bfMAdd, bfMExists, bfReserve, bfReserve, bfScanDump, bitcount, bitcount, bitcount, bitcount, bitcount, bitcount, bitfield, bitfield, bitfieldReadonly, bitfieldReadonly, bitop, bitop, bitpos, bitpos, bitpos, bitpos, blmove, blmove, blmpop, blmpop, blmpop, blmpop, blpop, blpop, blpop, blpop, blpop, blpop, brpop, brpop, brpop, brpop, brpop, brpop, brpoplpush, brpoplpush, bzmpop, bzmpop, bzmpop, bzmpop, bzpopmax, bzpopmax, bzpopmin, bzpopmin, cfAdd, cfAddNx, cfCount, cfDel, cfExists, cfInfo, cfInsert, cfInsert, cfInsertNx, cfInsertNx, cfLoadChunk, cfReserve, cfReserve, cfScanDump, clear, close, cmsIncrBy, cmsInfo, cmsInitByDim, cmsInitByProb, cmsMerge, cmsMerge, cmsQuery, copy, copy, decr, decr, decrBy, decrBy, del, del, del, del, dump, dump, eval, eval, eval, eval, eval, eval, eval, eval, evalReadonly, evalReadonly, evalsha, evalsha, evalsha, evalsha, evalsha, evalsha, evalsha, evalsha, evalshaReadonly, evalshaReadonly, executeCommand, exists, exists, exists, exists, expire, expire, expire, expire, expireAt, expireAt, expireAt, expireAt, expireTime, expireTime, fcall, fcall, fcallReadonly, fcallReadonly, ftAggregate, ftAliasAdd, ftAliasDel, ftAliasUpdate, ftAlter, ftAlter, ftConfigGet, ftConfigGet, ftConfigSet, ftConfigSet, ftCreate, ftCreate, ftCursorDel, ftCursorRead, ftDictAdd, ftDictAddBySampleKey, ftDictDel, ftDictDelBySampleKey, ftDictDump, ftDictDumpBySampleKey, ftDropIndex, ftDropIndexDD, ftExplain, ftExplainCLI, ftInfo, ftSearch, ftSearch, ftSearch, ftSearch, ftSpellCheck, ftSpellCheck, ftSugAdd, ftSugAddIncr, ftSugDel, ftSugGet, ftSugGet, ftSugGetWithScores, ftSugGetWithScores, ftSugLen, ftSynDump, ftSynUpdate, ftTagVals, functionDelete, functionDelete, functionDump, functionFlush, functionFlush, functionKill, functionList, functionList, functionList, functionListBinary, functionListWithCode, functionListWithCode, functionListWithCode, functionListWithCodeBinary, functionLoad, functionLoad, functionLoadReplace, functionLoadReplace, functionRestore, functionRestore, functionStats, functionStatsBinary, geoadd, geoadd, geoadd, geoadd, geoadd, geoadd, geodist, geodist, geodist, geodist, geohash, geohash, geopos, geopos, georadius, georadius, georadius, georadius, georadiusByMember, georadiusByMember, georadiusByMember, georadiusByMember, georadiusByMemberReadonly, georadiusByMemberReadonly, georadiusByMemberReadonly, georadiusByMemberReadonly, georadiusByMemberStore, georadiusByMemberStore, georadiusReadonly, georadiusReadonly, georadiusReadonly, georadiusReadonly, georadiusStore, georadiusStore, geosearch, geosearch, geosearch, geosearch, geosearch, geosearch, geosearch, geosearch, geosearch, geosearch, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStoreStoreDist, geosearchStoreStoreDist, get, get, getbit, getbit, getDel, getDel, getEx, getEx, getrange, getrange, getSet, getSet, graphDelete, graphProfile, graphQuery, graphQuery, graphQuery, graphQuery, graphReadonlyQuery, graphReadonlyQuery, graphReadonlyQuery, graphReadonlyQuery, hdel, hdel, hexists, hexists, hget, hget, hgetAll, hgetAll, hincrBy, hincrBy, hincrByFloat, hincrByFloat, hkeys, hkeys, hlen, hlen, hmget, hmget, hmset, hmset, hrandfield, hrandfield, hrandfield, hrandfield, hrandfieldWithValues, hrandfieldWithValues, hscan, hscan, hset, hset, hset, hset, hsetnx, hsetnx, hstrlen, hstrlen, hvals, hvals, incr, incr, incrBy, incrBy, incrByFloat, incrByFloat, jsonArrAppend, jsonArrAppend, jsonArrAppendWithEscape, jsonArrIndex, jsonArrIndex, jsonArrIndexWithEscape, jsonArrInsert, jsonArrInsert, jsonArrInsertWithEscape, jsonArrLen, jsonArrLen, jsonArrLen, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrTrim, jsonArrTrim, jsonClear, jsonClear, jsonClear, jsonDel, jsonDel, jsonDel, jsonGet, jsonGet, jsonGet, jsonGet, jsonGet, jsonMGet, jsonMGet, jsonNumIncrBy, jsonNumIncrBy, jsonSet, jsonSet, jsonSet, jsonSet, jsonSetWithEscape, jsonSetWithEscape, jsonStrAppend, jsonStrAppend, jsonStrAppend, jsonStrLen, jsonStrLen, jsonStrLen, jsonToggle, jsonToggle, jsonType, jsonType, jsonType, keys, keys, lcs, lcs, lindex, lindex, linsert, linsert, llen, llen, lmove, lmove, lmpop, lmpop, lmpop, lmpop, lpop, lpop, lpop, lpop, lpos, lpos, lpos, lpos, lpos, lpos, lpush, lpush, lpushx, lpushx, lrange, lrange, lrem, lrem, lset, lset, ltrim, ltrim, memoryUsage, memoryUsage, memoryUsage, memoryUsage, mget, mget, migrate, migrate, migrate, migrate, mset, mset, msetnx, msetnx, multi, objectEncoding, objectEncoding, objectFreq, objectFreq, objectIdletime, objectIdletime, objectRefcount, objectRefcount, persist, persist, pexpire, pexpire, pexpire, pexpire, pexpireAt, pexpireAt, pexpireAt, pexpireAt, pexpireTime, pexpireTime, pfadd, pfadd, pfcount, pfcount, pfcount, pfcount, pfmerge, pfmerge, psetex, psetex, pttl, pttl, publish, publish, randomBinaryKey, randomKey, rename, rename, renamenx, renamenx, restore, restore, restore, restore, rpop, rpop, rpop, rpop, rpoplpush, rpoplpush, rpush, rpush, rpushx, rpushx, sadd, sadd, scan, scan, scan, scan, scan, scan, scard, scard, scriptExists, scriptExists, scriptFlush, scriptFlush, scriptFlush, scriptFlush, scriptKill, scriptKill, scriptLoad, scriptLoad, sdiff, sdiff, sdiffstore, sdiffstore, sendCommand, sendCommand, sendCommand, set, set, set, set, setbit, setbit, setex, setex, setGet, setGet, setJsonObjectMapper, setnx, setnx, setrange, setrange, sinter, sinter, sintercard, sintercard, sintercard, sintercard, sinterstore, sinterstore, sismember, sismember, smembers, smembers, smismember, smismember, smove, smove, sort, sort, sort, sort, sort, sort, sort, sort, sortReadonly, sortReadonly, spop, spop, spop, spop, srandmember, srandmember, srandmember, srandmember, srem, srem, sscan, sscan, strAlgoLCSKeys, strAlgoLCSKeys, strAlgoLCSStrings, strAlgoLCSStrings, strlen, strlen, substr, substr, sunion, sunion, sunionstore, sunionstore, tdigestAdd, tdigestByRank, tdigestByRevRank, tdigestCDF, tdigestCreate, tdigestCreate, tdigestInfo, tdigestMax, tdigestMerge, tdigestMerge, tdigestMin, tdigestQuantile, tdigestRank, tdigestReset, tdigestRevRank, tdigestTrimmedMean, topkAdd, topkCount, topkIncrBy, topkInfo, topkList, topkListWithCount, topkQuery, topkReserve, topkReserve, touch, touch, touch, touch, tsAdd, tsAdd, tsAdd, tsAlter, tsCreate, tsCreate, tsCreateRule, tsCreateRule, tsDecrBy, tsDecrBy, tsDel, tsDeleteRule, tsGet, tsGet, tsIncrBy, tsIncrBy, tsMAdd, tsMGet, tsMRange, tsMRange, tsMRevRange, tsMRevRange, tsQueryIndex, tsRange, tsRange, tsRevRange, tsRevRange, ttl, ttl, type, type, unlink, unlink, unlink, unlink, unwatch, waitAOF, waitAOF, waitReplicas, waitReplicas, waitReplicas, watch, watch, xack, xack, xadd, xadd, xadd, xautoclaim, xautoclaim, xautoclaimJustId, xautoclaimJustId, xclaim, xclaim, xclaimJustId, xclaimJustId, xdel, xdel, xgroupCreate, xgroupCreate, xgroupCreateConsumer, xgroupCreateConsumer, xgroupDelConsumer, xgroupDelConsumer, xgroupDestroy, xgroupDestroy, xgroupSetID, xgroupSetID, xinfoConsumers, xinfoConsumers, xinfoGroup, xinfoGroup, xinfoGroups, xinfoGroups, xinfoStream, xinfoStream, xinfoStreamFull, xinfoStreamFull, xinfoStreamFull, xinfoStreamFull, xlen, xlen, xpending, xpending, xpending, xpending, xpending, xpending, xrange, xrange, xrange, xrange, xrange, xrange, xread, xread, xreadGroup, xreadGroup, xrevrange, xrevrange, xrevrange, xrevrange, xrevrange, xrevrange, xtrim, xtrim, xtrim, xtrim, zadd, zadd, zadd, zadd, zadd, zadd, zadd, zadd, zaddIncr, zaddIncr, zcard, zcard, zcount, zcount, zcount, zcount, zdiff, zdiff, zdiffStore, zdiffStore, zdiffWithScores, zdiffWithScores, zincrby, zincrby, zincrby, zincrby, zinter, zinter, zintercard, zintercard, zintercard, zintercard, zinterstore, zinterstore, zinterstore, zinterstore, zinterWithScores, zinterWithScores, zlexcount, zlexcount, zmpop, zmpop, zmpop, zmpop, zmscore, zmscore, zpopmax, zpopmax, zpopmax, zpopmax, zpopmin, zpopmin, zpopmin, zpopmin, zrandmember, zrandmember, zrandmember, zrandmember, zrandmemberWithScores, zrandmemberWithScores, zrange, zrange, zrange, zrange, zrangeByLex, zrangeByLex, zrangeByLex, zrangeByLex, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangestore, zrangestore, zrangeWithScores, zrangeWithScores, zrangeWithScores, zrangeWithScores, zrank, zrank, zrankWithScore, zrankWithScore, zrem, zrem, zremrangeByLex, zremrangeByLex, zremrangeByRank, zremrangeByRank, zremrangeByScore, zremrangeByScore, zremrangeByScore, zremrangeByScore, zrevrange, zrevrange, zrevrangeByLex, zrevrangeByLex, zrevrangeByLex, zrevrangeByLex, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeWithScores, zrevrangeWithScores, zrevrank, zrevrank, zrevrankWithScore, zrevrankWithScore, zscan, zscan, zscore, zscore, zunion, zunion, zunionstore, zunionstore, zunionstore, zunionstore, zunionWithScores, zunionWithScores

Methods inherited from class redis.clients.jedis.Queable

clean, enqueResponse, generateResponse, getPipelinedResponseLength

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface redis.clients.jedis.commands.HashPipelineBinaryCommands

hscan

Methods inherited from interface redis.clients.jedis.commands.HashPipelineCommands

hscan

Methods inherited from interface redis.clients.jedis.search.RediSearchPipelineCommands

ftAlter, ftAlter, ftCreate, ftCreate, ftCreate, ftSearch

Methods inherited from interface redis.clients.jedis.json.RedisJsonPipelineCommands

jsonMGet, jsonMGet, jsonSet, jsonSet, jsonSetLegacy, jsonSetLegacy, jsonSetWithEscape, jsonSetWithEscape

Methods inherited from interface redis.clients.jedis.commands.SetPipelineBinaryCommands

sscan

Methods inherited from interface redis.clients.jedis.commands.SetPipelineCommands

sscan

Methods inherited from interface redis.clients.jedis.commands.SortedSetPipelineBinaryCommands

zscan

Methods inherited from interface redis.clients.jedis.commands.SortedSetPipelineCommands

zscan

Methods inherited from interface redis.clients.jedis.commands.StreamPipelineBinaryCommands

xadd

Methods inherited from interface redis.clients.jedis.commands.StreamPipelineCommands

xadd

Field Details

jedis

private final Jedis jedis

Constructor Details

Transaction

public Transaction(Jedis jedis)

Transaction

public Transaction(Connection connection)

Creates a new transaction. A MULTI command will be added to be sent to server. WATCH/UNWATCH/MULTI commands must not be called with this object.

Parameters:

connection - connection

Transaction

public Transaction(Connection connection,
 boolean doMulti)

Creates a new transaction. A user wanting to WATCH/UNWATCH keys followed by a call to MULTI (TransactionBase.multi()) it should be doMulti=false.

Parameters:

connection - connection

doMulti - false should be set to enable manual WATCH, UNWATCH and MULTI

Transaction

public Transaction(Connection connection,
 boolean doMulti,
 boolean closeConnection)

Creates a new transaction. A user wanting to WATCH/UNWATCH keys followed by a call to MULTI (TransactionBase.multi()) it should be doMulti=false.

Parameters:

connection - connection

doMulti - false should be set to enable manual WATCH, UNWATCH and MULTI

closeConnection - should the 'connection' be closed when 'close()' is called?

Method Details

processMultiResponse

protected final void processMultiResponse()

Specified by:

processMultiResponse in class TransactionBase

processAppendStatus

protected final void processAppendStatus()

Specified by:

processAppendStatus in class TransactionBase

processPipelinedResponses

protected final void processPipelinedResponses()

Specified by:

processPipelinedResponses in class TransactionBase

exec

public final List<Object> exec()

Overrides:

exec in class TransactionBase

discard

public final String discard()

Overrides:

discard in class TransactionBase