CheckServer/lib/dbwrapper.php

<?php
/*	DBWrapper.php - Version 1.4.1
	This script is a simple wrapper for SQLite3, MySQL and PgSQL, 
	for make possible to use different BD systems without changing the functions.
	For use, in dbw_connect you have to specify type of database (see below)
	Read README.md for details of every function and use
*/


/** Connect with database */
function dbw_connect($tdb,$server,$database=NULL,$user = NULL,$password=NULL){
	switch ($tdb){
		case "mysql":
		case "mysqli":
			$return[0] = mysqli_connect($server,$user,$password,$database) or die("Error de conexion");
			$return[1] = "mysqli"; //Return standard mysqli for other funcs.
			break;
		case "sqlite":
		case "sqlite3":
			$return[0] = new SQLite3($server);
			if (!$return[0]) die ("Error de conexion");
			$return[1] = "sqlite"; //Return standard SQLite3 for other funcs.
			break;
		case "PostgreSQL":
		case "pg":
		case "PgSQL":
			$return[0] = pg_connect("host=$server dbname=$database user=$user password=$password") or die ('Error de conexion: ' . pg_last_error());
			$return[1] = "PgSQL"; //Return standard PgSQL for other funcs.
			break;
		default:
			return false;
			break;
	}
	return $return;
}

/** Escapes conflictive chars for inserting into database */
function dbw_escape_string($conn,$string){
    switch ($conn[1]){
        case "mysqli":
            return mysqli_escape_string($conn[0],$string);
        case "sqlite":
            return SQLite3::escapeString($string);
        case "PgSQL":
            return pg_escape_string($string);
    }
}


/** Make query */
function dbw_query($conn,$query){
	$time = microtime(true);
	switch ($conn[1]){
		case "mysqli":
			$ret = mysqli_query($conn[0],$query);
		break;
		case "sqlite":
			$ret = $conn[0]->query($query);
		break;
		case "PgSQL":
			$ret = pg_query($query);
		break;
	}
	//echo "<p>".$query."->".(microtime(true)-$time)." milisegundos</p>";
	return $ret;
}

/** Fetch array from query */
function dbw_fetch_array($conn,$result,$typearray = NULL){
	if ($result == false || $result == NULL){return false;}
	switch ($conn[1]){
		case "mysqli":
			if ($typearray == NULL || $typearray == "BOTH"){return mysqli_fetch_array($result);}
			if ($typearray == "ASSOC"){return mysqli_fetch_array($result,MYSQLI_ASSOC);}
			if ($typearray == "NUM"){return mysqli_fetch_array($result,MYSQLI_NUM);}
		break;
		case "sqlite":
			if ($typearray == NULL || $typearray == "BOTH"){return $result->fetchArray();}
			if ($typearray == "ASSOC"){return $result->fetchArray(SQLITE3_ASSOC);}
			if ($typearray == "NUM"){return $result->fetchArray(SQLITE3_NUM);}
		break;
		case "PgSQL":
			if ($typearray == NULL || $typearray == "BOTH"){return pg_fetch_array($result);}
			if ($typearray == "ASSOC"){return pg_fetch_array($result,NULL,PGSQL_ASSOC);}
			if ($typearray == "NUM"){return pg_fetch_array($result,NULL,PGSQL_NUM);}
		break;
	}
}

/** Make query and fetch array */
function dbw_query_fetch_array($conn,$query){
	$time = microtime(true);

	switch ($conn[1]){
		case "mysqli":
			$result = mysqli_query($conn[0],$query);
			if (!$result){return false;}
			$ret = mysqli_fetch_array($result);
		break;
		case "sqlite":
			$result = $conn[0]->query($query);
			if (!$result){return false;}
			$ret = $result->fetchArray();
		break;
		case "PgSQL":
			$result = pg_query($query);
			if (!$result){return false;}
			$ret = pg_fetch_array($result); //Last error (pg_last_error()) not implemented
		break;
	}
	//echo "<p>".$query."->".(microtime(true)-$time)." milisegundos</p>";
	return $ret;
}

/** Goes a query to $row. $row starts in 0 as first row as if not specified */
function dbw_query_goto($conn,$result,$row = 0){
	switch ($conn[1]){
		case "mysqli":
			mysqli_data_seek($result,$row);
			break;
		case "sqlite":
			$result->reset();
			$count = 0;
			while ($count != $row){
				$result->fetchArray();
			}
			break;
		case "PgSQL":
			pg_result_seek($result, $row);
			break;
	}
}

/** Does multiple querys in one command */
function dbw_multi_query($conn,$query){
	switch ($conn[1]){
		case "mysqli":
			mysqli_multi_query($conn[0],$query);
			break;
		case "sqlite":
			$conn[0]->exec($query);
			break;
		case "PgSQL":
			$null = pg_query($query);
			break;
	}
}

/** Returns the lastest Insert ID */
function dbw_last_id($conn){
	switch ($conn[1]){
		case "mysqli":
			return mysqli_insert_id($conn[0]);
		case "sqlite":
			return $conn[0]->lastInsertRowID();
		case "PgSQL":
			return pg_fetch_array(pg_query("SELECT lastval();"))[0];
	}
}


/** Returns number of results */
function dbw_num_rows($conn,$result){
	switch ($conn[1]){
		case "mysqli":
			return mysqli_num_rows($result);
		case "sqlite":
			die("Sqlite3 not supports numRows, use query with COUNT(*)");
			return $result->numRows(); //ERROR
		case "PgSQL":
			return pg_num_rows ($result);
	}
}


/** Close connection */
function dbw_close($conn){
	switch ($conn[1]){
		case "mysqli":
			mysqli_close($conn[0]);
			break;
		case "sqlite":
			$conn[0]->close();
			break;
		case "PgSQL":
			pg_close($conn[0]);
			break;
	}
}

/** Some internal wrappers for functions that are equal to other with arguments */

function dbw_fetch_assoc($conn,$result){return dbw_fetch_array($conn,$result,"ASSOC");}
function dbw_fetch_row($conn,$result){return dbw_fetch_array($conn,$result,"NUM");}

function dbw_data_seek($conn,$result){return dbw_query_goto($conn,$result,$row = 0);}
function dbw_result_seek($conn,$result){return dbw_query_goto($conn,$result,$row = 0);}

function dbw_insert_id($conn){return dbw_last_id($conn);}

?>