Fix: fix Error: Connection already released when use connectionLimi…

…t in mysql
arterli · Mar 2, 2016 · 63f14ca · 63f14ca
1 parent dbedf55
commit 63f14ca
Showing 1 changed file with 6 additions and 8 deletions.
diff --git a/src/adapter/socket/mysql.js b/src/adapter/socket/mysql.js
@@ -43,15 +43,13 @@ export default class extends Base {
     let str = `mysql://${config.user}:${config.password}@${config.host}:${config.port}/${config.database}`;
 
     if (this.pool) {
-      return think.await(str, () => {
-        let fn = think.promisify(this.pool.getConnection, this.pool);
-        let promise = fn().catch(err => {
-          this.close();
-          return Promise.reject(err);
-        });
-        let err = new Error(str);
-        return think.error(promise, err);
+      let fn = think.promisify(this.pool.getConnection, this.pool);
+      let promise = fn().catch(err => {
+        this.close();
+        return Promise.reject(err);
       });
+      let err = new Error(str);
+      return think.error(promise, err);
     }
 
     let mysql = await think.npm('mysql');