当前位置: 首页 > 工具软件 > strDB > 使用案例 >

db_connection.execute(sql_str, *args)执行sql语句

文志学
2023-12-01

在学习sqlchemy的时候遇到db_connection.execute(sql_str, *args),不太理解这个不定参数怎么传入的,查询得知:
在db_connection.execute(sql_str, *args)语句中,sql_str是SQL查询语句,*args是一个元组,包含查询语句中占位符需要的参数。这些参数将按照位置的顺序与查询语句中的占位符一一对应。例如,如果查询语句中有一个占位符%s,则第一个元素将替换该占位符。

在调用execute方法时,*args将使用元组展开并传递给该方法作为参数。因此,execute方法将接收元组中的值,并使用它们来替换查询语句中的占位符。

代码举例:

from sqlalchemy import create_engine
engine = create_engine()
db_connection = engine.connect()
sql_str='select * from volumes where update_at<%s;'
def func(sql_str,*args):
    db_connection.execute(sql_str, *args)  
func(sql_str,2022)

在这段代码中,*args是将参数以元组的形式进行传递,*是用于对元组或列表进行解包的操作符。
通过SQLAlchemy模块创建了一个数据库引擎对象engine,并且通过引擎对象创建了一个数据库连接对象db_connection。然后定义了一个函数func,函数中调用了db_connection.execute()方法执行SQL语句。

在主程序中,调用函数func并传入两个参数,第一个参数是SQL语句字符串sql_str,表示从表volumes中查询update_at字段小于2022的所有数据。第二个参数*args中传入了一个数值2022。

因为args在函数调用时加上了符号,所以在func()函数内部,*args表示将传入的参数打散成一个个单独的参数,即db_connection.execute(sql_str, 2022),表示执行的SQL语句为:

select * from volumes where update_at<2022;
 类似资料: