JDBC Datenquellen dynamisch unter OSGi nutzen

public void start() throws InstantiationException, IllegalAccessException, ClassNotFoundException {
    //Load driver if not already done...
    Class<?> clazz = Class.forName("com.mysql.jdbc.Driver");
    // The newInstance() call is a work around for some
    // broken Java implementations, see MySQL Connector/J documentation
    clazz.newInstance();
}

@Override
public DataSource createDataSource(Properties props) throws SQLException {
    MysqlDataSource source = new MysqlDataSource();
    setup(source, props);
    return source;
}

@Override
public ConnectionPoolDataSource createConnectionPoolDataSource(Properties props) throws SQLException {
   MysqlConnectionPoolDataSource source = new MysqlConnectionPoolDataSource();
   setup(source, props);
   return source;
}

@Override
public XADataSource createXADataSource(Properties props) throws SQLException {
   MysqlXADataSource source = new MysqlXADataSource();
   setupXSource(source, props);
   return source;
}

@Override
public Driver createDriver(Properties props) throws SQLException {
   com.mysql.jdbc.Driver driver = new com.mysql.jdbc.Driver();
   //Any setup neccessary?
   return driver;
}

/**
 * Setups the basic properties for {@link DataSource}s
 */
private void setup(MysqlDataSource source, Properties props) {
    if (props == null) {
        return;
    }
    if (props.containsKey(JDBC_DATABASE_NAME)) {
        source.setDatabaseName(props.getProperty(JDBC_DATABASE_NAME));
    }
    if (props.containsKey(JDBC_DATASOURCE_NAME)) {
        //not supported?
    }
    if (props.containsKey(JDBC_DESCRIPTION)) {
        //not suported?
    }
    if (props.containsKey(JDBC_NETWORK_PROTOCOL)) {
        //not supported?
    }
    if (props.containsKey(JDBC_PASSWORD)) {
        source.setPassword(props.getProperty(JDBC_PASSWORD));
    }
    if (props.containsKey(JDBC_PORT_NUMBER)) {
        source.setPortNumber(Integer.parseInt(props.getProperty(JDBC_PORT_NUMBER)));
    }
    if (props.containsKey(JDBC_ROLE_NAME)) {
        //not supported?
    }
    if (props.containsKey(JDBC_SERVER_NAME)) {
        source.setServerName(props.getProperty(JDBC_SERVER_NAME));
    }
    if (props.containsKey(JDBC_URL)) {
        source.setURL(props.getProperty(JDBC_URL));
    }
    if (props.containsKey(JDBC_USER)) {
        source.setUser(props.getProperty(JDBC_USER));
    }
}

/**
 * Setup the basic and extended properties for {@link XADataSource}s and
 * {@link ConnectionPoolDataSource}s
 */
private void setupXSource(MysqlXADataSource source, Properties props) {
    if (props == null) {
        return;
    }
    setup(source, props);
    if (props.containsKey(JDBC_INITIAL_POOL_SIZE)) {
        //not supported?
    }
    if (props.containsKey(JDBC_MAX_IDLE_TIME)) {
        //not supported?
    }
    if (props.containsKey(JDBC_MAX_STATEMENTS)) {
        //not supported?
    }
    if (props.containsKey(JDBC_MAX_POOL_SIZE)) {
        //not supported?
    }
    if (props.containsKey(JDBC_MIN_POOL_SIZE)) {
        //not supported?
    }
}

public void setDataSourceFactory(DataSourceFactory factory) throws SQLException {
    System.out.println("Starting MySQL OSGi Test...");
    Properties prop = new Properties();
    prop.put(DataSourceFactory.JDBC_DATABASE_NAME, "test");
    prop.put(DataSourceFactory.JDBC_SERVER_NAME, "localhost");
    prop.put(DataSourceFactory.JDBC_USER, "test_user");
    DataSource source = factory.createDataSource(prop);
    Connection connection = source.getConnection();
    Statement stm = connection.createStatement();
    ResultSet result = stm.executeQuery("SELECT * FROM test_table");
    while (result.next()) {
        System.out.println(result.getObject(1));
    }
    result.close();
    stm.close();
    connection.close();
}