(client)
| 33 | }; |
| 34 | |
| 35 | const recordSchemaVersion = async (client) => { |
| 36 | await ensureMigrationLedger(client); |
| 37 | await client.query( |
| 38 | `INSERT INTO ${migrationTable} (version, label) |
| 39 | VALUES ($1, $2) |
| 40 | ON CONFLICT (version) |
| 41 | DO UPDATE SET label = EXCLUDED.label, applied_at = CURRENT_TIMESTAMP`, |
| 42 | [EXPECTED_SCHEMA_VERSION, EXPECTED_SCHEMA_LABEL] |
| 43 | ); |
| 44 | }; |
| 45 | |
| 46 | const getCurrentSchemaVersion = async (client) => { |
| 47 | await ensureMigrationLedger(client); |
no test coverage detected