在调用API时,确保正确地切换数据库或模式。可以使用数据库连接池或ORM框架来实现。
示例代码:
import mysql.connector
from mysql.connector import pooling
# 创建连接池
config = {
"host": "localhost",
"user": "yourusername",
"password": "yourpassword",
"database": "yourdatabase",
"pool_size": 5
}
connection_pool = mysql.connector.pooling.MySQLConnectionPool(**config)
# 从连接池获取连接并执行SQL语句
conn = connection_pool.get_connection()
cursor = conn.cursor()
cursor.execute("SELECT * FROM yourtable")
result = cursor.fetchall()
cursor.close()
conn.close()
from sqlalchemy import create_engine, MetaData, Table, Column, Integer, String
# 创建引擎和元数据
engine = create_engine("mysql://yourusername:yourpassword@localhost/yourdatabase")
metadata = MetaData()
# 定义表结构
users = Table("users", metadata,
Column("id", Integer, primary_key=True),
Column("name", String(50)),
)
# 使用ORM框架查询数据
with engine.connect() as conn:
result = conn.execute(users.select()).fetchall()
上一篇:API被调用了两次。