Pipelines.py

class MysqlStordPipeline(object):
    def __init__(self):
        self.connect=MySQLdb.connect('localhost','root','123654','niaoyundb',charset='utf8', use_unicode=False)
        self.cursors=self.connect.cursor()
    def process_item(self,item,spider):
        try:
            #self.cursors.execute("select version()")
            sql=''' INSERT INTO `niaoyunTable` (title, href) VALUES ("%s", "%s")'''%(item['title'],item['href'])
            self.cursors.execute(sql)

            self.connect.commit()

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