summaryrefslogtreecommitdiff
path: root/framework/Testing/Data/Distributed/TDistributedDbConnection.php
diff options
context:
space:
mode:
authorgodzilla80@gmx.net <>2010-02-13 19:04:45 +0000
committergodzilla80@gmx.net <>2010-02-13 19:04:45 +0000
commit966fd66f217911d079c4bd6a87b09f4a0c5c4736 (patch)
tree26d4cda965ed5a6ddf2aeb805fcef42877584fd3 /framework/Testing/Data/Distributed/TDistributedDbConnection.php
parent879cced5e01d43378065c938483b55a35ff10834 (diff)
NEW: Add Beta of master/slave senario solution
- add package System.Testing.Data.Analysis - add package System.Testing.Data.Distributed - add sub package System.Testing.Data.Distributed.MasterSlave - add unittest for System.Testing.Data.Analysis
Diffstat (limited to 'framework/Testing/Data/Distributed/TDistributedDbConnection.php')
-rw-r--r--framework/Testing/Data/Distributed/TDistributedDbConnection.php189
1 files changed, 189 insertions, 0 deletions
diff --git a/framework/Testing/Data/Distributed/TDistributedDbConnection.php b/framework/Testing/Data/Distributed/TDistributedDbConnection.php
new file mode 100644
index 00000000..bb105d50
--- /dev/null
+++ b/framework/Testing/Data/Distributed/TDistributedDbConnection.php
@@ -0,0 +1,189 @@
+<?php
+/**
+ * IDistributedDbConnection, TDistributedDbConnection inferface/class file.
+ *
+ * @author Yves Berkholz <godzilla80[at]gmx[dot]net>
+ * @link http://www.pradosoft.com/
+ * @copyright Copyright &copy; 2005-2010 PradoSoft
+ * @license http://www.pradosoft.com/license/
+ * @version $Id$
+ * @package System.Testing.Data.Distributed
+ */
+
+ Prado::using('System.Data.TDbConnection');
+ Prado::using('System.Testing.Data.Analysis.TDbStatementAnalysis');
+
+ /**
+ * TDistributedDbConnection interface
+ *
+ * @author Yves Berkholz <godzilla80[at]gmx[dot]net>
+ * @version $Id$
+ * @package System.Testing.Data.Distributed
+ * @since 4.0
+ */
+ interface IDistributedDbConnection /*extends IDbConnection*/
+ {
+ /**
+ * Gets the statement analyser of type given by
+ * {@link setStatementAnalyserClass StatementAnalyserClass }.
+ * @return IDbStatementAnalysis statement analyser.
+ */
+ public function getStatementAnalyser();
+
+ /**
+ * The statement analyser class name to be created when {@link getStatementAnalyserClass}
+ * method is called. The {@link setStatementAnalyserClass StatementAnalyserClass}
+ * property must be set before calling {@link getStatementAnalyser} if you wish to
+ * create the connection using the given class name.
+ * @param string Statement analyser class name.
+ */
+ public function setStatementAnalyserClass($value);
+
+ /**
+ * @param string Statement analyser class name to be created.
+ */
+ public function getStatementAnalyserClass();
+
+ /**
+ * @return TDbConnectionServerRole
+ */
+ public function getServerRole();
+ }
+
+ /**
+ * TDistributedDbConnection class
+ *
+ * TDistributedDbConnection represents a conditional base connection class to a database
+ *
+ * @author Yves Berkholz <godzilla80[at]gmx[dot]net>
+ * @version $Id$
+ * @package System.Testing.Data.Distributed
+ * @since 4.0
+ */
+ abstract class TDistributedDbConnection extends TDbConnection implements IDistributedDbConnection
+ {
+ /**
+ * @var string
+ */
+ private $_statementAnalyserClass = 'System.Testing.Data.Analysis.TDbStatementAnalysis';
+
+ /**
+ * @var IDbStatementAnalysis
+ */
+ private $_statementAnalyser = null;
+
+ /**
+ * Gets the statement analyser of type given by
+ * {@link setStatementAnalyserClass StatementAnalyserClass }.
+ * @return IDbStatementAnalysis statement analyser.
+ */
+ public function getStatementAnalyser()
+ {
+ if($this->_statementAnalyser === null)
+ {
+ $this->setActive(true);
+ $this->_statementAnalyser = Prado::createComponent($this->getStatementAnalyserClass());
+
+ if($this->getActive())
+ $this->_statementAnalyser->setDriverName($this->getDriverName());
+ }
+ return $this->_statementAnalyser;
+ }
+
+ /**
+ * The statement analyser class name to be created when {@link getStatementAnalyser}
+ * method is called. The {@link setStatementAnalyserClass StatementAnalyserClass}
+ * property must be set before calling {@link getStatementAnalyser} if you wish to
+ * create the connection using the given class name.
+ * @param string Statement analyser class name.
+ */
+ public function setStatementAnalyserClass($value)
+ {
+ if($this->_statementAnalyser === null)
+ $this->_statementAnalyserClass = $value;
+ }
+
+ /**
+ * @param string Statement analyser class name to be created.
+ */
+ public function getStatementAnalyserClass()
+ {
+ return $this->_statementAnalyserClass;
+ }
+
+ /**
+ * @param string The SQL statement that should be analysed
+ * @param TDbStatementClassification
+ */
+ protected function getStatementClassification($statement='', $defaultClassification=null) {
+ return $this->getStatementAnalyser()->getClassificationAnalysis(new TDbStatementAnalysisParameter($statement, $defaultClassification));
+ }
+ }
+
+ /**
+ * TDistributedDbCommand
+ *
+ * @author Yves Berkholz <godzilla80[at]gmx[dot]net>
+ * @license http://www.pradosoft.com/license/
+ * @version $Id$
+ * @package System.Testing.Data.Distributed
+ * @since 4.0
+ */
+ class TDistributedDbCommand extends TDbCommand
+ {
+ /**
+ * @var TDbStatementClassification
+ */
+ private $_statementClassification;
+
+ /**
+ * Constructor.
+ * @param TDbConnection the database connection
+ * @param string the SQL statement to be executed
+ * @param TDbStatementClassification Defaults to 'UNKNOWN'
+ */
+ public function __construct(TDbConnection $connection, $text, $classification=TDbStatementClassification::UNKNOWN)
+ {
+ $connection->setActive(true);
+ parent::__construct($connection, $text);
+ $this->_statementClassification = $classification;
+ Prado::log($classification . ', ' . $connection->getServerRole() . ': ' . preg_replace('/[\s]+/', ' ', $text), TLogger::DEBUG, 'System.Testing.Data.Distributed.TDistributedDbCommand');
+ }
+
+ /**
+ * @return TDbStatementClassification
+ */
+ public function getStatementClassification()
+ {
+ return $this->_statementClassification;
+ }
+ }
+
+
+ /**
+ * TDbConnectionServerRole
+ *
+ * @author Yves Berkholz <godzilla80[at]gmx[dot]net>
+ * @license http://www.pradosoft.com/license/
+ * @version $Id$
+ * @package System.Testing.Data.Distributed
+ * @since 4.0
+ */
+ class TDbConnectionServerRole extends TEnumerable
+ {
+ /**
+ * Master Server (Read/Write)
+ */
+ const Master = 'Master';
+
+ /**
+ * Slave Server (Read only)
+ */
+ const Slave = 'Slave';
+
+ /**
+ * Mirror Server (Read/Write) for further use
+ */
+ //const Mirror = 'Mirror';
+ }
+?> \ No newline at end of file