NodeJs之服务搭建与数据库连接
一,介绍与需求分析
1.1,介绍
Node.js 是一个基于 Chrome V8 引擎的 JavaScript 运行环境。 Node.js 使用了一个事件驱动、非阻塞式 I/O 的模型，使其轻量又高效。Node.js 的包管理器 npm，是全球最大的开源库生态系统。
二,node服务搭建
2.1,安装创建项目服务
第一步:安装NODE
第二步:安装express,使用熟悉的命令安装,
npm install -g express
第三步:最新express版本中将命令工具分家出来了(项目地址:https://github.com/expressjs/generator),所以我们还需要安装一个命令工具,命令如下:
npm install -g express-generator
第四步:使用express创建一个工程：
express myervice
第五步:安装包并启动
cd myervice
npm install //安装包
npm start //启动服务
第六步：访问http://localhost:3000/就看到熟悉的页面了
2.2,配置node服务器
具体的代码如下：
var express = require('express');//引入express模块
var app = express();//初始化化
var settingConfig = require('./config/settingConfig.js');//引入配置文件
var allow_Orgin = settingConfig.getValueByKey("Access_Control_Allow_Origin");//解析
// Access Control Allow
var cors = require('cors');//引入跨域资源共享
var whitelist = allow_Orgin.split(';');
var hostName = '127.0.0.1';//设置主机名
var port = 8080;//设置端口
var corsOptions = {//配置
credentials: true,
origin: function (origin, callback) {
if (origin==undefined || whitelist.indexOf(origin) !== -1) {
callback(null, true)
} else {
console.log(origin);
callback(new Error('Not allowed by CORS'))
}
}
}
app.use(cors(corsOptions));
app.use('/api', require('./routes/dbWebApi.js'));
// catch 404 and forward to error handler
app.use(function(req, res, next) {
var err = new Error('Not Found');
err.status = 404;
var result = {
httpCode: 404,
message: err.message,
}
res.status(404).json(result);
next();
});
// 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).json({
httpCode: err.status || 500,
message: err.message,
});
});
app.listen(port,hostName,function(){//监听
console.log(`服务器运行在http://${hostName}:${port}`);
});
解析配置文件的代码settingConfig.js如下：
var xml2js = require('xml2js');//xml解析
var fs = require('fs');//文件处理系统
function getValueByKey(key) {
var path = './config/settingConfig.xml';//xml配置文件
var result = '';
var data;
try {
data = fs.readFileSync(path, 'utf8');
}
catch (err) {
throw err;
}
var xmlDoc = xml2js.parseString(data, { explicitArray: true }, function (err, json) {
};
});
return result;
}
配置文件settingConfig.xml如下：
<?xml version="1.0" encoding="utf-8" ?>
<appSettings>
<add key="Access_Control_Allow_Origin" value="http://localhost:8080;http://localhost:3000"/>
<add key="dbName" value="test"/>
<add key="WhetherNeedAuth" value="true"/>
</appSettings>
如需完整代码,请先留言评论加关注
三,node连接数据库
3.1,连接数据库的配置与解析
目前只支持两种类型的数据库：MySQL sql server
解析配置文件:operateXML.js:
function params(){//简单配置
this.server="";
this.database="";
this.user="";
this.password="";
this.sp_name = "";
this.sp_output = "";
}
function mysqlparams(){
this.host="";
this.port="";
this.database="";
this.user="";
this.password="";
this.sp_name="";
this.sp_output = "";
}
function getMsSQLParamObj(appName,spName){ //sql server
var xml2js = require('xml2js');
var fs=require('fs');
var path='./config/databaseConfig.xml';
var param=new params();
var data;
try{
data= fs.readFileSync(path, 'utf8');
}
catch(err){
throw err;
}
var xmlDoc = xml2js.parseString(data, { explicitArray: true }, function (err, json) {
});
return param;
}
function getMySQLParamObj(appName,spName){ //mysql
var xml2js = require('xml2js');
var fs=require('fs');
var path='./config/databaseConfig.xml';
var param=new mysqlparams();
var data;
try{
data= fs.readFileSync(path, 'utf8');
}
catch(err){
throw err;
}
var xmlDoc = xml2js.parseString(data, { explicitArray : true },function(err, json) { //解析
});
return param;
}
XML配置文件:databaseConfig:
<?xml version="1.0" encoding="UTF-8"?>
<root>
<sqlserver>
<database name="TEST" server="localhost\MSSQL" database="test" user="sa" pwd="908">
<!--登录注册-->
<storedProcedure name="RegisterToUser" value="[Auth].[usp_RegisterToUser]" description="注册"/>
</database>
</sqlserver>
<mysql>
<database name="test" host="localhost" port="3306" database="test" user="root" pwd="root">
<storedProcedure name="getUserPages" value="sp_getUserPages" output="total"/>
<storedProcedure name="getUserCount" value="sp_getUserCount"/>
</database>
</mysql>
</root>
3.2,连接数据库
连接数据库:db_mssql.JS
var sql = require("mssql");
var xml = require('../config/operateXML.js');//加载解析配置文件
function operateDatabase(appName, spName, json, callback) {
var paraarr = {}
if ((typeof json) == "string")
parr = JSON.parse(json);
else
parr = json;
var config = xml.getMsSQLParamObj(appName, spName);
try {//连接数据库
new sql.ConnectionPool(config).connect().then(function (pool) {
} catch (err) {
}
}
3.2,get与post请求
定义请求方式：dbWebApi.js
var express = require('express');
var router = express.Router();
var dbservice = require('../services/db_mssql.js');
router.get('/readData/:appName/:spName/:json', function (req, res) {
dbservice.operateDatabase(appName, spName, json, function (data) { });
});
router.post('/postData', function (req, res) {
dbservice.operateDatabase(appName, spName, json, function (data) {
});
});