| 123 | return self.executeQuery(db, sql, requestRow) |
| 124 | |
| 125 | def executeQuery(self, db, sql, row_builder = None): |
| 126 | if not self.sdk: |
| 127 | return False, "please init driver first" |
| 128 | |
| 129 | status = sql_router_sdk.Status() |
| 130 | if row_builder is not None: |
| 131 | rs = self.sdk.ExecuteSQL(db, sql, row_builder, status) |
| 132 | else: |
| 133 | rs = self.sdk.ExecuteSQL(db, sql, status) |
| 134 | if status.code != 0: |
| 135 | return False, status.msg |
| 136 | else: |
| 137 | return True, rs |
| 138 | |
| 139 | def getRowBySp(self, db, sp): |
| 140 | status = sql_router_sdk.Status() |