()
| 108 | } |
| 109 | |
| 110 | async rollback(): Promise<void> { |
| 111 | debug(`[js::rollback]`) |
| 112 | |
| 113 | try { |
| 114 | await this.client.query({ sql: 'ROLLBACK' }) |
| 115 | } catch (err) { |
| 116 | this.onError(err) |
| 117 | } finally { |
| 118 | this.cleanup?.() |
| 119 | await this.client.end() |
| 120 | } |
| 121 | } |
| 122 | |
| 123 | async createSavepoint(name: string): Promise<void> { |
| 124 | await this.client.query({ sql: `SAVEPOINT ${name}` }).catch(this.onError.bind(this)) |