不需要安装Oralce客户端，不影响其它使用Oracle客户端的程序运行

安装Node.JS

node-v12.13.0-x64.msi

安装VC++ 2013运行时

vcredist_x64.exe

运行的版本要与Oracle 客户端匹配，

下载Oracle 客户端

instantclient-basiclite-windows.x64-18.5.0.0.0dbru.zip

解压并放到一个目录下：

C:\instantclient_18_5

写个Run.bat

REM mynode.bat

SET PATH=C:\instantclient_18_5;%PATH%

node dist/index.js

附源码

import oracledb from 'oracledb'

import http from 'http'

import urllib from 'url'

import _ from 'lodash'

let md5 = require('md5-node')

const oraConfig = {

connectString :'192.168.*.*:1521/orcl',

user: '****', // 登录oracle的用户名

password: '***' // 请换为实际密码

}

function doRelease (connection:oracledb.Connection) {

connection.close(

function (err) {

if (err) {

console.error(err.message)

}

})

}

var server:http.Server = http.createServer();

server.on('request', async (request, response)=>{

console.log('收到客户端的请求了，请求路径是：' + request.url);

let urlObj = urllib.parse(request.url, true);

if (urlObj.pathname === '/SyncDeviceConfig')

{

response.writeHead(200, { 'Content-Type': 'application/json;charset:utf-8' });

let jsoObj = await GetDeviceConfig(urlObj.query.version_code as string).catch((err)=>{

response.writeHead(406, err.message);

response.end(err);

return;

});

response.end(JSON.stringify(jsoObj));

}

else{

response.writeHead(404, { 'Content-Type': 'text/html' });

response.end('404 Not Found.')

}

});

server.listen(3000, ()=>{

console.log('服务器启动成功了，可以通过 http://127.0.0.1:3000/ 来进行访问')

})

async function GetDeviceConfig(OldVersionCode :string){

let connection:any;

connection = await oracledb.getConnection(oraConfig)

.catch(err=>{

console.error(err)

throw(err)

});

try

{

let SQL = "select ****";

const V3006 = (await connection.execute(SQL)).rows[0][0];

SQL = "select ****"

const V3007 = (await connection.execute(SQL)).rows[0][0];

SQL = "select *****"

const V3011 = (await connection.execute(SQL)).rows[0][0];

SQL = "select ****"

const V1040 = await connection.execute(SQL);

const mOrgCode = md5(`{"3006":${V3006}, "3007":${V3007}, "1040":[${_.join(V1040.rows.map((m:any)=>`{"NODEID":"${m[0]}","VERSION":${m[1]}}`))}]}`);

if (OldVersionCode === mOrgCode){

throw('already is new vesion!')

}

let jsonObj = {

version_code: mOrgCode,

publishTime : Date.now().toString(),

lines:Array()

};

SQL = `*****`;

let dtLine = await connection.execute(SQL)

jsonObj.lines = dtLine.rows.map( (drLine:any) =>({

lineID:drLine[0], lineName:drLine[2]

}))

for(let lineNode of jsonObj.lines){

lineNode.stations = await FillLineStations(connection, lineNode.lineID)

}

return jsonObj;

}catch(err){

console.error(err);

throw (err)

}finally {

if (connection) {

try {

await connection.close();

} catch (err) {

console.error(err);

}

}

}

}

let FillLineStations = async (connection:oracledb.Connection, LineID:string) =>{

const SQL = `******`;

let dbStations = await connection.execute(SQL)

let r = dbStations.rows?.map((drStation:any)=>({

Node:drStation[0], StationName:drStation[1], IP:drStation[2], Port:drStation[3],

devices:Array.of()

}));

if(r)

{

for(let StationNode of r){

StationNode.devices = await FillStationDevices(connection, StationNode.Node)

}

}

return r;

}

let FillStationDevices = async (connection:any, StationNodeID:string)=>{

const SQL1040 = `*******`;

const V1040 = (await connection.execute(SQL1040, [StationNodeID], { maxRows: 1 } ));

if (V1040 == null || V1040.rows === null || V1040.rows?.length === 0 )

return []

let iv1040 = V1040.rows[0][0];

const SQL_DEVICE = `******`;

let devices = (await connection.execute(SQL_DEVICE))

if (devices.rows)

return devices.rows.map((drDevcie:any)=>({

DeviceCode:drDevcie[4], Node:drDevcie[0], DeviceType:_.trim(drDevcie[1]),IP:drDevcie[2], OS:'', Port:_.toNumber(drDevcie[3])

}))

else

return []

}