n0rdye/puzzle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update

Browse Source 
added:
db users
admin user edit
cleared router
cleared sql
new sid creation
new log creation
cleaned code (a bit) (
removed db check value function and replaced with get one value.
This commit is contained in:
N0rdye
2023-07-08 03:47:32 +05:00
parent c25bd2e274
commit e628d10ec7
20 changed files with 902 additions and 563 deletions
Download Patch File Download Diff File Expand all files Collapse all files

126
db.js
View File

@ -1,126 +1,98 @@
const mysql = require('mysql');
const vars = require('./vars');
const db_host = "localhost";
const logcon = mysql.createConnection({
host: 'db',
const admin = mysql.createConnection({
host: db_host,
user: 'admin',
password: '484',
database: 'users'
});
const user = mysql.createConnection({
host: db_host,
user: 'user',
password: 'user',
database: 'users'
});
logcon.connect();
// check_for
module.exports.cv = (table,key,value,callback) => {
logcon.query(`SELECT * FROM ${table}`, (err, rows, fields) => {
let log = '';
if (err) {
console.log("sql err");
throw err;
}
rows.forEach(rec => {
if (rec[key]==value){
log = rec[key];
return;
}
});
if (log != ''){
callback(log);
}
else{
callback(null);
}
})
db = (prevs = false) => {
if(prevs) return admin;
else return user;
}
// module.exports.ccv = (table,ekey,key,value,callback) => {
// logcon.query('SELECT * FROM `'+table+'`', (err, rows, fields) => {
// let log = '';
// if (err) {
// console.log("sql err");
// throw err;
// }
// rows.forEach(rec => {
// if (rec[key]==value){
// log = rec[key];
// return;
// }
// });
// if (log != ''){
// callback(log);
// }
// else{
// callback(null);
// }
// })
// }
admin.connect();
user.connect();
module.exports.dl = (table,key,value,callback) => {
module.exports.dl = (table,key,value,callback,prevs = false) => {
// console.log('SELECT * FROM `'+table+'` WHERE `'+key+'` = '+value);
logcon.query(`DELETE FROM ${table} WHERE ${key} = ${value}`, (err, rows, fields) => {
db(prevs).query(`DELETE FROM ${table} WHERE ${key} = ${value}`, (err, rows, fields) => {
if (err) {
console.log("sql err");
throw err;
}else{
callback(rows);
if(callback)callback(rows);
}
})
}
// get_from
module.exports.gv = (table,key,value,callback) => {
// get values where
module.exports.gv = (table,key,value,callback,prevs = false) => {
// console.log('SELECT * FROM `'+table+'` WHERE `'+key+'` = '+value);
logcon.query(`SELECT * FROM ${table} WHERE ${key} = ${value}`, (err, rows, fields) => {
db(prevs).query(`SELECT * FROM ${table} WHERE ${key} = ${value}`, (err, rows, fields) => {
if (err) {
console.log("sql err");
throw err;
}else{
callback(rows);
if(callback)callback(rows);
}
})
}
module.exports.gav = (table,callback) => {
// get all from table
module.exports.gav = (table,limit = "0",callback,prevs = false) => {
// console.log('SELECT * FROM `'+table+'` WHERE `'+key+'` = '+value);
logcon.query(`SELECT * FROM ${table} WHERE 1`, (err, rows, fields) => {
limit = (limit != "0")? `LIMIT ${limit}`:"";
db(prevs).query(`SELECT * FROM ${table} WHERE 1 ${limit}`, (err, rows, fields) => {
if (err) {
console.log("sql err");
throw err;
}else{
callback(rows);
if(callback)callback(rows);
}
})
}
module.exports.ggv = (table,ekey,key,value,callback) => {
// get value where
module.exports.ggv = (table,ekey,key,value,callback,prevs = false) => {
// console.log('SELECT * FROM `'+table+'` WHERE `'+key+'` = '+value);
logcon.query(`SELECT ${ekey} FROM ${table} WHERE ${key} = ${value}`, (err, rows, fields) => {
db(prevs).query(`SELECT ${ekey} FROM ${table} WHERE ${key} = ${value}`, (err, rows, fields) => {
if (err) {
console.log("sql err");
throw err;
}else{
callback(rows);
if(callback)callback(rows);
}
})
}
// set_in
module.exports.sv = (table,key,value,ekey,evalue,callback) => {
logcon.query(`UPDATE ${table} SET ${key} = '${value}' WHERE ${ekey} = '${evalue}'`, (err , rows) => {
// set value where
module.exports.sv = (table,key,value,ekey,evalue,callback,prevs = false) => {
db(prevs).query(`UPDATE ${table} SET ${key} = '${value}' WHERE ${ekey} = '${evalue}'`, (err , rows) => {
// console.log("UPDATE `"+table+"` SET `"+key+"` = '"+value+"' WHERE `"+ekey+"` = '"+evalue+"'");
if (err) {
console.log("sql err");
throw err;
}else{
callback(rows);
if(callback)callback(rows);
}
})
}
module.exports.nr = (table,keys,values) =>{
// new record
module.exports.nr = (table,keys,values,prevs = false) =>{
// console.log('INSERT INTO `'+table+'`('+keys+') VALUES ('+values+')');
logcon.query(`INSERT INTO ${table} (${keys}) VALUES (${values})`,(err,res) =>{
db(prevs).query(`INSERT INTO ${table} (${keys}) VALUES (${values})`,(err,res) =>{
if (err) {
console.log("sql err");
throw err;
@ -129,15 +101,27 @@ module.exports.nr = (table,keys,values) =>{
}
})
}
module.exports.glv = (table,last_value,callback) =>{
// get last value
module.exports.glv = (table,last_value,callback,prevs = false) =>{
// console.log('INSERT INTO `'+table+'`('+keys+') VALUES ('+values+')');
logcon.query(`SELECT * FROM ${table} ORDER BY ${last_value} DESC LIMIT 1;`,(err,res) =>{
db(prevs).query(`SELECT * FROM ${table} ORDER BY ${last_value} DESC LIMIT 1;`,(err,rows) =>{
if (err) {
console.log("sql err");
throw err;
}else{
callback(res);
if(callback)callback(rows);
}
})
}
module.exports.crc = (table,callback,prevs = false) =>{
// console.log('INSERT INTO `'+table+'`('+keys+') VALUES ('+values+')');
db(prevs).query(`SELECT COUNT(*) FROM ${table}`,(err,rows) =>{
if (err) {
console.log("sql err");
throw err;
}else{
if(callback)callback(rows[0]["COUNT(*)"]);
}
})
}