Last active
February 17, 2021 16:37
-
-
Save willboudle/8cfdf9eb61c9b6270f5b1123e0155a0a to your computer and use it in GitHub Desktop.
Created with Copy to Gist
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<?php | |
namespace [Vendor]\[Module]\Helper; | |
use Magento\Framework\App\Helper\AbstractHelper; | |
use Magento\Framework\App\Helper\Context; | |
use Magento\Framework\App\ResourceConnection; | |
use Magento\Framework\App\ObjectManager; | |
class Data extends AbstractHelper | |
{ | |
protected $resourceConnection; | |
public function __construct(Context $context, ResourceConnection $resourceConnection) | |
{ | |
$this->resourceConnection = $resourceConnection; | |
parent::__construct($context); | |
} | |
public function runSqlQuery($table) | |
{ | |
$connection = $this->resourceConnection->getConnection(); | |
// $table is table name | |
$table = $connection->getTableName('my_custom_table'); | |
//For Select query | |
$query = "Select * FROM " . $table; | |
$result = $connection->fetchAll($query); | |
$this->_logger->log(print_r($result, true)); | |
$id = 2; | |
$query = "SELECT * FROM `" . $table . "` WHERE id = $id "; | |
$result1 = $connection->fetchAll($query); | |
$this->_logger->log(print_r($result1, true)); | |
//For Insert query | |
$tableColumn = ['id', 'name', 'age']; | |
$tableData[] = [5, 'xyz', '20']; | |
$connection->insertArray($table, $tableColumn, $tableData); | |
$query = "INSERT INTO `" . $table . "`(`id`, `name`, `age`) VALUES (7,'mtm',33)"; | |
$connection->query($query); | |
// For Update query | |
$id = 1; | |
$query = "UPDATE `" . $table . "` SET `name`= 'test' WHERE id = $id "; | |
$connection->query($query); | |
$query1 = "UPDATE `" . $table . "` SET `name`= 'test', `age` = 14 WHERE id = $id "; | |
$connection->query($query1); | |
// For Delete query | |
$id = 1; | |
$query = "DELETE FROM `" . $table . "` WHERE id = $id "; | |
$connection->query($query); | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment