我有两个网站，一个是 TLS，一个不是，两者都针对同一个客户端，但我需要这些网站为用户彼此(并且只彼此)共享公共(public)数据， 订单、账户等

这通常是用 $_SESSION 数据完成的，但我显然不能在其他站点上使用这些数据，而且我发现我可以将 session 数据存储在数据库 (MySQL) 中，而不是文件系统。

我四处寻找并找到了This useful guide以及这个较旧但 useful guide .我还找到了this guide它有稍微更新的 MySQL。

我写了一个接口(interface)类，但它只能部分工作，它将 session 数据存储在数据库中，但不检索它。我也用过 suggested method from the PHP manual .

My MySQL(从上述链接的前几个复制而来):

CREATE TABLE `sessions` (
  `id` varchar(32) COLLATE utf8_unicode_ci NOT NULL,
  `access` int(10) NOT NULL,
  `data` text COLLATE utf8_unicode_ci NOT NULL,
  UNIQUE KEY `id` (`id`)
) ENGINE=InnoDb DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;

Please Note: Before I show you my interface class please know that the Db connetion uses my own custom made interface and that works perfectly, in itself.

The $sessionDBconnectionUrl contains the Session Database connection details as I am keeping sessions on a seperate Database from the main website contents.

我的界面类(基于以上所有链接)

<?php
/***
 * Created by PhpStorm.
 ***/
class HafSessionHandler implements SessionHandler {
    private $database = null;
    
    public function __construct($sessionDBconnectionUrl){

        if(!empty($sessionDBconnectionUrl) && file_exists($_SERVER['DOCUMENT_ROOT'].$sessionDBconnectionUrl)) {
            require_once "class.dataBase.php";
            // Instantiate new Database object
            $this->database = new Database($sessionDBconnectionUrl);
        }
        else {
            error_log("Session could not initialise class.");
        }
        
    }

    /**
     * Open
     */
    public function open($savepath, $id){
         $openRow = $this->database->getSelect("SELECT `data` FROM sessions WHERE id = ? LIMIT 1",$id);
    if($this->database->selectRowsFoundCounter() == 1){
        // Return True
        return $openRow['data'];
        }
    else {
        // Return False
        return ' ';
    }
    /**
     * Read
     */
    public function read($id)
    {
        // Set query
        $readRow = $this->database->getSelect('SELECT `data` FROM sessions WHERE id = ? LIMIT 1', $id,TRUE);
        if ($this->database->selectRowsFoundCounter() > 0) {
            return $readRow['data'];
        } else {
            error_log("could not read session id ".$id);
            return '';
        }
    }

    /**
     * Write
     */
    public function write($id, $data)
    {
        $access = time();
        // Set query
        $dataReplace[0] = $id;
        $dataReplace[1] = $access;
        $dataReplace[2] = $data;
        if ($this->database->noReturnQuery('REPLACE INTO sessions(id,access,`data`) VALUES (?, ?, ?)', $dataReplace)) {
            return TRUE;
        } else {
            return FALSE;
        }
    }

    /**
     * Destroy
     */
    public function destroy($id)
    {
        // Set query
        if ($this->database->noReturnQuery('DELETE * FROM sessions WHERE id = ? ', $id)) {
            return TRUE;
        } else {

            return FALSE;
        }
    }
    /**
     * Close
     */
    public function close(){
        // Close the database connection
        // If successful
        if($this->database->dbiLink->close){
            // Return True
            return true;
        }
        // Return False
        return false;
    }

    /**
     * Garbage Collection
     */
    public function gc($max)
    {
        // Calculate what is to be deemed old
        $old = time() - $max;

        // Set query
        if ($this->database->noReturnQuery('DELETE * FROM sessions WHERE access < ?', $old)) {
            return TRUE;
        } else {
            return FALSE;
        }
    }
    
    public function __destruct()
    {
        $this->close();
    }

}

我的测试页(从头开始写!)

<?php
require "class.sessionHandler.inc.php";
$HSH = new HafSessionHandler("connection.session.dbxlink.php");
session_set_save_handler( $HSH, TRUE );
session_start();

print "<p>Hello this is an index page</p>";
$_SESSION['horses'] = "treesx3";
$_SESSION['tiespan'] = (int)$_SESSION['tiespan']+7;

print "<p>There should be some session data in the database now. <a href='index3.php'>link</a></p>";
var_dump($_SESSION);


exit;

问题:

我运行的测试页面可以将数据保存到数据库，但它们似乎没有检索数据，

我启用了错误记录，没有报告任何 PHP 错误。没有报告严重的 MySQL 错误。

为什么它不起作用？

最佳答案

在几个小时的调试过程中，我发现在众多 Google 搜索中找到的引用文章以及 Stack Overflow 答案的重要子集，例如 here , here和 here都提供无效或过时的信息。

在将 session 数据保存到数据库时可能会导致 [严重] 问题:

• 虽然所有在线示例都表明您可以“填写”session_set_save_handler，但没有一个说明您还必须设置 register_shutdown_function('session_write_close') 也是(reference)。

• 一些(较旧的)指南提到过时的 SQL 数据库结构，应该不使用。将 session 数据保存到数据库所需的数据库结构是:id/access/data。而已。正如我在一些“指南”和示例中看到的那样，不需要各种额外的时间戳列。

