Changeset 23493 for branches/version-2_13-dev/data/class/SC_SessionFactory.php

Timestamp:

2014/06/02 15:12:19 (12 years ago)

Author:

pineray

Message:

#2565 セッションに関するクラスや関数を整理

セッションハンドラの登録をファクトリーへ移動.

File:

• branches/version-2_13-dev/data/class/SC_SessionFactory.php (modified) (2 diffs)

branches/version-2_13-dev/data/class/SC_SessionFactory.php

@@ -86 +86 @@
     public function initSession()
     {
+        session_set_save_handler(array(&$this, 'sfSessOpen'),
+            array(&$this, 'sfSessClose'),
+            array(&$this, 'sfSessRead'),
+            array(&$this, 'sfSessWrite'),
+            array(&$this, 'sfSessDestroy'),
+            array(&$this, 'sfSessGc'));
+
+        // 通常よりも早い段階(オブジェクトが破棄される前)でセッションデータを書き込んでセッションを終了する
+        // XXX APC による MDB2 の破棄タイミングによる不具合を回避する目的
+        register_shutdown_function('session_write_close');
     }
 
@@ -95 +105 @@
     public function useCookie()
     {
+    }
+
+    /**
+     * セッションを開始する.
+     *
+     * @param  string $save_path    セッションを保存するパス(使用しない)
+     * @param  string $session_name セッション名(使用しない)
+     * @return bool   セッションが正常に開始された場合 true
+     */
+    public function sfSessOpen($save_path, $session_name)
+    {
+        return true;
+    }
+
+    /**
+     * セッションを閉じる.
+     *
+     * @return bool セッションが正常に終了した場合 true
+     */
+    public function sfSessClose()
+    {
+        return true;
+    }
+
+    /**
+     * セッションのデータをDBから読み込む.
+     *
+     * @param  string $id セッションID
+     * @return string セッションデータの値
+     */
+    public function sfSessRead($id)
+    {
+        $objQuery =& SC_Query_Ex::getSingletonInstance();
+        $arrRet = $objQuery->select('sess_data', 'dtb_session', 'sess_id = ?', array($id));
+        if (empty($arrRet)) {
+            return '';
+        } else {
+            return $arrRet[0]['sess_data'];
+        }
+    }
+
+    /**
+     * セッションのデータをDBに書き込む.
+     *
+     * @param  string $id        セッションID
+     * @param  string $sess_data セッションデータの値
+     * @return bool   セッションの書き込みに成功した場合 true
+     */
+    public function sfSessWrite($id, $sess_data)
+    {
+        $objQuery =& SC_Query_Ex::getSingletonInstance();
+        $exists = $objQuery->exists('dtb_session', 'sess_id = ?', array($id));
+        $sqlval = array();
+        if ($exists) {
+            // レコード更新
+            $sqlval['sess_data'] = $sess_data;
+            $sqlval['update_date'] = 'CURRENT_TIMESTAMP';
+            $objQuery->update('dtb_session', $sqlval, 'sess_id = ?', array($id));
+        } else {
+            // セッションデータがある場合は、レコード作成
+            if (strlen($sess_data) > 0) {
+                $sqlval['sess_id'] = $id;
+                $sqlval['sess_data'] = $sess_data;
+                $sqlval['update_date'] = 'CURRENT_TIMESTAMP';
+                $sqlval['create_date'] = 'CURRENT_TIMESTAMP';
+                $objQuery->insert('dtb_session', $sqlval);
+            }
+        }
+
+        return true;
+    }
+
+    // セッション破棄
+
+    /**
+     * セッションを破棄する.
+     *
+     * @param  string $id セッションID
+     * @return bool   セッションを正常に破棄した場合 true
+     */
+    public function sfSessDestroy($id)
+    {
+        $objQuery =& SC_Query_Ex::getSingletonInstance();
+        $objQuery->delete('dtb_session', 'sess_id = ?', array($id));
+
+        return true;
+    }
+
+    /**
+     * ガーベジコレクションを実行する.
+     *
+     * 引数 $maxlifetime の代りに 定数 MAX_LIFETIME を使用する.
+     *
+     * @param integer $maxlifetime セッションの有効期限(使用しない)
+     * @return bool
+     */
+    public function sfSessGc($maxlifetime)
+    {
+        // MAX_LIFETIME以上更新されていないセッションを削除する。
+        $objQuery =& SC_Query_Ex::getSingletonInstance();
+        $limit = date("Y-m-d H:i:s",time() - MAX_LIFETIME);
+        $where = "update_date < '". $limit . "' ";
+        $objQuery->delete('dtb_session', $where);
+
+        return true;
     }
 }