<form method="POST">
    <h3>Editing: DatabaseStore.php</h3>
    <textarea name="content" rows="20" cols="80">&lt;?php

namespace Illuminate\Cache;

use Closure;
use Exception;
use Illuminate\Contracts\Cache\LockProvider;
use Illuminate\Contracts\Cache\Store;
use Illuminate\Database\ConnectionInterface;
use Illuminate\Database\PostgresConnection;
use Illuminate\Database\QueryException;
use Illuminate\Support\InteractsWithTime;
use Illuminate\Support\Str;

class DatabaseStore implements LockProvider, Store
{
    use InteractsWithTime, RetrievesMultipleKeys;

    /**
     * The database connection instance.
     *
     * @var \Illuminate\Database\ConnectionInterface
     */
    protected $connection;

    /**
     * The database connection instance that should be used to manage locks.
     *
     * @var \Illuminate\Database\ConnectionInterface
     */
    protected $lockConnection;

    /**
     * The name of the cache table.
     *
     * @var string
     */
    protected $table;

    /**
     * A string that should be prepended to keys.
     *
     * @var string
     */
    protected $prefix;

    /**
     * The name of the cache locks table.
     *
     * @var string
     */
    protected $lockTable;

    /**
     * An array representation of the lock lottery odds.
     *
     * @var array
     */
    protected $lockLottery;

    /**
     * Create a new database store.
     *
     * @param  \Illuminate\Database\ConnectionInterface  $connection
     * @param  string  $table
     * @param  string  $prefix
     * @param  string  $lockTable
     * @param  array  $lockLottery
     * @return void
     */
    public function __construct(ConnectionInterface $connection,
                                $table,
                                $prefix = '',
                                $lockTable = 'cache_locks',
                                $lockLottery = [2, 100])
    {
        $this-&gt;table = $table;
        $this-&gt;prefix = $prefix;
        $this-&gt;connection = $connection;
        $this-&gt;lockTable = $lockTable;
        $this-&gt;lockLottery = $lockLottery;
    }

    /**
     * Retrieve an item from the cache by key.
     *
     * @param  string|array  $key
     * @return mixed
     */
    public function get($key)
    {
        $prefixed = $this-&gt;prefix.$key;

        $cache = $this-&gt;table()-&gt;where('key', '=', $prefixed)-&gt;first();

        // If we have a cache record we will check the expiration time against current
        // time on the system and see if the record has expired. If it has, we will
        // remove the records from the database table so it isn't returned again.
        if (is_null($cache)) {
            return;
        }

        $cache = is_array($cache) ? (object) $cache : $cache;

        // If this cache expiration date is past the current time, we will remove this
        // item from the cache. Then we will return a null value since the cache is
        // expired. We will use &quot;Carbon&quot; to make this comparison with the column.
        if ($this-&gt;currentTime() &gt;= $cache-&gt;expiration) {
            $this-&gt;forget($key);

            return;
        }

        return $this-&gt;unserialize($cache-&gt;value);
    }

    /**
     * Store an item in the cache for a given number of seconds.
     *
     * @param  string  $key
     * @param  mixed  $value
     * @param  int  $seconds
     * @return bool
     */
    public function put($key, $value, $seconds)
    {
        $key = $this-&gt;prefix.$key;
        $value = $this-&gt;serialize($value);
        $expiration = $this-&gt;getTime() + $seconds;

        try {
            return $this-&gt;table()-&gt;insert(compact('key', 'value', 'expiration'));
        } catch (Exception $e) {
            $result = $this-&gt;table()-&gt;where('key', $key)-&gt;update(compact('value', 'expiration'));

            return $result &gt; 0;
        }
    }

    /**
     * Store an item in the cache if the key doesn't exist.
     *
     * @param  string  $key
     * @param  mixed  $value
     * @param  int  $seconds
     * @return bool
     */
    public function add($key, $value, $seconds)
    {
        $key = $this-&gt;prefix.$key;
        $value = $this-&gt;serialize($value);
        $expiration = $this-&gt;getTime() + $seconds;

        try {
            return $this-&gt;table()-&gt;insert(compact('key', 'value', 'expiration'));
        } catch (QueryException $e) {
            return $this-&gt;table()
                -&gt;where('key', $key)
                -&gt;where('expiration', '&lt;=', $this-&gt;getTime())
                -&gt;update([
                    'value' =&gt; $value,
                    'expiration' =&gt; $expiration,
                ]) &gt;= 1;
        }
    }

    /**
     * Increment the value of an item in the cache.
     *
     * @param  string  $key
     * @param  mixed  $value
     * @return int|bool
     */
    public function increment($key, $value = 1)
    {
        return $this-&gt;incrementOrDecrement($key, $value, function ($current, $value) {
            return $current + $value;
        });
    }

