先上目录结构：
简单描述一下，主要的目录文件
config /
dbConfig: 文件配置了，数据库信息
DBHelp: 数据库连接池的连接与释放
controller：放置开发的接口
routes: 接口抛出（接口路由层）
app 启动入口，配置接口跨域，返回字符编码···
dbConfig.js
const config = {
// 启动端口
port: 3000,
// 数据库配置
database: {
DATABASE: 'test',
USERNAME: 'root',
PASSWORD: '密码',
PORT: '3306',
HOST: 'localhost',
insecureAuth : true,
useConnectionPooling: true
}}
module.exports = config
DBHelp.js
let DB_MYSQL = require('mysql');
let DB_CONFIG = require('../config/dbConfig');
/**
- 数据库连接池
- @type {Pool}
*/
let pool = DB_MYSQL.createPool({
host: DB_CONFIG.database.HOST,
user: DB_CONFIG.database.USERNAME,
password: DB_CONFIG.database.PASSWORD,
database: DB_CONFIG.database.DATABASE,
port: DB_CONFIG.database.PORT});
/**
- 通用方法
- @param sql
- @param options
- @param callback
*/
let query = (sql, options, callback) =>{
pool.getConnection((error, connection) =>{
if (error) {
callback(error, null, null);
} else {
connection.query(sql, options, (error, results, fields) =>{
//释放连接
connection.release();
//事件驱动回调
callback(error, results, fields);
});
}
});};
module.exports=query;
controller/ ····
/**
- 获取列表
- @type {Connection}
*/
let _ = require('lodash')
let DBHelp = require('../../config/DBHelp.js');
let getArticle = (data, success) =>{
// SQL 语句
let SQL = 'SELECT * FROM websites';
let counter = 0
let SQL_ = SQL+' WHERE ';
// 多个条件时循环data去除key, val
_.forEach(data, (key, val) =>{
if (counter > 0){
SQL = SQL+ ' AND ' + val + ' = ' + key;
} else {
SQL = SQL_+ val + '= ' + key + ' OR name LIKE %' + key +'%';
}
counter++
});
/**
* resultData
* @code: 状态码
* @data：data
* @codeMessage: 状态消息
*/
const resultData = {
code: null,
data: null,
codeMessage: null
}
DBHelp(SQL, (error, result, fields) =>{
if(error){
resultData.error = error.message
}
resultData.code = 200;
resultData.data = result;
resultData.codeMessage = 'success'
success(resultData);
})
}
module.exports = getArticle
router/index.js
let express = require('express');
let router = express.Router();
let getArticle = require('../controller/article/getArticle_controller.js');
let addArticle = require('../controller/article/addArticle_controller.js');
/**
- 数据查询
*/
router.get('/article/list/get', (request, response, next)=>{
getArticle(request.query, data =>{
response.end(JSON.stringify(data));})
});
/**
- 数据新增
- @type {Router|router}
- request.body.XX
*/
router.post('/article/list/add', (request, response, next)=>{
request.body = {
name: '测试',
url: 'http://www.test.aa',
alexa: '32',
country: 'CN'}
addArticle(request.body, data =>{
response.end(JSON.stringify(data));})
});
module.exports = router;
app.js
let createError = require('http-errors');
let express = require('express');
let path = require('path');
let cookieParser = require('cookie-parser');
let logger = require('morgan');
let indexRouter = require('./routes/index');
let usersRouter = require('./routes/users');
let app = express();
// view engine setup
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'pug');
app.use(logger('dev'));
app.use(express.json());
app.use(express.urlencoded({ extended: false }));
app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public')));
// 可跨域 ,编码格式
app.all('*',function(request, response, next){
response.header('Access-Control-Allow-Origin','*');
response.header('Access-Control-Allow-Headers','X-Requested-With');
response.header('Access-Control-Allow-Methods','PUT,POST,GET,DELETE,OPTIONS');
response.header('X-Powered-By','3.2.1');
response.header('Content-Type','application/json;charset=utf-8');
next();
});
// 抛出接口
app.use('/', indexRouter);
app.use('/users', usersRouter);
// catch 404 and forward to error handler
app.use(function(req, res, next) {
next(createError(404));
});
// error handler
app.use(function(err, req, res, next) {
// set locals, only providing error in development
res.locals.message = err.message;
res.locals.error = req.app.get('env') === 'development' ? err : {};
// render the error page
res.status(err.status || 500);
res.render('error');
});
module.exports = app;
// 下面奉上运行结果：（post方法用postman测试就好啦！）
