Skip to content

Commit

Permalink
fix knex query
Browse files Browse the repository at this point in the history
  • Loading branch information
dunnock committed Feb 16, 2020
1 parent 6ca06cc commit 29800b5
Show file tree
Hide file tree
Showing 2 changed files with 15 additions and 14 deletions.
12 changes: 7 additions & 5 deletions node/db/api.js
Original file line number Diff line number Diff line change
@@ -1,14 +1,16 @@
const knex = require('../db/knex.js');

const tasks = knex.from('tasks')
.innerJoin('workers as assignee', 'assignee.id', 'tasks.assignee_id');
function tasks() {
return knex.from('tasks')
.innerJoin('workers as assignee', 'assignee.id', 'tasks.assignee_id');
}

function get_task(id) {
return tasks.where('id', id).select('tasks.id', 'tasks.summary', 'tasks.description', 'assignee.id', 'assignee.name');
return tasks().select('tasks.id', 'tasks.summary', 'tasks.description', 'assignee.id', 'assignee.name').where('id', id);
}

function get_tasks(query) {
return tasks.where(query).select('tasks.id', 'tasks.summary', 'tasks.description', 'assignee.id', 'assignee.name');
function get_tasks() {
return tasks().select('tasks.id', 'tasks.summary', 'tasks.description', 'assignee.id', 'assignee.name');
}

module.exports = {
Expand Down
17 changes: 8 additions & 9 deletions node/rest/api.js
Original file line number Diff line number Diff line change
Expand Up @@ -24,17 +24,16 @@ async function get_task(id, res) {
}

function get_tasks(params, offset, res) {
let query = db.get_tasks();

let query = function (builder) {
if (!!params["assignee_name"]) {
builder.where("assignee.name", "LIKE", "%" + params["assignee_name"] + "%")
}
if (!!params["summary"]) {
builder.where("summary", "LIKE", "%" + params["summary"] + "%")
}
};
if (!!params["assignee_name"]) {
query.where("assignee.name", "LIKE", "%" + params["assignee_name"] + "%")
}
if (!!params["summary"]) {
query.where("summary", "LIKE", "%" + params["summary"] + "%")
}

db.get_tasks(query).offset(offset).limit(20).then(rows => {
query.then(rows => {
res.send(rows)
})
.catch(err => {throw err})
Expand Down

0 comments on commit 29800b5

Please sign in to comment.