Added port to database connections

Author: marcocesarato

README.md

@@ -1,7 +1,7 @@
 # PHP Database Web API
 ![](cover.png)
 
-**Version:** 0.6.127 beta
+**Version:** 0.6.128 beta
 
 **Github:** https://github.com/marcocesarato/Database-Web-API
 

includes/classes/API.php

@@ -291,7 +291,6 @@ public function setDatabase($db = null) {
 	 * Establish a database connection
 	 * @param string $db the database slug
 	 * @return object the PDO object
-	 * @todo support port #s and test on each database
 	 */
 	public function &connect($db = null) {
 
@@ -308,24 +307,24 @@ public function &connect($db = null) {
 
 		try {
 			if($db->type == 'mysql') {
-				$dbh = new PDO("mysql:host={$db->server};dbname={$db->name}", $db->username, $db->password);
+				$dbh = new PDO("mysql:host={$db->server};port={$db->port};dbname={$db->name}", $db->username, $db->password);
 			} elseif($db->type == 'pgsql') {
-				$dbh = new PDO("pgsql:host={$db->server};dbname={$db->name}", $db->username, $db->password);
+				$dbh = new PDO("pgsql:host={$db->server};port={$db->port};dbname={$db->name}", $db->username, $db->password);
 			} elseif($db->type == 'mssql') {
-				$dbh = new PDO("sqlsrv:Server={$db->server};Database={$db->name}", $db->username, $db->password);
+				$dbh = new PDO("sqlsrv:Server={$db->server},{$db->port};Database={$db->name}", $db->username, $db->password);
 			} elseif($db->type == 'sqlite') {
 				$dbh = new PDO("sqlite:/{$db->name}");
 			} elseif($db->type == 'oracle') {
 				$dbh = new PDO("oci:dbname={$db->name}");
 			} elseif($db->type == 'ibm') {
 				// May require a specified port number as per http://php.net/manual/en/ref.pdo-ibm.connection.php.
-				$dbh = new PDO("ibm:DRIVER={IBM DB2 ODBC DRIVER};DATABASE={$db->name};HOSTNAME={$db->server};PROTOCOL=TCPIP;", $db->username, $db->password);
+				$dbh = new PDO("ibm:DRIVER={IBM DB2 ODBC DRIVER};DATABASE={$db->name};PORT={$db->port};HOSTNAME={$db->server};PROTOCOL=TCPIP;", $db->username, $db->password);
 			} elseif(($db->type == 'firebird') || ($db->type == 'interbase')) {
-				$dbh = new PDO("firebird:dbname={$db->name};host={$db->server}");
+				$dbh = new PDO("firebird:dbname={$db->name};host={$db->server};port={$db->port};");
 			} elseif($db->type == '4D') {
-				$dbh = new PDO("4D:host={$db->server}", $db->username, $db->password);
+				$dbh = new PDO("4D:host={$db->server};port={$db->port};dbname={$db->name}", $db->username, $db->password);
 			} elseif($db->type == 'informix') {
-				$dbh = new PDO("informix:host={$db->server}; database={$db->name}; server={$db->server}", $db->username, $db->password);
+				$dbh = new PDO("informix:host={$db->server};port={$db->port};database={$db->name};server={$db->server}", $db->username, $db->password);
 			} else {
 				Response::error('Unknown database type.');
 			}