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模块 5 
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));
35 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) { 8     });
});

router.post('/postData', function (req, res) {
    dbservice.operateDatabase(appName, spName, json, function (data) {
      
    });
});

下一章：NodeJs连接操作MongoDB数据库