db.py 文件源码

def update_user_info(self,mdn,params):


        sql = '''select id from user where mdn = '%s' '''%mdn
        user_id = self.mysql_read.query(sql)[0]['id']

        sql = '''select id,info_json from user_info where user_id = %s ''' %user_id
        result = self.mysql_read.query(sql)

        if result:
            info_json = json_decode(result[0]['info_json'])
            info_json.update(params)
            sql = '''update user_info set info_json='%s',update_time=now() where id=%s ''' %(json_encode(info_json),result[0]['id'])

            self.mysql_write.execute(sql)
        else:
            sql = '''insert into user_info (user_id,info_json,update_time) values(%s,'%s',now()) ''' %(user_id,json_encode(params))

            self.mysql_write.execute(sql)