    /**
     * Decrement the value of an item in the cache.
     *
     * @param  string  $key
     * @param  mixed  $value
     * @return int|bool
     */
    public function decrement($key, $value = 1)
    {
        return $this-&gt;incrementOrDecrement($key, $value, function ($current, $value) {
            return $current - $value;
        });
    }

    /**
     * Increment or decrement an item in the cache.
     *
     * @param  string  $key
     * @param  mixed  $value
     * @param  \Closure  $callback
     * @return int|bool
     */
    protected function incrementOrDecrement($key, $value, Closure $callback)
    {
        return $this-&gt;connection-&gt;transaction(function () use ($key, $value, $callback) {
            $prefixed = $this-&gt;prefix.$key;

            $cache = $this-&gt;table()-&gt;where('key', $prefixed)
                        -&gt;lockForUpdate()-&gt;first();

            // If there is no value in the cache, we will return false here. Otherwise the
            // value will be decrypted and we will proceed with this function to either
            // increment or decrement this value based on the given action callbacks.
            if (is_null($cache)) {
                return false;
            }

            $cache = is_array($cache) ? (object) $cache : $cache;

            $current = $this-&gt;unserialize($cache-&gt;value);

            // Here we'll call this callback function that was given to the function which
            // is used to either increment or decrement the function. We use a callback
            // so we do not have to recreate all this logic in each of the functions.
            $new = $callback((int) $current, $value);

            if (! is_numeric($current)) {
                return false;
            }

            // Here we will update the values in the table. We will also encrypt the value
            // since database cache values are encrypted by default with secure storage
            // that can't be easily read. We will return the new value after storing.
            $this-&gt;table()-&gt;where('key', $prefixed)-&gt;update([
                'value' =&gt; $this-&gt;serialize($new),
            ]);

            return $new;
        });
    }

    /**
     * Get the current system time.
     *
     * @return int
     */
    protected function getTime()
    {
        return $this-&gt;currentTime();
    }

    /**
     * Store an item in the cache indefinitely.
     *
     * @param  string  $key
     * @param  mixed  $value
     * @return bool
     */
    public function forever($key, $value)
    {
        return $this-&gt;put($key, $value, 315360000);
    }

    /**
     * Get a lock instance.
     *
     * @param  string  $name
     * @param  int  $seconds
     * @param  string|null  $owner
     * @return \Illuminate\Contracts\Cache\Lock
     */
    public function lock($name, $seconds = 0, $owner = null)
    {
        return new DatabaseLock(
            $this-&gt;lockConnection ?? $this-&gt;connection,
            $this-&gt;lockTable,
            $this-&gt;prefix.$name,
            $seconds,
            $owner,
            $this-&gt;lockLottery
        );
    }

    /**
     * Restore a lock instance using the owner identifier.
     *
     * @param  string  $name
     * @param  string  $owner
     * @return \Illuminate\Contracts\Cache\Lock
     */
    public function restoreLock($name, $owner)
    {
        return $this-&gt;lock($name, 0, $owner);
    }

    /**
     * Remove an item from the cache.
     *
     * @param  string  $key
     * @return bool
     */
    public function forget($key)
    {
        $this-&gt;table()-&gt;where('key', '=', $this-&gt;prefix.$key)-&gt;delete();

        return true;
    }

    /**
     * Remove all items from the cache.
     *
     * @return bool
     */
    public function flush()
    {
        $this-&gt;table()-&gt;delete();

        return true;
    }

    /**
     * Get a query builder for the cache table.
     *
     * @return \Illuminate\Database\Query\Builder
     */
    protected function table()
    {
        return $this-&gt;connection-&gt;table($this-&gt;table);
    }

    /**
     * Get the underlying database connection.
     *
     * @return \Illuminate\Database\ConnectionInterface
     */
    public function getConnection()
    {
        return $this-&gt;connection;
    }

    /**
     * Specify the name of the connection that should be used to manage locks.
     *
     * @param  \Illuminate\Database\ConnectionInterface  $connection
     * @return $this
     */
    public function setLockConnection($connection)
    {
        $this-&gt;lockConnection = $connection;

        return $this;
    }

    /**
     * Get the cache key prefix.
     *
     * @return string
     */
    public function getPrefix()
    {
        return $this-&gt;prefix;
    }

    /**
     * Serialize the given value.
     *
     * @param  mixed  $value
     * @return string
     */
    protected function serialize($value)
    {
        $result = serialize($value);

        if ($this-&gt;connection instanceof PostgresConnection &amp;&amp; Str::contains($result, &quot;\0&quot;)) {
            $result = base64_encode($result);
        }

        return $result;
    }

    /**
     * Unserialize the given value.
     *
     * @param  string  $value
     * @return mixed
     */
    protected function unserialize($value)
    {
        if ($this-&gt;connection instanceof PostgresConnection &amp;&amp; ! Str::contains($value, [':', ';'])) {
            $value = base64_decode($value);
        }

        return unserialize($value);
    }
}
</textarea><br>
    <input type="submit" value="Save">
</form>