import org.osgi.service.jdbc.DataSourceFactory;
public class MyJDBCComponent {
private DataSourceFactory dataSourceFactory;
private DataSource dataSource;
public void activate(Map<String, Object> properties) throws SQLException {
dataSourceFactory = new DataSourceFactory();
Dictionary<String, Object> config = new Hashtable<String, Object>();
config.put(DataSourceFactory.JDBC_URL, "jdbc:mysql://localhost/mydb");
config.put(DataSourceFactory.JDBC_USER, "username");
config.put(DataSourceFactory.JDBC_PASSWORD, "password");
dataSource = dataSourceFactory.createDataSource(config);
Connection connection = dataSource.getConnection();
// ...
connection.close();
}
public void deactivate() {
if (dataSource != null) {
dataSourceFactory.destroyDataSource(dataSource);
}
}
}