Config
const mysql = require(‘mysql’)
const connectdb = () => {
let connection = mysql.createConnection({
host: '127.0.0.1',
user: 'root',
password: 'chencanyi1015',
port: 3306,
database: 'ccycoder'
})
return connection;
}
module.exports = connectdb;Db.js
const conn = require('./config');
const connection = conn();
// 查询所有数据
let selectAll = (sql, callback)=>{
// sql = getSql(select, table, where, order)
connection.query(sql,(err,result)=>{
if(err){
console.log('错误信息-',err.sqlMessage);
let errNews = err.sqlMessage;
callback(errNews,'');
return;
}
var string=JSON.stringify(result);
var data = JSON.parse(string);
callback('',data);
// console.log(string);
})
}
// 插入一条数据
let insertData = (table,datas,callback)=>{
var fields='';
var values='';
for( var k in datas){
fields+=k+',';
values=values+"'"+datas[k]+"',"
}
fields=fields.slice(0,-1);
values=values.slice(0,-1);
console.log(fields,values);
var sql="INSERT INTO "+table+'('+fields+') VALUES('+values+')';
connection.query(sql,(err,result) => callback(err,result));
}
// 更新一条数据
let updateData = function(table,sets,where,callback){
var _SETS='';
var _WHERE='';
var keys='';
var values='';
for(var k in sets){
_SETS+=k+"='"+sets[k]+"',";
}
_SETS=_SETS.slice(0,-1);
for(var k2 in where){
// _WHERE+=k2+"='"+where[k2]+"' AND ";
_WHERE+= k2+"="+where[k2];
}
// UPDATE user SET Password='321' WHERE UserId=12
//update table set username='admin2',age='55' where id="5";
var sql="UPDATE "+table+' SET '+_SETS+' WHERE '+_WHERE;
console.log(sql);
connection.query(sql,(err,result) => callback(err,result));
}
// 删除一条数据
let deleteData = function(table,where,callback){
var _WHERE='';
for(var k2 in where){
//多个筛选条件使用 _WHERE+=k2+"='"+where[k2]+"' AND ";
_WHERE+= k2+"="+where[k2];
}
// DELETE FROM user WHERE UserId=12 注意UserId的数据类型要和数据库一致
var sql="DELETE FROM "+table+' WHERE '+_WHERE;
connection.query(sql,(err,result) => callback(err,result));
}
let getSql = function(select, table, where, order = 'asc'){
return `select ${select} from ${table} where ${where} order by ${order}`
}
exports.selectAll = selectAll;
exports.insertData = insertData;
exports.deleteData = deleteData;
exports.updateData = updateData;MySql错误 1251 – Client does not support authentication protocol requested by server 解决方案