Use write connection on create to prevent replica lag. Fix #14256

phalcon · Sep 21, 2019 · 870dff0 · 870dff0
1 parent cd5aeb4
commit 870dff0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/phalcon/Mvc/Model.zep b/phalcon/Mvc/Model.zep
@@ -955,10 +955,10 @@ abstract class Model extends AbstractInjectionAware implements EntityInterface,
         let metaData = this->getModelsMetaData();
 
         /**
-         * Get the current connection
+         * Get the current connection use write to prevent replica lag
          * If the record already exists we must throw an exception
          */
-        if this->_exists(metaData, this->getReadConnection()) {
+        if this->_exists(metaData, this->getWriteConnection()) {
             let this->errorMessages = [
                 new Message(
                     "Record cannot be created because it already exists",