Refactor and add TTableGateway, System.Data.Common, System.Data.DataGateway

4 files changed, 513 insertions, 0 deletions

diff --git a/tests/simple_unit/DbCommon/CommandBuilderMysqlTest.php b/tests/simple_unit/DbCommon/CommandBuilderMysqlTest.php
new file mode 100644
index 00000000..500d5277
--- /dev/null
+++ b/tests/simple_unit/DbCommon/CommandBuilderMysqlTest.php
@@ -0,0 +1,19 @@
+<?php
+Prado::using('System.Data.*');

+Prado::using('System.Data.Common.Mysql.TMysqlMetaData');

+

+class CommandBuilderMysqlTest extends UnitTestCase

+{

+	function mysql_meta_data()

+	{

+		$conn = new TDbConnection('mysql:host=localhost;dbname=tests', 'test','test');

+		return new TMysqlMetaData($conn);

+	}

+

+	function test()

+	{

+		$this->mysql_meta_data()->getTableInfo("tests.table1");

+	}

+}

+
+?>
\ No newline at end of file
diff --git a/tests/simple_unit/DbCommon/CommandBuilderPgsqlTest.php b/tests/simple_unit/DbCommon/CommandBuilderPgsqlTest.php
new file mode 100644
index 00000000..8bf2848e
--- /dev/null
+++ b/tests/simple_unit/DbCommon/CommandBuilderPgsqlTest.php
@@ -0,0 +1,77 @@
+<?php
+

+Prado::using('System.Data.*');

+Prado::using('System.Data.Common.Pgsql.TPgsqlMetaData');

+

+class CommandBuilderPgsqlTest extends UnitTestCase

+{

+	function pgsql_meta_data()

+	{

+		$conn = new TDbConnection('pgsql:host=localhost;dbname=test', 'test','test');

+		return new TPgsqlMetaData($conn);

+	}

+

+	function test_insert_command_using_named_array()

+	{

+		$builder = $this->pgsql_meta_data()->createCommandBuilder('address');

+		$address=array(

+			'username' => 'Username',

+			'phone' => 121987,

+			'field1_boolean' => true,

+			'field2_date' => '1213',

+			'field3_double' => 121.1,

+			'field4_integer' => 345,

+			'field6_time' => time(),

+			'field7_timestamp' => time(),

+			'field8_money' => '121.12',

+			'field9_numeric' => 984.22,

+			'int_fk1'=>1,

+			'int_fk2'=>1,

+		);

+		$insert = $builder->createInsertCommand($address);

+		$sql = 'INSERT INTO public.address("username", "phone", "field1_boolean", "field2_date", "field3_double", "field4_integer", "field6_time", "field7_timestamp", "field8_money", "field9_numeric", "int_fk1", "int_fk2") VALUES (:username, :phone, :field1_boolean, :field2_date, :field3_double, :field4_integer, :field6_time, :field7_timestamp, :field8_money, :field9_numeric, :int_fk1, :int_fk2)';

+		$this->assertEqual($sql, $insert->Text);

+	}

+

+	function test_update_command()

+	{

+		$builder = $this->pgsql_meta_data()->createCommandBuilder('address');

+		$data = array(

+			'phone' => 9809,

+			'int_fk1' => 1212,

+		);

+		$update = $builder->createUpdateCommand($data, '1');

+		$sql = 'UPDATE public.address SET "phone" = :phone, "int_fk1" = :int_fk1 WHERE 1';

+		$this->assertEqual($sql, $update->Text);

+	}

+

+	function test_delete_command()

+	{

+		$builder = $this->pgsql_meta_data()->createCommandBuilder('address');

+		$where = 'phone is NULL';

+		$delete = $builder->createDeleteCommand($where);

+		$sql = 'DELETE FROM public.address WHERE phone is NULL';

+		$this->assertEqual($sql, $delete->Text);

+	}

+

+	function test_select_limit()

+	{

+		$meta = $this->pgsql_meta_data();

+		$builder = $meta->createCommandBuilder('address');

+		$query = 'SELECT * FROM '.$meta->getTableInfo('address')->getTableFullName();

+

+		$limit = $builder->createLimitCondition($query, 1);

+		$expect = $query.' LIMIT 1';

+		$this->assertEqual($expect, $limit);

+

+		$limit = $builder->createLimitCondition($query, -1, 10);

+		$expect = $query.' OFFSET 10';

+		$this->assertEqual($expect, $limit);

+

+		$limit = $builder->createLimitCondition($query, 2, 3);

+		$expect = $query.' LIMIT 2 OFFSET 3';

+		$this->assertEqual($expect, $limit);

+	}

+}

