MediaWiki
master
|
Class to store objects in the database. More...
Public Member Functions | |
__construct ($params) | |
Constructor. More... | |
createTables () | |
Create shard tables. More... | |
delete ($key) | |
deleteAll () | |
Delete content of shard tables in every server. More... | |
deleteObjectsExpiringBefore ($timestamp, $progressCallback=false) | |
Delete objects from the database which expire before a certain date. More... | |
expireAll () | |
getMulti (array $keys, $flags=0) | |
incr ($key, $step=1) | |
merge ($key, callable $callback, $exptime=0, $attempts=10, $flags=0) | |
set ($key, $value, $exptime=0, $flags=0) | |
setMulti (array $data, $expiry=0) | |
Public Member Functions inherited from BagOStuff | |
__construct (array $params=[]) | |
$params include: More... | |
add ($key, $value, $exptime=0) | |
clearLastError () | |
Clear the "last error" registry. More... | |
decr ($key, $value=1) | |
Decrease stored value of $key by $value while preserving its TTL. More... | |
delete ($key) | |
Delete an item. More... | |
deleteObjectsExpiringBefore ($date, $progressCallback=false) | |
Delete all objects expiring before a certain date. More... | |
get ($key, $flags=0, $oldFlags=null) | |
Get an item with the given key. More... | |
getLastError () | |
Get the "last error" registered; clearLastError() should be called manually. More... | |
getMulti (array $keys, $flags=0) | |
Get an associative array containing the item for each of the keys that have items. More... | |
getScopedLock ($key, $timeout=6, $expiry=30, $rclass= '') | |
Get a lightweight exclusive self-unlocking lock. More... | |
getWithSetCallback ($key, $ttl, $callback, $flags=0) | |
Get an item with the given key, regenerating and setting it if not found. More... | |
incr ($key, $value=1) | |
Increase stored value of $key by $value while preserving its TTL. More... | |
incrWithInit ($key, $ttl, $value=1, $init=1) | |
Increase stored value of $key by $value while preserving its TTL. More... | |
lock ($key, $timeout=6, $expiry=6, $rclass= '') | |
Acquire an advisory lock on a key string. More... | |
makeGlobalKey () | |
Make a global cache key. More... | |
makeKey () | |
Make a cache key, scoped to this instance's keyspace. More... | |
makeKeyInternal ($keyspace, $args) | |
Construct a cache key. More... | |
merge ($key, callable $callback, $exptime=0, $attempts=10, $flags=0) | |
Merge changes into the existing cache value (possibly creating a new one) More... | |
modifySimpleRelayEvent (array $event) | |
Modify a cache update operation array for EventRelayer::notify() More... | |
set ($key, $value, $exptime=0, $flags=0) | |
Set an item. More... | |
setDebug ($bool) | |
setLogger (LoggerInterface $logger) | |
setMulti (array $data, $exptime=0) | |
Batch insertion. More... | |
unlock ($key) | |
Release an advisory lock on a key string. More... | |
Protected Member Functions | |
cas ($casToken, $key, $value, $exptime=0) | |
doGet ($key, $flags=0) | |
garbageCollect () | |
getDB ($serverIndex) | |
Get a connection to the specified database. More... | |
getMaxDateTime ($db) | |
getTableByKey ($key) | |
Get the server index and table name for a given key. More... | |
getTableNameByShard ($index) | |
Get the table name for a given shard index. More... | |
getWithToken ($key, &$casToken, $flags=0) | |
handleReadError (DBError $exception, $serverIndex) | |
Handle a DBError which occurred during a read operation. More... | |
handleWriteError (DBError $exception, $serverIndex) | |
Handle a DBQueryError which occurred during a write operation. More... | |
isExpired ($db, $exptime) | |
markServerDown ($exception, $serverIndex) | |
Mark a server down due to a DBConnectionError exception. More... | |
serialize (&$data) | |
Serialize an object and, if possible, compress the representation. More... | |
unserialize ($serial) | |
Unserialize and, if necessary, decompress an object. More... | |
waitForSlaves () | |
Protected Member Functions inherited from BagOStuff | |
cas ($casToken, $key, $value, $exptime=0) | |
Check and set an item. More... | |
convertExpiry ($exptime) | |
Convert an optionally relative time to an absolute time. More... | |
convertToRelative ($exptime) | |
Convert an optionally absolute expiry time to a relative time. More... | |
debug ($text) | |
doGet ($key, $flags=0) | |
getWithToken ($key, &$casToken, $flags=0) | |
isInteger ($value) | |
Check if a value is an integer. More... | |
mergeViaCas ($key, $callback, $exptime=0, $attempts=10) | |
mergeViaLock ($key, $callback, $exptime=0, $attempts=10, $flags=0) | |
setLastError ($err) | |
Set the "last error" registry. More... | |
Protected Attributes | |
array | $connFailureErrors = [] |
Exceptions. More... | |
array | $connFailureTimes = [] |
UNIX timestamps. More... | |
array | $conns |
int | $lastExpireAll = 0 |
int | $numServers |
int | $purgePeriod = 100 |
array[] | $serverInfos |
(server index => server config) More... | |
string[] | $serverTags |
(server index => tag/host name) More... | |
int | $shards = 1 |
bool | $slaveOnly = false |
int | $syncTimeout = 3 |
string | $tableName = 'objectcache' |
Protected Attributes inherited from BagOStuff | |
callback null | $asyncHandler |
string | $keyspace = 'local' |
integer | $lastError = self::ERR_NONE |
array[] | $locks = [] |
Lock tracking. More... | |
LoggerInterface | $logger |
Additional Inherited Members | |
Public Attributes inherited from BagOStuff | |
const | ERR_NO_RESPONSE = 1 |
const | ERR_NONE = 0 |
Possible values for getLastError() More... | |
const | ERR_UNEXPECTED = 3 |
const | ERR_UNREACHABLE = 2 |
const | READ_LATEST = 1 |
Bitfield constants for get()/getMulti() More... | |
const | READ_VERIFIED = 2 |
const | WRITE_CACHE_ONLY = 2 |
const | WRITE_SYNC = 1 |
Bitfield constants for set()/merge() More... | |
Public Attributes inherited from IExpiringStore | |
const | TTL_DAY = 86400 |
const | TTL_HOUR = 3600 |
const | TTL_INDEFINITE = 0 |
const | TTL_MINUTE = 60 |
const | TTL_MONTH = 2592000 |
const | TTL_PROC_LONG = 30 |
const | TTL_PROC_SHORT = 3 |
const | TTL_WEEK = 604800 |
const | TTL_YEAR = 31536000 |
Class to store objects in the database.
Definition at line 29 of file SqlBagOStuff.php.
SqlBagOStuff::__construct | ( | $params | ) |
Constructor.
Parameters are:
array | $params |
Definition at line 92 of file SqlBagOStuff.php.
References $params, $tag, as, and tableName().
|
protected |
Definition at line 362 of file SqlBagOStuff.php.
References $e, $tableName, $value, BagOStuff\convertExpiry(), getDB(), getMaxDateTime(), getTableByKey(), handleWriteError(), and list.
SqlBagOStuff::createTables | ( | ) |
Create shard tables.
For use from eval.php.
Definition at line 725 of file SqlBagOStuff.php.
References $numServers, $shards, and getDB().
SqlBagOStuff::delete | ( | $key | ) |
Definition at line 402 of file SqlBagOStuff.php.
References $e, $tableName, getDB(), getTableByKey(), handleWriteError(), and list.
SqlBagOStuff::deleteAll | ( | ) |
Delete content of shard tables in every server.
Return true if the operation is successful, false otherwise.
Definition at line 595 of file SqlBagOStuff.php.
References $e, $numServers, $shards, getDB(), getTableNameByShard(), and handleWriteError().
SqlBagOStuff::deleteObjectsExpiringBefore | ( | $timestamp, | |
$progressCallback = false |
|||
) |
Delete objects from the database which expire before a certain date.
string | $timestamp | |
bool | callable | $progressCallback |
Definition at line 519 of file SqlBagOStuff.php.
References $e, $keys, $numServers, $shards, $timestamp, as, getDB(), getTableNameByShard(), handleWriteError(), TS_UNIX, and wfTimestamp().
Referenced by expireAll().
|
protected |
Definition at line 218 of file SqlBagOStuff.php.
References $flags, and getWithToken().
SqlBagOStuff::expireAll | ( | ) |
Definition at line 509 of file SqlBagOStuff.php.
References deleteObjectsExpiringBefore(), and wfTimestampNow().
Referenced by garbageCollect().
|
protected |
Definition at line 492 of file SqlBagOStuff.php.
References expireAll().
Referenced by getMulti(), and setMulti().
|
protected |
Get a connection to the specified database.
int | $serverIndex |
MWException |
Definition at line 137 of file SqlBagOStuff.php.
References $type, DB_MASTER, DB_SLAVE, DBO_TRX, DatabaseBase\factory(), wfGetDB(), and wfGetLBFactory().
Referenced by cas(), createTables(), delete(), deleteAll(), deleteObjectsExpiringBefore(), getMulti(), incr(), and setMulti().
|
protected |
IDatabase | $db |
Definition at line 484 of file SqlBagOStuff.php.
Referenced by cas(), isExpired(), and setMulti().
SqlBagOStuff::getMulti | ( | array | $keys, |
$flags = 0 |
|||
) |
Definition at line 233 of file SqlBagOStuff.php.
References $e, $res, $tableName, as, BagOStuff\debug(), garbageCollect(), getDB(), getTableByKey(), handleReadError(), handleWriteError(), isExpired(), list, and unserialize().
Referenced by getWithToken().
|
protected |
Get the server index and table name for a given key.
string | $key |
Definition at line 185 of file SqlBagOStuff.php.
References $serverTags, $shards, ArrayUtils\consistentHashSort(), getTableNameByShard(), and key.
Referenced by cas(), delete(), getMulti(), incr(), and setMulti().
|
protected |
Get the table name for a given shard index.
int | $index |
Definition at line 208 of file SqlBagOStuff.php.
References $tableName, and tableName().
Referenced by deleteAll(), deleteObjectsExpiringBefore(), and getTableByKey().
|
protected |
|
protected |
Handle a DBError which occurred during a read operation.
DBError | $exception | |
int | $serverIndex |
Definition at line 655 of file SqlBagOStuff.php.
References BagOStuff\ERR_UNEXPECTED, BagOStuff\ERR_UNREACHABLE, markServerDown(), and BagOStuff\setLastError().
Referenced by getMulti().
|
protected |
Handle a DBQueryError which occurred during a write operation.
DBError | $exception | |
int | $serverIndex |
Definition at line 675 of file SqlBagOStuff.php.
References $e, BagOStuff\ERR_UNEXPECTED, BagOStuff\ERR_UNREACHABLE, markServerDown(), and BagOStuff\setLastError().
Referenced by cas(), delete(), deleteAll(), deleteObjectsExpiringBefore(), getMulti(), incr(), and setMulti().
SqlBagOStuff::incr | ( | $key, | |
$step = 1 |
|||
) |
Definition at line 418 of file SqlBagOStuff.php.
References $e, $tableName, getDB(), getTableByKey(), handleWriteError(), isExpired(), list, and unserialize().
|
protected |
IDatabase | $db | |
string | $exptime |
Definition at line 476 of file SqlBagOStuff.php.
References getMaxDateTime(), TS_UNIX, and wfTimestamp().
Referenced by getMulti(), and incr().
|
protected |
Mark a server down due to a DBConnectionError exception.
DBError | $exception | |
int | $serverIndex |
Definition at line 704 of file SqlBagOStuff.php.
Referenced by handleReadError(), and handleWriteError().
SqlBagOStuff::merge | ( | $key, | |
callable | $callback, | ||
$exptime = 0 , |
|||
$attempts = 10 , |
|||
$flags = 0 |
|||
) |
Definition at line 462 of file SqlBagOStuff.php.
References $flags, BagOStuff\mergeViaCas(), and waitForSlaves().
|
protected |
Serialize an object and, if possible, compress the representation.
On typical message and page data, this can provide a 3X decrease in storage requirements.
mixed | $data |
Definition at line 618 of file SqlBagOStuff.php.
Referenced by setMulti().
SqlBagOStuff::set | ( | $key, | |
$value, | |||
$exptime = 0 , |
|||
$flags = 0 |
|||
) |
Definition at line 353 of file SqlBagOStuff.php.
References $flags, $value, setMulti(), and waitForSlaves().
SqlBagOStuff::setMulti | ( | array | $data, |
$expiry = 0 |
|||
) |
Definition at line 294 of file SqlBagOStuff.php.
References $e, $tableName, $value, as, BagOStuff\convertExpiry(), garbageCollect(), getDB(), getMaxDateTime(), getTableByKey(), handleWriteError(), list, and serialize().
Referenced by set().
|
protected |
Unserialize and, if necessary, decompress an object.
string | $serial |
Definition at line 633 of file SqlBagOStuff.php.
References $ret.
Referenced by getMulti(), and incr().
|
protected |
Definition at line 741 of file SqlBagOStuff.php.
References $e, wfGetLBFactory(), and wfWikiID().
|
protected |
Exceptions.
Definition at line 54 of file SqlBagOStuff.php.
|
protected |
UNIX timestamps.
Definition at line 52 of file SqlBagOStuff.php.
|
protected |
Definition at line 50 of file SqlBagOStuff.php.
|
protected |
Definition at line 37 of file SqlBagOStuff.php.
|
protected |
Definition at line 35 of file SqlBagOStuff.php.
Referenced by createTables(), deleteAll(), and deleteObjectsExpiringBefore().
|
protected |
Definition at line 39 of file SqlBagOStuff.php.
|
protected |
(server index => server config)
Definition at line 31 of file SqlBagOStuff.php.
|
protected |
(server index => tag/host name)
Definition at line 33 of file SqlBagOStuff.php.
Referenced by getTableByKey().
|
protected |
Definition at line 41 of file SqlBagOStuff.php.
Referenced by createTables(), deleteAll(), deleteObjectsExpiringBefore(), and getTableByKey().
|
protected |
Definition at line 45 of file SqlBagOStuff.php.
|
protected |
Definition at line 47 of file SqlBagOStuff.php.
|
protected |
Definition at line 43 of file SqlBagOStuff.php.
Referenced by cas(), delete(), getMulti(), getTableNameByShard(), incr(), and setMulti().