MySQL transport support. Closes #3

Author: bazilio91

.travis.yml

@@ -19,6 +19,7 @@ matrix:
 services:
   - redis-server
   - rabbitmq
+  - mysql
 
 # faster builds on new travis setup not using sudo
 sudo: false
@@ -37,6 +38,7 @@ install:
   - travis_retry composer install --prefer-dist --no-interaction
 
 before_script:
+  - mysql -e 'create database `async-test`;'
 
 script:
   - vendor/bin/codecept run

CHANGELOG.md

@@ -1,3 +1,7 @@
+0.2.0
+=====
+- Mysql transport support
+
 0.0.5
 =====
 - [Fix first message send in AMQP provider + travis ci](https://github.com/bazilio91/yii2-async/commit/961fc05bf4776509074c062f944124fe090e1b6f)

Dockerfile

@@ -1,9 +1,8 @@
-FROM php:cli
+FROM php:5.6-cli
 
-RUN apt-get update && apt-get install -y redis-server \
-    rabbitmq-server librabbitmq-dev
+RUN apt-get update && apt-get install -y librabbitmq-dev
 RUN php -r "readfile('https://getcomposer.org/installer');" | php
-RUN docker-php-ext-install pcntl shmop mbstring
+RUN docker-php-ext-install pcntl shmop mbstring pdo_mysql
 RUN pecl install amqp && echo "extension=amqp.so" >> /usr/local/etc/php/conf.d/amqp.ini
 
 ADD . /var/code

README.md

@@ -19,6 +19,7 @@ Install: `php composer.phar require bazilio/yii2-async:dev-master`
 #####Using with AMQP:
 `php composer.phar require pdezwart/php-amqp:dev-master`
 
+main.php:
 ```php
 'components' => [
     'async' => [
@@ -39,6 +40,7 @@ Install: `php composer.phar require bazilio/yii2-async:dev-master`
 #####Using with Redis:
 `php composer.phar require yiisoft/yii2-redis:*`
 
+main.php:
 ```php
 'components' => [
     'redis' => [
@@ -58,7 +60,32 @@ Install: `php composer.phar require bazilio/yii2-async:dev-master`
 ]
 ```
 
+#####Using with MySQL (probably any sql, but tested only with mysql)
 
+main.php:
+```php
+'components' => [
+    'db' => [
+        'class' => 'yii\db\Connection',
+        'dsn' => 'mysql:host=localhost;dbname=yii2advenced',
+        'username' => 'root',
+        'password' => '',
+        'charset' => 'utf8',
+    ],
+    'async' => [
+        'class' => 'bazilio\async\AsyncComponent',
+        'transportClass' => 'bazilio\async\transports\AsyncMysqlTransport',
+        'transportConfig' => [
+            'connection' => 'db',
+        ]
+    ]
+]
+```
+
+Apply migrations:
+```php
+./yii migrate/up --migrationPath=@vendor/bazilio/yii2-async/migrations
+```
 
 #####Usage:
 

docker-compose.yml

@@ -0,0 +1,18 @@
+yii2-async:
+  build: .
+  links:
+    - mysql
+    - redis
+    - rabbitmq
+
+mysql:
+  image: mysql
+  environment:
+    MYSQL_ALLOW_EMPTY_PASSWORD: "yes"
+    MYSQL_DATABASE: "async-test"
+
+redis:
+  image: redis
+
+rabbitmq:
+  image: rabbitmq

migrations/m160401_090723_async.php

@@ -0,0 +1,29 @@
+<?php
+
+use yii\db\Migration;
+
+class m160401_090723_async extends Migration
+{
+    public function up()
+    {
+        $this->createTable(
+            '{{%async}}',
+            [
+                'id' => 'pk',
+                'data' => 'longblob',
+                'status' => 'int(1) UNSIGNED DEFAULT 0',
+                'queue' => 'varchar(255) NOT NULL'
+            ]
+        );
+
+        $this->createIndex('queue', '{{%async}}', 'queue');
+        $this->createIndex('queue_status', '{{%async}}', ['queue', 'status']);
+    }
+
+    public function down()
+    {
+        $this->dropIndex('queue', '{{%async}}');
+        $this->dropIndex('queue_status', '{{%async}}');
+        $this->dropTable('{{%async}}');
+    }
+}

test.sh

@@ -3,5 +3,5 @@ set -x
 #docker rmi yii2-async
 set -e
 
-docker build -t yii2-async .
-docker run --rm yii2-async
+docker-compose build yii2-async
+docker-compose run --rm yii2-async

tests/docker-test.sh

@@ -3,11 +3,6 @@ set -e
 set -x
 cd /var/code
 
-redis-server &
-rabbitmq-server &
-
-sleep 5
-
 /composer.phar install
 
 vendor/bin/codecept run

tests/unit/BaseTestClass.php

@@ -222,8 +222,8 @@ public function testSubscribe()
     }
 
     public function testConsoleCommandDaemon() {
-        if (get_called_class() == 'bazilio\async\tests\unit\AmqpTest') {
-            $this->markTestSkipped('No support for AMQP yet');
+        if (get_called_class() !== 'bazilio\async\tests\unit\RedisTest') {
+            $this->markTestSkipped('No support for this transport yet');
             return;
         }
 

tests/unit/MysqlTest.php

@@ -0,0 +1,28 @@
+<?php
+namespace bazilio\async\tests\unit;
+
+class MysqlTest extends BaseTestClass
+{
+    public $appConfig = '@tests/unit/_config.mysql.php';
+
+    protected static $migrated = false;
+
+    public static function migrate()
+    {
+        if (self::$migrated) {
+            return;
+        }
+
+        $migrateController = new \yii\console\controllers\MigrateController('migrate', \Yii::$app);
+        $migrateController->migrationPath = '@tests/../migrations';
+        $migrateController->runAction('up', ['interactive' => 0]);
+
+        self::$migrated = true;
+    }
+
+    public function loadFixtures($fixtures = null)
+    {
+        $this->migrate();
+        parent::loadFixtures($fixtures);
+    }
+}