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); } } }


上一篇:
下一篇:
切换中文