sqlalchemy

sqlalchemy-mysql

参考：

Python之使用Pandas库实现MySQL数据库的读写SQLAlchemy的简单使用sqlalchemy学习笔记python使用sqlalchemy连接mysql数据库doc: pandas.read_sqldoc: pandas.read_sql_querydoc: pandas.DataFrame.to_sql

第三方库安装与简单使用

PyMySQL PEP 249 -- Python Database API Specification v2.0 pip install PyMySQL import pymysql # pymysql.connect('<主机HOST>', '<用户名>', '<密码>', '<数据库名>'[[, charset='<编码>'][, port=<端口(默认3306)>]]) # 创建-数据库连接对象 conn = pymysql.connect('localhost:3306', 'root', 'root', 'mysql', charset='utf8') # 创建-游标对象 cursor = conn.cursor() # 执行SQL语句(查询MySQL版本) cursor.execute('select version()') # 获取一条SQL语句（查询类型）执行结果 cursor.fetchone() # 关闭游标 cursor.close() # 关闭数据库连接（释放资源） conn.close() SQLAlchemy Working with Engines and Connections pip install SQLAlchemy # 导入创建引擎的方法 from sqlalchemy import create_engine # 数据库配置 db_config = { 'username': 'root', 'password': 'root', 'host': '127.0.0.1', 'port': 3306, 'database': 'mysql', 'charset': 'utf8' } # SQLAlchemy连接URI uri = 'mysql+pymysql://{username}:{password}@{host}:{port}/{database}?charset={charset}'.format(**db_config) # 创建数据库引擎 engine = create_engine(uri) # 发动引擎，得到一个SQLAlchemy中的数据库连接 conn = engine.connect() # 执行sql语句（查询当前时间）（返回一代理对象） rp = conn.execute('select now()') # 获取结果 rp.fetchone() # 关闭结果代理对象 rp.close() # 关闭连接 conn.close() # 查看连接是否已经关闭 print(conn.closed) SQLAlchemy-Utils sqlalchemy_utils.functions.database_exists(url)sqlalchemy_utils.functions.create_database(url, encoding='utf8', template=None)sqlalchemy_utils.functions.drop_database(url) pip install SQLAlchemy-Utils from sqlalchemy import create_engine import sqlalchemy_utils # 数据库配置 db_config = { 'username': 'root', 'password': 'root', 'host': '127.0.0.1', 'port': 3306, 'database': 'hello', 'charset': 'utf8' } # SQLAlchemy连接URI uri = 'mysql+pymysql://{username}:{password}@{host}:{port}/{database}?charset={charset}'.format(**db_config) # 判断数据是否存在 if not sqlalchemy_utils.database_exists(uri): print('不存在') sqlalchemy_utils.create_database(uri) else: print('存在') sqlalchemy_utils.drop_database(uri)

SQLAlchemy-操作数据库

SQLAlchemy连接关系型数据库URI(字符串)格式:数据库类型+数据库驱动名称://用户名:口令@机器地址:端口号/数据库名

 

转载于:https://www.cnblogs.com/cp9648/p/10415646.html