Args: sql: Returns: 影响行数
(self, sql)
| 382 | return affect_count |
| 383 | |
| 384 | def execute(self, sql) -> int: |
| 385 | """ |
| 386 | |
| 387 | Args: |
| 388 | sql: |
| 389 | |
| 390 | Returns: 影响行数 |
| 391 | """ |
| 392 | affect_count = None |
| 393 | conn, cursor = None, None |
| 394 | try: |
| 395 | conn, cursor = self.get_connection() |
| 396 | affect_count = cursor.execute(sql) |
| 397 | conn.commit() |
| 398 | except Exception as e: |
| 399 | log.error( |
| 400 | """ |
| 401 | error:%s |
| 402 | sql: %s |
| 403 | """ |
| 404 | % (e, sql) |
| 405 | ) |
| 406 | finally: |
| 407 | self.close_connection(conn, cursor) |
| 408 | |
| 409 | return affect_count |
no test coverage detected