I didn't spot the fork in your code, but could your problem be fixed if you'd just connect to the database after you fork()ed?