在SQLAlchemy中，如何返回ResultProxy而不是列表？
在SQLAlchemy中，可以使用execute()方法来执行SQL语句并返回一个ResultProxy对象，而不是返回一个列表。
ResultProxy对象是SQLAlchemy中的一个结果集代理对象，它提供了访问查询结果的方法和属性。要返回ResultProxy对象，可以按照以下步骤进行操作：
- 导入SQLAlchemy库：
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker- 创建数据库引擎和会话：
engine = create_engine('数据库连接字符串')
Session = sessionmaker(bind=engine)
session = Session()- 执行SQL语句并返回
ResultProxy对象：
result_proxy = session.execute('SQL语句')在这个过程中，你需要将数据库连接字符串替换为你实际使用的数据库连接字符串，SQL语句替换为你要执行的SQL查询语句。
通过以上步骤，你可以获得一个ResultProxy对象，然后可以使用fetchone()、fetchall()等方法来获取查询结果。
需要注意的是，返回ResultProxy对象而不是列表的主要优势在于，它可以提供更灵活的结果处理方式。你可以根据需要逐行处理结果，或者使用fetchall()方法一次性获取所有结果。
对于SQLAlchemy的详细介绍和更多用法，请参考腾讯云的SQLAlchemy产品文档：SQLAlchemy产品介绍。
相关·内容
我正在编写一个简单的测试，以验证"id“列中不同值的数量与每个表的行数是否匹配。我希望能够访问对象的特定值，但是当我运行代码并尝试打印变量的值时，我可以看到我的对象是位于...的sqlalchemy.engine.result.ResultProxy对象，而不是人类可读的对象。我已经在SQLAlchemy网站上呆了一个多小时了，我用谷歌搜索了我问题的几个排列，但还没有找到我想要的。
我的带有终端输出的代码如下：
from sqlalchemy import create_engine
engine = create_engine('postgresql://kyle.peko
浏览 0提问于2017-09-23得票数 13
回答已采纳
我正在尝试执行一个按钮，单击该按钮运行python文件，执行朴素的bayes操作，并将值更新到Mysql表。我的代码如下：
Controller.php
public function execute_excel()
{
shell_exec('python D:\laravel-crud\public\admin\mysqlku.py');
return redirect()->back();
}
mysqlku.py
*some codes*
# update the database with new values
logging.basicConf
浏览 0提问于2019-09-19得票数 0
我有一个原始sql查询，它是：
select distinct(user_id) from details_table where event_id in (29,10) and user_id in (7,11,24,45) and epoch_timestamp >= 1433116800 and epoch_timestamp <= 1506816000;
它在psql中返回：
user_id
---------
7
24
(2 rows)
现在，当我通过sqlalchemy运行这个原始的sql查询时，我得到了一个sqlalchemy.engin
浏览 0提问于2018-03-30得票数 2
回答已采纳
1回答
我尝试从insert查询中选择返回值：
HOST_INSERT_QUERY = (
Host.__table__.insert()
.values(
name=bindparam("name"),
source=bindparam("source"),
type=bindparam("type")
)
.returning(Host.__table__.c.id)
)
result = db_conn.e
浏览 1提问于2019-03-25得票数 3
回答已采纳
我试图更改ResultProxy.rowcount属性对于SQLAlchemy的行为。配置为mysql+mysqlconnector。在connect_args ()中设置ClientFlag.FOUND_ROWS={‘客户端_标志’：ClientFlag.FOUND_ROWS}。
问题是它似乎不起作用。我仍然得到匹配的记录数量，而不是影响更新查询。
在FOUND_ROWS中设置SQLAlchemy客户端标志的正确方法是什么？
获得client_flags状态的正确方法是什么？
谢谢,
浏览 1提问于2014-01-12得票数 3
我正在尝试执行sqlalchemy中的SET语句。
>>> from sqlalchemy import create_engine
>>> c = create_engine('postgres://myuser@myremoteserver/mydb?keepalives_idle=4&keepalives_interval=1&keepalives_count=5')
>>> c.execute('SET statement_timeout=1000')
<sqlalchemy.e
浏览 4提问于2013-02-26得票数 1
回答已采纳
3回答
我是hadoop和impala的新手。通过安装并执行以下代码，我成功地连接到impala。这是通过LDAP连接：
from impala.dbapi import connect
from impala.util import as_pandas
conn = connect(host="server.lrd.com",port=21050, database='tcad',auth_mechanism='PLAIN', user="alexcj", use_ssl=True,timeout=20, password="s
浏览 16提问于2016-09-20得票数 2
如何迭代resultproxy对象的每一列？
我已经尝试了这个的答案
for col in class_mapper(obj.__class__).mapped_table.c)
获取此错误：
sqlalchemy.orm.exc.UnmappedClassError: Class 'sqlalchemy.engine.result.RowProxy' is not mapped
浏览 10提问于2018-08-03得票数 0
你好?我试图用SQLAlchemy编写一个查询(它有两个子查询)，但是我得到了一个错误AttributeError：'list‘对象没有属性'l_date’
这是我的代码：
import sqlalchemy as db
from sqlalchemy import func
from sqlalchemy import desc
from sqlalchemy.orm import sessionmaker
from sqlalchemy import or_
from sqlalchemy import and_
from sqlalchemy.sql.expression
浏览 1提问于2018-11-26得票数 3
回答已采纳
1回答
如何使用sqlalchemy获取update语句受影响的行数？(我正在使用mysql和python/金字塔)：
from sqlalchemy.engine.base import ResultProxy
@classmethod
def myupdate(cls, id, myvalue):
DBSession.query(cls).filter(cls.id == id).update({'mycolumn': myvalue})
if ResultProxy.rowcount == 1:
return True
else:
浏览 2提问于2012-10-10得票数 5
回答已采纳
1回答
这个查询有什么问题。
self.connection.execute(select([func.count(table.c.id)]).as_scalar())
这个给我这个回溯
StatementError: Not an executable clause (original cause: ArgumentError:
Not an executable clause) '(SELECT count(table.id) AS count_1 \nFROM agent)'
或者如何使用SqlAlchemy Core获取表中的所有行数
浏览 3提问于2012-12-27得票数 2
回答已采纳
我试图在sqlalchemy中查询像这样的表中的3个字段：
if request.method == 'GET':
search_form = SearchForm()
result = dbSession.execute(
"SELECT * FROM books WHERE (isbn LIKE '%:text%') OR (title LIKE '%:text%') OR (author LIKE '%:text%') LIMIT 10",
浏览 0提问于2018-09-21得票数 7
回答已采纳
我有以下代码：
query = """
SELECT Coalesce((SELECT sp.param_value
FROM sites_params sp
WHERE sp.param_name = 'ci'
AND sp.site_id = s.id
ORDER BY sp.id DESC
LIMIT 1), -1) AS ci
FROM sites s
浏览 17提问于2013-12-23得票数 26
我刚刚开始使用SQLAlchemy来处理现有的Postgres DB。我想要做的是自动加载两个表，执行内部连接，并将列的子集映射到一个对象。为了完成除最后一部分之外的所有工作，我编写了以下代码：
from sqlalchemy.orm import mapper, sessionmaker
from sqlalchemy.sql import join, select
engine = create_engine("postgresql://<username>:@localhost/<DBname>")
metadata = Metadata(eng
浏览 0提问于2011-10-08得票数 3
回答已采纳
这是我想要运行的示例代码：
for i in range(1,2000):
db = create_engine('mysql://root@localhost/test_database')
conn = db.connect()
#some simple data operations
conn.close()
db.dispose()
有没有办法运行它而不从MySQL得到“太多的连接”错误？我已经知道我可以以其他方式处理连接，或者有一个连接池。我只想了解如何正确地关闭来自sqlalchemy的连接。提前感谢！
浏览 1提问于2011-12-27得票数 81
回答已采纳
我正在寻找一种使用SQLAlchemy计算给定查询(可能包括过滤器)返回的行数的方法，但我在网上找到的所有内容都显式地使用了模型(例如here)。我的问题是我没有模型，我只有一个Table对象(因为我要处理的临时表的格式有时会有所不同)。目前，我可以做到以下几点： tbl = Table(mytablename,metadata,autoload=True, autoload_with=myengine, schema=myschemaname)
query = select([tbl])
filters = build_filters(...) #my function that bui
浏览 20提问于2020-01-25得票数 1
回答已采纳
我在SQLAlchemy中有一个非常简单的查询，它工作得很好，类似于： query = session.query(MyModel)
query = query.filter(MyModel.col1 == 'foo')
# .. additional filters here...
result = query.limit(50).all() 这将返回一个list类型的结果--如果不使用session.execute()，如何返回ResultProxy对象呢？我使用query()方法来构造一个带有可选过滤器参数的动态查询，但是ResultProxy对象有一些我想使用的属性(
浏览 9提问于2019-09-11得票数 0
回答已采纳
from sqlalchemy import create_engine, MetaData, Table, Column, select, insert, and_, update, delete
load_dotenv()
engine = create_engine(os.getenv('SQLALCHEMY_DATABASE_URI'))
connection = engine.connect()
metadata = MetaData()
Inventory = Table('inventory', metadata, autoload=True,
浏览 6提问于2021-03-20得票数 2
回答已采纳
3回答
我有：
res = db.engine.execute('select count(id) from sometable')
返回的对象为sqlalchemy.engine.result.ResultProxy。
如何从res获取计数值？
Res不是通过索引访问的，但我已经弄清楚了这一点：
count=None
for i in res:
count = res[0]
break
一定有更简单的方法，对吧？那是什么？我还没发现呢。注:数据库是postgres数据库。
浏览 3提问于2017-06-22得票数 9
回答已采纳
1回答
我希望在使用SQLAlchemy插入postgresql之后获得最后插入记录的ID。这是密码，
insert_record = {list of data}
result = connection.execute(tbl_example.insert().returning(tbl_example.c.id), insert_record)
print result.id
插入做得很好，但我似乎无法获得最后插入的ID，我得到以下错误，
AttributeError：'ResultProxy‘对象没有属性'id’
返回对象中的返回ID位于哪里？
浏览 2提问于2016-09-30得票数 9
1回答
是否可以创建具有游标数据的sqlalchemy模型实例(我正在使用postgresql psycopg2游标)。
问题是，我需要使用游标执行一些操作，然后创建模型实例(基于现有记录)，这样我就可以使用orm layer对它们做一些花哨的事情。
我在文档中找不到这样的东西，有人设法做了这样的事情吗？
浏览 1提问于2014-11-12得票数 1
1回答
我使用以下代码将数据从.csv文件复制到表中：
带有头的csv文件(逗号分隔)：
uid,name,val1,val2,file
SKU001,glasses,blue,metal,block_0
...
创建表：
ih_sql = 'CREATE TABLE "sku_data" (uid VARCHAR, name VARCHAR, val1 VARCHAR, val2 VARCHAR, file VARCHAR, PRIMARY KEY (uid));'
engine.execute(ih_sql)
#<sqlalchemy.engine.resul
浏览 0提问于2018-10-13得票数 2
回答已采纳
sqlalchemy+cx_Oracle可能不在您的域中。不过，如果你能帮我提供几个网站链接/帮助将是很好的。
from sqlalchemy import create_engine
from sqlalchemy import MetaData
from sqlalchemy import Table
import cx_Oracle
engine = create_engine('oracle+cx_oracle://user:passwd@FTSDBLAB')
meta = MetaData()
meta.reflect(bind=engine)
tbl_mgr_th
浏览 0提问于2018-07-05得票数 0
回答已采纳
1回答
我想在flask-SQLAlchemy中执行以下子查询，但不知道如何执行：
SELECT *
FROM (
SELECT *
FROM `articles`
WHERE publisher_id = "bild"
ORDER BY date_time DESC
LIMIT 10
) AS t
ORDER BY RAND( )
LIMIT 2
我知道我可以这样构建查询：
subq = Article.query.filter(Article.publisher_id =='bild').order_by
浏览 0提问于2016-08-17得票数 5
回答已采纳
1回答
环境：
Python 2.7.5
SQLAlchemy 0.9.6
我所做的：
出于不同的原因，我希望将SQLAlchemy源代码包含到我的项目中。主要的原因是以后避免为我的用户提供任何虚拟环境。
好吧，我的结构是这样的：
$ tree . -L 2
myapp
├── libs
│ ├── ...
│ └── sqlalchemy
├── myapp
│ └── ...
└── MyApp.py
好的，我将libs路径添加到系统路径中。
### MyApp.py
# ...
BASE_DIR = os.path.dirname(__file__)
LIBRARY_
浏览 4提问于2014-07-18得票数 3
在SQLAlchemy中，调用存储数据库过程的首选方法是什么？(包括设置参数、接收退出状态和输出变量)
我见过一些使用execute()执行原始数据库字符串的示例，但这可能包含特定于供应商的语法，对吧？
浏览 0提问于2011-07-16得票数 2
回答已采纳
1回答
打印查询Python的结果
、、、、
我的应用程序使用SQLAlchemy/SQL查询数据库。我想打印出查询的结果，但我得到了一个<sqlalchemy.engine.result.ResultProxy object作为响应。
我试用了中的建议，但我得到了"Uncaught exception"
见下面的代码：
query = f"SELECT COUNT(DISTINCT id)"\
f"FROM group"
result = db.session.execute(query)
id_count = result.first()[0]
print(id_coun
浏览 5提问于2022-06-27得票数 -2
我试图使用SQLAlchemy建立到PostgreSQL数据库的连接，执行PostgreSQL查询，并将文件的输出输出到linux中的文件中。
from sqlalchemy import create_engine
import yaml
import csv
outfile = open('/path/filename.csv', 'wb')
outcsv = csv.writer(outfile, delimiter='\t')
with open('config.yml') as f:
cfg = yaml.
浏览 0提问于2018-07-27得票数 6
回答已采纳
我试图调用一个使用SQLAlchemy返回多个结果集的存储过程。如果重要的话，下面我使用的是PyODBC和FreeTDS。我使用一个原始查询调用exec()方法，"exec“调用会话对象上的存储过程，然后返回一个ResultProxy对象。
使用原始的pyodbc游标，我可以调用nextset()函数，以进入下一个结果集。我看不出用从ResultProxy获得的SQLAlchemy做同样的事情。事实上，说：
当所有结果行(如果有的话)都用完时，ResultProxy将关闭DBAPI游标。
是否有一种使用SQLAlchemy读取多个结果集的方法，还是必须使用原始DBAPI执行此查
浏览 0提问于2012-04-28得票数 6
回答已采纳
我正在尝试从数据库(Postgre SQL)导入一些数据，以便在Python中使用它们。我尝试了下面的代码，它似乎与我在互联网上找到的非常相似。 import psycopg2
import sqlalchemy as db
import pandas as pd
engine = db.create_engine('database specifications')
connection = engine.connect()
metadata = db.MetaData()
data = db.Table(tabela, metadata, schema=shema, a
浏览 37提问于2021-05-10得票数 0
回答已采纳
我找不到一种严肃的方法来做一些琐碎的事情。当查询变得复杂时，我发现用普通的老式SQL编写它们更容易：
q = 'SELECT...'
entries = db.session.execute(q)
它返回给我一个<class 'sqlalchemy.engine.result.ResultProxy'>对象。
在这一点上，我想把这个对象当做一个python列表，也许可以做一些jsonify(entries)之类的工作，但这些都不能在框外工作。
在谷歌上搜索一下，我得到了一大堆陈词滥调的解决方案，所以我只能在这里乞求一个好的。
浏览 2提问于2014-08-06得票数 0
我很难通过SQLAlchemy在Server中插入一对多的关系。无论我尝试什么，我都会得到一个Invalid parameter type错误。
import pyodbc
from sqlalchemy import BigInteger, Column, create_engine, ForeignKey, String,
MetaData, Table
meta = MetaData()
logFile = Table('logFile', meta,
Column('id', BigInteger, primary_key=True),
浏览 18提问于2014-11-12得票数 3
回答已采纳
我已经知道，在SQLAlchemy的会话中，update()将无法工作，甚至在使用session.commit之前甚至无法与数据库通信。
这是我的代码，我认为我使用的技能叫做optimistic lock
with Session() as session:
# get one record
object = session.query(Table).where(key=param).limit(1)
content = "here is the calculated value of my business"
# update th
浏览 1提问于2018-12-26得票数 1
回答已采纳
我有一个类似sql的
select * from log where concat_ws('-',year,month,day) between 2017-09-13 and 2017-09-19
这是错误的，因为没有2017-09-13和2017-09-19被“”包围。
在直线中，它将导致错误msg，如
错误:在编译语句时出错:失败: ParseException第2行:0在‘选择’近‘]处缺少EOF (state=42000，code=40000)
但是在PyHive中，它与空结果[]一样正常。顺便说一下，我是通过炼金术来使用它的。
我尝试在echo=True ()
浏览 5提问于2017-09-21得票数 0
我有一个关于Python和sqlalchemy模块的问题。sqlalchemy Python中cursor.rowcount的等价物是什么？
浏览 4提问于2009-03-31得票数 39
回答已采纳
我试图使用原始sqlalchemy Postgres11查询将值插入到text()数据库中。当我通过psql客户机运行以下SQL查询时，它工作正常：
WITH a AS (
INSERT INTO person (id)
VALUES ('a')
RETURNING id
)
INSERT INTO person_info (person_id)
SELECT id
FROM a;
正确插入所有行：
# select id from person;
id
----
a
(1 row)
但是，如果我在sqlalche
浏览 3提问于2020-01-12得票数 1
回答已采纳
1回答
如何查看实际插入了多少行？
engine_str = 'mysql+mysqlconnector://root:mypass@localhost/mydb'
engine = sqlalchemy.create_engine(engine_str, echo=False, encoding='utf-8')
connection = engine.connect()
query = "INSERT INTO TEST(a,b,c)VALUES(1,2,3) ON DUPLICATE KEY UPDATE B = VALUES(B), C = VALUES
浏览 4提问于2016-11-12得票数 0
我正在使用SQLAlchemy从我的数据库中提取数据。更具体地说，我使用db.select方法。因此，我设法仅从列中提取值或仅提取列的名称，但需要以NAME: VALUE格式提取。帮助如何做到这一点？ connection = engine.connect()
metadata = db.MetaData()
report = db.Table('report', metadata, autoload=True, autoload_with=engine)
query = db.select([report])
ResultProxy = c
浏览 32提问于2021-10-26得票数 0
回答已采纳
1回答
我需要通过SQLAlchemy插入/更新批量行。并获得插入的行。
我试着用session.execute这样做：
>>> posts = db.session.execute(Post.__table__.insert(), [{'title': 'dfghdfg', 'content': 'sdfgsdf', 'topic': topic}]*2)
>>> posts.fetchall()
ResourceClosedError
浏览 3提问于2013-01-17得票数 9
回答已采纳
2回答
我正在尝试查询名为“book”的表，并使用原始sql获取该书的标题。目前，表有5列: id、isbn、title、author、p_year。查询返回一个ResultProxy对象，但我想不出从其中提取标题的方法 @app.route("/", methods=['GET', 'POST'])
@app.route("/home", methods=['GET', 'POST'])
def home():
form = SearchForm()
if form.validate_o
浏览 42提问于2019-10-16得票数 1
我需要构建一个复杂的查询，并且我更喜欢使用原始postgres。但是查询返回一个sqlalchemy.engine.result.ResultProxy对象，当我遍历这些对象时，每个对象都是一个sqlalchemy.engine.result.RowProxy对象
search_term = "%{0}%".format(d)
items = db.engine.execute("SELECT inventory.id,inventory.location,inventory.amount,inventory.units, plant_material.variety
浏览 3提问于2015-09-10得票数 4
使用Pandas，我可以非常容易地将数据从数据库读取到dataframe中：
from sqlalchemy import create_engine
import pandas
query = 'SELECT * FROM Table_Name;'
engine = create_engine('...')
df = pandas.read_sql_query(query, engine)
print(df.head())
我想确保在执行.read_sql_query()之后，没有任何连接保持打开，如果查询成功或引发异常，也不重要。
我目前正在：
浏览 2提问于2018-07-04得票数 21
回答已采纳
我正在使用下面的脚本。如果我更改脚本以避免使用bytea数据类型，我就可以很容易地将数据从postgres表复制到python变量中。
但是，如果数据位于bytea列中，我会遇到一个名为memory的奇怪对象，它会让我感到困惑。
下面是我在anaconda python 3.5.2上运行的脚本：
# bytea.py
import sqlalchemy
# I should create a conn
db_s = 'postgres://dan:dan@127.0.0.1/dan'
conn = sqlalchemy.create_engine(db_s).connect
浏览 23提问于2017-01-20得票数 3
回答已采纳
我对整个ORM主题相当陌生，而且我已经搜索过论坛和文档。这个问题是关于一个使用SQLAlchemy作为PostgreSQL的对象关系管理的flask应用程序。
__init__.py包含以下行：
db = SQLAlchemy()
创建的对象在其他文件中被引用以访问数据库。
模型有一个保存功能：
def save(self): db.session.add(self) db.session.commit()
还有一个更新函数：
def update(self): for var_name in self.__dict__.keys(): if var_n
浏览 0提问于2018-01-06得票数 1
回答已采纳
例如，当我执行以下代码时，结果数据类型为str
result = engine.execute('''
SELECT CAST('{"foo": "bar"}' as JSON) as `json`
''')
row = result.fetchone()
json = row[0]
type(json)
具有str类型的json列值并不是元编程友好的。
问题
是否有任何方法从result (或ResultProxy的一个实例)获取信息，每个列的类型是什么？
环境
MySQL: 8.0.11
浏览 0提问于2019-03-13得票数 0
回答已采纳
1回答
我在Python中使用postgreSQL (使用烧瓶和SQLAlchemy作为ORM)，我正在实现一个网站，该网站要求用户注册和登录，注册后我希望用户自动登录，为此我使用了：
# storing id in session
rows = db.execute("SELECT * FROM users WHERE username = :username ",
{"username": request.form.get("username")})
session["user_id"] = rows[0]["id
浏览 0提问于2018-06-26得票数 1
回答已采纳
我可以使用以下脚本从我的jupyter笔记本成功连接到SQL Server Management Studio： from sqlalchemy import create_engine
import pyodbc
import csv
import time
import urllib
params = urllib.parse.quote_plus('''DRIVER={SQL Server Native Client 11.0};
SERVER=SV;
浏览 25提问于2019-12-13得票数 2
回答已采纳
我正在慢慢地尝试使用烧瓶、Marshmallow、SQLAlchemy和SQLite3构建一个小型Rest。在最近的某个时候，我对users表的简单"Get“调用似乎有效，但后来我在尝试使用时开始一遍又一遍地得到相同的论点。
错误："TypeError: string参数没有编码“
在我的浏览器中尝试localhost:5000/users时会发生这种情况。确切的行是96“user= Users.query.all()”，根据堆栈跟踪(我将在下面发布)，确切的函数似乎是SQLAlchemy.query()。
我通过很多教程尝试过这个简单的方法，但是没有用。这可能是Python
浏览 2提问于2018-03-08得票数 0
回答已采纳
我试图根据使用bindparam的字典列表执行更新，但我不知道为什么这个示例不起作用：
import sqlalchemy
from sqlalchemy import Table, exc, and_
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.sql.expression import bindparam
from sqlalchemy.orm import sessionmaker
con_string = 'mysql+mysqlconnector://{login}:{pas
浏览 3提问于2017-08-09得票数 3
回答已采纳
我正在通过一个在后端利用pymssql的库从SQL Server数据库下载一些数据。curson.execute("""<QUERY BODY>""")的结果是一个sqlalchemy.engine.result.ResultProxy对象。如何检查查询结果是否为空，因此没有行？
cur = ff.sql.create_engine(server=dw.address, db=dw.BI_DW,
login=":".join([os.environ["
浏览 4提问于2016-06-08得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
