(session: SessionDep, id: int, sql: str)
| 166 | |
| 167 | |
| 168 | def execSql(session: SessionDep, id: int, sql: str): |
| 169 | ds = session.exec(select(CoreDatasource).where(CoreDatasource.id == id)).first() |
| 170 | return exec_sql(ds, sql, True) |
| 171 | |
| 172 | |
| 173 | def sync_single_fields(session: SessionDep, trans: Trans, id: int): |