尝试使用 SQLAlchemy 从 <Table> 中删除
Trying to DELETE FROM <Table> using SQLAlchemy
正在尝试使用 SQLAlchemy 从中删除。错误是 sqlalchemy.exc.ArgumentError:主题 table 对于预期的 INSERT、UPDATE 或 DELETE,得到了 'organization'。
组织是我要从中删除的 table 的名称。
这适用于从一个数据库实例获取 table 列表并将行复制到另一个数据库实例的实用程序——但我希望目标 table 为空——登录的用户不是管理员,因此无法进行截断。如果有更好的方法,我很开放。谢谢
调用代码存根:
for item in table_list:
process_tbl(engine_in, engine_out, item["table"])
调用函数:
def process_tbl(engine_in, engine_out, table):
pd = pandas.read_sql(table, engine_in)
print(pd.columns)
stmt = delete(table)
print(stmt)
rows = pd.to_sql(table, engine_out, if_exists="append", index=False)
print("Table: " + table + " inserted rows: " + str(rows))
嗯,我无法让 delete(table)
调用起作用,但因为它是一个简单的删除语句,所以我能够使用:
command = "DELETE FROM " + table
engine_out.execute(command)
正在尝试使用 SQLAlchemy 从中删除。错误是 sqlalchemy.exc.ArgumentError:主题 table 对于预期的 INSERT、UPDATE 或 DELETE,得到了 'organization'。
组织是我要从中删除的 table 的名称。
这适用于从一个数据库实例获取 table 列表并将行复制到另一个数据库实例的实用程序——但我希望目标 table 为空——登录的用户不是管理员,因此无法进行截断。如果有更好的方法,我很开放。谢谢
调用代码存根:
for item in table_list:
process_tbl(engine_in, engine_out, item["table"])
调用函数:
def process_tbl(engine_in, engine_out, table):
pd = pandas.read_sql(table, engine_in)
print(pd.columns)
stmt = delete(table)
print(stmt)
rows = pd.to_sql(table, engine_out, if_exists="append", index=False)
print("Table: " + table + " inserted rows: " + str(rows))
嗯,我无法让 delete(table)
调用起作用,但因为它是一个简单的删除语句,所以我能够使用:
command = "DELETE FROM " + table
engine_out.execute(command)