(self, db_name, query)
| 85 | return [column['name'] for column in columns] |
| 86 | |
| 87 | def execute_query(self, db_name, query): |
| 88 | engine = self.engines[db_name] |
| 89 | with engine.connect() as connection: |
| 90 | result = connection.execute(query) |
| 91 | return result.fetchall() |
| 92 | |
| 93 | |
| 94 | if __name__ == "__main__": |