require_once "sessions.php"; require_once "config.php"; require_once "functions.php"; require_once "db.php"; define('MAX_SOURCE_SCHEMA_VERSION', 5); define('TARGET_SCHEMA_VERSION', 5); $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 "
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 "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_updated = db_escape_string($data["date_updated"]);
			$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_updated,
					comments)
				VALUES
					('$entry_title', 
					'$entry_guid', 
					'$entry_link',
					'$updated', 
					'$entry_content', 
					'$content_hash',
					false, 
					'$date_updated', 
					'$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' AND owner_uid = '$owner_uid'");
		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");
	}
?>

Return to preferences"; } else { print "Error: could not parse document."; } } else { print "
Error: please upload XMLDB.
"; } } ?>