rework postUser
This commit is contained in:
parent
22f46999d3
commit
a9ee960e1f
21
lib/getUser.js
Normal file
21
lib/getUser.js
Normal file
@ -0,0 +1,21 @@
|
|||||||
|
const sql = require('./mysql')
|
||||||
|
|
||||||
|
function getUserAccounts(user) {
|
||||||
|
let data = sql.query(`SELECT
|
||||||
|
userAccounts.username,
|
||||||
|
streams.streamName,
|
||||||
|
streams.streamURL
|
||||||
|
FROM users
|
||||||
|
INNER JOIN userAccounts
|
||||||
|
ON users.idusers = userAccounts.userID
|
||||||
|
INNER JOIN streams
|
||||||
|
ON userAccounts.stream = streams.streamName
|
||||||
|
WHERE users.username = '${user}'`)
|
||||||
|
// console.log(data)
|
||||||
|
return data
|
||||||
|
}
|
||||||
|
|
||||||
|
module.exports = {
|
||||||
|
getUserAccounts
|
||||||
|
}
|
||||||
|
|
19
lib/mysql.js
19
lib/mysql.js
@ -1,22 +1,3 @@
|
|||||||
// var mysql = require('mysql');
|
|
||||||
|
|
||||||
|
|
||||||
// var connection = mysql.createConnection({
|
|
||||||
// host: 'localhost',
|
|
||||||
// port: 3306,
|
|
||||||
// user: 'root',
|
|
||||||
// password: 'example',
|
|
||||||
// database: 'BBLB_DNS',
|
|
||||||
// insecureAuth: true
|
|
||||||
// })
|
|
||||||
|
|
||||||
// connection.connect(function (err) {
|
|
||||||
// if (err) throw err;
|
|
||||||
// });
|
|
||||||
|
|
||||||
// module.exports = connection;
|
|
||||||
|
|
||||||
|
|
||||||
var mysql = require('sync-mysql');
|
var mysql = require('sync-mysql');
|
||||||
|
|
||||||
var connection = new mysql({
|
var connection = new mysql({
|
||||||
|
@ -2,30 +2,14 @@ var express = require('express');
|
|||||||
var router = express.Router();
|
var router = express.Router();
|
||||||
|
|
||||||
const sql = require('../lib/mysql')
|
const sql = require('../lib/mysql')
|
||||||
|
|
||||||
|
const { getUserAccounts } = require('../lib/getUser')
|
||||||
|
|
||||||
/* POST postUser page. */
|
/* POST postUser page. */
|
||||||
router.post('/', async function (req, res, next) {
|
router.post('/', async function (req, res, next) {
|
||||||
sql.query(`SELECT
|
let data = await getUserAccounts(req.body.username)
|
||||||
userAccounts.username,
|
res.send(data)
|
||||||
streams.streamName,
|
|
||||||
streams.streamURL
|
|
||||||
FROM users
|
|
||||||
INNER JOIN userAccounts
|
|
||||||
ON users.idusers = userAccounts.userID
|
|
||||||
INNER JOIN streams
|
|
||||||
ON userAccounts.stream = streams.streamName
|
|
||||||
WHERE users.username = '${req.body.username}'`, function (err, tt) {
|
|
||||||
if (err) {
|
|
||||||
console.log("User Not Found: ", err);
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
if (tt.length === 0) {
|
|
||||||
res.send('User Not Found')
|
|
||||||
} else {
|
|
||||||
console.log(tt);
|
|
||||||
res.send(tt);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
});
|
});
|
||||||
|
|
||||||
module.exports = router;
|
module.exports = router;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user