如何使用 SQLAlchemy 库与数据库进行数据交互?
步骤:
- 导入库:
from sqlalchemy import create_engine
- 连接数据库:
engine = create_engine('mysql://user:password@host:port/database_name')
- 执行 SQL 语句:
cursor = engine.cursor()
cursor.execute("SELECT * FROM table_name")
- 获取结果:
results = cursor.fetchall()
- 关闭连接:
engine.dispose()
示例代码:
import sqlalchemy
# 连接数据库
engine = create_engine('mysql://root:password@localhost/test_db')
# 执行 SQL 语句
cursor = engine.cursor()
cursor.execute("SELECT * FROM users")
results = cursor.fetchall()
# 打印结果
for row in results:
print(row)
# 关闭连接
engine.dispose()
注意:
- 确保将
user
,password
和database_name
替换为实际值。 - 可以使用
cursor.execute()
方法传递 SQL 语句,也可以使用create_all_tables()
方法创建所有表。 - 可以使用
engine.execute()
方法执行 SQL 语句并返回结果。