<?php
# CREATE DATABASE demo;
# CREATE USER 'demo'@'%' IDENTIFIED BY 'Demo1234';
# GRANT CREATE, DROP, INSERT, DELETE, UPDATE, SELECT ON demo.* TO 'demo'@'%';

date_default_timezone_set('Asia/Tokyo');

$opts = getopt("", array('user:', 'host:', 'port:', 'pass:'));
$ERROR = red('ERROR');
$INFO  = green('INFO');

$user = isset($opts['user']) ? $opts['user'] : 'root';
$pass = isset($opts['pass']) ? $opts['pass'] : '';

$host =  'localhost';
$port = isset($opts['port']) ? $opts['port'] : 24100;


$conn = new PDO("mysql:host=$host;port=$port", $user, $pass);
$conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

$attributes = array(
    "AUTOCOMMIT", "ERRMODE", "CASE", "CLIENT_VERSION", "CONNECTION_STATUS",
    "ORACLE_NULLS", "PERSISTENT", "SERVER_INFO", "SERVER_VERSION",
    "TIMEOUT"
);

foreach ($attributes as $val) {
  //  echo "PDO::ATTR_$val: ";
//    echo $conn->getAttribute(constant("PDO::ATTR_$val")) . "\n";
}


$conn->query("CREATE TABLE IF NOT EXISTS demo.lostcheck3 (v int PRIMARY KEY) ENGINE=InnoDB ");
$conn->query("DELETE FROM demo.lostcheck3");

$c = 0;
while (1) {
    $q = "INSERT INTO demo.lostcheck3 (v) VALUES($c);";
    try {
    $f=    $conn->query($q);
	print ( $f->errorCode() );
        printf("[$INFO] $q, Query OK\n", strftime("%Y%m%d %H:%M:%S"));
    } catch (Exception $e) {
        printf("[$ERROR] $q FAILED, %s", $e);
        exit(1);
    }
    $c++;
}

function green($str) {
    return "\033[1;32m$str\033[0m";
}

function red($str) {
    return "\033[0;31m$str\033[0m";
}

?>