在 Node.js 中使用 Web 服务并批量插入到 Oracle 数据库

问题描述

我需要使用 node js 使用第三方 webservice 并将其写入 oracle table 。基本上我得到了获取数据的代码。从节点json将批量数据插入oracle的命令是什么?我将得到一个巨大的文件,我正在解析它。代码如下。

有人可以在这里帮助我插入命令吗?


    const express = require("express");
    const oracledb = require("oracledb");
    const cors = require("cors");
    const bodyparser = require("body-parser");
    const request = require("request");
    let app = express();
    app.use(cors());
    app.use(bodyparser.json());
    app.use(bodyparser.urlencoded({extended:false}));
    app.get("/demo",(req,res)=>{
            oracledb.getConnection({
                user:"INFO",password:"12345",connectString:"194.234.222.22:1521/TEST"
            },(err,connection)=>{
                if(err) throw err;
                else{
                    //make request call
                    try{
                        request.post({
                            url:     'https://qmilet.com/api/v1/partners/login',body:    {"user":"_api","password":"_api"},json: true
                        },function(error,response,body){
                            //console.log(body);
                            token = body.access_token
                            console.log(token);
                            //make api request
                            //31ae0b786d4958c0a93a459f46a59d67b8a9cff8
                            try{
                                //replace thw dynamic token
                                //Syntax : ${token}
                                request.post({
                                    url : `https://qmilet.com/api/v1/orders/pull?access_token=${token}&date_from=2020-05-01&date_to=2021-05-30&include_synced=1`
                                },function(err,body){
                                    let obj = JSON.parse(body);
                                    res.send(obj.data);
                                    
                                    //how to read parsed data,and insert into oracle db
                                    
                                })
                            }catch(err){
                                console.log(err);
                            }
                        });                
                    }catch(err){
                        console.log(err);
                    }
                }
            });    
    });
    
    
    app.listen(8080,()=>{
        console.log("server started");
    });

我使用的是 12.1.0.2 版本的 Oracle。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)