+
+?>
\ No newline at end of file
diff --git a/tests/simple_unit/DbCommon/MysqlColumnTest.php b/tests/simple_unit/DbCommon/MysqlColumnTest.php
new file mode 100644
index 00000000..d8bb8194
--- /dev/null
+++ b/tests/simple_unit/DbCommon/MysqlColumnTest.php
@@ -0,0 +1,270 @@
+<?php
+

+Prado::using('System.Data.*');

+Prado::using('System.Data.Common.Mysql.TMysqlMetaData');

+

+class MysqlColumnTest extends UnitTestCase

+{

+	function create_meta_data()

+	{

+		$conn = new TDbConnection('mysql:host=localhost;dbname=tests', 'test','test');

+		return new TMysqlMetaData($conn);

+	}

+

+	function test_columns()

+	{

+		$table = $this->create_meta_data()->getTableInfo('table1');

+		$this->assertEqual(count($table->getColumns()), 18);

+

+		$columns['id'] = array(

+			'ColumnName'       => '`id`',

+			'ColumnSize'       => 10,

+			'ColumnIndex'      => 0,

+			'DbType'           => 'int unsigned',

+			'AllowNull'        => false,

+			'DefaultValue'     => TDbTableColumn::UNDEFINED_VALUE,

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => true,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+			'AutoIncrement'    => true,

+		);

+

+		$columns['name'] = array(

+			'ColumnName'       => '`name`',

+			'ColumnSize'       => 45,

+			'ColumnIndex'      => 1,

+			'DbType'           => 'varchar',

+			'AllowNull'        => false,

+			'DefaultValue'     => TDbTableColumn::UNDEFINED_VALUE,

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => true,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+			'AutoIncrement'    => false,

+		);

+

+		$columns['field1'] = array(

+			'ColumnName'       => '`field1`',

+			'ColumnSize'       => 4,

+			'ColumnIndex'      => 2,

+			'DbType'           => 'tinyint',

+			'AllowNull'        => false,

+			'DefaultValue'     => TDbTableColumn::UNDEFINED_VALUE,

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+			'AutoIncrement'    => false,

+		);

+

+		$columns['field2_text'] = array(

+			'ColumnName'       => '`field2_text`',

+			'ColumnSize'       => null,

+			'ColumnIndex'      => 3,

+			'DbType'           => 'text',

+			'AllowNull'        => true,

+			'DefaultValue'     => TDbTableColumn::UNDEFINED_VALUE,

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+			'AutoIncrement'    => false,

+		);

+

+		$columns['field3_date'] = array(

+			'ColumnName'       => '`field3_date`',

+			'ColumnSize'       => null,

+			'ColumnIndex'      => 4,

+			'DbType'           => 'date',

+			'AllowNull'        => true,

+			'DefaultValue'     => '2007-02-25',

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+			'AutoIncrement'    => false,

+		);

+

+		$columns['field4_float'] = array(

+			'ColumnName'       => '`field4_float`',

+			'ColumnSize'       => null,

+			'ColumnIndex'      => 5,

+			'DbType'           => 'float',

+			'AllowNull'        => false,

+			'DefaultValue'     => 10,

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+			'AutoIncrement'    => false,

+		);

+

+		$columns['field5_float'] = array(

+			'ColumnName'       => '`field5_float`',

+			'ColumnSize'       => null,

+			'ColumnIndex'      => 6,

+			'DbType'           => 'float',

+			'AllowNull'        => false,

+			'DefaultValue'     => TDbTableColumn::UNDEFINED_VALUE,

+			'NumericPrecision' => 5,

+			'NumericScale'     => 4,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+			'AutoIncrement'    => false,

+		);

+

+		$columns['field6_double'] = array(

+			'ColumnName'       => '`field6_double`',

+			'ColumnSize'       => null,

+			'ColumnIndex'      => 7,

+			'DbType'           => 'double',

+			'AllowNull'        => false,

+			'DefaultValue'     => TDbTableColumn::UNDEFINED_VALUE,

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+			'AutoIncrement'    => false,

+		);

+

+		$columns['field7_datetime'] = array(

+			'ColumnName'       => '`field7_datetime`',

+			'ColumnSize'       => null,

+			'ColumnIndex'      => 8,

+			'DbType'           => 'datetime',

+			'AllowNull'        => false,

+			'DefaultValue'     => TDbTableColumn::UNDEFINED_VALUE,

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+			'AutoIncrement'    => false,

+		);

+

+		$columns['field8_timestamp'] = array(

+			'ColumnName'       => '`field8_timestamp`',

+			'ColumnSize'       => null,

+			'ColumnIndex'      => 9,

+			'DbType'           => 'timestamp',

+			'AllowNull'        => true,

+			'DefaultValue'     => 'CURRENT_TIMESTAMP',

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+			'AutoIncrement'    => false,

+		);

+

+		$columns['field9_time'] = array(

+			'ColumnName'       => '`field9_time`',

+			'ColumnSize'       => null,

+			'ColumnIndex'      => 10,

+			'DbType'           => 'time',

+			'AllowNull'        => false,

+			'DefaultValue'     => TDbTableColumn::UNDEFINED_VALUE,

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+			'AutoIncrement'    => false,

+		);

+

+		$columns['field10_year'] = array(

+			'ColumnName'       => '`field10_year`',

+			'ColumnSize'       => 4,

+			'ColumnIndex'      => 11,

+			'DbType'           => 'year',

+			'AllowNull'        => false,

+			'DefaultValue'     => TDbTableColumn::UNDEFINED_VALUE,

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+			'AutoIncrement'    => false,

+		);

+

+		$columns['field11_enum'] = array(

+			'ColumnName'       => '`field11_enum`',

+			'ColumnSize'       => null,

+			'ColumnIndex'      => 12,

+			'DbType'           => 'enum',

+			'AllowNull'        => false,

+			'DefaultValue'     => 'one',

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+			'AutoIncrement'    => false,

+			'DbTypeValues'     => array('one', 'two', 'three'),

+		);

+

+		$columns['field12_SET'] = array(

+			'ColumnName'       => '`field12_SET`',

+			'ColumnSize'       => null,

+			'ColumnIndex'      => 13,

+			'DbType'           => 'set',

+			'AllowNull'        => false,

+			'DefaultValue'     => TDbTableColumn::UNDEFINED_VALUE,

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+			'AutoIncrement'    => false,

+			'DbTypeValues'     => array('blue', 'red', 'green'),

+		);

+

+		$this->assertColumn($columns, $table);

+

+		$this->assertNull($table->getSchemaName());

+		$this->assertEqual('table1', $table->getTableName());

+		$this->assertEqual(array('id', 'name'), $table->getPrimaryKeys());

+		$this->assertEqual(array('fk3'), $table->getUniqueKeys());

+	}

+

+	function assertColumn($columns, $table)

+	{

+		foreach($columns as $id=>$asserts)

+		{

+			$column = $table->Columns[$id];

+			foreach($asserts as $property=>$assert)

+			{

+				$ofAssert= var_export($assert,true);

+				$value = $column->{$property};

+				$ofValue = var_export($value, true);

+				$this->assertEqual($value, $assert,

+					"Column [{$id}] {$property} value {$ofValue} did not match {$ofAssert}");

+			}

+		}

+	}

+}

