WebSVN – lars-tiefland.prado – /framework/I18N/core/MessageSource_MySQL.php

<?php

/**
 * MessageSource_MySQL class file.
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the BSD License.
 *
 * Copyright(c) 2004 by Qiang Xue. All rights reserved.
 *
 * To contact the author write to {@link mailto:qiang.xue@gmail.com Qiang Xue}
 * The latest version of PRADO can be obtained from:
 * {@link http://prado.sourceforge.net/}
 *
 * @author Wei Zhuo <weizhuo[at]gmail[dot]com>
 * @version $Revision: 1.4 $  $Date: 2005/02/25 09:59:40 $
 * @package System.I18N.core
 */

/**
 * Get the MessageSource class file.
 */
require_once(dirname(__FILE__).'/MessageSource.php');

/**
 * Get the I18N utility file, contains the DSN parser.
 */
require_once(dirname(__FILE__).'/util.php');

/**
 * MessageSource_MySQL class.
 *
 * Retrive the message translation from a MySQL database.
 *
 * See the MessageSource::factory() method to instantiate this class.
 *
 * @author Xiang Wei Zhuo <weizhuo[at]gmail[dot]com>
 * @version v1.0, last update on Fri Dec 24 16:58:58 EST 2004
 * @package System.I18N.core
 */
class MessageSource_MySQL extends MessageSource
{
        /**
         * The datasource string, full DSN to the database.
         * @var string
         */
        protected $source;

        /**
         * The DSN array property, parsed by PEAR's DB DSN parser.
         * @var array
         */
        protected $dns;

        /**
         * A resource link to the database
         * @var db
         */
        protected $db;
        /**
         * Constructor.
         * Create a new message source using MySQL.
         * @param string MySQL datasource, in PEAR's DB DSN format.
         * @see MessageSource::factory();
         */
        function __construct($source)
        {
                $this->source = (string)$source;
                $this->dns = parseDSN($this->source);
                $this->db = $this->connect();
        }

        /**
         * Destructor, close the database connection.
         */
        function __destruct()
        {
                @mysql_close($this->db);
        }

        /**
         * Connect to the MySQL datasource
         * @return resource MySQL connection.
         * @throws Exception, connection and database errors.
         */
        protected function connect()
        {
                /*static $conn;

                if(!is_null($conn))
                        return $conn;
                */
                $dsninfo = $this->dns;

        if (isset($dsninfo['protocol']) && $dsninfo['protocol'] == 'unix')
            $dbhost = ':' . $dsninfo['socket'];
        else
        {
                        $dbhost = $dsninfo['hostspec'] ? $dsninfo['hostspec'] : 'localhost';
            if (!empty($dsninfo['port']))
                $dbhost .= ':' . $dsninfo['port'];
        }
        $user = $dsninfo['username'];
        $pw = $dsninfo['password'];

        $connect_function = 'mysql_connect';

        if ($dbhost && $user && $pw)
            $conn = @$connect_function($dbhost, $user, $pw);
        elseif ($dbhost && $user)
            $conn = @$connect_function($dbhost, $user);
        elseif ($dbhost)
            $conn = @$connect_function($dbhost);
        else
            $conn = false;

        if (empty($conn))
        {
                throw new Exception('Error in connecting to '.$dsninfo);
        }

        if ($dsninfo['database'])
        {
                if (!@mysql_select_db($dsninfo['database'], $conn))
                        throw new Exception('Error in connecting database, dns:'.
                                                                $dsninfo);
        }
        else
                throw new Exception('Please provide a database for message'.
                                                        ' translation.');
       return $conn;
        }

        /**
         * Get the database connection.
         * @return db database connection.
         */
        public function connection()
        {
                return $this->db;
        }

        /**
         * Get an array of messages for a particular catalogue and cultural
         * variant.
         * @param string the catalogue name + variant
         * @return array translation messages.
         */
        protected function &loadData($variant)
        {
                $variant = mysql_real_escape_string($variant);

                $statement =
                        "SELECT t.id, t.source, t.target, t.comments
                                FROM trans_unit t, catalogue c
                                WHERE c.cat_id =  t.cat_id
                                        AND c.name = '{$variant}'
                                ORDER BY id ASC";

                $rs = mysql_query($statement,$this->db);

                $result = array();

                while($row = mysql_fetch_array($rs,MYSQL_NUM))
                {
                        $source = $row[1];
                        $result[$source][] = $row[2]; //target
                        $result[$source][] = $row[0]; //id
                        $result[$source][] = $row[3]; //comments
                }

                return $result;
        }

        /**
         * Get the last modified unix-time for this particular catalogue+variant.
         * We need to query the database to get the date_modified.
         * @param string catalogue+variant
         * @return int last modified in unix-time format.
         */
        protected function getLastModified($source)
        {
                $source = mysql_real_escape_string($source);

                $rs = mysql_query(
                        "SELECT date_modified FROM catalogue WHERE name = '{$source}'",
                        $this->db);

                $result = $rs ? (int)mysql_result($rs,0) : 0;

                return $result;
        }

        /**
         * Check if a particular catalogue+variant exists in the database.
         * @param string catalogue+variant
         * @return boolean true if the catalogue+variant is in the database,
         * false otherwise.
         */
        protected function isValidSource($variant)
        {
                $variant = mysql_real_escape_string ($variant);

                $rs = mysql_query(
                        "SELECT COUNT(*) FROM catalogue WHERE name = '{$variant}'",
                        $this->db);

                $row = mysql_fetch_array($rs,MYSQL_NUM);

                $result = $row && $row[0] == '1';

                return $result;
        }

