docker-mysql-driver
Advanced tools
Comparing version 0.0.3 to 0.0.4
@@ -16,3 +16,3 @@ var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; }; | ||
async function StreamToString(stream) { | ||
async function StreamToString(stream, timeout) { | ||
const chucks = []; | ||
@@ -29,3 +29,3 @@ return new Promise((resolve, reject) => { | ||
}); | ||
}).timeout(2000).then(data => { | ||
}).timeout(timeout || 2000).then(data => { | ||
return data; | ||
@@ -39,3 +39,3 @@ }, e => { | ||
async function execCommand(container, cmds) { | ||
async function execCommand(container, cmds, timeout) { | ||
const exec = await container.exec({ | ||
@@ -49,3 +49,3 @@ Cmd: cmds, | ||
container.modem.demuxStream(stream.output, process.stdout, process.stderr); | ||
const result = await StreamToString(stream.output); | ||
const result = await StreamToString(stream.output, timeout); | ||
return result; | ||
@@ -72,3 +72,3 @@ } | ||
async function resetMysql(container, rootPwd, database) { | ||
const result = await execCommand(container, ['mysql', '-uroot', `-p${rootPwd}`, `-e DROP DATABASE IF EXISTS \`${database}\`; CREATE DATABASE \`${database}\`;`]); | ||
const result = await execCommand(container, ['mysql', '-uroot', `-p${rootPwd}`, `-e DROP DATABASE IF EXISTS \`${database}\`; CREATE DATABASE \`${database}\`;`], 10000); | ||
log.info(`reset mysql result: ${result}`); | ||
@@ -75,0 +75,0 @@ } |
{ | ||
"name": "docker-mysql-driver", | ||
"version": "0.0.3", | ||
"version": "0.0.4", | ||
"description": "docker mysql driver for unit test", | ||
@@ -5,0 +5,0 @@ "main": "dist", |
6454