View source  
  <?php
namespace Drupal\Tests\views\Kernel\Plugin;
use Drupal\Core\Database\Database;
use Drupal\Tests\views\Kernel\ViewsKernelTestBase;
use Drupal\views\Views;
class SqlQueryTest extends ViewsKernelTestBase {
  
  public static $testViews = [
    'test_view',
  ];
  
  protected function viewsData() {
    $data = parent::viewsData();
    $data['views_test_data']['table']['base']['access query tag'] = 'test_tag';
    $data['views_test_data']['table']['base']['query metadata'] = [
      'key1' => 'test_metadata',
      'key2' => 'test_metadata2',
    ];
    return $data;
  }
  
  public function testExecuteMetadata() {
    $view = Views::getView('test_view');
    $view
      ->setDisplay();
    $view
      ->initQuery();
    $view
      ->execute();
    
    $main_query = $view->build_info['query'];
    
    $count_query = $view->build_info['count_query'];
    foreach ([
      $main_query,
      $count_query,
    ] as $query) {
      
      $this
        ->assertTrue($query
        ->hasTag('test_tag'));
      
      $this
        ->assertSame('test_metadata', $query
        ->getMetaData('key1'));
      $this
        ->assertSame('test_metadata2', $query
        ->getMetaData('key2'));
    }
    $query_options = $view->display_handler
      ->getOption('query');
    $query_options['options']['disable_sql_rewrite'] = TRUE;
    $view->display_handler
      ->setOption('query', $query_options);
    $view
      ->save();
    $view
      ->destroy();
    $view = Views::getView('test_view');
    $view
      ->setDisplay();
    $view
      ->initQuery();
    $view
      ->execute();
    
    $main_query = $view->build_info['query'];
    
    $count_query = $view->build_info['count_query'];
    foreach ([
      $main_query,
      $count_query,
    ] as $query) {
      
      $this
        ->assertFalse($query
        ->hasTag('test_tag'));
      
      $this
        ->assertNull($query
        ->getMetaData('key1'));
      $this
        ->assertNull($query
        ->getMetaData('key2'));
    }
  }
  
  public function testGetConnection() {
    $view = Views::getView('test_view');
    $view
      ->setDisplay();
    
    $connection_info = Database::getConnectionInfo('default');
    Database::addConnectionInfo('default', 'replica', $connection_info['default']);
    Database::addConnectionInfo('corefake', 'default', $connection_info['default']);
    Database::addConnectionInfo('corefake', 'replica', $connection_info['default']);
    
    $this
      ->assertSame('default', $view
      ->getQuery()
      ->getConnection()
      ->getKey());
    $this
      ->assertSame('default', $view
      ->getQuery()
      ->getConnection()
      ->getTarget());
    
    $view
      ->getQuery()->options['replica'] = TRUE;
    $this
      ->assertSame('default', $view
      ->getQuery()
      ->getConnection()
      ->getKey());
    $this
      ->assertSame('replica', $view
      ->getQuery()
      ->getConnection()
      ->getTarget());
    
    $view
      ->getQuery()->options['replica'] = FALSE;
    $view->base_database = 'corefake';
    $this
      ->assertSame('corefake', $view
      ->getQuery()
      ->getConnection()
      ->getKey());
    $this
      ->assertSame('default', $view
      ->getQuery()
      ->getConnection()
      ->getTarget());
    
    $view
      ->getQuery()->options['replica'] = TRUE;
    $this
      ->assertSame('corefake', $view
      ->getQuery()
      ->getConnection()
      ->getKey());
    $this
      ->assertSame('replica', $view
      ->getQuery()
      ->getConnection()
      ->getTarget());
    
    Database::closeConnection('replica', 'default');
    Database::closeConnection('default', 'corefake');
    Database::closeConnection('replica', 'corefake');
  }
}