  • 一些较旧的指南也有过时的 MySQL 语法，例如 DELETE * FROM ...

• [在我的问题中提出的]类必须 implement SessionHandlerInterface 。我已经看到指南(上面引用过)给出了 sessionHandler 的实现，这不是一个合适的接口(interface)。也许以前版本的 PHP 有一个稍微不同的方法(可能 <5.4)。>

• session 类方法必须返回 PHP 手册中规定的值。同样，可能继承自 5.4 之前的 PHP，但我阅读的两个指南指出 class->open 返回要读取的行，而 PHP manual states它只需要返回 true 或 false。

• 这是我原来的问题的原因:我使用的是自定义 session 名称(实际上 id 作为 session 名称和 session id 的是一回事!)根据 this very good StackOverflow post这会生成一个 128 个字符长的 session 名称。由于 session 名称是破解 session 并使用 session hijacking 接管所需的唯一 key 。那么更长的名字/身份证是一件非常好的事情。

  • 但是，这导致了一个问题，因为 MySQL 默默地将 session ID 分割为 32 个字符而不是 128 个字符，因此它永远无法找到 session 数据在数据库中。这是一个完全无声的问题(可能是由于我的数据库连接类没有对此类事情发出警告)。但这是需要注意的。如果您在从数据库中检索 session 时遇到任何问题，请首先检查 full session ID 是否可以存储在提供的字段中。

因此，除了所有这些之外，还需要添加一些额外的细节:

PHP 手册页(上面链接)显示了一堆不适合类对象的行:

$handler = new MySessionHandler();
session_set_save_handler($handler, true);
session_start();

如果你把它放在类构造函数中，它也同样有效:

class MySessionHandler implements SessionHandlerInterface {

    private $database = null;

public function __construct(){

    $this->database = new Database(whatever);

    // Set handler to overide SESSION
    session_set_save_handler(
        array($this, "open"),
        array($this, "close"),
        array($this, "read"),
        array($this, "write"),
        array($this, "destroy"),
        array($this, "gc")
        );
    register_shutdown_function('session_write_close');
    session_start();
    }
...
}

这意味着在你的输出页面上开始一个 session 你只需要:

<?php
require "path/to/sessionhandler.class.php"; 
new MySessionHandler();

//Bang session has been setup and started and works

完整的 Session 通信类引用如下，这适用于 PHP 5.6(可能是 7，但尚未在 7 上测试)

<?php
/***
 * Created by PhpStorm.
 ***/
class MySessionHandler implements SessionHandlerInterface {
    private $database = null;

    public function __construct($sessionDBconnectionUrl){
        /***
         * Just setting up my own database connection. Use yours as you need.
         ***/ 

            require_once "class.database.include.php";
            $this->database = new DatabaseObject($sessionDBconnectionUrl);

        // Set handler to overide SESSION
        session_set_save_handler(
            array($this, "open"),
            array($this, "close"),
            array($this, "read"),
            array($this, "write"),
            array($this, "destroy"),
            array($this, "gc")
        );
        register_shutdown_function('session_write_close');
        session_start();
    }

    /**
     * Open
     */
    public function open($savepath, $id){
        // If successful
        $this->database->getSelect("SELECT `data` FROM sessions WHERE id = ? LIMIT 1",$id,TRUE);
        if($this->database->selectRowsFoundCounter() == 1){
            // Return True
            return true;
        }
        // Return False
        return false;
    }
    /**
     * Read
     */
    public function read($id)
    {
        // Set query
        $readRow = $this->database->getSelect('SELECT `data` FROM sessions WHERE id = ? LIMIT 1', $id,TRUE);
        if ($this->database->selectRowsFoundCounter() > 0) {
            return $readRow['data'];
        } else {
            return '';
        }
    }

    /**
     * Write
     */
    public function write($id, $data)
    {
        // Create time stamp
        $access = time();

        // Set query
        $dataReplace[0] = $id;
        $dataReplace[1] = $access;
        $dataReplace[2] = $data;
        if ($this->database->noReturnQuery('REPLACE INTO sessions(id,access,`data`) VALUES (?, ?, ?)', $dataReplace)) {
            return true;
        } else {
            return false;
        }
    }

    /**
     * Destroy
     */
    public function destroy($id)
    {
        // Set query
        if ($this->database->noReturnQuery('DELETE FROM sessions WHERE id = ? LIMIT 1', $id)) {
            return true;
        } else {

            return false;
        }
    }
    /**
     * Close
     */
    public function close(){
        // Close the database connection
        if($this->database->dbiLink->close){
            // Return True
            return true;
        }
        // Return False
        return false;
    }

    /**
     * Garbage Collection
     */
    public function gc($max)
    {
        // Calculate what is to be deemed old
        $old = time() - $max;

        if ($this->database->noReturnQuery('DELETE FROM sessions WHERE access < ?', $old)) {
            return true;
        } else {
            return false;
        }
    }

    public function __destruct()
    {
        $this->close();
    }

}

用法:如上面的类代码文本所示。

关于php - 如何将 PHP session 数据保存到数据库而不是文件系统中？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/36753513/