@Test public void testGetURL() throws Exception { DatabaseConnection conn = new DatabaseConnection(); conn.setAccessType( DatabaseAccessType.NATIVE ); Assert.assertEquals( dialect.getURL( conn ), "jdbc:hive: }
@Override public String getURL( IDatabaseConnection connection ) throws DatabaseDialectException { StringBuffer urlBuffer = new StringBuffer( getNativeJdbcPre() ); urlBuffer.append( connection.getHostname() ); urlBuffer.append( ":" ); urlBuffer.append( connection.getDatabasePort() ); urlBuffer.append( "/" ); urlBuffer.append( connection.getDatabaseName() ); return urlBuffer.toString(); }
HiveDatabaseDialect extends AbstractDatabaseDialect { @Override public String getURL( IDatabaseConnection connection ) throws DatabaseDialectException { StringBuffer urlBuffer = new StringBuffer( getNativeJdbcPre() ); urlBuffer.append( connection.getHostname() ); urlBuffer.append( ":" ); urlBuffer.append( connection.getDatabasePort() ); urlBuffer.append( "/" ); urlBuffer.append( connection.getDatabaseName() ); return urlBuffer.toString(); } }
HiveDatabaseDialect extends AbstractDatabaseDialect { @Override public String getURL( IDatabaseConnection connection ) throws DatabaseDialectException { StringBuffer urlBuffer = new StringBuffer( getNativeJdbcPre() ); urlBuffer.append( connection.getHostname() ); urlBuffer.append( ":" ); urlBuffer.append( connection.getDatabasePort() ); urlBuffer.append( "/" ); urlBuffer.append( connection.getDatabaseName() ); return urlBuffer.toString(); } HiveDatabaseDialect(); }
HiveDatabaseDialect extends AbstractDatabaseDialect { @Override public String getURL( IDatabaseConnection connection ) throws DatabaseDialectException { StringBuffer urlBuffer = new StringBuffer( getNativeJdbcPre() ); urlBuffer.append( connection.getHostname() ); urlBuffer.append( ":" ); urlBuffer.append( connection.getDatabasePort() ); urlBuffer.append( "/" ); urlBuffer.append( connection.getDatabaseName() ); return urlBuffer.toString(); } HiveDatabaseDialect(); IDatabaseType getDatabaseType(); @Override String getNativeDriver(); @Override String getURL( IDatabaseConnection connection ); @Override String getNativeJdbcPre(); @Override String getAddColumnStatement( String tablename, IValueMeta v, String tk, boolean use_autoinc, String pk,
      boolean semicolon ); @Override String getModifyColumnStatement( String tablename, IValueMeta v, String tk, boolean use_autoinc, String pk,
      boolean semicolon ); @Override String getFieldDefinition( IValueMeta v, String tk, String pk, boolean use_autoinc, boolean add_fieldname,
      boolean add_cr ); @Override String[] getUsedLibraries(); @Override int getDefaultDatabasePort(); @Override boolean supportsSchemas(); @Override boolean initialize( String classname ); }
HiveDatabaseDialect extends AbstractDatabaseDialect { @Override public String getURL( IDatabaseConnection connection ) throws DatabaseDialectException { StringBuffer urlBuffer = new StringBuffer( getNativeJdbcPre() ); urlBuffer.append( connection.getHostname() ); urlBuffer.append( ":" ); urlBuffer.append( connection.getDatabasePort() ); urlBuffer.append( "/" ); urlBuffer.append( connection.getDatabaseName() ); return urlBuffer.toString(); } HiveDatabaseDialect(); IDatabaseType getDatabaseType(); @Override String getNativeDriver(); @Override String getURL( IDatabaseConnection connection ); @Override String getNativeJdbcPre(); @Override String getAddColumnStatement( String tablename, IValueMeta v, String tk, boolean use_autoinc, String pk,
      boolean semicolon ); @Override String getModifyColumnStatement( String tablename, IValueMeta v, String tk, boolean use_autoinc, String pk,
      boolean semicolon ); @Override String getFieldDefinition( IValueMeta v, String tk, String pk, boolean use_autoinc, boolean add_fieldname,
      boolean add_cr ); @Override String[] getUsedLibraries(); @Override int getDefaultDatabasePort(); @Override boolean supportsSchemas(); @Override boolean initialize( String classname );  }