@Test public void testGetUrlJndi() throws KettleDatabaseException { baseSimbaDatabaseMeta.setAccessType( DatabaseMeta.TYPE_ACCESS_JNDI ); assertEquals( Hive2SimbaDatabaseMeta.URL_IS_CONFIGURED_THROUGH_JNDI, baseSimbaDatabaseMeta.getURL( "", "", "" ) ); }
@Override public String getURL( String hostname, String port, String databaseName ) { return SimbaUrl.Builder.create() .withAccessType( getAccessType() ) .withDatabaseName( databaseName ) .withPort( port ) .withDefaultPort( getDefaultDatabasePort() ) .withHostname( hostname ) .withJdbcPrefix( getJdbcPrefix() ) .withUsername( getUsername() ) .withPassword( getPassword() ) .withIsKerberos( isKerberos() ) .build() .getURL(); }
BaseSimbaDatabaseMeta extends Hive2DatabaseMeta { @Override public String getURL( String hostname, String port, String databaseName ) { return SimbaUrl.Builder.create() .withAccessType( getAccessType() ) .withDatabaseName( databaseName ) .withPort( port ) .withDefaultPort( getDefaultDatabasePort() ) .withHostname( hostname ) .withJdbcPrefix( getJdbcPrefix() ) .withUsername( getUsername() ) .withPassword( getPassword() ) .withIsKerberos( isKerberos() ) .build() .getURL(); } }
BaseSimbaDatabaseMeta extends Hive2DatabaseMeta { @Override public String getURL( String hostname, String port, String databaseName ) { return SimbaUrl.Builder.create() .withAccessType( getAccessType() ) .withDatabaseName( databaseName ) .withPort( port ) .withDefaultPort( getDefaultDatabasePort() ) .withHostname( hostname ) .withJdbcPrefix( getJdbcPrefix() ) .withUsername( getUsername() ) .withPassword( getPassword() ) .withIsKerberos( isKerberos() ) .build() .getURL(); } BaseSimbaDatabaseMeta( DriverLocator driverLocator, NamedClusterService namedClusterService,
                         MetastoreLocator metastoreLocator ); }
BaseSimbaDatabaseMeta extends Hive2DatabaseMeta { @Override public String getURL( String hostname, String port, String databaseName ) { return SimbaUrl.Builder.create() .withAccessType( getAccessType() ) .withDatabaseName( databaseName ) .withPort( port ) .withDefaultPort( getDefaultDatabasePort() ) .withHostname( hostname ) .withJdbcPrefix( getJdbcPrefix() ) .withUsername( getUsername() ) .withPassword( getPassword() ) .withIsKerberos( isKerberos() ) .build() .getURL(); } BaseSimbaDatabaseMeta( DriverLocator driverLocator, NamedClusterService namedClusterService,
                         MetastoreLocator metastoreLocator ); @Override abstract String getDriverClass(); @Override int[] getAccessTypeList(); @Override String getURL( String hostname, String port, String databaseName ); @Override String getFieldDefinition( ValueMetaInterface v, String tk, String pk, boolean useAutoinc,
                                    boolean addFieldname, boolean addCr ); }
BaseSimbaDatabaseMeta extends Hive2DatabaseMeta { @Override public String getURL( String hostname, String port, String databaseName ) { return SimbaUrl.Builder.create() .withAccessType( getAccessType() ) .withDatabaseName( databaseName ) .withPort( port ) .withDefaultPort( getDefaultDatabasePort() ) .withHostname( hostname ) .withJdbcPrefix( getJdbcPrefix() ) .withUsername( getUsername() ) .withPassword( getPassword() ) .withIsKerberos( isKerberos() ) .build() .getURL(); } BaseSimbaDatabaseMeta( DriverLocator driverLocator, NamedClusterService namedClusterService,
                         MetastoreLocator metastoreLocator ); @Override abstract String getDriverClass(); @Override int[] getAccessTypeList(); @Override String getURL( String hostname, String port, String databaseName ); @Override String getFieldDefinition( ValueMetaInterface v, String tk, String pk, boolean useAutoinc,
                                    boolean addFieldname, boolean addCr );  }