1. sfMessageSource_Database.class.php
  2. /**
 * sfMessageSource_Database class.
 *
 * This is the base class for database based message sources like MySQL or SQLite.
 *
 * @author Xiang Wei Zhuo 
 * @version v1.0, last update on Fri Dec 24 16:18:44 EST 2004
 * @package    symfony
 * @subpackage i18n
 */
  3. abstract class sfMessageSource_Database extends sfMessageSource
  4. {
  5.   /**
  6.    * For a given DSN (database connection string), return some information about the DSN.
  7.    *
  8.    * This function comes from PEAR's DB package.
  9.    *
  10.    * @param string $dsn DSN format, similar to PEAR's DB
  11.    * @return array DSN information. 
  12.    */
  13.   protected function parseDSN($dsn)
  14.   {
  15.     if (is_array($dsn))
  16.     {
  17.       return $dsn;
  18.     }
  20.     $parsed = array(
  21.       'phptype'  => false,
  22.       'dbsyntax' => false,
  23.       'username' => false,
  24.       'password' => false,
  25.       'protocol' => false,
  26.       'hostspec' => false,
  27.       'port'     => false,
  28.       'socket'   => false,
  29.       'database' => false
  30.     );
  32.     // Find phptype and dbsyntax
  33.     if (($pos = strpos($dsn, '://')) !== false)
  34.     {
  35.       $str = substr($dsn, 0, $pos);
  36.       $dsn = substr($dsn, $pos + 3);
  37.     }
  38.     else
  39.     {
  40.       $str = $dsn;
  41.       $dsn = NULL;
  42.     }
  44.     // Get phptype and dbsyntax
  45.     // $str => phptype(dbsyntax)
  46.     if (preg_match('|^(.+?)\((.*?)\)$|', $str, $arr))
  47.     {
  48.       $parsed['phptype']  = $arr[1];
  49.       $parsed['dbsyntax'] = (empty($arr[2])) ? $arr[1] : $arr[2];
  50.     }
  51.     else
  52.     {
  53.       $parsed['phptype']  = $str;
  54.       $parsed['dbsyntax'] = $str;
  55.     }
  57.     if (empty($dsn))
  58.     {
  59.       return $parsed;
  60.     }
  62.     // Get (if found): username and password
  63.     // $dsn => username:password@protocol+hostspec/database
  64.     if (($at = strrpos($dsn,'@')) !== false)
  65.     {
  66.       $str = substr($dsn, 0, $at);
  67.       $dsn = substr($dsn, $at + 1);
  68.       if (($pos = strpos($str, ':')) !== false)
  69.       {
  70.         $parsed['username'] = rawurldecode(substr($str, 0, $pos));
  71.         $parsed['password'] = rawurldecode(substr($str, $pos + 1));
  72.       }
  73.       else
  74.       {
  75.         $parsed['username'] = rawurldecode($str);
  76.       }
  77.     }
  79.     // Find protocol and hostspec
  81.     // $dsn => proto(proto_opts)/database
  82.     if (preg_match('|^([^(]+)\((.*?)\)/?(.*?)$|', $dsn, $match))
  83.     {
  84.       $proto       = $match[1];
  85.       $proto_opts  = (!empty($match[2])) ? $match[2] : false;
  86.       $dsn         = $match[3];
  87.     // $dsn => protocol+hostspec/database (old format)
  88.     }
  89.     else
  90.     {
  91.       if (strpos($dsn, '+') !== false)
  92.       {
  93.         list($proto, $dsn) = explode('+', $dsn, 2);
  94.       }
  95.       if (strpos($dsn, '/') !== false)
  96.       {
  97.         list($proto_opts, $dsn) = explode('/', $dsn, 2);
  98.       }
  99.       else
  100.       {
  101.         $proto_opts = $dsn;
  102.         $dsn = null;
  103.       }
  104.     }
  106.     // process the different protocol options
  107.     $parsed['protocol'] = (!empty($proto)) ? $proto : 'tcp';
  108.     $proto_opts = rawurldecode($proto_opts);
  109.     if ($parsed['protocol'] == 'tcp')
  110.     {
  111.       if (strpos($proto_opts, ':') !== false)
  112.       {
  113.         list($parsed['hostspec'], $parsed['port']) = explode(':', $proto_opts);
  114.       }
  115.       else
  116.       {
  117.         $parsed['hostspec'] = $proto_opts;
  118.       }
  119.     }
  120.     else if ($parsed['protocol'] == 'unix')
  121.     {
  122.       $parsed['socket'] = $proto_opts;
  123.     }
  125.     // Get dabase if any
  126.     // $dsn => database
  127.     if (!empty($dsn))
  128.     {
  129.       // /database
  130.       if (($pos = strpos($dsn, '?')) === false)
  131.       {
  132.         $parsed['database'] = $dsn;
  133.       // /database?param1=value1&param2=value2
  134.       }
  135.       else
  136.       {
  137.         $parsed['database'] = substr($dsn, 0, $pos);
  138.         $dsn = substr($dsn, $pos + 1);
  139.         if (strpos($dsn, '&') !== false)
  140.         {
  141.           $opts = explode('&', $dsn);
  142.         }
  143.         else
  144.         { // database?param1=value1
  145.           $opts = array($dsn);
  146.         }
  147.         foreach ($opts as $opt)
  148.         {
  149.           list($key, $value) = explode('=', $opt);
  150.           if (!isset($parsed[$key]))
  151.           { // don't allow params overwrite
  152.             $parsed[$key] = rawurldecode($value);
  153.           }
  154.         }
  155.       }
  156.     }
  158.     return $parsed;
  159.   }
  161.   /**
  162.    * Gets all the variants of a particular catalogue.
  163.    *
  164.    * @param string $catalogue catalogue name
  165.    * @return array list of all variants for this catalogue.
  166.    */
  167.   public function getCatalogueList($catalogue)
  168.   {
  169.     $variants = explode('_', $this->culture);
  171.     $catalogues = array($catalogue);
  173.     $variant = null;
  175.     for ($i = 0, $max = count($variants); $i < $max; $i++)
  176.     {
  177.       if (strlen($variants[$i]) > 0)
  178.       {
  179.         $variant .= $variant ? '_'.$variants[$i] : $variants[$i];
  180.         $catalogues[] = $catalogue.'.'.$variant;
  181.       }
  182.     }
  184.     return array_reverse($catalogues);
  185.   }
  187.   public function getId()
  188.   {
  189.     return md5($this->source);
  190.   }
  191. }
Debug toolbar