(self, db, sql)
| 78 | return True, row_builder |
| 79 | |
| 80 | def getInsertBatchBuilder(self, db, sql): |
| 81 | if not self.sdk: |
| 82 | return False, "please init driver first" |
| 83 | status = sql_router_sdk.Status() |
| 84 | rows_builder = self.sdk.GetInsertRows(db, sql, status) |
| 85 | if status.code != 0: |
| 86 | return False, status.msg |
| 87 | return True, rows_builder |
| 88 | |
| 89 | def executeInsert(self, db, sql, row_builder = None): |
| 90 | if not self.sdk: |