        /**
         * Get all the variants of a particular catalogue.
         * @param string catalogue name
         * @return array list of all variants for this catalogue.
         */
        protected function getCatalogueList($catalogue)
        {
                $variants = explode('_',$this->culture);

                $catalogues = array($catalogue);

                $variant = null;

                for($i = 0, $k = count($variants); $i < $k; ++$i)
                {
                        if(isset($variants[$i]{0}))
                        {
                                $variant .= ($variant)?'_'.$variants[$i]:$variants[$i];
                                $catalogues[] = $catalogue.'.'.$variant;
                        }
                }
                return array_reverse($catalogues);
        }

        /**
         * Retrive catalogue details, array($cat_id, $variant, $count).
         * @param string catalogue
         * @return array catalogue details, array($cat_id, $variant, $count).
         */
        private function getCatalogueDetails($catalogue='messages')
        {
                if(empty($catalogue))
                        $catalogue = 'messages';

                $variant = $catalogue.'.'.$this->culture;

                $name = mysql_real_escape_string($this->getSource($variant));

                $rs = mysql_query("SELECT cat_id
                                        FROM catalogue WHERE name = '{$name}'", $this->db);

                if(mysql_num_rows($rs) != 1)
                        return false;

                $cat_id = (int)mysql_result($rs,0);

                //first get the catalogue ID
                $rs = mysql_query(
                        "SELECT count(msg_id)
                                FROM trans_unit
                                WHERE cat_id = {$cat_id}", $this->db);

                $count = (int)mysql_result($rs,0);

                return array($cat_id, $variant, $count);
        }

        /**
         * Update the catalogue last modified time.
         * @return boolean true if updated, false otherwise.
         */
        private function updateCatalogueTime($cat_id, $variant)
        {
                $time = time();

                $result = mysql_query("UPDATE catalogue
                                                        SET date_modified = {$time}
                                                        WHERE cat_id = {$cat_id}", $this->db);

                if(!empty($this->cache))
                        $this->cache->clean($variant, $this->culture);

                return $result;
        }

        /**
         * Save the list of untranslated blocks to the translation source.
         * If the translation was not found, you should add those
         * strings to the translation source via the <b>append()</b> method.
         * @param string the catalogue to add to
         * @return boolean true if saved successfuly, false otherwise.
         */
        function save($catalogue='messages')
        {
                $messages = $this->untranslated;

                if(count($messages) <= 0) return false;

                $details = $this->getCatalogueDetails($catalogue);

                if($details)
                        list($cat_id, $variant, $count) = $details;
                else
                        return false;

                if($cat_id <= 0) return false;
                $inserted = 0;

                $time = time();

                foreach($messages as $message)
                {
                        $count++; $inserted++;
                        $message = mysql_real_escape_string($message);
                        $statement = "INSERT INTO trans_unit
                                (cat_id,id,source,date_added) VALUES
                                ({$cat_id}, {$count},'{$message}',$time)";
                        mysql_query($statement, $this->db);
                }
                if($inserted > 0)
                        $this->updateCatalogueTime($cat_id, $variant);

                return $inserted > 0;
        }

        /**
         * Delete a particular message from the specified catalogue.
         * @param string the source message to delete.
         * @param string the catalogue to delete from.
         * @return boolean true if deleted, false otherwise.
         */
        function delete($message, $catalogue='messages')
        {
                $details = $this->getCatalogueDetails($catalogue);
                if($details)
                        list($cat_id, $variant, $count) = $details;
                else
                        return false;

                $text = mysql_real_escape_string($message);

                $statement = "DELETE FROM trans_unit WHERE
                                                cat_id = {$cat_id} AND source = '{$message}'";
                $deleted = false;

                mysql_query($statement, $this->db);

                if(mysql_affected_rows($this->db) == 1)
                        $deleted = $this->updateCatalogueTime($cat_id, $variant);

                return $deleted;

        }

        /**
         * Update the translation.
         * @param string the source string.
         * @param string the new translation string.
         * @param string comments
         * @param string the catalogue of the translation.
         * @return boolean true if translation was updated, false otherwise.
         */
        function update($text, $target, $comments, $catalogue='messages')
        {
                $details = $this->getCatalogueDetails($catalogue);
                if($details)
                        list($cat_id, $variant, $count) = $details;
                else
                        return false;

                $comments = mysql_real_escape_string($comments);
                $target = mysql_real_escape_string($target);
                $text = mysql_real_escape_string($text);

                $time = time();

                $statement = "UPDATE trans_unit SET
                                                target = '{$target}',
                                                comments = '{$comments}',
                                                date_modified = '{$time}'
                                        WHERE cat_id = {$cat_id}
                                                AND source = '{$text}'";

                $updated = false;

                mysql_query($statement, $this->db);
                if(mysql_affected_rows($this->db) == 1)
                        $updated = $this->updateCatalogueTime($cat_id, $variant);

                return $updated;
        }

        /**
         * Returns a list of catalogue as key and all it variants as value.
         * @return array list of catalogues
         */
        function catalogues()
        {
                $statement = 'SELECT name FROM catalogue ORDER BY name';
                $rs = mysql_query($statement, $this->db);
                $result = array();
                while($row = mysql_fetch_array($rs,MYSQL_NUM))
                {
                        $details = explode('.',$row[0]);
                        if(!isset($details[1])) $details[1] = null;

                        $result[] = $details;
                }
                return $result;
        }

}

?>
Subversion-Projekte lars-tiefland.prado

(root)/framework/I18N/core/MessageSource_MySQL.php – Revision 1
