require_once "config.php";
require_once "functions.php";
require_once "db.php";
define('SOURCE_SCHEMA_VERSION', 1);
define('TARGET_SCHEMA_VERSION', 2);
$link = db_connect(DB_HOST, DB_USER, DB_PASS, DB_NAME);
login_sequence($link);
if (!$link) {
if (DB_TYPE == "mysql") {
print mysql_error();
}
// PG seems to display its own errors just fine by default.
return;
}
if (DB_TYPE == "pgsql") {
pg_query("set client_encoding = 'utf-8'");
}
$result = db_query($link, "SELECT schema_version FROM ttrss_version");
$schema_version = db_fetch_result($result, 0, "schema_version");
if ($schema_version != TARGET_SCHEMA_VERSION) {
print "Error: database schema is invalid
(got version $schema_version; expected ".TARGET_SCHEMA_VERSION.")";
return;
}
function import_article($link, $data) {
print "Processing article ".$data["title"].
" (".$data["feed_title"].")
";
$owner_uid = $_SESSION["uid"];
db_query($link, "BEGIN");
$result = db_query($link, "SELECT id FROM ttrss_feeds WHERE feed_url = '".
db_escape_string($data["feed_url"]) . "' AND owner_uid = '$owner_uid'");
if (db_num_rows($result) == 0) {
return false;
}
$feed_id = db_fetch_result($result, 0, "id");
$result = db_query($link, "SELECT id FROM ttrss_entries WHERE
guid = '".$data["guid"]."'");
if (db_num_rows($result) == 0) {
print "Not found, adding base entry...
";
$entry_title = db_escape_string($data["title"]);
$entry_guid = db_escape_string($data["guid"]);
$entry_link = db_escape_string($data["link"]);
$updated = db_escape_string($data["updated"]);
$date_entered = db_escape_string($data["date_entered"]);
$entry_content = db_escape_string($data["content"]);
$content_hash = "SHA1:" . sha1(strip_tags($entry_content));
$entry_comments = db_escape_string($data["comments"]);
$result = db_query($link,
"INSERT INTO ttrss_entries
(title,
guid,
link,
updated,
content,
content_hash,
no_orig_date,
date_entered,
comments)
VALUES
('$entry_title',
'$entry_guid',
'$entry_link',
'$updated',
'$entry_content',
'$content_hash',
false,
'$date_entered',
'$entry_comments')");
}
$result = db_query($link, "SELECT id FROM ttrss_entries WHERE
guid = '".$data["guid"]."'");
if (db_num_rows($result) == 0) { return false; }
$entry_id = db_fetch_result($result, 0, "id");
print "Found base ID: $entry_id
";
$result = db_query($link, "SELECT int_id FROM ttrss_user_entries WHERE
ref_id = '$entry_id'");
if (db_num_rows($result) == 0) {
print "User table entry not found, creating...
";
$unread = sql_bool_to_string(db_escape_string($data["unread"]));
$marked = sql_bool_to_string(db_escape_string($data["marked"]));
$last_read = db_escape_string($data["last_read"]);
if (!$last_read) {
$last_read_qpart = 'NULL';
} else {
$last_read_qpart = "'$last_read'";
}
$result = db_query($link,
"INSERT INTO ttrss_user_entries
(ref_id, owner_uid, feed_id, unread, marked, last_read)
VALUES ('$entry_id', '$owner_uid', '$feed_id', $unread, $marked,
$last_read_qpart)");
} else {
print "User table entry already exists, nothing to do.
";
}
db_query($link, "COMMIT");
}
?>
Error: please upload XMLDB.
"; } } ?>