db_transfer.py 文件源码

def pull_db_all_user(self):
        import cymysql
        #?????????
        if self.cfg["ssl_enable"] == 1:
            conn = cymysql.connect(host=self.cfg["host"], port=self.cfg["port"],
                    user=self.cfg["user"], passwd=self.cfg["password"],
                    db=self.cfg["db"], charset='utf8',
                    ssl={'ca':self.cfg["ssl_ca"],'cert':self.cfg["ssl_cert"],'key':self.cfg["ssl_key"]})
        else:
            conn = cymysql.connect(host=self.cfg["host"], port=self.cfg["port"],
                    user=self.cfg["user"], passwd=self.cfg["password"],
                    db=self.cfg["db"], charset='utf8')

        try:
            rows = self.pull_db_users(conn)
        finally:
            conn.close()

        if not rows:
            logging.warn('no user in db')
        return rows