(pool: mysql.Pool, queryTimeout: number)
| 171 | } |
| 172 | |
| 173 | function mysqlPool(pool: mysql.Pool, queryTimeout: number): Pool { |
| 174 | return { |
| 175 | async getConnection(): Promise<Conn> { |
| 176 | return mysqlConn(await pool.getConnection(), queryTimeout); |
| 177 | }, |
| 178 | end() { |
| 179 | pool.end(); |
| 180 | }, |
| 181 | }; |
| 182 | } |
| 183 | |
| 184 | function mysqlConn(conn: mysql.PoolConnection, queryTimeout: number): Conn { |
| 185 | return { |