Fix mysql transaction concurrence connection error, fix #424

thinkjs · Aug 16, 2016 · 262489d · 262489d
1 parent d88c551
commit 262489d
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/adapter/socket/mysql.js b/src/adapter/socket/mysql.js
@@ -72,7 +72,11 @@ export default class extends Base {
       return this.getConnection();
     }
 
-    return think.await(str, () => {
+    let awaitKey = str;
+    if(this.config.forceNewNum){
+      awaitKey += '_' + this.config.forceNewNum;
+    }
+    return think.await(awaitKey, () => {
       let deferred = think.defer();
       this.connection = mysql.createConnection(config);
       this.connection.connect(err => {