Add ability to add table specific 'where' conditions

Author: Ashley Hindle

README.md

@@ -104,6 +104,19 @@ $dumper->setTransformColumnValueHook(function ($tableName, $colName, $colValue)
 $dumper->start('storage/work/dump.sql');
 ```
 
+## Table specific export conditions
+You can register table specific 'where' clauses to limit data on a per table basis.  These override the default `where` dump setting:
+
+```php
+$dumper = new IMysqldump\Mysqldump('mysql:host=localhost;dbname=testdb', 'username', 'password');
+
+$dumper->setTableWheres(array(
+    'users' => 'date_registered > NOW() - INTERVAL 3 MONTH AND deleted=0',
+    'logs' => 'date_logged > NOW() - INTERVAL 1 DAY',
+    'posts' => 'isLive=1'
+));
+```
+
 ## Constructor and default parameters
 ```php
 /**

composer.json

@@ -17,7 +17,8 @@
         "php": ">=5.3.0"
     },
     "require-dev": {
-        "squizlabs/php_codesniffer": "1.*"
+        "squizlabs/php_codesniffer": "1.*",
+        "phpunit/phpunit": "4.8.36"
     },
     "autoload": {
         "psr-4": {"Ifsnop\\": "src/Ifsnop/"}

phpunit.xml

@@ -0,0 +1,21 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<phpunit xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:noNamespaceSchemaLocation="https://schema.phpunit.de/5.7/phpunit.xsd"
+         bootstrap="vendor/autoload.php"
+         backupGlobals="false"
+         beStrictAboutCoversAnnotation="true"
+         beStrictAboutOutputDuringTests="true"
+         beStrictAboutTestsThatDoNotTestAnything="true"
+         beStrictAboutTodoAnnotatedTests="true"
+         colors="true"
+         verbose="true">
+    <testsuite name="default">
+        <directory suffix="Test.php">unit-tests</directory>
+    </testsuite>
+
+    <filter>
+        <whitelist processUncoveredFilesFromWhitelist="true">
+            <directory suffix=".php">src</directory>
+        </whitelist>
+    </filter>
+</phpunit>

src/Ifsnop/Mysqldump/Mysqldump.php

@@ -98,6 +98,14 @@ class Mysqldump
      */
     private $dsnArray = array();
 
+    /**
+     * Keyed on table name, with the value as the conditions
+     * e.g. - 'users' => 'date_registered > NOW() - INTERVAL 6 MONTH'
+     *
+     * @var array
+     */
+    private $tableWheres = array();
+
     /**
      * Constructor of Mysqldump. Note that in the case of an SQLite database
      * connection, the filename must be in the $db parameter.
@@ -223,6 +231,33 @@ public static function array_replace_recursive($array1, $array2)
         return $array1;
     }
 
+    /**
+     * Keyed by table name, with the value as the conditions:
+     * e.g. 'users' => 'date_registered > NOW() - INTERVAL 6 MONTH AND deleted=0'
+     *
+     * @param array $tableWheres
+     */
+    public function setTableWheres(array $tableWheres)
+    {
+        $this->tableWheres = $tableWheres;
+    }
+
+    /**
+     * @param $tableName
+     *
+     * @return bool|mixed
+     */
+    public function getTableWhere($tableName)
+    {
+        if (!empty($this->tableWheres[$tableName])) {
+            return $this->tableWheres[$tableName];
+        } elseif ($this->dumpSettings['where']) {
+            return $this->dumpSettings['where'];
+        }
+
+        return false;
+    }
+
     /**
      * Parse DSN string and extract dbname value
      * Several examples of a DSN string
@@ -977,9 +1012,13 @@ private function listValues($tableName)
 
         $stmt = "SELECT ".implode(",", $colStmt)." FROM `$tableName`";
 
-        if ($this->dumpSettings['where']) {
-            $stmt .= " WHERE {$this->dumpSettings['where']}";
+        // Table specific conditions override the default 'where'
+        $condition = $this->getTableWhere($tableName);
+
+        if ($condition) {
+            $stmt .= " WHERE {$condition}";
         }
+
         $resultSet = $this->dbHandler->query($stmt);
         $resultSet->setFetchMode(PDO::FETCH_ASSOC);
 

unit-tests/MysqldumpTest.php

@@ -0,0 +1,31 @@
+<?php
+
+use Ifsnop\Mysqldump\Mysqldump;
+
+class MysqldumpTest extends PHPUnit_Framework_TestCase
+{
+
+    /** @test */
+    public function tableSpecificWhereConditionsWork()
+    {
+        $dump = new Mysqldump('mysql:host=localhost;dbname=test', 'testing', 'testing', array(
+            'where' => 'defaultWhere'
+        ));
+
+        $dump->setTableWheres(array(
+            'users' => 'date_registered > NOW() - INTERVAL 3 MONTH AND is_deleted=0',
+            'logs' => 'date_registered > NOW() - INTERVAL 1 DAY',
+            'posts' => 'active=1'
+        ));
+
+        $this->assertEquals(
+            'date_registered > NOW() - INTERVAL 3 MONTH AND is_deleted=0',
+            $dump->getTableWhere('users')
+        );
+
+        $this->assertEquals(
+            'defaultWhere',
+            $dump->getTableWhere('non_overriden_table')
+        );
+    }
+}