Execute SQL query Args: ds: Data source instance sql: SQL query statement Returns: Query results
(self, sql: str)
| 1119 | return finish_record(session=session, record_id=self.record.id) |
| 1120 | |
| 1121 | def execute_sql(self, sql: str): |
| 1122 | """Execute SQL query |
| 1123 | |
| 1124 | Args: |
| 1125 | ds: Data source instance |
| 1126 | sql: SQL query statement |
| 1127 | |
| 1128 | Returns: |
| 1129 | Query results |
| 1130 | """ |
| 1131 | SQLBotLogUtil.info(f"Executing SQL on ds_id {self.ds.id}: {sql}") |
| 1132 | try: |
| 1133 | return exec_sql(ds=self.ds, sql=sql, origin_column=False) |
| 1134 | except Exception as e: |
| 1135 | if isinstance(e, ParseSQLResultError): |
| 1136 | raise e |
| 1137 | else: |
| 1138 | err = traceback.format_exc(limit=1, chain=True) |
| 1139 | raise SQLBotDBError(err) |
| 1140 | |
| 1141 | def pop_chunk(self): |
| 1142 | try: |
no test coverage detected