Python ORM之SQLAlchemy 数据库连接引擎实现Mysql、PostgreSQL、Oracle连接以及高级查询的相关实例

from sqlalchemy import create_engine
 
# 定义数据库引擎字典
DATABASES = {
    'mysql': 'mysql+pymysql://user:password@host:port/database',
    'postgresql': 'postgresql+psycopg2://user:password@host:port/database',
    'oracle': 'oracle+cx_oracle://user:password@host:port/database'
}
 
# 获取数据库引擎函数
def get_db_engine(db_type):
    if db_type in DATABASES:
        return create_engine(DATABASES[db_type])
    raise ValueError(f"Unsupported database type: {db_type}")
 
# 使用示例
if __name__ == '__main__':
    db_type = 'mysql'  # 可以更换为 'postgresql' 或 'oracle'
    engine = get_db_engine(db_type)
    print(f"Database engine for {db_type} is successfully created.")

这段代码定义了一个字典DATABASES来存储不同数据库的连接字符串，并提供了一个函数get_db_engine来根据数据库类型创建对应的数据库引擎。使用时，只需更换db_type变量的值即可连接不同的数据库。