$om = MagentoFrameworkAppObjectManager::getInstance(); $connectionO = $om->create('MagentoFrameworkAppResourceConnection'); $connection= $connectionO->getConnection(); $sql = 'some query'; $results = $connection->fetchAll($sql);