id')");
if($post_result === FALSE or mysql_affected_rows() != 1)
{
mysql_query("ROLLBACK");
exit( "Could not insert post into database: " . mysql_error() );
}
// get the auto incremented post id generated by the database
$postId = mysql_insert_id();
// insert categories into database
if(!empty($categories))
{
$tokens = explode(",", $categories);
foreach($tokens as $token)
{
$category = trim($token);
// check to see if the category already exists
$category_exists_result = mysql_query("SELECT id FROM categories WHERE category = '$category'");
if($category_exists_result === FALSE)
{
mysql_query("ROLLBACK");
exit( "Could not check category exists in database: " . mysql_error() );
}
if(mysql_num_rows($category_exists_result) == 1)
{
// category exists, fetch the category id from the existing row
$row = mysql_fetch_assoc($category_exists_result);
$categoryId = $row["id"];
}
else
{
// category does not exists, insert the category in the categories table and fetch the auto incremented category id
$category_insert_result = mysql_query("INSERT INTO categories (category) VALUES ('$category') ON DUPLICATE KEY UPDATE category=category");
if($category_insert_result === FALSE or mysql_affected_rows() != 1)
{
mysql_query("ROLLBACK");
exit( "Could not insert category into database: " . mysql_error() );
}
// get the auto incremented category id generated by the database
$categoryId = mysql_insert_id();
}
// insert post->category mapping into the posts2categories table
$p2c_result = mysql_query("INSERT INTO posts2categories (post_id, category_id) VALUES ('$postId', '$categoryId')");
if($p2c_result === FALSE or mysql_affected_rows() != 1)
{
mysql_query("ROLLBACK");
exit( "Could not insert post2category into database: " . mysql_error() );
}
}
}
// no db errors, we can commit the transaction
$commit_result = mysql_query("COMMIT");
if($commit_result === FALSE)
{
mysql_query("ROLLBACK");
exit( "Could not commit transaction: " . mysql_error() );
}
// success, redirect the user to the new post with message that it was added
$feedback = new Feedback(Feedback::PostAdded);
$feedback->addMessage("Thank you, your post has been added!");
$_SESSION[BLOG_FEEDBACK] = $feedback;
blog_redirect(blog_createpostlink($postId));
}
// invalid form submission if we reached here AND the $_POST is not empty
$invalid = !empty($_POST);
?>