Magento – Magento Read & Write Connection Close Manually Needed

databasemagento-1.9

In case of customisation we need to initiate read and write connection in our .phtml file.

Should we manually close these connection at the end of file? or Magento self handles it?

In my case I have several time called read connections in my templates now I am feeling there must be any other solutions to handle this.

If I use multiple time Read Connection, would it may load up my database or server?

Somewhere I found it to be used.

Read Connection

$db = Mage::getSingleton('core/resource')->getConnection('core_read');

You can close the connection with this:

$db->closeConnection();

And then re-open it with this

$db->getConnection();

Should I do this for handling multiple and concurrent connections?

Let me know if any suggestion.

Best Answer

No, you dont have to close the connection .

There should be no read and write calls in .phtml file or template files , it is not best practice in MVC or Magento. You should use model for that .

Mage::getSingleton('core/resource')->getConnection('core_wri‌te'); gets an already open connection. If you close it, other code will fail to reuse that connection

Related Solutions

Magento – Magento get read or write connection for model / resource model

Please follow bellow steps

Config.xml

    <?xml version="1.0"?>
<config>
    <modules>
        <AR_Externaldb>
            <version>0.1.0</version>
        </AR_Externaldb>
    </modules>
    <frontend>
        <routers>
            <externaldb>
                <use>standard</use>
                <args>
                    <module>AR_Externaldb</module>
                    <frontName>externaldb</frontName>
                </args>
            </externaldb>
        </routers>
        <layout>
            <updates>
                <externaldb>
                    <file>externaldb.xml</file>
                </externaldb>
            </updates>
        </layout>
    </frontend>
    <admin>
        <routers>
            <externaldb>
                <use>admin</use>
                <args>
                    <module>AR_Externaldb</module>
                    <frontName>externaldb</frontName>
                </args>
            </externaldb>
        </routers>
    </admin>
    <adminhtml>
        <layout>
            <updates>
                <externaldb>
                    <file>externaldb.xml</file>
                </externaldb>
            </updates>
        </layout>
    </adminhtml>
    <global>
        <models>
            <externaldb>
                <class>AR_Externaldb_Model</class>
                <resourceModel>externaldb_mysql4</resourceModel>
            </externaldb>
            <externaldb_mysql4>
                <class>AR_Externaldb_Model_Mysql4</class>
                <entities>
                    <vehicle><table>BaseVehicle</table></vehicle>
                </entities>
            </externaldb_mysql4>
        </models>
        <resources>
            <!-- End DB -1 --> 
            <externaldb_write>
                <connection>
                    <use>externaldb_database</use>
                </connection>
            </externaldb_write>
            <externaldb_read>
                <connection>
                    <use>externaldb_database</use>
                </connection>
            </externaldb_read>
            <externaldb_setup>
                <connection>
                    <use>core_setup</use>
                </connection>
            </externaldb_setup>
            <externaldb_database>
                <connection>
                    <host><![CDATA[localhost]]></host>
                    <username><![CDATA[testsql]]></username>
                    <password><![CDATA[test123]]></password>
                    <dbname><![CDATA[database-1]]></dbname>
                    <model>mysql4</model>
                    <type>pdo_mysql</type>
                    <active>1</active>
                </connection>
            </externaldb_database>
            <!-- End DB-1 --> 
            <!-- DB -2 -->
            <pcdb_write>
                <connection>
                  <use>pcdb_database</use>
                </connection>
            </pcdb_write>
            <pcdb_read>
                <connection>
                  <use>pcdb_database</use>
                </connection>
            </pcdb_read>
            <pcdb_setup>
                <connection>
                  <use>core_setup</use>
                </connection>
            </pcdb_setup>
            <pcdb_database>
                <connection>
                  <host><![CDATA[localhost]]></host>
                  <username><![CDATA[test]]></username>
                  <password><![CDATA[test123]]></password>
                  <dbname><![CDATA[database-2]]></dbname>
                  <model>mysql4</model>
                  <type>pdo_mysql</type>
                  <active>1</active>
                </connection>
            </pcdb_database>
            <!-- End DB -2 -->
        </resources>
        <blocks>
            <externaldb>
                <class>AR_Externaldb_Block</class>
            </externaldb>
        </blocks>
        <helpers>
            <externaldb>
                <class>AR_Externaldb_Helper</class>
            </externaldb>
        </helpers>
    </global>
</config>

Bellow Read & write function use in model or resource

<?php
class AR_Externaldb_Model_Test extends Mage_Core_Model_Abstract
{
protected $_readAdaptor;
protected $_readPcdbAdaptor;
protected $_writeAdaptor;

public function readAdaptor()
{
    if(empty($this->_readAdaptor)) {
        $this->_readAdaptor = Mage::getSingleton('core/resource')->getConnection('externaldb_read');
    }
    return $this->_readAdaptor;
}

public function writeAdaptor()
{
    if(empty($this->_writeAdaptor)) {
        $this->_writeAdaptor = Mage::getSingleton('core/resource')->getConnection('externaldb_write');
    }
    return $this->_writeAdaptor;
}

public function readPcdbAdaptor()
{
    if(empty($this->_readPcdbAdaptor)) {
        $this->_readPcdbAdaptor = Mage::getSingleton('core/resource')->getConnection('pcdb_read');
    }
    return $this->_readPcdbAdaptor;
}

}

Magento – get generated Id from custom write connection

You can get it like this:

$writeConnection->lastInsertId();

But you are doing it wrong.
You should have a model and a resource model that maps on your table and you should use the ORM to persist data.
Have something like this:

$model = Mage::getModel('[module]/test');
$model->setData(array('column1' => 3, 'column2' => 4 ));
$model->save();
$id = $model->getId();

Best Answer

Related Solutions

Magento – Magento get read or write connection for model / resource model

Magento – get generated Id from custom write connection

Related Topic