funnymoney
09-05-2009, 12:37 PM
Custom PHP Class for manipulating MySQL. Simple to follow, and to use.
<?php
class Database {
public function connect($host, $name, $pass) {
$connection = mysql_connect($host, $name, $pass) or die(mysql_error());
return $connection;
}
public function usedatabase($databasename) {
return mysql_select_db($databasename) or die(mysql_error()."method usedatabase");
}
public function selectdata($tablename, $fields) {
$sql = ("SELECT $fields FROM $tablename");
$query = mysql_query($sql) or die(mysql_error()."method selectdata 1");
if (!$query) {
return "Could not successfully run query ($sql) from DB: " . mysql_error()."method selectdata";
exit;
}
if (mysql_num_rows($query) == 0) {
return 0;
exit;
}
if(preg_match("/,/", $fields)) {
$fields = explode(",", $fields);
#print_r($fields);
}
while ($row = mysql_fetch_assoc($query)) {
if (is_array($fields)) {
foreach ($fields as $field) {
$rezultati[$field][] = $row[$field];
}
}
else {
$rezultati[$fields][] = $row[$fields];
}
}
mysql_free_result($query);
return $rezultati;
}
public function selectwhere($tablename, $fields, $where) {
$sql = ("SELECT $fields FROM $tablename $where");
$query = mysql_query($sql) or die(mysql_error()."select where 1");
if (!$query) {
return "Could not successfully run query ($sql) from DB: " . mysql_error()."select where 2";
exit;
}
if (mysql_num_rows($query) == 0) {
return 0;
exit;
}
if(preg_match("/,/", $fields)) {
$fields = explode(",", $fields);
#print_r($fields);
}
while ($row = mysql_fetch_assoc($query)) {
if (is_array($fields)) {
foreach ($fields as $field) {
$rezultati[$field] = $row[$field];
}
}
else {
$rezultati[$fields] = $row[$fields];
}
}
mysql_free_result($query);
return $rezultati;
}
public function selectallwhere ($tablename, $fields, $where) {
$sql = ("SELECT $fields FROM $tablename $where");
$query = mysql_query($sql) or die(mysql_error()."select where 1");
if (!$query) {
return "Could not successfully run query ($sql) from DB: " . mysql_error()."select where 2";
exit;
}
if (mysql_num_rows($query) == 0) {
return 0;
exit;
}
if(preg_match("/,/", $fields)) {
$fields = explode(",", $fields);
#print_r($fields);
}
while ($row = mysql_fetch_assoc($query)) {
if (is_array($fields)) {
foreach ($fields as $field) {
$rezultati[$field][] = $row[$field];
}
}
else {
$rezultati[$fields][] = $row[$fields];
}
}
mysql_free_result($query);
return $rezultati;
}
public function leftjoin($lefttable, $righttable, $matchedrow, $fields, $order) {
$sql = ("SELECT $fields FROM $lefttable LEFT JOIN $righttable ON $lefttable.$matchedrow = $righttable.$matchedrow $order");
$query = mysql_query($sql) or die(mysql_error()."method selectdata left join");
if (!$query) {
return "Could not successfully run query ($sql) from DB: " . mysql_error()."method selectdata";
exit;
}
if (mysql_num_rows($query) == 0) {
return 0;
exit;
}
if(preg_match("/,/", $fields)) {
$fields = explode(",", $fields);
#print_r($fields);
}
while ($row = mysql_fetch_assoc($query)) {
if (is_array($fields)) {
foreach ($fields as $field) {
$rezultati[$field][] = $row[$field];
}
}
else {
$rezultati[$fields][] = $row[$fields];
}
}
mysql_free_result($query);
return $rezultati;
}
public function insertdata($tablename, $fields, $values) {
return mysql_query(
"INSERT INTO $tablename ($fields) VALUES ($values)"
)
or die(mysql_error());
}
public function update($tablename, $field, $value, $where) {
return mysql_query("UPDATE $tablename SET $field = $value $where") or die(mysql_error());
}
public function newupdate($tablename, $values, $where) {
return mysql_query("UPDATE $tablename SET $values $where") or die(mysql_error());
}
public function delete($tablename, $where) {
return mysql_query("DELETE FROM $tablename $where");
}
}
#usage
$mysql = new Database();
$mysql->connect("localhost", "username", "password");
$mysql->usedatabase("test");
$selectdata = $mysql->selectdata("tablename", "tablefield1,tablefield2");
$selectallwhere = $mysql->selectallwhere("tablename", "tablefield1,tablefield2,tablefield3", "where status='1'");
#class outputs multidimenstional array so you can access values like this
print_r($selectdata['tablefield1']);
print_r($selectallwhere);
#try and see the difference
?>
<?php
class Database {
public function connect($host, $name, $pass) {
$connection = mysql_connect($host, $name, $pass) or die(mysql_error());
return $connection;
}
public function usedatabase($databasename) {
return mysql_select_db($databasename) or die(mysql_error()."method usedatabase");
}
public function selectdata($tablename, $fields) {
$sql = ("SELECT $fields FROM $tablename");
$query = mysql_query($sql) or die(mysql_error()."method selectdata 1");
if (!$query) {
return "Could not successfully run query ($sql) from DB: " . mysql_error()."method selectdata";
exit;
}
if (mysql_num_rows($query) == 0) {
return 0;
exit;
}
if(preg_match("/,/", $fields)) {
$fields = explode(",", $fields);
#print_r($fields);
}
while ($row = mysql_fetch_assoc($query)) {
if (is_array($fields)) {
foreach ($fields as $field) {
$rezultati[$field][] = $row[$field];
}
}
else {
$rezultati[$fields][] = $row[$fields];
}
}
mysql_free_result($query);
return $rezultati;
}
public function selectwhere($tablename, $fields, $where) {
$sql = ("SELECT $fields FROM $tablename $where");
$query = mysql_query($sql) or die(mysql_error()."select where 1");
if (!$query) {
return "Could not successfully run query ($sql) from DB: " . mysql_error()."select where 2";
exit;
}
if (mysql_num_rows($query) == 0) {
return 0;
exit;
}
if(preg_match("/,/", $fields)) {
$fields = explode(",", $fields);
#print_r($fields);
}
while ($row = mysql_fetch_assoc($query)) {
if (is_array($fields)) {
foreach ($fields as $field) {
$rezultati[$field] = $row[$field];
}
}
else {
$rezultati[$fields] = $row[$fields];
}
}
mysql_free_result($query);
return $rezultati;
}
public function selectallwhere ($tablename, $fields, $where) {
$sql = ("SELECT $fields FROM $tablename $where");
$query = mysql_query($sql) or die(mysql_error()."select where 1");
if (!$query) {
return "Could not successfully run query ($sql) from DB: " . mysql_error()."select where 2";
exit;
}
if (mysql_num_rows($query) == 0) {
return 0;
exit;
}
if(preg_match("/,/", $fields)) {
$fields = explode(",", $fields);
#print_r($fields);
}
while ($row = mysql_fetch_assoc($query)) {
if (is_array($fields)) {
foreach ($fields as $field) {
$rezultati[$field][] = $row[$field];
}
}
else {
$rezultati[$fields][] = $row[$fields];
}
}
mysql_free_result($query);
return $rezultati;
}
public function leftjoin($lefttable, $righttable, $matchedrow, $fields, $order) {
$sql = ("SELECT $fields FROM $lefttable LEFT JOIN $righttable ON $lefttable.$matchedrow = $righttable.$matchedrow $order");
$query = mysql_query($sql) or die(mysql_error()."method selectdata left join");
if (!$query) {
return "Could not successfully run query ($sql) from DB: " . mysql_error()."method selectdata";
exit;
}
if (mysql_num_rows($query) == 0) {
return 0;
exit;
}
if(preg_match("/,/", $fields)) {
$fields = explode(",", $fields);
#print_r($fields);
}
while ($row = mysql_fetch_assoc($query)) {
if (is_array($fields)) {
foreach ($fields as $field) {
$rezultati[$field][] = $row[$field];
}
}
else {
$rezultati[$fields][] = $row[$fields];
}
}
mysql_free_result($query);
return $rezultati;
}
public function insertdata($tablename, $fields, $values) {
return mysql_query(
"INSERT INTO $tablename ($fields) VALUES ($values)"
)
or die(mysql_error());
}
public function update($tablename, $field, $value, $where) {
return mysql_query("UPDATE $tablename SET $field = $value $where") or die(mysql_error());
}
public function newupdate($tablename, $values, $where) {
return mysql_query("UPDATE $tablename SET $values $where") or die(mysql_error());
}
public function delete($tablename, $where) {
return mysql_query("DELETE FROM $tablename $where");
}
}
#usage
$mysql = new Database();
$mysql->connect("localhost", "username", "password");
$mysql->usedatabase("test");
$selectdata = $mysql->selectdata("tablename", "tablefield1,tablefield2");
$selectallwhere = $mysql->selectallwhere("tablename", "tablefield1,tablefield2,tablefield3", "where status='1'");
#class outputs multidimenstional array so you can access values like this
print_r($selectdata['tablefield1']);
print_r($selectallwhere);
#try and see the difference
?>