pipelines.py

class MysqlStordPipeline(object):
    def __int__(self):
        self.connect=MySQLdb.connect('root','123654','niaoyundb','localhost',charset="utf8", use_unicode=True)

        self.cursor=self.connect.cursor()
    def process_item(self,item,spider):
        try:

            self.cursor.execute("""INSERT INTO niaoyunTable (title, href)
                        VALUES (%s, %s)""",
                                (item['title'].encode('utf-8'),
                                 item['href'].encode('utf-8')))

            self.conn.commit()
        except MySQLdb.Error,e:
            print "Error %d: %s" % (e.args[0], e.args[1])
        return item