<?php
require_once($INC . "/xlog.inc.php");

$sql_debug = 0;

$sql_error = "";

/*
 * Set error string
 */
function sql_set_error($str)
{
	global $sql_error;

	$sql_error = $str;
}

function sql_error()
{
	global $sql_error;

	return $sql_error;
}

/*
 * Connect to database
 */
function sql_open($str)
{
	global $sql_debug;

	if ($sql_debug > 0)
		xlog("DB: opening [$str]...");

	if (strncmp($str, "sqlite:", 7) != 0) {
		sql_set_error("$str connect string not supported");
		return FALSE;
	}

	$file = substr($str, 7);

	$db = new SQLite3($file);
	if ($db === FALSE) {
		sql_set_error("Cannot connect to database $file: " . $db->lastErrorMsg());
		return FALSE;
	}

	return $db;
}

/*
 * Escaping
 */
function sql_escape($db, $str)
{
	return $db->escapeString($str);
}

/*
 * Do a query
 */
function sql_query($db, $sql)
{
	global $sql_debug;

	if ($sql_debug > 0)
		xlog("DB: running [$sql]...");

	$res = $db->query($sql);
	if ($res === FALSE) {
		sql_set_error("$sql: " . $db->lastErrorMsg());
		return FALSE;
	}

	return $res;
}

/*
 * Close database
 */
function sql_close($db)
{
	$db->close();
}

/*
 * Free results
 */
function sql_free_result($res)
{
	$res->finalize();
}

/*
 * Returns a row as an associated array
 */
function sql_fetch_array($res)
{
	return $res->fetchArray(SQLITE3_ASSOC);
}

function sql_last_id($db)
{
	return $db->lastInsertRowID();
}

?>