db_operation.py 文件源码

def get_connect(self):
        if self.db_lock.acquire():
            try:
                self.conn = MySQLdb.Connection(
                    host = self.host, user = self.user, passwd = self.passwd, charset = self.charset)
            except MySQLdb.Error, e:
                print 'get_connect error_info: %d: %s' % (e.args[0], e.args[1])

            self.cursor = self.conn.cursor()
            if not self.cursor:
                raise(NameError, "Connect failure")

            # # ????
            # try:
            #     self.cursor.execute('SET character_set_connection=utf8, character_set_results=utf8, character_set_client=utf8')
            # except MySQLdb.Error, e:  
            #     print str(datetime.datetime.now()).split(".")[0], "ERROR %d: %s" % (e.args[0], e.args[1])
            self.db_lock.release()

    # ???????