When you do a project in php related to web the main thing you have to came across is the management of database.This all functions including,connectig to database,retreiving values from databse,deleting,updating,inserting....etc.. so by including the library file iam providing below, you can just call that functions in your code and do all operations very fast without manually writing functions again and again:-
You can download the library from here: https://github.com/litto/PHP-MYSQL-Library
The code is
<?php
class MySql
{
private $dbUser;
private $dbPass;
private $dbName;
private $dbHost;
private $dbConnection;
private $errorString;
private $filter;
private $util;
public static $instance;
public $query;
public $newCon;
function __construct(){
$this->dbConnection = null;
$this->filter = true;
$this->newCon = false;
}
function setNew(){
$this->newCon = true;
}
function noFilter()
{
$this->filter = false;
}
/*
* Setting Error Message on Db Operation
* Input String Message
* Called upon db operation
*/
function setError($string)
{
$this->errorString = $string;
//echo "MYSQL ERROR - ".$this->errorString;
}
/*
* get Error Message after a db operation
* Retrieves the current error Status
*/
function getError()
{
return $this->errorString;
}
/*
* Connect to Mysql Database using set up data
* Set up data being hold on Constructor
* Modify the constrct params for connection change
*/
function connect()
{
if(is_null($this->dbConnection)){
require_once(CONST_BASEDIR.'/config.php') ;
$this->dbUser = $config["databaseUser"];
$this->dbPass = $config["databasePass"];
$this->dbName = $config["databaseName"];
$this->dbHost = $config["databaseHost"];
try{
if($this->newCon==true){
$this->dbConnection = mysql_connect($this->dbHost,$this->dbUser,$this->dbPass,true);
}else{
$this->dbConnection = mysql_connect($this->dbHost,$this->dbUser,$this->dbPass);
}
if($this->dbConnection){
if(mysql_select_db($this->dbName,$this->dbConnection)){
}else{
$this->setError(mysql_error());
}
}else{
$this->setError(mysql_error());
}
}catch(Exception $c){
$this->setError($c);
}
}
}
function getInstance(){
return $this->dbConnection;
}
/*
* Close the Mysql Connection
*/
function close()
{
if($this->dbConnection){
mysql_close($this->dbConnection);
$this->dbConnection = null;
}else{
$this->dbConnection = null;
}
}
/*
* get ALl results for an SQL Select Statement
* Retrieves the result set values in 2 dimensional array
* Parms : query String
* Returns Array
*/
function fetchAll($query)
{
$this->query=$query;
$fileds = array();
$resultSet = array();
try{
$result = mysql_query($query);
if($result){
$fieldsLength = mysql_num_fields($result);
for($i=0;$i<$fieldsLength;$i++ ){
$fileds[$i] = mysql_field_name($result,$i);
}
if(mysql_num_rows($result)>0){
$start = 0;
while($row=mysql_fetch_row($result)){
for($i=0;$i<$fieldsLength;$i++ ){
if($this->filter){
$resultSet[$start][$fileds[$i]] = $this->removeFilter($row[$i]);
}else{
$resultSet[$start][$fileds[$i]] = $row[$i];
}
}
$start++;
}
}
mysql_free_result($result);
}
}catch(Exception $c){
$this->setError($c);
}
return $resultSet;
}
/*
* Mysql Insert operations
* Paramms $fild->value pair , table name
*/
function insert($options,$table)
{
$queryString = "";
$p = count($options);
$start = 0;
$fieldString = null;
$valueString = null;
foreach($options as $key=>$val){
$fieldString.=" `{$key}`";
$valueString.=" '{$val}' ";
if($start<$p-1){
$fieldString.=",";
$valueString.=",";
}
$start++;
}
$queryString = "INSERT INTO `{$table}` ({$fieldString}) VALUES ({$valueString}) ";
//echo "db".$queryString;
try{
$result = mysql_query($queryString) or $this->setError("Insert".mysql_error());
}catch(Exception $c){
$this->setError($c);
}
}
function insertMulti($fields,$values,$table)
{
$queryString = "";
$p = count($fields);
$start = 0;
foreach($fields as $key=>$val){
$fieldString.=" `{$val}`";
if($start<$p-1){
$fieldString.=",";
}
$start++;
}
for($i=0;$i<count($values);$i++){
$p = count($values[$i]);
$start = 0;
$valueString.="(";
foreach($values[$i] as $key=>$val){
$valueString.="'{$val}'";
if($start<$p-1){
$valueString.=",";
}
$start++;
}
$valueString.=")";
if($i<count($values)-1){
$valueString.=",";
}
}
unset($fields);
unset($values);
$queryString = "INSERT INTO `{$table}` ({$fieldString}) VALUES {$valueString} ";
//echo $queryString;
try{
$result = mysql_query($queryString);
}catch(Exception $c){
$this->setError($c);
}
}
/*
* Mysql Update
* Params - field->value pair,table name,update condition
*/
function update($options,$table,$condition)
{
$queryString = "";
$fieldString = "";
$p = count($options);
$start = 0;
foreach($options as $key=>$val){
$fieldString.=" `{$key}`='{$val}'";
if($start<$p-1){
$fieldString.=",";
}
$start++;
}
$queryString = "UPDATE `{$table}` SET {$fieldString} ";
if(!empty($condition)){
$queryString.=" WHERE {$condition} ";
}
$this->query = $queryString;
try{
$result = mysql_query($queryString) or $this->setError(mysql_error());
}catch(Exception $c){
$this->setError($c);
}
//echo $this->query." <br/>";
}
/*
* Mysql Delete Operation
* Params - table name , condition
*/
function delete($table,$condition)
{
$queryString = "DELETE FROM `{$table}` ";
if(!empty($condition)){
$queryString.=" WHERE {$condition} ";
}
try{
$result = mysql_query($queryString) or $this->setError(mysql_error());
}catch(Exception $c){
$this->setError($c);
}
}
function execute($query){
$result = mysql_query($query) or $this->setError(mysql_error());
}
/*
* Returns last insert ID
*/
function lastInsertId()
{
return mysql_insert_id();
}
function affectedRows($instance){
return mysql_affected_rows($instance);
}
/*
* Filter with Slash on special chars
*/
function addFilter($string){
//return addslashes($string);
return $string;
}
/*
* Remove added special chars on STring
*/
function removeFilter($string){
return stripslashes($string);
}
function escapeHtml($text){
return strip_tags($text);
}
}
?>
Now i will explain how it is used:-
@for deleting arecord you have to just call like this
for eg:-
$this->delete('cms_company','`company_id`='.$list[$i]);
@for updating a record you have to just call like this
for eg:
$this->update(array('status'=>'0'),"cms_company",'`company_id`='.$list[$i]);
@for fetching data ,you have to call like this.
for eg:
$query = "SELECT count(c.`company_id`) FROM `cms_company` c WHERE c.`company_id`!=''";
$query.=$qry;
$rec = $this->fetchAll($query);
@for inserting data you have to only do like this
for eg:
$insert = array('company_name'=>$txtTitle,'company_logo'=>$file,'company_banner'=>$file1,'company_address'=>$txtContent,'company_desc'=>$txtdesc,'company_web'=>$web);// array of values in table
$this->insert($insert,'cms_company');
Download PHP-MYSQL Library from here https://github.com/litto/PHP-MYSQL-Library
You can download the library from here: https://github.com/litto/PHP-MYSQL-Library
The code is
<?php
class MySql
{
private $dbUser;
private $dbPass;
private $dbName;
private $dbHost;
private $dbConnection;
private $errorString;
private $filter;
private $util;
public static $instance;
public $query;
public $newCon;
function __construct(){
$this->dbConnection = null;
$this->filter = true;
$this->newCon = false;
}
function setNew(){
$this->newCon = true;
}
function noFilter()
{
$this->filter = false;
}
/*
* Setting Error Message on Db Operation
* Input String Message
* Called upon db operation
*/
function setError($string)
{
$this->errorString = $string;
//echo "MYSQL ERROR - ".$this->errorString;
}
/*
* get Error Message after a db operation
* Retrieves the current error Status
*/
function getError()
{
return $this->errorString;
}
/*
* Connect to Mysql Database using set up data
* Set up data being hold on Constructor
* Modify the constrct params for connection change
*/
function connect()
{
if(is_null($this->dbConnection)){
require_once(CONST_BASEDIR.'/config.php') ;
$this->dbUser = $config["databaseUser"];
$this->dbPass = $config["databasePass"];
$this->dbName = $config["databaseName"];
$this->dbHost = $config["databaseHost"];
try{
if($this->newCon==true){
$this->dbConnection = mysql_connect($this->dbHost,$this->dbUser,$this->dbPass,true);
}else{
$this->dbConnection = mysql_connect($this->dbHost,$this->dbUser,$this->dbPass);
}
if($this->dbConnection){
if(mysql_select_db($this->dbName,$this->dbConnection)){
}else{
$this->setError(mysql_error());
}
}else{
$this->setError(mysql_error());
}
}catch(Exception $c){
$this->setError($c);
}
}
}
function getInstance(){
return $this->dbConnection;
}
/*
* Close the Mysql Connection
*/
function close()
{
if($this->dbConnection){
mysql_close($this->dbConnection);
$this->dbConnection = null;
}else{
$this->dbConnection = null;
}
}
/*
* get ALl results for an SQL Select Statement
* Retrieves the result set values in 2 dimensional array
* Parms : query String
* Returns Array
*/
function fetchAll($query)
{
$this->query=$query;
$fileds = array();
$resultSet = array();
try{
$result = mysql_query($query);
if($result){
$fieldsLength = mysql_num_fields($result);
for($i=0;$i<$fieldsLength;$i++ ){
$fileds[$i] = mysql_field_name($result,$i);
}
if(mysql_num_rows($result)>0){
$start = 0;
while($row=mysql_fetch_row($result)){
for($i=0;$i<$fieldsLength;$i++ ){
if($this->filter){
$resultSet[$start][$fileds[$i]] = $this->removeFilter($row[$i]);
}else{
$resultSet[$start][$fileds[$i]] = $row[$i];
}
}
$start++;
}
}
mysql_free_result($result);
}
}catch(Exception $c){
$this->setError($c);
}
return $resultSet;
}
/*
* Mysql Insert operations
* Paramms $fild->value pair , table name
*/
function insert($options,$table)
{
$queryString = "";
$p = count($options);
$start = 0;
$fieldString = null;
$valueString = null;
foreach($options as $key=>$val){
$fieldString.=" `{$key}`";
$valueString.=" '{$val}' ";
if($start<$p-1){
$fieldString.=",";
$valueString.=",";
}
$start++;
}
$queryString = "INSERT INTO `{$table}` ({$fieldString}) VALUES ({$valueString}) ";
//echo "db".$queryString;
try{
$result = mysql_query($queryString) or $this->setError("Insert".mysql_error());
}catch(Exception $c){
$this->setError($c);
}
}
function insertMulti($fields,$values,$table)
{
$queryString = "";
$p = count($fields);
$start = 0;
foreach($fields as $key=>$val){
$fieldString.=" `{$val}`";
if($start<$p-1){
$fieldString.=",";
}
$start++;
}
for($i=0;$i<count($values);$i++){
$p = count($values[$i]);
$start = 0;
$valueString.="(";
foreach($values[$i] as $key=>$val){
$valueString.="'{$val}'";
if($start<$p-1){
$valueString.=",";
}
$start++;
}
$valueString.=")";
if($i<count($values)-1){
$valueString.=",";
}
}
unset($fields);
unset($values);
$queryString = "INSERT INTO `{$table}` ({$fieldString}) VALUES {$valueString} ";
//echo $queryString;
try{
$result = mysql_query($queryString);
}catch(Exception $c){
$this->setError($c);
}
}
/*
* Mysql Update
* Params - field->value pair,table name,update condition
*/
function update($options,$table,$condition)
{
$queryString = "";
$fieldString = "";
$p = count($options);
$start = 0;
foreach($options as $key=>$val){
$fieldString.=" `{$key}`='{$val}'";
if($start<$p-1){
$fieldString.=",";
}
$start++;
}
$queryString = "UPDATE `{$table}` SET {$fieldString} ";
if(!empty($condition)){
$queryString.=" WHERE {$condition} ";
}
$this->query = $queryString;
try{
$result = mysql_query($queryString) or $this->setError(mysql_error());
}catch(Exception $c){
$this->setError($c);
}
//echo $this->query." <br/>";
}
/*
* Mysql Delete Operation
* Params - table name , condition
*/
function delete($table,$condition)
{
$queryString = "DELETE FROM `{$table}` ";
if(!empty($condition)){
$queryString.=" WHERE {$condition} ";
}
try{
$result = mysql_query($queryString) or $this->setError(mysql_error());
}catch(Exception $c){
$this->setError($c);
}
}
function execute($query){
$result = mysql_query($query) or $this->setError(mysql_error());
}
/*
* Returns last insert ID
*/
function lastInsertId()
{
return mysql_insert_id();
}
function affectedRows($instance){
return mysql_affected_rows($instance);
}
/*
* Filter with Slash on special chars
*/
function addFilter($string){
//return addslashes($string);
return $string;
}
/*
* Remove added special chars on STring
*/
function removeFilter($string){
return stripslashes($string);
}
function escapeHtml($text){
return strip_tags($text);
}
}
?>
Now i will explain how it is used:-
@for deleting arecord you have to just call like this
for eg:-
$this->delete('cms_company','`company_id`='.$list[$i]);
@for updating a record you have to just call like this
for eg:
$this->update(array('status'=>'0'),"cms_company",'`company_id`='.$list[$i]);
@for fetching data ,you have to call like this.
for eg:
$query = "SELECT count(c.`company_id`) FROM `cms_company` c WHERE c.`company_id`!=''";
$query.=$qry;
$rec = $this->fetchAll($query);
@for inserting data you have to only do like this
for eg:
$insert = array('company_name'=>$txtTitle,'company_logo'=>$file,'company_banner'=>$file1,'company_address'=>$txtContent,'company_desc'=>$txtdesc,'company_web'=>$web);// array of values in table
$this->insert($insert,'cms_company');
Download PHP-MYSQL Library from here https://github.com/litto/PHP-MYSQL-Library
No comments:
Post a Comment