(query, params)
| 111 | } |
| 112 | |
| 113 | async query(query, params) { |
| 114 | const connection = await this._db.connect(); |
| 115 | let table; |
| 116 | try { |
| 117 | if (params?.length > 0) { |
| 118 | const statement = await connection.prepare(query); |
| 119 | table = await statement.query(...params); |
| 120 | } else { |
| 121 | table = await connection.query(query); |
| 122 | } |
| 123 | } finally { |
| 124 | await connection.close(); |
| 125 | } |
| 126 | return table; |
| 127 | } |
| 128 | |
| 129 | async queryRow(query, params) { |
| 130 | const result = await this.queryStream(query, params); |
no test coverage detected