parent
ff39922e86
commit
38f9ebc606
@ -0,0 +1,45 @@
|
||||
var cp = require('duplex-child-process');
|
||||
var pg = require('pg')
|
||||
|
||||
var copy = require('../').from
|
||||
|
||||
var client = function() {
|
||||
var client = new pg.Client()
|
||||
client.connect()
|
||||
return client
|
||||
}
|
||||
|
||||
var inStream = function() {
|
||||
return cp.spawn('seq', ['0', '29999999']);
|
||||
}
|
||||
|
||||
var running = true;
|
||||
|
||||
var c = client();
|
||||
c.query('DROP TABLE IF EXISTS plugnumber', function() {
|
||||
c.query('CREATE TABLE plugnumber (num int)', function() {
|
||||
var seq = inStream()
|
||||
var from = c.query(copy('COPY plugnumber FROM STDIN'))
|
||||
seq.pipe(from);
|
||||
from.on('end', function() {
|
||||
running = false;
|
||||
c.end();
|
||||
})
|
||||
})
|
||||
})
|
||||
|
||||
|
||||
var rssMin = process.memoryUsage().rss / 1024 / 1024
|
||||
var rssMax = rssMin
|
||||
|
||||
memlog = function() {
|
||||
var rss = process.memoryUsage().rss / 1024 / 1024
|
||||
rssMin = Math.min(rss, rssMin)
|
||||
rssMax = Math.max(rss, rssMax)
|
||||
console.log('rss:' + Math.round(rss*100)/100 + 'MB rssMin:'+ Math.round(rssMin*100)/100 + 'MB rssMax:' + Math.round(rssMax*100)/100 + 'MB')
|
||||
if (running) {
|
||||
setTimeout(memlog, 1000);
|
||||
}
|
||||
}
|
||||
|
||||
memlog()
|
Loading…
Reference in new issue