/**
* Sets the database link identifier
*
* @subpackage Author
* @author Marten van Urk .: ComSi www.comsi.nl :.
* @param String $host
* @param String $user
* @param String $pass
* @param String $database
*/
public function setDb($host, $user, $pass, $database) {
try {
$pdo = new PDO('mysql:host=' .$host. ';dbname=' .$database. '', '' .$user. '', '' .$pass. '' , array(PDO::ATTR_PERSISTENT => true));
$this->db = $pdo;
} catch (Exception $e) {
return false;
}
}
/**
* Insert query builder for news system
*
* @author Marten van Urk .: ComSi www.comsi.nl :.
* @param Array $values
* @param String $table
* @return Boolean
*/
public function insertFunction($values, $table) {
$sQuery_fields = "SHOW COLUMNS FROM " . $table;
try {
$rResult_fields = $this->db->query($sQuery_fields);
$sFields = '';
$aFields = array();
$sValues = '';
$looped = 1;
$count = count($values);
foreach ($rResult_fields as $r) {
$aFields[$r[0]] = '';
}
foreach ($values as $key => $value) {
if (array_key_exists($key, $aFields)) {
if ($looped < $count) {
$sFields .= $key . ', ';
$sValues .= "'" .$value. "',";
} elseif ($looped == $count) {
$sFields .= $key;
$sValues .= "'" .$value. "'";
}
}
$looped++;
}
$sQuery = "INSERT INTO " .$table. " (" .$sFields. ") VALUES (" .$sValues. ")";
$rResult = $this->db->query($sQuery);
return true;
} catch (Exception $e) {
return false;
}
}
/**
* Sets the database link identifier
*
* @subpackage Author
* @author Marten van Urk .: ComSi www.comsi.nl :.
* @param String $host
* @param String $user
* @param String $pass
* @param String $database
*/
public function setDb($host, $user, $pass, $database) {
try {
$pdo = new PDO
('mysql:host=' .$host. ';dbname=' .$database. '', '' .$user. '', '' .$pass. '' , array(PDO
::ATTR_PERSISTENT => true)); $this->db = $pdo;
} catch (Exception $e) {
return false;
}
}
/**
* Insert query builder for news system
*
* @author Marten van Urk .: ComSi www.comsi.nl :.
* @param Array $values
* @param String $table
* @return Boolean
*/
public function insertFunction($values, $table) {
$sQuery_fields = "SHOW COLUMNS FROM " . $table;
try {
$rResult_fields = $this->db->query($sQuery_fields);
$sFields = '';
$sValues = '';
$looped = 1;
foreach ($rResult_fields as $r) {
$aFields[$r[0]] = '';
}
foreach ($values as $key => $value) {
if ($looped < $count) {
$sFields .= $key . ', ';
$sValues .= "'" .$value. "',";
} elseif ($looped == $count) {
$sFields .= $key;
$sValues .= "'" .$value. "'";
}
}
$looped++;
}
$sQuery = "INSERT INTO " .$table. " (" .$sFields. ") VALUES (" .$sValues. ")";
$rResult = $this->db->query($sQuery);
return true;
} catch (Exception $e) {
return false;
}
}