-
Notifications
You must be signed in to change notification settings - Fork 24
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
d0e13a7
commit 1efef64
Showing
12 changed files
with
1,670 additions
and
32 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,26 @@ | ||
| const { exec } = require('child_process'); | ||
| const fs = require('fs'); | ||
| const path = require('path'); | ||
|
|
||
| const packagePath = path.join(__dirname, 'package.json'); | ||
| const package = JSON.parse(fs.readFileSync(packagePath, 'utf8')); | ||
| const pgEnv = package.libpgQueryConfig.PGENV; | ||
|
|
||
| // Construct the Mocha command | ||
| const testCommand = `mocha --timeout 5000 "test/${pgEnv}.test.js"`; | ||
|
|
||
| console.log(`Running tests: ${pgEnv}`); | ||
| console.log(`Executing: ${testCommand}`); | ||
|
|
||
| // Execute the Mocha command | ||
| exec(testCommand, (error, stdout, stderr) => { | ||
| if (error) { | ||
| console.error(`Error: ${error.message}`); | ||
| return; | ||
| } | ||
| if (stderr) { | ||
| console.error(`stderr: ${stderr}`); | ||
| return; | ||
| } | ||
| console.log(stdout); | ||
| }); |
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
File renamed without changes.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,143 @@ | ||
| const query = require("../"); | ||
| const { expect } = require("chai"); | ||
| const { omit, cloneDeepWith } = require("lodash"); | ||
|
|
||
| describe("Queries", () => { | ||
| describe("Sync Parsing", () => { | ||
| it("should return a single-item parse result for common queries", () => { | ||
| const queries = ["select 1", "select null", "select ''", "select a, b"]; | ||
| const results = queries.map(query.parseQuerySync); | ||
| results.forEach((res) => { | ||
| expect(res.stmts).to.have.lengthOf(1); | ||
| }); | ||
|
|
||
| // Do some rough asserting on the shape of the result. | ||
| // These tests aren't really meant to test the parsing functionality | ||
| // itself, but doing a bit for sanity doesn't hurt. | ||
| const selectedDatas = results.map( | ||
| (it) => it.stmts[0].stmt.SelectStmt.targetList | ||
| ); | ||
|
|
||
| expect(selectedDatas[0][0].ResTarget.val.A_Const.ival.ival).to.eq( | ||
| 1 | ||
| ); | ||
| expect(selectedDatas[1][0].ResTarget.val.A_Const.isnull).to.eq( | ||
| true | ||
| ); | ||
| expect(selectedDatas[2][0].ResTarget.val.A_Const.sval.sval).to.eq( | ||
| "" | ||
| ); | ||
| expect(selectedDatas[3]).to.have.lengthOf(2); | ||
| }); | ||
|
|
||
| it("should support parsing multiple queries", () => { | ||
| const res = query.parseQuerySync("select 1; select null;"); | ||
| const changedProps = [ | ||
| "stmt_len", | ||
| "stmt_location", | ||
| "stmt.SelectStmt.targetList[0].ResTarget.location", | ||
| "stmt.SelectStmt.targetList[0].ResTarget.val.A_Const.location", | ||
| ]; | ||
| const removeChangedProps = (stmt) => omit(stmt, changedProps); | ||
| expect(res.stmts.map(removeChangedProps)).to.deep.eq([ | ||
| ...query.parseQuerySync("select 1;").stmts.map(removeChangedProps), | ||
| ...query.parseQuerySync("select null;").stmts.map(removeChangedProps), | ||
| ]); | ||
| }); | ||
|
|
||
| it("should not parse a bogus query", () => { | ||
| expect(() => query.parseQuerySync("NOT A QUERY")).to.throw(Error); | ||
| }); | ||
| }); | ||
|
|
||
| describe("Async parsing", () => { | ||
| it("should return a promise resolving to same result", async () => { | ||
| const testQuery = "select * from john;"; | ||
| const resPromise = query.parseQuery(testQuery); | ||
| const res = await resPromise; | ||
|
|
||
| expect(resPromise).to.be.instanceof(Promise); | ||
| expect(res).to.deep.eq(query.parseQuerySync(testQuery)); | ||
| }); | ||
|
|
||
| it("should reject on bogus queries", async () => { | ||
| return query.parseQuery("NOT A QUERY").then( | ||
| () => { | ||
| throw new Error("should have rejected"); | ||
| }, | ||
| (e) => { | ||
| expect(e).instanceof(Error); | ||
| expect(e.message).to.match(/NOT/); | ||
| } | ||
| ); | ||
| }); | ||
| }); | ||
|
|
||
| describe("Fingerprint", () => { | ||
| context("sync", () => { | ||
| it("should not fingerprint a bogus query", () => { | ||
| expect(() => query.fingerprintSync("NOT A QUERY")).to.throw(Error); | ||
| }); | ||
|
|
||
| it("should fingerprint a query", () => { | ||
| const queries = ["select 1", "select null", "select ''", "select a, b"]; | ||
| const results = queries.map(query.fingerprintSync); | ||
|
|
||
| results.forEach((res) => { | ||
| expect(res).to.have.lengthOf(16); | ||
| }); | ||
| }); | ||
| }); | ||
|
|
||
| context("async", () => { | ||
| it("should not fingerprint a bogus query", () => { | ||
| return query.fingerprint("NOT A QUERY").then( | ||
| () => { | ||
| throw new Error("should have rejected"); | ||
| }, | ||
| (e) => { | ||
| expect(e).instanceof(Error); | ||
| expect(e.message).to.match(/NOT/); | ||
| } | ||
| ); | ||
| }); | ||
|
|
||
| it("should fingerprint a query", async () => { | ||
| const queries = ["select 1", "select null", "select ''", "select a, b"]; | ||
| const results = await Promise.all(queries.map(query.fingerprint)); | ||
|
|
||
| results.forEach((res) => { | ||
| expect(res).to.have.lengthOf(16); | ||
| }); | ||
| }); | ||
| }); | ||
| }); | ||
| }); | ||
|
|
||
| describe("PlPgSQL (async)", () => { | ||
| it("should parse a function", async () => { | ||
| const testFunction = ` | ||
| CREATE FUNCTION t() RETURNS trigger AS | ||
| $BODY$ | ||
| DECLARE | ||
| resultVal integer; | ||
| finalVal integer; | ||
| BEGIN | ||
| resultVal = 0; | ||
| IF (resultVal >= 5) | ||
| THEN finalVal = 'Yes'; | ||
| ELSE finalVal = 'No'; | ||
| END IF; | ||
| RETURN finalVal; | ||
| END; | ||
| $BODY$ | ||
| LANGUAGE plpgsql; | ||
| `; | ||
|
|
||
| const resPromise = query.parsePlPgSQL(testFunction); | ||
| const res = await resPromise; | ||
|
|
||
| expect(resPromise).to.be.instanceof(Promise); | ||
| expect(res).to.deep.have.property("0.PLpgSQL_function"); | ||
| }); | ||
| }); |
Oops, something went wrong.