4417510579

Build Type

push

github

Committed by GitHub

Commit Message

chore(main): release 11.0.7 (#1221)

Run Details

259 of 259 branches covered (100.0%)

Branch coverage included in aggregate %.

527 of 527 relevant lines covered (100.0%)

14.21 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

100.0

/src/migrate.js

/* eslint-disable no-console */
const mssql = require("mssql");
const path = require("upath");
const pg = require("pg");
const pgParse = require("pg-connection-string").parse;
const Postgrator = require("postgrator");
const getConfig = require("./config");

/**
 * @author Frazer Smith
 * @description Run Postgrator to execute SQL queries in ../migrations/** directories.
 */
async function migrate() {
        let client;
        let db;
        let postgrator;

        try {
                const { database } = await getConfig();

                db = database.client.toLowerCase();

                switch (db) {
                        case "postgresql":
                                client = new pg.Client(database.connection);
                                postgrator = new Postgrator({
                                        migrationPattern: path.join(
                                                __dirname,
                                                "../migrations/postgres/*"
                                        ),
                                        driver: "pg",
                                        database: pgParse(database.connection).database,
                                        execQuery: /* istanbul ignore next */ (query) =>
                                                client.query(query),
                                });
                                break;

                        case "mssql":
                        default:
                                client = new mssql.ConnectionPool(database.connection);
                                postgrator = new Postgrator({
                                        migrationPattern: path.join(
                                                __dirname,
                                                "../migrations/mssql/*"
                                        ),
                                        driver: "mssql",
                                        database: client.config.database,
                                        execQuery: /* istanbul ignore next */ async (query) => {
                                                const request = new mssql.Request(client);
                                                const result = await request.batch(query);

                                                return {
                                                        rows: result?.recordset ? result.recordset : result,
                                                };
                                        },
                                });
                                break;
                }

                await client.connect();

                // Migrate to latest version
                const migrationResult = await postgrator.migrate();

                /* istanbul ignore else */
                if (migrationResult.length === 0) {
                        console.log("No migrations run, already on latest schema version");
                }

                console.log("Migration complete");
        } catch (err) {
                console.error(err);
                process.exitCode = 1;
        } finally {
                // Close the DB connection
                switch (db) {
                        case "postgresql":
                                await client.end();
                                break;

                        case "mssql":
                        default:
                                await client.close();
                                break;
                }
        }
}

// If file called directly, then run function
/* istanbul ignore if */
if (require.main === module) {
        migrate();
}

module.exports = migrate;

1	/* eslint-disable no-console */
2	const mssql = require("mssql");	1✔
3	const path = require("upath");	1✔
4	const pg = require("pg");	1✔
5	const pgParse = require("pg-connection-string").parse;	1✔
6	const Postgrator = require("postgrator");	1✔
7	const getConfig = require("./config");	1✔
8
9	/**
10	* @author Frazer Smith
11	* @description Run Postgrator to execute SQL queries in ../migrations/** directories.
12	*/
13	async function migrate() {
14	let client;
15	let db;
16	let postgrator;
17
18	try {	4✔
19	const { database } = await getConfig();	4✔
20
21	db = database.client.toLowerCase();	4✔
22
23	switch (db) {	4✔
24	case "postgresql":
25	client = new pg.Client(database.connection);	2✔
26	postgrator = new Postgrator({	2✔
27	migrationPattern: path.join(
28	__dirname,
29	"../migrations/postgres/*"
30	),
31	driver: "pg",
32	database: pgParse(database.connection).database,
33	execQuery: /* istanbul ignore next */ (query) =>
34	client.query(query),
35	});
36	break;	2✔
37
38	case "mssql":
39	default:
40	client = new mssql.ConnectionPool(database.connection);	2✔
41	postgrator = new Postgrator({	2✔
42	migrationPattern: path.join(
43	__dirname,
44	"../migrations/mssql/*"
45	),
46	driver: "mssql",
47	database: client.config.database,
48	execQuery: /* istanbul ignore next */ async (query) => {
49	const request = new mssql.Request(client);
50	const result = await request.batch(query);
51
52	return {
53	rows: result?.recordset ? result.recordset : result,
54	};
55	},
56	});
57	break;	2✔
58	}
59
60	await client.connect();	4✔
61
62	// Migrate to latest version
63	const migrationResult = await postgrator.migrate();	4✔
64
65	/* istanbul ignore else */
66	if (migrationResult.length === 0) {	2✔
67	console.log("No migrations run, already on latest schema version");	2✔
68	}
69
70	console.log("Migration complete");	2✔
71	} catch (err) {
72	console.error(err);	2✔
73	process.exitCode = 1;	2✔
74	} finally {
75	// Close the DB connection
76	switch (db) {	4✔
77	case "postgresql":
78	await client.end();	2✔
79	break;	2✔
80
81	case "mssql":
82	default:
83	await client.close();	2✔
84	break;	2✔
85	}
86	}
87	}
88
89	// If file called directly, then run function
90	/* istanbul ignore if */
91	if (require.main === module) {	1✔
92	migrate();
93	}
94
95	module.exports = migrate;	1✔

Fdawgs / ydh-myydh-crud-api / 4417510579

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous