|
@@ -36,7 +36,7 @@ function getTransactionConnection() {
|
|
});
|
|
});
|
|
}
|
|
}
|
|
|
|
|
|
-function query(connection, sql, datas) {
|
|
|
|
|
|
+function _query(connection, sql, datas) {
|
|
return new Promise((resolve, reject) => {
|
|
return new Promise((resolve, reject) => {
|
|
connection.query(sql, datas, (err, results, fields) => {
|
|
connection.query(sql, datas, (err, results, fields) => {
|
|
if (err) {
|
|
if (err) {
|
|
@@ -48,22 +48,22 @@ function query(connection, sql, datas) {
|
|
});
|
|
});
|
|
}
|
|
}
|
|
|
|
|
|
-export funtion init () {
|
|
|
|
|
|
+export function init() {
|
|
if (pool != undefined) {
|
|
if (pool != undefined) {
|
|
pool.end();
|
|
pool.end();
|
|
pool = undefined;
|
|
pool = undefined;
|
|
}
|
|
}
|
|
initPool();
|
|
initPool();
|
|
-};
|
|
|
|
|
|
+}
|
|
|
|
|
|
-export funtion close () {
|
|
|
|
|
|
+export function close() {
|
|
if (pool != undefined) {
|
|
if (pool != undefined) {
|
|
pool.end();
|
|
pool.end();
|
|
pool = undefined;
|
|
pool = undefined;
|
|
}
|
|
}
|
|
-};
|
|
|
|
|
|
+}
|
|
|
|
|
|
-export funtion query (sql, datas) {
|
|
|
|
|
|
+export function query(sql, datas) {
|
|
return new Promise((resolve, reject) => {
|
|
return new Promise((resolve, reject) => {
|
|
pool.query(sql, datas, (err, results, fields) => {
|
|
pool.query(sql, datas, (err, results, fields) => {
|
|
if (err) {
|
|
if (err) {
|
|
@@ -73,15 +73,15 @@ export funtion query (sql, datas) {
|
|
}
|
|
}
|
|
});
|
|
});
|
|
});
|
|
});
|
|
-};
|
|
|
|
|
|
+}
|
|
|
|
|
|
-export funtion batchQuery (sql, datas) {
|
|
|
|
|
|
+export function batchQuery(sql, datas) {
|
|
return new Promise((resolve, reject) => {
|
|
return new Promise((resolve, reject) => {
|
|
getTransactionConnection()
|
|
getTransactionConnection()
|
|
.then((connection) => {
|
|
.then((connection) => {
|
|
const results = [];
|
|
const results = [];
|
|
for (let i = 0; i < datas.length; i++) {
|
|
for (let i = 0; i < datas.length; i++) {
|
|
- results.push(query(connection, sql, datas[i]));
|
|
|
|
|
|
+ results.push(_query(connection, sql, datas[i]));
|
|
}
|
|
}
|
|
|
|
|
|
Promise.all(results)
|
|
Promise.all(results)
|
|
@@ -107,4 +107,11 @@ export funtion batchQuery (sql, datas) {
|
|
reject(err);
|
|
reject(err);
|
|
});
|
|
});
|
|
});
|
|
});
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+export default {
|
|
|
|
+ init,
|
|
|
|
+ close,
|
|
|
|
+ query,
|
|
|
|
+ batchQuery,
|
|
};
|
|
};
|