Prepare for #194

.travis.yml

@@ -22,7 +22,7 @@ before_install:
   - psql -c 'create database testing;' -U postgres
   - psql -U postgres -c "create extension postgis"
   # - mysql -e 'CREATE DATABASE testing;'
-  - cp tests/config.php.travis tests/config.php
+  - cp tests/Config.php.travis tests/Config.php
 
 script:
   - curl https://phar.phpunit.de/phpunit-4.8.phar -L -o phpunit.phar && chmod +x phpunit.phar

tests/config.php.dist → tests/Config.php.dist

@@ -1,6 +1,6 @@
 <?php
 
-class PHP_CRUD_API_Config
+class Config
 {
     /**
      * Configure one or more database connections as associative arrays.

tests/config.php.travis → tests/Config.php.travis

@@ -1,6 +1,6 @@
 <?php
 
-class PHP_CRUD_API_Config
+class Config
 {
     /**
      * Configure one or more database connections as associative arrays.

tests/MysqlTest.php

@@ -1,49 +1,89 @@
 <?php
 
-require_once(__DIR__ . '/tests.php');
+require_once(__DIR__ . '/Tests.php');
 
-class MysqlTest extends PHP_CRUD_API_Test
+class MysqlTest extends Tests
 {
-    public static function setUpBeforeClass()
+    /**
+     * Connects to the Database
+     *
+     * @return object Database connection
+     */
+    public function connect($config)
+    {
+        $db = mysqli_connect(
+            $config['hostname'],
+            $config['username'],
+            $config['password'],
+            $config['database']
+        );
+
+        if (mysqli_connect_errno()) {
+            die("Connect failed: ".mysqli_connect_error()."\n");
+        }
+
+        mysqli_set_charset($db,'utf8');
+
+        return $db;
+    }
+
+    /**
+     * Disconnects from the Database
+     *
+     * @return boolean Success
+     */
+    public function disconnect($db)
     {
-        self::setConfig('MySQL');
-        self::seedDatabase();
+        return mysqli_close($db);
     }
 
     /**
-     * Seeds the database for this connection
+     * Checks the version of the Database
      *
      * @return void
      */
-    public function seedDatabase()
+    public function checkVersion($db)
     {
-        if (static::$config['database']=='{{test_database}}') {
-            die("Configure database in 'config.php' before running tests.\n");
+        $major = 5;
+        $minor = 5;
+        $version = mysqli_get_server_version($db);
+        $v = array(floor($version/10000),floor($version/100));
+        if ($v[0]<$major || ($v[0]==$major && $v[1]<$minor)) {
+            die("Detected MySQL $v[0].$v[1], but only $major.$minor and up are supported\n");
         }
+    }
 
-        $fixture = __DIR__.'/data/blog_'.strtolower(static::$config['dbengine']).'.sql';
-
-        $link = mysqli_connect(
-            static::$config['hostname'],
-            static::$config['username'],
-            static::$config['password'],
-            static::$config['database']
-        );
-
-        if (mysqli_connect_errno()) {
-            die("Connect failed: ".mysqli_connect_error()."\n");
+    /**
+     * Gets the capabilities of the Database
+     *
+     * @return int Capabilites
+     */
+    public function getCapabilities($db)
+    {
+        $capabilities = 0;
+        $version = mysqli_get_server_version($db);
+        if ($version>50600) {
+            $capabilities |= self::GIS;
         }
+        return $capabilities;
+    }
 
-        mysqli_set_charset($link,'utf8');
+    /**
+     * Seeds the database for this connection
+     *
+     * @return void
+     */
+    public function seedDatabase($db, $capabilities)
+    {
+        $fixture = __DIR__.'/data/blog_mysql.sql';
 
         $i=0;
-        if (mysqli_multi_query($link, file_get_contents($fixture))) {
-            do { $i++; mysqli_next_result($link); } while (mysqli_more_results($link));
-        }
-        if (mysqli_errno($link)) {
-            die("Loading '$fixture' failed on statemement #$i with error:\n".mysqli_error($link)."\n");
+        if (mysqli_multi_query($db, file_get_contents($fixture))) {
+            do { $i++; mysqli_next_result($db); } while (mysqli_more_results($db));
         }
 
-        mysqli_close($link);
+        if (mysqli_errno($db)) {
+            die("Loading '$fixture' failed on statemement #$i with error:\n".mysqli_error($db)."\n");
+        }
     }
 }

tests/PostgresqlTest.php

@@ -1,41 +1,77 @@
 <?php
 
-require_once(__DIR__ . '/tests.php');
+require_once(__DIR__ . '/Tests.php');
 
-class PostgresqlTest extends PHP_CRUD_API_Test
+class PostgresqlTest extends Tests
 {
-    public static function setUpBeforeClass()
+    /**
+     * Connects to the Database
+     *
+     * @return object Database connection
+     */
+    public function connect($config)
     {
-        static::setConfig('PostgreSQL');
-        self::seedDatabase();
+        $e = function ($v) { return str_replace(array('\'','\\'),array('\\\'','\\\\'),$v); };
+        $hostname = $e($config['hostname']);
+        $database = $e($config['database']);
+        $username = $e($config['username']);
+        $password = $e($config['password']);
+        $connectionString = "host='$hostname' dbname='$database' user='$username' password='$password' options='--client_encoding=UTF8'";
+
+        return pg_connect($connectionString);
     }
 
     /**
-     * Seeds the database for this connection
+     * Disconnects from the Database
+     *
+     * @return boolean Success
+     */
+    public function disconnect($db)
+    {
+        return pg_close($db);
+    }
+
+    /**
+     * Checks the version of the Database
      *
      * @return void
      */
-    public function seedDatabase()
+    public function checkVersion($db)
     {
-        if (static::$config['database']=='{{test_database}}') {
-            die("Configure database in 'config.php' before running tests.\n");
+        $major = 9;
+        $minor = 1;
+        $version = pg_version();
+        $v = explode('.',$version['server']);
+        if ($v[0]<$major || ($v[0]==$major && $v[1]<$minor)) {
+            die("Detected PostgreSQL $v[0].$v[1], but only $major.$minor and up are supported\n");
         }
+    }
 
-        $fixture = __DIR__.'/data/blog_'.strtolower(static::$config['dbengine']).'.sql';
-
-        $e = function ($v) { return str_replace(array('\'','\\'),array('\\\'','\\\\'),$v); };
-        $hostname = $e(static::$config['hostname']);
-        $database = $e(static::$config['database']);
-        $username = $e(static::$config['username']);
-        $password = $e(static::$config['password']);
-        $conn_string = "host='$hostname' dbname='$database' user='$username' password='$password' options='--client_encoding=UTF8'";
-
-        $db = pg_connect($conn_string);
-
-        if (!$db) {
-            die("Connect failed: ". pg_last_error());
+    /**
+     * Gets the capabilities of the Database
+     *
+     * @return int Capabilites
+     */
+    public function getCapabilities($db)
+    {
+        $capabilities = 0;
+        $extensions = pg_fetch_all(pg_query($db, "SELECT * FROM pg_extension;"));
+        foreach ($extensions as $extension) {
+          if ($extension['extname'] === 'postgis') {
+            $capabilities |= self::GIS;
+          }
         }
+        return $capabilities;
+    }
 
+    /**
+     * Seeds the database for this connection
+     *
+     * @return void
+     */
+    public function seedDatabase($db,$capabilities)
+    {
+        $fixture = __DIR__.'/data/blog_postgresql.sql';
         $queries = preg_split('/;\s*\n/', file_get_contents($fixture));
         array_pop($queries);
 
@@ -45,7 +81,5 @@ class PostgresqlTest extends PHP_CRUD_API_Test
                 die("Loading '$fixture' failed on statemement #$i with error:\n".print_r( pg_last_error($db), true)."\n");
             }
         }
-
-        pg_close($db);
     }
 }

tests/SqlServerTest.php

@@ -1,45 +1,77 @@
 <?php
 
-require_once(__DIR__ . '/tests.php');
+require_once(__DIR__ . '/Tests.php');
 
-class SqlServerTest extends PHP_CRUD_API_Test
+class SqlServerTest extends Tests
 {
-    public static function setUpBeforeClass()
+    /**
+     * Connects to the Database
+     *
+     * @return object Database connection
+     */
+    public function connect($config)
     {
-        self::setConfig('SQLServer');
+        $connectionInfo = array(
+            'UID' => $config['username'],
+            'PWD' => $config['password'],
+            'Database' => $config['database'],
+            'CharacterSet' => 'UTF-8',
+        );
+
+        $db = sqlsrv_connect($config['hostname'], $dbectionInfo);
 
-        if (static::$config['database']=='{{test_database}}') {
-            die("Configure database in 'config.php' before running tests.\n");
+        if (!$db) {
+            die("Connect failed: ".print_r( sqlsrv_errors(), true));
         }
 
-        self::seedDatabase();
+        return $db;
     }
 
     /**
-     * Seeds the database for this connection
+     * Disconnects from the Database
+     *
+     * @return boolean Success
+     */
+    public function disconnect($db)
+    {
+        return sqlsrv_close($db);
+    }
+
+    /**
+     * Checks the version of the Database
      *
      * @return void
      */
-    public function seedDatabase()
+    public function checkVersion($db)
     {
-        if (static::$config['database']=='{{test_database}}') {
-            die("Configure database in 'config.php' before running tests.\n");
+        $major = 5;
+        $minor = 5;
+        $version = sqlsrv_server_info($db);
+        $v = explode('.',$version['SQLServerVersion']);
+        if ($v[0]<$major || ($v[0]==$major && $v[1]<$minor)) {
+            die("Detected MySQL $v[0].$v[1], but only $major.$minor and up are supported\n");
         }
+    }
 
-        $fixture = __DIR__.'/data/blog_'.strtolower(static::$config['dbengine']).'.sql';
-
-        $connectionInfo = array(
-            'UID' => static::$config['username'],
-            'PWD' => static::$config['password'],
-            'Database' => static::$config['database'],
-            'CharacterSet' => 'UTF-8',
-        );
+    /**
+     * Gets the capabilities of the Database
+     *
+     * @return int Capabilites
+     */
+    public function getCapabilities($db)
+    {
+        return self::GIS;
+    }
 
-        $conn = sqlsrv_connect(static::$config['hostname'], $connectionInfo);
 
-        if (!$conn) {
-            die("Connect failed: ".print_r( sqlsrv_errors(), true));
-        }
+    /**
+     * Seeds the database for this connection
+     *
+     * @return void
+     */
+    public function seedDatabase($db, $capabilities)
+    {
+        $fixture = __DIR__.'/data/blog_sqlserver.sql';
 
         $queries = preg_split('/\n\s*GO\s*\n/', file_get_contents($fixture));
         array_pop($queries);
@@ -50,7 +82,5 @@ class SqlServerTest extends PHP_CRUD_API_Test
                 die("Loading '$fixture' failed on statemement #$i with error:\n".print_r( sqlsrv_errors(), true)."\n");
             }
         }
-
-        sqlsrv_close($conn);
     }
 }

tests/SqliteTest.php

@@ -1,35 +1,71 @@
 <?php
 
-require_once(__DIR__ . '/tests.php');
+require_once(__DIR__ . '/Tests.php');
 
-class SqliteTest extends PHP_CRUD_API_Test
+class SqliteTest extends Tests
 {
-    public static function setUpBeforeClass()
+    /**
+     * Connects to the Database
+     *
+     * @return object Database connection
+     */
+    public function connect($config)
     {
-        self::setConfig('SQLite');
-        self::seedDatabase();
+        $db = new SQLite3($config['database']);
+
+        if (!$db) {
+            die("Could not open '$database' SQLite database: ".SQLite3::lastErrorMsg().' ('.SQLite3::lastErrorCode().")\n");
+        }
+
+        return $db;
     }
 
     /**
-     * Seeds the database for this connection
+     * Disconnects from the Database
+     *
+     * @return boolean Success
+     */
+    public function disconnect($db)
+    {
+        return $db->close();
+    }
+
+    /**
+     * Checks the version of the Database
      *
      * @return void
      */
-    public function seedDatabase()
+    public function checkVersion($db)
     {
-        if (static::$config['database']=='{{test_database}}') {
-            die("Configure database in 'config.php' before running tests.\n");
+        $major = 3;
+        $minor = 0;
+        $version = SQLite3::version();
+        $v = explode('.',$version['versionString']);
+        if ($v[0]<$major || ($v[0]==$major && $v[1]<$minor)) {
+            die("Detected SQLite $v[0].$v[1], but only $major.$minor and up are supported\n");
         }
+    }
 
-        $database = static::$config['database'];
-
-        $fixture = __DIR__.'/data/blog_'.strtolower(static::$config['dbengine']).'.sql';
-
-        $db = new SQLite3($database);
+    /**
+     * Gets the capabilities of the Database
+     *
+     * @return int Capabilites
+     */
+    public function getCapabilities($db)
+    {
+        $capabilities = 0;
+        
+        return $capabilities;
+    }
 
-        if (!$db) {
-            die("Could not open '$database' SQLite database: ".SQLite3::lastErrorMsg().' ('.SQLite3::lastErrorCode().")\n");
-        }
+    /**
+     * Seeds the database for this connection
+     *
+     * @return void
+     */
+    public function seedDatabase($db, $capabilities)
+    {
+        $fixture = __DIR__.'/data/blog_sqlite.sql';
 
         $queries = preg_split('/;\s*\n/', file_get_contents($fixture));
         array_pop($queries);
@@ -40,7 +76,5 @@ class SqliteTest extends PHP_CRUD_API_Test
                 die("Loading '$fixture' failed on statemement #$i with error:\n".$db->lastErrorCode().': '.$db->lastErrorMsg()."\n");
             }
         }
-
-        $db->close();
     }
-}
+}

tests/TestBase.php

@@ -0,0 +1,46 @@
+<?php
+
+require_once(__DIR__ . '/Config.php');
+
+abstract class TestBase extends PHPUnit_Framework_TestCase
+{
+    protected function getConfig()
+    {
+        $dbengine = strtolower(substr(get_called_class(),0,-4));
+        foreach (Config::$config as $database) {
+            if (strtolower($database['dbengine']) == $dbengine) {
+                if ($database['database']!='{{test_database}}') {
+                    return $database;
+                }
+            }
+        }
+        self::markTestSkipped("Configuration for '{$dbengine}' in 'Config.php' not found.");
+        return false;
+    }
+
+    public static function setUpBeforeClass()
+    {
+        $config = self::getConfig();
+        $db = static::connect($config);
+        static::checkVersion($db);
+        $capabilities = static::getCapabilities($db);
+        static::seedDatabase($db,$capabilities);
+        static::disconnect($db);
+        // set params for test
+        static::$config = $config;
+        static::$capabilities = $capabilities;
+    }
+
+    public static $config;
+    public static $capabilities;
+
+    const GIS = 1;
+    const JSON = 2;
+
+    public abstract function checkVersion($db);
+
+    public abstract function getCapabilities($db);
+
+    public abstract function seedDatabase($db,$capabilities);
+
+}

tests/tests.php → tests/Tests.php

@@ -1,7 +1,7 @@
 <?php
 
-require __DIR__.'/config.php';
-require __DIR__.'/../api.php';
+require_once(__DIR__ . '/TestBase.php');
+require_once(__DIR__ . '/../api.php');
 
 class API
 {
@@ -113,24 +113,8 @@ class API
     }
 }
 
-abstract class PHP_CRUD_API_Test extends PHPUnit_Framework_TestCase
+abstract class Tests extends TestBase
 {
-    public static $config;
-
-    public abstract function seedDatabase();
-
-    protected function setConfig($dbengine = '')
-    {
-        foreach (PHP_CRUD_API_Config::$config as $database) {
-            if ($database['dbengine'] == $dbengine) {
-                static::$config = $database;
-                return true;
-            }
-        }
-        self::markTestSkipped("Configuration for {$dbengine} database not found.");
-        return false;
-    }
-
     public function testListPosts()
     {
         $test = new API($this, static::$config);