sqlalchemy 执行sql

1. 引言

SQLAlchemy是一个Python SQL工具和对象-关系映射（ORM）库。它提供了一套强大的API，可以与多种数据库进行交互。在某些情况下，我们可能需要直接执行原生的SQL语句，而不是使用ORM。

本文将详细介绍SQLAlchemy如何执行SQL语句，并提供一些示例代码。首先，我们将介绍如何建立SQLAlchemy连接。然后，我们将讨论如何使用SQLAlchemy执行SQL语句，包括查询和修改操作。

2. 建立连接

要执行SQL语句，我们需要先与数据库建立连接。SQLAlchemy提供了各种数据库引擎的支持，例如SQLite、MySQL、PostgreSQL等。我们可以使用相应的数据库引擎来建立连接。

下面是一个使用SQLite数据库的示例代码：

from sqlalchemy import create_engine

# 使用SQLite数据库
engine = create_engine('sqlite:///mydatabase.db')

在上述示例中，我们使用create_engine函数创建了一个SQLite数据库引擎对象，并指定了数据库的位置。

3. 执行查询操作

执行查询操作时，我们可以使用SQLAlchemy的execute方法执行SQL语句，并通过fetchall方法获取查询结果。

下面是一个查询所有用户的示例代码：

from sqlalchemy import create_engine

# 使用SQLite数据库
engine = create_engine('sqlite:///mydatabase.db')

# 建立连接
conn = engine.connect()

# 执行查询操作
result = conn.execute('SELECT * FROM users')

# 获取查询结果
rows = result.fetchall()

# 打印查询结果
for row in rows:
    print(f'ID: {row["id"]}, Name: {row["name"]}, Age: {row["age"]}')

# 关闭连接
conn.close()

在上述示例中，我们首先使用connect方法建立了一个连接对象，然后使用execute方法执行了一个查询操作。最后，我们通过调用fetchall方法获取了查询结果，并通过一个循环打印了每一行的内容。

3.1 参数化查询

在执行查询操作时，我们可以使用参数化查询来防止SQL注入攻击。参数化查询使用占位符来表示输入的参数，例如?或:name。

下面是一个使用参数化查询的示例代码：

from sqlalchemy import create_engine

# 使用SQLite数据库
engine = create_engine('sqlite:///mydatabase.db')

# 建立连接
conn = engine.connect()

# 执行参数化查询操作
name = 'John'
result = conn.execute('SELECT * FROM users WHERE name = ?', name)

# 获取查询结果
rows = result.fetchall()

# 打印查询结果
for row in rows:
    print(f'ID: {row["id"]}, Name: {row["name"]}, Age: {row["age"]}')

# 关闭连接
conn.close()

在上述示例中，我们使用?作为占位符，并将参数传递给execute方法。这样可以确保输入的参数不会被误解为SQL语句的一部分。

4. 执行修改操作

除了查询操作，SQLAlchemy还允许我们执行修改操作，例如插入、更新和删除。

下面是一个插入新用户的示例代码：

from sqlalchemy import create_engine

# 使用SQLite数据库
engine = create_engine('sqlite:///mydatabase.db')

# 建立连接
conn = engine.connect()

# 执行插入操作
new_user = {'name': 'Alice', 'age': 25}
conn.execute('INSERT INTO users (name, age) VALUES (:name, :age)', **new_user)

# 关闭连接
conn.close()

在上述示例中，我们通过传递一个包含字段和值的字典来执行插入操作。我们使用了:name和:age作为占位符，并将字典解包传递给execute方法。

类似地，我们可以使用execute方法执行更新和删除操作。