#!/usr/bin/env php
<?php

$options = getopt('', ['dbname:', 'dbport:', 'username:', 'password:', 'host:']);

if (!isset($options['dbname'], $options['dbport'], $options['username'], $options['password'], $options['host'])) {
    print "Required parameters --dbname --dbport --username --password --host. \n";
    exit(1);
}

ob_get_level() && ob_end_flush();

$dsn = sprintf('mysql:dbname=%s;port=%s;host=%s', $options['dbname'], $options['dbport'], $options['host']);

$pdo = new \PDO($dsn, $options['username'], $options['password']);
$pdo->exec('SET NAMES utf8');

$query = 'CREATE TABLE IF NOT EXISTS `rbmq_messages` (

  `id` INT(10) UNSIGNED NOT NULL AUTO_INCREMENT,
  `exchange_name` TEXT NOT NULL,
  `routing_key` TEXT NOT NULL,
  `message_body` TEXT NOT NULL,
  `ts_created` INT(10) UNSIGNED NOT NULL,
   PRIMARY KEY  (`id`),
   KEY `ts_created` (`ts_created`)

)ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;';
$pdo->exec($query);

print "Table `rbmq_messages` created successfully.\n";