不需要安装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 []
}
