OpenPNE 3

  /**

   * Writes data to this storage replacing 4 byte utf8 characters.

   *

   * @param string $key   A unique key identifying your data

   * @param mixed  $data  Data associated with your key

   *

   * @see sfSessionStorage

   */

  public function write($key, $data)

  {

    // "utf8", a type of character set in MySQL, can't handle 4 bytes utf8 characters

    // so we replace such a character to "U+FFFD" (A unicode "REPLACEMENT CHARACTER").

    if (!$this->isReadyFor4BytesUtf8())

    {

      $data = $this->replace4BytesUtf8Characters($data);

    }

    parent::write($key, $data);

  }

  protected function replace4BytesUtf8Characters($value)

  {

    if (is_array($value))

    {

      $result = array();

      foreach ($value as $k => $v)

      {

        $result[$this->replace4BytesUtf8Characters($k)] = $this->replace4BytesUtf8Characters($v);

      }

      return $result;

    }

    elseif (!is_string($value))

    {

      return $value;

    }

    // See: RFC 3629 (section 4, Syntax of UTF-8 Byte Sequences)

    // http://tools.ietf.org/html/rfc3629#section-4

    return preg_replace('/(

      \xF0[\x90-\xBF][\x80-\xBF]{2}| # %xF0 %x90-BF 2( UTF8-tail )

      [\xF1-\xF3][\x80-\xBF]{3}|     # %xF1-F3 3( UTF8-tail )

      \xF4[\x80-\x8F][\x80-\xBF]{2}  # %xF4 %x80-8F 2( UTF8-tail )

    )/x', "\xEF\xBF\xBD", $value);

  }

  protected function isReadyFor4BytesUtf8()

  {

    return 'mysql' !== $this->db->getAttribute(PDO::ATTR_DRIVER_NAME);

  }

<?php

require_once(dirname(__FILE__).'/../../bootstrap/unit.php');

$_app = 'pc_frontend';

$_end = 'test';

$configuration = ProjectConfiguration::getApplicationConfiguration($_app, $_env, true);

sfContext::createInstance($configuration);

new sfDatabaseManager($configuration);

$t = new lime_test(2 + 2, new lime_output_color());

$storage = new opPDODatabaseSessionStorage(array(

  'db_table'    => 'session',

  'database'    => 'doctrine',

  'db_id_col'   => 'id',

  'db_data_col' => 'session_data',

  'db_time_col' => 'time',

));

$t->ok($storage instanceof sfStorage, 'sfPDOSessionStorage is an instance of sfStorage');

$t->ok($storage instanceof sfDatabaseSessionStorage, 'sfPDOSessionStorage is an instance of sfDatabaseSessionStorage');

$storage->sessionOpen();

// main test

$sessionId = '1';

$newSessionData = 'foo:bar:baz';

$storage->write($sessionId, $newSessionData);

$t->is($storage->read($sessionId), $newSessionData, 'session data can get data correctly');

$sessionId = '1';

$newSessionData = 'testⓉⒺⓈⓉテスト🅃🄴🅂🅃てすと';

$strConverted = 'testⓉⒺⓈⓉテスト����てすと';

$storage->write($sessionId, $newSessionData);

$t->is($storage->read($sessionId), $strConverted, 'session data using 4 byte utf characters can get data correctly');