setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
}
catch(PDOException $e)
{
echo '';
echo 'PDO Error : '.$e->getMessage().'
';
echo 'N° : '.$e->getCode();
echo '
';
}
}
}
//This method provides the mecanism for creating and executing SQL Queries from a child using the unique $sqlCon DB connection instance
// - $query represents the SQL query that's going to be executed
// - $params is an optinal parameter allowing you to pass the data to bind to the prepared request
protected function sqlQuery($query, $params=array(''))
{
try
{
$prep_req = self::$sqlCon->prepare($query);
$prep_req->execute($params);
$reply = $prep_req->fetchAll(PDO::FETCH_OBJ);
$prep_req->closeCursor();
return $reply;
}
catch(PDOException $e)
{
echo '';
echo 'Error : '.$e->getMessage().'
';
echo 'N° : '.$e->getCode().'
';
echo 'Request: '.$query.'
';
echo 'Parameters:
';
var_dump($params);
echo '
';
}
}
}
?>
sqlQuery($query, $params);
//If it doesn't, we create it
if (empty($reply)) $this->install();
}
catch(PDOException $e)
{
echo '';
echo 'PDO Error : '.$e->getMessage().'
';
echo 'N° : '.$e->getCode();
echo '
';
}
}
//Install the table
private function install()
{
$query = "CREATE TABLE IF NOT EXISTS `Engine2_Sample` ("
."`id` int(11) NOT NULL AUTO_INCREMENT,"
."`text` text NOT NULL,"
."PRIMARY KEY (`id`) ) ENGINE=MyISAM DEFAULT CHARSET=utf8 AUTO_INCREMENT=1";
$this->sqlQuery($query);
}
//Check the db for a text entry and add it to the DB if it doesn't exists
public function add($text)
{
if(!empty($text))
{
$query = "SELECT `text` FROM `Engine2_Sample` WHERE `text` = ?";
$params = array($text);
$result = $this->sqlQuery($query, $params);
if(empty($result))
{
$query = "INSERT INTO `Engine2_Sample` VALUES('',?)";
$params = array($text);
$this->sqlQuery($query, $params);
return true;
}
else
{
return false;
}
}
}
}
}
?>