SinkConnectionFactory implements ConnectionFactory { public String getDatabaseDriver() { return databaseDriver; } protected  SinkConnectionFactory(); void init(Configuration configuration); static SinkConnectionFactory instance(); String getDatabaseUrl(); String getDatabaseDriver(); @Override Connection getConnection();  }
@Test public void testGetDatabaseDriver() throws Exception { SinkConnectionFactory factory = getFactory("myURL", "myDriver"); Assert.assertEquals("myDriver", factory.getDatabaseDriver()); }