Ich habe versucht, node-jt400 (SQL-Stream)
SQL stream Im Codierungsbeispiel verhält es sich wie CPYF. Versuchen Sie also, auf die gleiche Weise zu codieren. Erstellen Sie eine physische Kopierzieldatei. Ich habe es ein wenig geändert, weil es eine große Sache war. (Ändern Sie die Attribute von LNAME und FNAME, ändern Sie TOKUTEN in TENSU, ändern Sie das Datensatzformat.)
MYLIB/MEMBER2.PF
*****************************************************************
*Datei-ID: MEMBER2
*****************************************************************
A R MEMBER2R TEXT('Mitglied')
*
A ID 3S 0 COLHDG(' ＩＤ ')
A LNAME 6G COLHDG('Familienname, Nachname')
A FNAME 12J COLHDG('Name')
A PROF 40O COLHDG('Profil')
A TENSU 7P 3 COLHDG('Ergebnis')
SQLstream.js
var jt400 = require("node-jt400");
var JSONStream = require("JSONStream");
var express = require("express");
var app = express();
var pool = jt400.pool({ host: '192.168.X.XXX', user: 'MYUSER', password: 'MYPASS' });
var server = app.listen(8888, function () {
console.log("curl http://localhost:" + server.address().port + '/~');
});
app.get("/stream", function (req, res, next) {
pool.createReadStream("select * from member")
.pipe(JSONStream.parse([true]))
.pipe(pool.createWriteStream("insert into member2 (ID,FNAME,LNAME,PROF,TENSU) VALUES(?,?,?,?,?)"));
res.send('end');
});
Versuchen Sie es auszuführen.
Ausführungsergebnis
Der Nachname und der Vorname wurden korrekt ersetzt und festgelegt.
Recommended Posts