59 lines
1.4 KiB
JavaScript
59 lines
1.4 KiB
JavaScript
|
const { request } = require('express');
|
||
|
|
var config = require('../config.json');
|
||
|
|
|
||
|
|
const Pool = require('pg').Pool
|
||
|
|
const pool = new Pool({
|
||
|
|
user: config.user,
|
||
|
|
host: config.host,
|
||
|
|
database: config.database,
|
||
|
|
password: config.password,
|
||
|
|
port: config.port
|
||
|
|
})
|
||
|
|
|
||
|
|
const create = (nameF) => {
|
||
|
|
return new Promise((resolve, reject) => {
|
||
|
|
pool.query('INSERT INTO test_type (id, name) VALUES (nextval($1), $2) RETURNING *', ["seq_test_type", nameF], (error, result) => {
|
||
|
|
if(error)
|
||
|
|
reject(error)
|
||
|
|
resolve('success added')
|
||
|
|
})
|
||
|
|
})
|
||
|
|
}
|
||
|
|
|
||
|
|
const del = (id) => {
|
||
|
|
return new Promise((resolve, reject) => {
|
||
|
|
pool.query('DELETE FROM test_type WHERE id = $1', [id], (error, result) => {
|
||
|
|
if(error)
|
||
|
|
reject(error)
|
||
|
|
resolve(result.rows)
|
||
|
|
})
|
||
|
|
})
|
||
|
|
}
|
||
|
|
|
||
|
|
const update = (id, name) => {
|
||
|
|
return new Promise((resolve, reject) => {
|
||
|
|
pool.query('UPDATE test_type SET name = $1 WHERE id = $2', [name, id], (error, result) => {
|
||
|
|
if(error)
|
||
|
|
reject(error)
|
||
|
|
resolve(result.rows)
|
||
|
|
})
|
||
|
|
})
|
||
|
|
}
|
||
|
|
|
||
|
|
const get = () => {
|
||
|
|
return new Promise(function(resolve, reject) {
|
||
|
|
pool.query('SELECT * FROM test_type', (error, results) => {
|
||
|
|
if (error) {
|
||
|
|
reject(error)
|
||
|
|
}
|
||
|
|
resolve(results.rows)
|
||
|
|
})
|
||
|
|
})
|
||
|
|
}
|
||
|
|
|
||
|
|
module.exports = {
|
||
|
|
create,
|
||
|
|
get,
|
||
|
|
del,
|
||
|
|
update
|
||
|
|
}
|