119 lines
3.1 KiB
JavaScript
119 lines
3.1 KiB
JavaScript
const mysql = require('mysql');
|
|
const vars = require('./vars');
|
|
|
|
const logcon = mysql.createConnection({
|
|
host: 'localhost',
|
|
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);
|
|
}
|
|
})
|
|
}
|
|
|
|
// 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);
|
|
// }
|
|
// })
|
|
// }
|
|
|
|
module.exports.dl = (table,key,value,callback) => {
|
|
// console.log('SELECT * FROM `'+table+'` WHERE `'+key+'` = '+value);
|
|
logcon.query('DELETE FROM `'+table+'` WHERE `'+key+'` = '+value, (err, rows, fields) => {
|
|
if (err) {
|
|
console.log("sql err");
|
|
throw err;
|
|
}else{
|
|
callback(rows);
|
|
}
|
|
})
|
|
}
|
|
|
|
// get_from
|
|
module.exports.gv = (table,key,value,callback) => {
|
|
// console.log('SELECT * FROM `'+table+'` WHERE `'+key+'` = '+value);
|
|
logcon.query('SELECT * FROM `'+table+'` WHERE `'+key+'` = '+value, (err, rows, fields) => {
|
|
if (err) {
|
|
console.log("sql err");
|
|
throw err;
|
|
}else{
|
|
callback(rows);
|
|
}
|
|
})
|
|
}
|
|
|
|
|
|
module.exports.ggv = (table,ekey,key,value,callback) => {
|
|
// console.log('SELECT * FROM `'+table+'` WHERE `'+key+'` = '+value);
|
|
logcon.query('SELECT '+ekey+' FROM `'+table+'` WHERE `'+key+'` = '+value, (err, rows, fields) => {
|
|
if (err) {
|
|
console.log("sql err");
|
|
throw err;
|
|
}else{
|
|
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) => {
|
|
// console.log("UPDATE `"+table+"` SET `"+key+"` = '"+value+"' WHERE `"+ekey+"` = '"+evalue+"'");
|
|
if (err) {
|
|
console.log("sql err");
|
|
throw err;
|
|
}else{
|
|
callback(rows);
|
|
}
|
|
})
|
|
}
|
|
|
|
module.exports.nr = (table,keys,values) =>{
|
|
// console.log('INSERT INTO `'+table+'`('+keys+') VALUES ('+values+')');
|
|
logcon.query('INSERT INTO `'+table+'`('+keys+') VALUES ('+values+')',(err,res) =>{
|
|
if (err) {
|
|
console.log("sql err");
|
|
throw err;
|
|
}else{
|
|
return true;
|
|
}
|
|
})
|
|
} |