-
-
Save jamilhf/400b31a35e9739223d3cbf18adf35df9 to your computer and use it in GitHub Desktop.
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
module.exports = function() { | |
Cypress.Commands.add('sqlServer', (query) => { | |
if(!query) { | |
throw new Error('Query must be set'); | |
} | |
cy.task('sqlServer:execute', query).then(response => { | |
let result = []; | |
const flatten = r => Array.isArray(r) && r.length === 1 ? flatten(r[0]) : r; | |
if(response) { | |
for (let i in response) { | |
result[i] = []; | |
for (let c in response[i]) { | |
result[i][c] = response[i][c].value; | |
} | |
} | |
result = flatten(result); | |
} else { | |
result = response; | |
} | |
return result; | |
}); | |
}); | |
} |
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
const Tedious = require('tedious'); | |
module.exports = (dbConfig) => { | |
return { | |
'sqlServer:execute': (sql) => { | |
const connection = new Tedious.Connection(dbConfig); | |
return new Promise((res, rej) => { | |
connection.on('connect', err => { | |
if (err) { | |
rej(err); | |
} | |
const request = new Tedious.Request(sql, function(err, rowCount, rows) { | |
return err ? rej(err) : res(rows); | |
}); | |
connection.execSql(request); | |
}); | |
}); | |
} | |
} | |
}; |
You save my day! your solution works for me!
awesome! i know it was pain couple days spent till I found this solution
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
I ended up using different plugin I think this one worked for me what are you trying to do ? Run queries and pass those data in your tests ? Tasks was the option in Cypress
const sql = require('mssql');
module.exports = (on) => {
};
constconfigDB = {
server: '',
port: ,
domain: '',
user: '',
password: '',
database: '',
requestTimeout: 300000,
driver: 'tedious',
options: {
enableArithAbort: true,
},
};
async function queryTestDb(query, config) {
await sql.connect(constconfigDB);
}