From 2f4dfd9d9e4d254492cd98592f1093e4ec2787c1 Mon Sep 17 00:00:00 2001
From: Timothy Warren <tim@timshomepage.net>
Date: Thu, 15 Mar 2012 15:46:04 -0400
Subject: [PATCH] Added mysql tests

---
 .gitignore                    |   1 +
 query_builder.php             |   2 +-
 tests/databases/mysql-qb.php  | 224 +++++++++++++++++++++++++++++++++-
 tests/databases/mysql.php     | 149 +++++++++++++++++++++-
 tests/test_dbs/FB_TEST_DB.FDB | Bin 802816 -> 802816 bytes
 tests/test_dbs/test_sqlite.db | Bin 3072 -> 3072 bytes
 6 files changed, 371 insertions(+), 5 deletions(-)
 create mode 100644 .gitignore

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..44d7ee7
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1 @@
+test_config.json
diff --git a/query_builder.php b/query_builder.php
index 1953d22..e3b6fe1 100644
--- a/query_builder.php
+++ b/query_builder.php
@@ -82,7 +82,7 @@ class Query_Builder {
 		switch($dbtype)
 		{
 			default:
-				$this->db = new $dbtype("host={$params->host};port={$params->port};dbname={$this->database}", $params->user, $params->pass);
+				$this->db = new $dbtype("host={$params->host};port={$params->port};dbname={$params->database}", $params->user, $params->pass);
 			break;
 
 			case "sqlite":
diff --git a/tests/databases/mysql-qb.php b/tests/databases/mysql-qb.php
index 2b6d235..c58413a 100644
--- a/tests/databases/mysql-qb.php
+++ b/tests/databases/mysql-qb.php
@@ -15,12 +15,230 @@
 class MySQLQBTest extends UnitTestCase {
 
 	function __construct()
-	{
-	
-	}
+ 	{
+ 		parent::__construct();
+ 		
+ 		// Attempt to connect, if there is a test config file
+		if (is_file("../test_config.json"))
+		{
+			$params = json_decode(file_get_contents("../test_config.json"));
+			$params = $params->mysql;
+			$params->type = "mysql";
+			
+			$this->db = new Query_Builder($params);
+			
+			echo '<hr /> MySQL Queries <hr />';		
+			
+		}
+ 	}
+
 	
 	function TestExists()
 	{
 		$this->assertTrue(in_array('mysql', pdo_drivers()));
 	}
+	
+	function TestGet()
+	{
+		if (empty($this->db))  return;
+	
+		$query = $this->db->get('create_test');
+		
+		$this->assertIsA($query, 'PDOStatement');
+	}
+	
+	function TestGetLimit()
+	{
+		if (empty($this->db))  return;
+	
+		$query = $this->db->get('create_test', 2);
+		
+		$this->assertIsA($query, 'PDOStatement');
+	}
+	
+	function TestGetLimitSkip()
+	{
+		if (empty($this->db))  return;
+	
+		$query = $this->db->get('create_test', 2, 1);
+		
+		$this->assertIsA($query, 'PDOStatement');
+	}
+
+	function TestSelectWhereGet()
+	{
+		if (empty($this->db))  return;
+	
+		$query = $this->db->select('id, key as k, val')
+			->where('id >', 1)
+			->where('id <', 900)
+			->get('create_test', 2, 1);
+
+		$this->assertIsA($query, 'PDOStatement');
+	}
+	
+	function TestSelectWhereGet2()
+	{
+		if (empty($this->db))  return;
+	
+		$query = $this->db->select('id, key as k, val')
+			->where('id !=', 1)
+			->get('create_test', 2, 1);
+
+		$this->assertIsA($query, 'PDOStatement');
+	}
+
+	function TestSelectGet()
+	{
+		if (empty($this->db))  return;
+	
+		$query = $this->db->select('id, key as k, val')
+			->get('create_test', 2, 1);
+
+		$this->assertIsA($query, 'PDOStatement');
+	}
+	
+	function TestSelectFromGet()
+	{
+		if (empty($this->db))  return;
+	
+		$query = $this->db->select('id, key as k, val')
+			->from('create_test ct')
+			->where('id >', 1)
+			->get();
+			
+		$this->assertIsA($query, 'PDOStatement');
+	}
+	
+	function TestSelectFromLimitGet()
+	{
+		if (empty($this->db))  return;
+	
+		$query = $this->db->select('id, key as k, val')
+			->from('create_test ct')
+			->where('id >', 1)
+			->limit(3)
+			->get();
+			
+		$this->assertIsA($query, 'PDOStatement');
+	}
+	
+	function TestOrderBy()
+	{
+		if (empty($this->db))  return;
+	
+		$query = $this->db->select('id, key as k, val')
+			->from('create_test')
+			->where('id >', 0)
+			->where('id <', 9000)
+			->order_by('id', 'DESC')
+			->order_by('k', 'ASC')
+			->limit(5,2)
+			->get();
+			
+		$this->assertIsA($query, 'PDOStatement');
+	}
+	
+	function TestOrderByRandom()
+	{
+		if (empty($this->db))  return;
+		
+		$query = $this->db->select('id, key as k, val')
+			->from('create_test')
+			->where('id >', 0)
+			->where('id <', 9000)
+			->order_by('id', 'rand')
+			->limit(5,2)
+			->get();
+			
+		$this->assertIsA($query, 'PDOStatement');
+	}
+	
+	function TestGroupBy()
+	{
+		if (empty($this->db))  return;
+	
+		$query = $this->db->select('id, key as k, val')
+			->from('create_test')
+			->where('id >', 0)
+			->where('id <', 9000)
+			->group_by('k')
+			->group_by('val')
+			->order_by('id', 'DESC')
+			->order_by('k', 'ASC')
+			->limit(5,2)
+			->get();
+			
+		$this->assertIsA($query, 'PDOStatement');
+	}
+	
+	function TestOrWhere()
+	{
+		if (empty($this->db))  return;
+	
+		$query = $this->db->select('id, key as k, val')
+			->from('create_test')
+			->where(' id ', 1)
+			->or_where('key >', 0)
+			->limit(2, 1)
+			->get();
+		
+		$this->assertIsA($query, 'PDOStatement');
+	}
+	
+	function TestLike()
+	{
+		if (empty($this->db))  return;
+	
+		$query = $this->db->from('create_test')
+			->like('key', 'og')
+			->get();
+			
+		$this->assertIsA($query, 'PDOStatement');
+	}
+	
+	function TestJoin()
+	{
+		if (empty($this->db))  return;
+	
+		$query = $this->db->from('create_test')
+			->join('create_join cj', 'cj.id = create_test.id')
+			->get();
+			
+		$this->assertIsA($query, 'PDOStatement');
+	}
+	
+	function TestInsert()
+	{
+		if (empty($this->db))  return;
+	
+		$query = $this->db->set('id', 4)
+			->set('key', 4)
+			->set('val', 5)
+			->insert('create_test');
+			
+		$this->assertIsA($query, 'PDOStatement');
+	}
+	
+	function TestUpdate()
+	{
+		if (empty($this->db))  return;
+	
+		$query = $this->db->set('id', 4)
+			->set('key', 'gogle')
+			->set('val', 'non-word')
+			->where('id', 4)
+			->update('create_test');
+			
+		$this->assertIsA($query, 'PDOStatement');
+	}
+	
+	function TestDelete()
+	{
+		if (empty($this->db))  return;
+	
+		$query = $this->db->where('id', 4)->delete('create_test');
+			
+		$this->assertIsA($query, 'PDOStatement');
+	}
 }
\ No newline at end of file
diff --git a/tests/databases/mysql.php b/tests/databases/mysql.php
index 1c4a01a..e1f1611 100644
--- a/tests/databases/mysql.php
+++ b/tests/databases/mysql.php
@@ -21,12 +21,159 @@ class MySQLTest extends UnitTestCase {
 
 	function __construct()
 	{
-
+		
+	}
+	
+	function setUp()
+	{
+		// Attempt to connect, if there is a test config file
+		if (is_file("../test_config.json"))
+		{
+			$params = json_decode(file_get_contents("../test_config.json"));
+			$params = $params->mysql;
+			
+			$this->db = new MySQL("host={$params->host};port={$params->port};dbname={$params->database}", $params->user, $params->pass);
+		}
+	}
+	
+	function tearDown()
+	{
+		unset($this->db);
 	}
 	
 	function TestExists()
 	{
 		$this->assertTrue(in_array('mysql', pdo_drivers()));
 	}
+	
+	function TestConnection()
+	{
+		if (empty($this->db))  return; 
+	
+		$this->assertIsA($this->db, 'MySQL');
+	}
+	
+	function TestGetTables()
+	{
+		if (empty($this->db))  return; 
+	
+		$tables = $this->db->get_tables();
+		$this->assertTrue(is_array($tables));
+	}
+	
+	function TestGetSystemTables()
+	{
+		if (empty($this->db))  return; 
+	
+		$tables = $this->db->get_system_tables();
+		
+		$this->assertTrue(is_array($tables));
+	}
+	
+	function TestCreateTransaction()
+	{
+		if (empty($this->db))  return; 
+	
+		$res = $this->db->beginTransaction();
+		$this->assertTrue($res);
+	}
+
+	function TestCreateTable()
+	{
+		if (empty($this->db))  return; 
+	
+		//Attempt to create the table
+		$sql = $this->db->sql->create_table('create_test', 
+			array(
+				'id' => 'INTEGER',
+				'key' => 'TEXT',
+				'val' => 'TEXT',
+			), 
+			array(
+				'id' => 'PRIMARY KEY'
+			)
+		);
+		$this->db->query($sql);
+		
+		//Attempt to create the table
+		$sql = $this->db->sql->create_table('create_join', 
+			array(
+				'id' => 'INTEGER',
+				'key' => 'TEXT',
+				'val' => 'TEXT',
+			), 
+			array(
+				'id' => 'PRIMARY KEY'
+			)
+		);
+		$this->db->query($sql);
+
+		//Check
+		$dbs = $this->db->get_tables();
+		//$this->assertEqual($dbs['create_test'], 'CREATE TABLE "create_test" (id INTEGER PRIMARY KEY, key TEXT , val TEXT )');
+	}
+	
+	/*function TestTruncate()
+	{
+		if (empty($this->db))  return; 
+	
+		$this->db->truncate('create_test');
+		$this->assertIsA($this->db->affected_rows(), 'int');
+	}*/
+	
+	function TestPreparedStatements()
+	{
+		if (empty($this->db))  return; 
+	
+		$sql = <<<SQL
+			INSERT INTO "create_test" ("id", "key", "val") 
+			VALUES (?,?,?)
+SQL;
+		$statement = $this->db->prepare_query($sql, array(1,"boogers", "Gross"));
+		
+		$statement->execute();
+
+	}
+	
+	function TestPrepareExecute()
+	{
+		if (empty($this->db))  return; 
+	
+		$sql = <<<SQL
+			INSERT INTO "create_test" ("id", "key", "val") 
+			VALUES (?,?,?)
+SQL;
+		$this->db->prepare_execute($sql, array(
+			2, "works", 'also?'
+		));
+	
+	}
+	
+	function TestCommitTransaction()
+	{
+		if (empty($this->db))  return; 
+	
+		$res = $this->db->beginTransaction();
+		
+		$sql = 'INSERT INTO "create_test" ("id", "key", "val") VALUES (10, 12, 14)';
+		$this->db->query($sql);
+	
+		$res = $this->db->commit();
+		$this->assertTrue($res);
+	}
+	
+	function TestRollbackTransaction()
+	{
+		if (empty($this->db))  return; 
+	
+		$res = $this->db->beginTransaction();
+		
+		$sql = 'INSERT INTO "create_test" ("id", "key", "val") VALUES (182, 96, 43)';
+		$this->db->query($sql);
+	
+		$res = $this->db->rollback();
+		$this->assertTrue($res);
+	}
+
 }
  
diff --git a/tests/test_dbs/FB_TEST_DB.FDB b/tests/test_dbs/FB_TEST_DB.FDB
index 6a52641bbd9d597278e52025e2de5a8723f0b7a9..01e68d6494b00a8b1b957a1b027e6e320a36a6f8 100755
GIT binary patch
delta 1668
zcmb7^L1+^}6o%hycAL0^IuTk+50co#)@UJ%4I&5?6;T6XG-&Y@#fpcLh%NL|B=)ce
zDX55yC@qLk1VuzkiXJ?OpeGeU5f9Q$%Ep@>dkHwR<1@pe(Co6a^JQn}oBxHKYSpP$
zonr*{WHY_cJ{YY={*b(TJpjJA01R^P8$faQhXHSs8o<C1XDI+8TCeAMvh-}@409QA
znc=dC%S@M9F6(kx)MYW3t*bHHWTd%dCG2_Y);^Y5dXTnv*>2XZWvTgeq|Z=uV|$8F
zSdF9u{1I6XhphyptgQf6KYTR@Az^L{o-LaFFl(l77Lt6rPJ78Hzg?$!a+-VcR^&qs
zdcZj$g1i#L4IttKK$fI41e_Z`%I`PC+edi3NmG2gPY1{$Uhu_C2SYO<<4njn(_T4K
zlD}V}8NOVnHt%cF{d{Lb^v?LSo97#JE-vdVm#1Dbz~`h+(>qx3lWbz3`f{x?ajAQ`
zQXZPBTt2_r@_C_76RF_ulH=tF`GzwrN4BpVtjO}D_?SoIo2M%BiKRxgEI2zpQ5k`T
zs@$@w+;=^%=p(DV&M>lCdJewGys1GkCmvR?l7G8CYX$zK3j8r7L`ESp3g4*$Klw?!
z_(hLy_)n_0(v&A}q-2Y%dfIudo4Nsz(S(eqmmNiWp+&2yXp12sG76DV_;_v69;s*#
zwP*_=6Ed2R(KO#tv^g!>T@~$4NQjI=WE9?5TeRyc+N>7sTF8WqCS)|tbQJBX7VV0P
zHXRZoqYxQ|lWU7Mp`u;VqLo7?WHce8=|V@*#<XbXq&0am+QN_22tHC4Y!z}NmK%d1
pwvUp&B+*9>mSmZKSuF{oqbj`I?!*=xd~(HhLOv;WsfAzk_-|-zKLY>&

delta 1705
zcmb7^O=uHA6vt;K*|zTUV;W2=qBSw54YAs$R;3~hC?Yl>6(lzyxd$rs;zbNS>`gEr
z%s~m%gNGtm6j~L{!9x{4P(%cK+9ZYcA}xYq4=K*f?rYa2wYXt3`A^=y-}~>|eZ^v`
zSWI1{WT=0llWZIuiUC)tb*O`oVR;h5=-qijE}#6^b0y>iaKhv#rv;VYLmf||xyQRE
zxW%c(nZ*MZ4_e%?c#FkbE#7AFZ8O{qa+;nsB4*i`{SY^gnWbFP>NjWlAvm3$Q+Yf`
zmVzY5_09_2K}G`+(i=EP+5$0Rvjj=7ZvEd279)39ymTqrWe~2nR3<~7&YCY=8%vYP
zuy|`jOsrO+=Vm#q<D6jnyFpq^X(u)CiWpgWQEP*cF^pg;sf<_2m^|g$kg<dJ<X%PZ
zQMs2dpjJx7qE=T>a(ukB&Sc{C5**%x_2H`P%-#-*wMALycN==xt*|&+hmLmD2E}r6
z$+n2qI>g%*#yQ%wb1M24pi}m4SX@|uh-#v+mmxw=iyJm%gk1wue750?=&j3NT~#<G
zuGZnY_*8`;JtC?#IHYe7O^Rp@&ZZJBm${x$qes-P$3jF*)*&j&HYDi*l`cc~sZ3oW
zBkN7=^`%3N=}=?3kV<#nsjl5q-A<>v?Y?xVF&%157xYvYaH=Eg)rHPA>G9fMJthP-
z5>O-IS6Eb*AR?x!kYqn~Cr8*1-NgMOU4y2O6(0mOLQo@QNkd}dSxr76i{8g&L6iEL
zIjQ*|s1br1A@g1*-&`kOw{Y^s2SJSx)ChU+b@I;Z<jv+z=6n#;2tkdIir2|Y*U9rO
zoILeGP&<%(0X0IVy-pr^ojly!$&?R*8l9j<$o&l`yPHoBHRa^=7&(E%$9Zw{1)LNA
wn2_1Bb592UYx=phie($(14wlX9!KhCBebLqbu)M78AgLR6E8}~9<0FVA0J0YPyhe`

diff --git a/tests/test_dbs/test_sqlite.db b/tests/test_dbs/test_sqlite.db
index af755449d764688b546f5e2ee8709975aea2a9f7..3490d13eb312e8d722dd73a5cc51e3ec6e81b08d 100644
GIT binary patch
delta 17
YcmZpWXpop7%~&*1#+k8bW5NP%0535GZU6uP

delta 17
YcmZpWXpop7%_uZc#+gxQW5NP%04b3Kt^fc4