<?php
$myHOST = isset($_SERVER['HTTP_HOST']) ? $_SERVER['HTTP_HOST'] : 'localhost';
switch($myHOST) {
	case 'localhost':
	case 'www.nextrek.net':
	case 'nextrek.net':
  	default:
		error_log('DB::using nextrek DB ('.$myHOST.')');
		define('DB_SERVER', 	'168.144.18.23');
		define('DB_SCHEMA', 	'pocketvision');
		define('DB_USER', 		'root');
		define('DB_PASSWORD', 	'pedalino101');
		define('DB_ENCODING',	'utf-8');

		define('DB_DEBUG', 		FALSE);
}

date_default_timezone_set('UTC');

/*
 * Instaura una connessione al DB)
* snippet:
* if (!sql_connect())
* {
* 		echo 'Errore: '.sql_last_error();
* }
*
* NB. Ricordarsi di chiudere la connessione con sql_close($con)
*/
function sql_connect()
{
	$con = mysql_connect(DB_SERVER, DB_USER, DB_PASSWORD);
	if (!$con)
	{
		error_log(mysql_error());
		return FALSE;
	}

	if (!mysql_select_db(DB_SCHEMA))
	{
		return FALSE;
	}

	mysql_query('set names \''.DB_ENCODING.'\'');

	return TRUE;
}

/*
 * Ritorna l'ultimo errore (se presente)
*/
function sql_last_error()
{
	return mysql_error();
}

/*
 * Chiude una connessione al DB precedentemente aperta con sql_connect()
*/
function sql_disconnect()
{
	mysql_close();
}

/*
 * Esegue una query e ritorna un cursore
*/
function sql_cursor_open($query)
{
	return mysql_query($query);
}

/*
 * ritorna la dimensione del cursore (numero di righe)
*/
function sql_get_cursor_size($cursor)
{
	return mysql_num_rows($cursor);
}

/*
 * Chiude un recordset aperto con sql_open_cursor()
*/
function sql_cursor_close($cursor)
{
	mysql_free_result($cursor);
}

/*
 * ritorna una riga del cursore ottenuto da sql_open_cursor come array associativo.
* ritorna FALSE in caso non ci sono più dati da leggere
* snippet:
* while ($row = sql_fetch_cursor($cursor)) {
*   echo $row['userid'];
*   echo $row['fullname'];
*   echo $row['userstatus'];
* }
*/
function sql_fetch_row($cursor)
{
	return mysql_fetch_assoc($cursor);
}

/*
 * Esegue uno statement sql (una query di update, insert, delete, etc..)
*/
function sql_execute_query($statement)
{
	if (DB_DEBUG) error_log('query: '.$statement);
	return mysql_query($statement);
}

function sql_fetch_single_row($query)
{
	$cursor = sql_cursor_open($query);
	if ($cursor)
	{
		$row = sql_fetch_row($cursor);
		sql_cursor_close($cursor);
		return $row;
	}
	else
	{
		return $cursor;
	}
}

function sql_escape($name)
{
	return mysql_real_escape_string($name);
}

function sql_quote($name)
{
	return '\''.mysql_real_escape_string($name).'\'';
}

/*
 * Genera ed esegue una query di inserimento.
* $table = nome tabella
* $params = array associativo con nome campi, valori
*/
function sql_insert($table, $params)
{
	$keys = array_keys($params);
	foreach($keys as &$k)
	{
		$k = '`'.$k.'`';
	}

	$values = array_values($params);
	foreach($values as &$v)
	{
		$v = '\''.mysql_real_escape_string($v).'\'';
	}

	$query = 'INSERT INTO `' . $table . '` (' . implode(',',$keys) . ') VALUES (' . implode(',',$values) . ');';

	return sql_execute_query($query);
}

function sql_insert_bulk($table, $fields, $data)
{
	foreach($fields as &$k)
	{
		$k = '`'.$k.'`';
	}

	$query = 'INSERT INTO `' . $table . '` (' . implode(',',$fields) . ') VALUES ';

	$first = true;
	foreach($data as &$params)
	{
		$values = array_values($params);
		foreach($values as &$v)
		{
			$v = '\''.mysql_real_escape_string($v).'\'';
		}
		if ($first)
		{
			$first = false;
		} else {
			$query .= ',';

		}
		$query .= '(' . implode(',',$values) . ')';
	}
	$query .= ';';

	return sql_execute_query($query);
}


/*
 * ritorna l'ultimo ID inserito
 */
function sql_last_inserted_id()
{
	return mysql_insert_id();
}

/*
 * Genera ed esegue una query di update.
* $table = nome tabella
* $params = array associativo con nome campi, valori
* $whereClause = se presente aggiunge una condizione di WHERE
*/
function sql_update($table, $params, $whereClause = NULL)
{
	$fields = array();
	foreach($params as $k=>$v)
	{
		$fields[] = '`' . $k . '`' .'=\''.mysql_real_escape_string($v) . '\'';
	}

	$query = 'UPDATE `' . $table . '` SET ' . implode(',',$fields);

	if (!empty($whereClause))
	{
		$query .= ' WHERE ('.$whereClause.');';
	}
	else
	{
		$query .= ';';
	}

	return sql_execute_query($query);
}

/*
 * Genera ed esegui una query di delete
 */
function sql_delete($table, $whereClause)
{
	$query = 'DELETE FROM `' . $table . '` WHERE (' . $whereClause . ');';
	return sql_execute_query($query);
}

function mapURL($relPath) {
	$filePathName = realpath($relPath);
	$filePath = realpath(dirname($relPath));
	$basePath = realpath($_SERVER['DOCUMENT_ROOT']);

	// can not create URL for directory lower than DOCUMENT_ROOT
	if (strlen($basePath) > strlen($filePath)) {
		return '';
	}

	//return 'http://' . $_SERVER['HTTP_HOST'] . substr($filePathName, strlen($basePath));
	$prot = 'http';
	if (array_key_exists('HTTPS', $_SERVER))
	{
		$prot .= 's';
	}

	$url = $prot . '://' . $_SERVER['SERVER_NAME'] . substr($filePathName, strlen($basePath));

	error_log($url);

	$url = str_replace('\\', '/', $url);
	return $url;
}

function sql_begin()
{
	if (DB_DEBUG) error_log('----------- BEGIN TRANSACTION');
	return mysql_query('BEGIN');
}

function sql_commit()
{
	if (DB_DEBUG) error_log('----------- COMMIT TRANSACTION');
	return mysql_query('COMMIT');
}

function sql_rollback()
{
	if (DB_DEBUG) error_log('----------- *ROLLBACK* TRANSACTION');
	return mysql_query('ROLLBACK');
}

?>