/* Database functions: OpenDataBase($dbname) CloseDataBase($dbi) RetrievePage($dbi, $pagename) InsertPage($dbi, $pagename, $pagehash) IsWikiPage($dbi, $pagename) InitTitleSearch($dbi, $search) TitleSearchNextMatch($dbi, &$pos) InitFullSearch($dbi, $search) FullSearchNextMatch($dbi, &$pos) */ // open a database and return a hash function OpenDataBase($table) { global $WikiDataBase, $pg_dbhost, $pg_dbport; $connectstring = "host=$pg_dbhost port=$pg_dbport dbname=$WikiDataBase"; if (!($dbc = pg_pconnect($connectstring))) { echo "Cannot establish connection to database, giving up."; exit(); } $dbi['dbc'] = $dbc; $dbi['table'] = $table; // echo "
dbi after open: '$dbi' '$dbi[table]' '$dbi[dbc]'
\n"; return $dbi; } function CloseDataBase($dbi) { // NOOP: we use persistent database connections } // Return hash of page + attributes or default function RetrievePage($dbi, $pagename) { $pagename = addslashes($pagename); $query = "select * from $dbi[table] where pagename='$pagename'"; $res = pg_exec($dbi['dbc'], $query); if (pg_numrows($res)) { if ($array = pg_fetch_array($res, 0)) { while (list($key, $val) = each($array)) { // pg_fetch_array gives us all the values twice, // so we have to manually edit out the indices if (gettype($key) == "integer") { continue; } $pagehash[$key] = $val; } // unserialize/explode content $pagehash['refs'] = unserialize($pagehash['refs']); $pagehash['content'] = explode("\n", $pagehash['content']); return $pagehash; } } // if we reach this the query failed return -1; } // Either insert or replace a key/value (a page) function InsertPage($dbi, $pagename, $pagehash) { $pagename = addslashes($pagename); // echo "
dbi in InsertPage: '$dbi' '$dbi[table]' '$dbi[dbc]'
"; // prepare the content for storage if (!isset($pagehash["pagename"])) $pagehash["pagename"] = $pagename; if (!isset($pagehash["flags"])) $pagehash["flags"] = 0; $pagehash["author"] = addslashes($pagehash["author"]); $pagehash["content"] = implode("\n", $pagehash["content"]); $pagehash["content"] = addslashes($pagehash["content"]); $pagehash["pagename"] = addslashes($pagehash["pagename"]); $pagehash["refs"] = serialize($pagehash["refs"]); // temporary hack until the time stuff is brought up to date $pagehash["created"] = time(); $pagehash["lastmodified"] = time(); if (IsWikiPage($dbi, $pagename)) { $PAIRS = "author='$pagehash[author]'," . "content='$pagehash[content]'," . "created=$pagehash[created]," . "flags=$pagehash[flags]," . "lastmodified=$pagehash[lastmodified]," . "pagename='$pagehash[pagename]'," . "refs='$pagehash[refs]'," . "version=$pagehash[version]"; $query = "UPDATE $dbi[table] SET $PAIRS WHERE pagename='$pagename'"; } else { // do an insert // build up the column names and values for the query $COLUMNS = "author, content, created, flags, " . "lastmodified, pagename, refs, version"; $VALUES = "'$pagehash[author]', '$pagehash[content]', " . "$pagehash[created], $pagehash[flags], " . "$pagehash[lastmodified], '$pagehash[pagename]', " . "'$pagehash[refs]', $pagehash[version]"; $query = "INSERT INTO $dbi[table] ($COLUMNS) VALUES($VALUES)"; } // echo "
Query: $query
\n";
$retval = pg_exec($dbi['dbc'], $query);
if ($retval == false)
echo "Insert/update failed: " . pg_errormessage($dbi['dbc']);
}
function IsWikiPage($dbi, $pagename) {
$pagename = addslashes($pagename);
$query = "select count(*) from $dbi[table] where pagename='$pagename'";
$res = pg_exec($query);
$array = pg_fetch_array($res, 0);
return $array[0];
}
// setup for title-search
function InitTitleSearch($dbi, $search) {
global $search_counter;
$search_counter = 0;
$search = addslashes($search);
$query = "select pagename from $dbi[table] where pagename " .
"like '%$search%' order by pagename";
// echo "search query: $query
\n";
$res = pg_exec($dbi["dbc"], $query);
return $res;
}
// iterating through database
function TitleSearchNextMatch($dbi, $res) {
global $search_counter;
if($o = @pg_fetch_object($res, $search_counter)) {
$search_counter++;
return $o->pagename;
} else {
return 0;
}
}
// setup for full-text search
function InitFullSearch($dbi, $search) {
global $search_counter;
$search_counter = 0;
$search = addslashes($search);
$query = "select pagename,content from $dbi[table] " .
"where content like '%$search%'";
$res = pg_exec($dbi["dbc"], $query);
return $res;
}
// iterating through database
function FullSearchNextMatch($dbi, $res) {
global $search_counter;
if ($hash = @pg_fetch_array($res, $search_counter)) {
$search_counter++;
$page['name'] = $hash["pagename"];
$page['hash']['content'] = explode("\n", $hash["content"]);
return $page;
}
else {
return 0;
}
}
?>