Pipelines.py

class MysqlStordPipeline(object):
    def __int__(self):
        self.connect=MySQLdb.connect('localhost','root','123654','niaoyundb',charset='utf8', use_unicode=True)
        self.cursors=self.connect.cursor()
    def process_item(self,item,spider):
        try:
            self.cursors.execute("select version()")
        except MySQLdb.Error,e:
            print "Error %d: %s" % (e.args[0], e.args[1])
        return item