| | |
| | | getSingleKursTeilnehmer, |
| | | getKursTeilnehmerCount, |
| | | |
| | | getKursOffline, |
| | | setKursOffline, |
| | | |
| | | getUdf, |
| | | |
| | | getKursTeilnehmerRolle, |
| | |
| | | LIMIT ${limit} |
| | | OFFSET ${offset} |
| | | ` |
| | | } |
| | | else { |
| | | } else { |
| | | const ids = await searchLib.search(search) |
| | | if (!ids.length) { |
| | | throw "nothing found" |
| | |
| | | WHERE om.usr_id = ${usr_id} |
| | | AND om.member = 1 |
| | | ` |
| | | log.info(q) |
| | | // log.info(q).catch(console.error) |
| | | const [results] = await pool.query(q) |
| | | return results |
| | | } |
| | | |
| | | async function getKursOffline(obj_id) { |
| | | const pool = await poolP |
| | | const q = `SELECT offline |
| | | FROM ${database}.object_data |
| | | WHERE obj_id = ${obj_id} |
| | | ` |
| | | const [results] = await pool.query(q) |
| | | return results[0] |
| | | } |
| | | |
| | | async function setKursOffline(isOffline, obj_id) { |
| | | const pool = await poolP |
| | | const q = `UPDATE ${database}.object_data |
| | | SET offline = ${isOffline} |
| | | WHERE obj_id = ${obj_id} |
| | | ` |
| | | const [results] = await pool.query(q) |
| | | // return results |
| | | return {offline: isOffline} |
| | | } |
| | | |
| | | /////// UDF //////////////////////////////////////////////////////////////// |
| | |
| | | if (results.length) { |
| | | const {obj_id, title, description} = results[0] |
| | | return obj_id |
| | | } |
| | | else { |
| | | } else { |
| | | return null |
| | | } |
| | | } |
| | |
| | | const [results] = await pool.query(q) |
| | | return results |
| | | } |
| | | |
| | | |
| | | |
| | | /////// STATUS //////////////////////////////////////////////////////////////// |
| | |
| | | |
| | | if (affectedRows1 && affectedRows2) { |
| | | return {status: "ok"} |
| | | } |
| | | else { |
| | | } else { |
| | | throw { |
| | | status: "error", |
| | | reason: {affectedRows1, affectedRows2} |