+
+?>
\ No newline at end of file
diff --git a/tests/simple_unit/DbCommon/PgsqlColumnTest.php b/tests/simple_unit/DbCommon/PgsqlColumnTest.php
new file mode 100644
index 00000000..0f633725
--- /dev/null
+++ b/tests/simple_unit/DbCommon/PgsqlColumnTest.php
@@ -0,0 +1,147 @@
+<?php
+

+Prado::using('System.Data.*');

+Prado::using('System.Data.Common.Pgsql.TPgsqlMetaData');

+class PgsqlColumnTest extends UnitTestCase

+{

+	function create_meta_data()

+	{

+		$conn = new TDbConnection('pgsql:host=localhost;dbname=test', 'test','test');

+		return new TPgsqlMetaData($conn);

+	}

+

+	function test_text_column_def()

+	{

+		$table = $this->create_meta_data()->getTableInfo('public.address');

+		$this->assertEqual(count($table->getColumns()), 14);

+

+		$columns['id'] = array(

+			'ColumnName'       => '"id"',

+			'ColumnSize'       => null,

+			'ColumnIndex'      => 0,

+			'DbType'           => 'integer',

+			'AllowNull'        => false,

+			'DefaultValue'     => TDbTableColumn::UNDEFINED_VALUE,

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => true,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => 'public.address_id_seq',

+		);

+

+		$columns['username'] = array(

+			'ColumnName'       => '"username"',

+			'ColumnSize'       => 128,

+			'ColumnIndex'      => 1,

+			'DbType'           => 'character varying',

+			'AllowNull'        => false,

+			'DefaultValue'     => TDbTableColumn::UNDEFINED_VALUE,

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => false,

+			'IsUnique'         => true,

+			'SequenceName'     => null,

+		);

+

+		$columns['phone'] = array(

+			'ColumnName'       => '"phone"',

+			'ColumnSize'       => 40,

+			'ColumnIndex'      => 2,

+			'DbType'           => 'character',

+			'AllowNull'        => false,

+			'DefaultValue'     => "'hello'::bpchar",

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => false,

+			'IsUnique'         => true,

+			'SequenceName'     => null,

+		);

+

+		$columns['field1_boolean'] = array(

+			'ColumnName'       => '"field1_boolean"',

+			'ColumnSize'       => null,

+			'ColumnIndex'      => 3,

+			'DbType'           => 'boolean',

+			'AllowNull'        => false,

+			'DefaultValue'     => TDbTableColumn::UNDEFINED_VALUE,

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+		);

+

+		$columns['field4_integer'] = array(

+			'ColumnName'       => '"field4_integer"',

+			'ColumnSize'       => null,

+			'ColumnIndex'      => 6,

+			'DbType'           => 'integer',

+			'AllowNull'        => false,

+			'DefaultValue'     => "1",

+			'NumericPrecision' => null,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => true,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+		);

+

+		$columns['field7_timestamp'] = array(

+			'ColumnName'       => '"field7_timestamp"',

+			'ColumnSize'       => 2,

+			'ColumnIndex'      => 9,

+			'DbType'           => 'timestamp without time zone',

+			'AllowNull'        => false,

+			'DefaultValue'     => TDbTableColumn::UNDEFINED_VALUE,

+			'NumericPrecision' => 6,

+			'NumericScale'     => null,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+		);

+

+		$columns['field9_numeric'] = array(

+			'ColumnName'       => '"field9_numeric"',

+			'ColumnSize'       => 393220,

+			'ColumnIndex'      => 11,

+			'DbType'           => 'numeric',

+			'AllowNull'        => false,

+			'DefaultValue'     => TDbTableColumn::UNDEFINED_VALUE,

+			'NumericPrecision' => 6,

+			'NumericScale'     => 4,

+			'IsPrimaryKey'     => false,

+			'IsForeignKey'     => false,

+			'IsUnique'         => false,

+			'SequenceName'     => null,

+		);

+		$this->assertColumn($columns, $table);

+

+		$this->assertEqual('public', $table->getSchemaName());

+		$this->assertEqual('address', $table->getTableName());

+		$this->assertEqual(array('id'), $table->getPrimaryKeys());

+		$this->assertEqual(array('username', 'phone'), $table->getUniqueKeys());

+	}

+

+	function assertColumn($columns, $table)

+	{

+		foreach($columns as $id=>$asserts)

+		{

+			$column = $table->Columns[$id];

+			foreach($asserts as $property=>$assert)

+			{

+				$ofAssert= var_export($assert,true);

+				$value = $column->{$property};

+				$ofValue = var_export($value, true);

+				$this->assertEqual($value, $assert,

+					"Column [{$id}] {$property} value {$ofValue} did not match {$ofAssert}");

+			}

+		}

+	}

+}

+
+?>
\ No newline at end of file