3类数据库的联动:mysql、mongodb、redis
2023-09-14 09:00:35 时间
3类数据库的联动:mysql、mongodb、redis
from pymysql import * from pymongo import * from redis import * class MySQL(object): def __init__(self): self.con = connect(host='localhost', port=3306, database='stu_info', user='root', password='mysql', charset='utf8') self.cur = self.con.cursor() self.flag = ["mysql", None] def close(self): self.cur.close() self.con.close() def check(self, sid): try: cur = self.cur param = [sid] sel_sql = "select name from student where id = %s" cur.execute(sel_sql, param) res = cur.fetchone() if res: self.flag[1] = res[0] except Exception: pass finally: self.close() return self.flag class Mongo(object): def __init__(self): self.client = MongoClient(host='localhost', port=27017) self.db = self.client.stu_info self.col = self.db.student self.flag = ["mongo", None] def check(self, sid): try: res = self.col.find_one({"id": sid}) if res: self.flag[1] = res["name"] except Exception: pass finally: return self.flag class Redis(object): def __init__(self): self.client = StrictRedis() self.flag = ["redis", None] def check(self, sid): try: res = self.client.get(sid) if res: self.flag[1] = res.decode() except Exception: pass finally: return self.flag class Check(object): def __init__(self): self.msg = ["不在库中", "未找到该学生"] def check(self, sid): redis = Redis() self.msg = redis.check(sid) if self.msg[1]: return self.msg else: mongo = Mongo() self.msg = mongo.check(sid) if self.msg[1]: return self.msg else: mysql = MySQL() self.msg = mysql.check(sid) if self.msg[1]: return self.msg else: self.msg = ["不在库中", "未找到该学生"] return self.msg def main(): stu_id = input("请输入要查询的id号:") check_id = Check() id_msg = check_id.check(stu_id) print(id_msg) if __name__ == '__main__': main()
相关文章
- 3类数据库的联动:mysql、mongodb、redis
- MYSQL
- Redis 学习笔记四 Mysql 与Redis的同步实践
- Mysql 之 添加innodb支持
- 通过mysql写入php一句话木马
- PHP连接MySQL数据库的三种方式(mysql、mysqli、pdo)--续
- MySQL max_allowed_packet设置及问题
- MySQL性能优化(四)redo log实现原理
- Mysql 如果有多个可选条件怎么加索引_MySQL|mysql-索引
- Starting MySQL. ERROR! The server quit without updating PID file (/data/mysql/mysql.pid).
- activemq持久化配置,设置为主从模式(带复制的主从模式,应用mysql数据库)
- ASP.NET Core微服务(六)——【.Net Core操作redis】StackExchange.Redis
- Starting MySQL ERROR! Couldn‘t find MySQL server (/usr/local/mysql/bin/mysqld_safe)
- mysql主键设置成auto_increment时,进行并发性能測试出现主键反复Duplicate entry 'xxx' for key 'PRIMARY'
- Mysql数据库的mysql Schema 究竟有哪些东西& 手工注入的基础要领
- MySQL技术内幕读书笔记(一)——Mysql体系结构和存储引擎
- Mysql 删除日志
- Mysql事务探索及其在Django中的实践(一)
- MySQL远程连接报错2003-cant connection to mysql server on ‘IP’(10061 unknown error)
- Docker学习笔记17:docker实例之安装 Node.js、PHP、MySQL、Tomcat、Python、Redis、MongoDB、Apache