Java 类org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder 实例源码
项目:amv-access-api-poc
文件:EmbeddedMySqlConfig.java
@Primary
@Bean(destroyMethod = "close")
public DataSource dataSource() {
final EmbeddedMysql embeddedMysql = embeddedMysql(); // make sure embeddedMySql is started.
Map<String, String> params = ImmutableMap.<String, String>builder()
.put("profileSQL", String.valueOf(false))
.put("generateSimpleParameterMetadata", String.valueOf(true))
.build();
final String url = String.format("jdbc:mysql://localhost:%d/%s?%s",
embeddedMysql.getConfig().getPort(),
SCHEMA_NAME,
Joiner.on("&").withKeyValueSeparator("=").join(params));
DataSourceBuilder dataSourceBuilder = DataSourceBuilder.create();
dataSourceBuilder.username(embeddedMysql.getConfig().getUsername());
dataSourceBuilder.password(embeddedMysql.getConfig().getPassword());
dataSourceBuilder.driverClassName(com.mysql.jdbc.Driver.class.getName());
dataSourceBuilder.url(url);
return dataSourceBuilder.build();
}
项目:calcite-sql-rewriter
文件:SqlRewriterConfiguration.java
@Bean
public JdbcTemplate postgresJdbcTemplate(
@Value("${postgres.jdbcUrl}") String postgresJdbcUrl,
@Value("${postgres.jdbcDriver}") String postgresJdbcDriver,
@Value("${postgres.jdbcUser}") String postgresJdbcUser,
@Value("${postgres.jdbcPassword}") String postgresJdbcPassword) {
DataSource targetDataSource = DataSourceBuilder
.create()
.driverClassName(postgresJdbcDriver)
.url(postgresJdbcUrl)
.username(postgresJdbcUser)
.password(postgresJdbcPassword)
.build();
return new JdbcTemplate(targetDataSource);
}
项目:BackOffice
文件:DataBaseCaller.java
/**
*
* @return экземпляр JDBCTemplate Для работы с тестовой базой данных
*/
public Database getFirstFunctionalInstance(){
if (firstFunctionalInstance == null) {
LOG.debug("Инициируем новый инстанс базы данных");
DataSource ds = DataSourceBuilder
.create()
.username(databaseUser)
.password(databasePassword)
.url("jdbc:sqlserver://192.168.20.28:49484;instance=maindb")
.driverClassName("com.microsoft.sqlserver.jdbc.SQLServerDriver")
.build();
this.firstFunctionalInstance = new Database(ds);
return firstFunctionalInstance;
}
else {
LOG.debug("Инстанс базы данных уже инициирован, возвращаем существующий");
return firstFunctionalInstance;}
}
项目:BackOffice
文件:DataBaseCaller.java
public Database getFirstFunctionalInstance(String databaseName){
if (firstFunctionalInstance == null) {
LOG.debug("Инициируем новый инстанс базы данных");
DataSource ds = DataSourceBuilder
.create()
.username(databaseUser)
.password(databasePassword)
.url("jdbc:sqlserver://192.168.20.28:49484;instance=maindb;databaseName="+databaseName)
.driverClassName("com.microsoft.sqlserver.jdbc.SQLServerDriver")
.build();
this.firstFunctionalInstance = new Database(ds);
return firstFunctionalInstance;
}
else {
LOG.debug("Инстанс базы данных уже инициирован, возвращаем существующий");
return firstFunctionalInstance;}
}
项目:BackOffice
文件:DataBaseCaller.java
/**
*
* @return экземпляр JDBCTemplate Для работы с базой данных нагрузочного стенда
*/
public Database getLoadInstance(){
if (loadInstance == null) {
LOG.debug("Инициируем новый инстанс базы данных");
DataSource ds = DataSourceBuilder
.create()
.username(databaseUser)
.password(databasePassword)
.url("jdbc:sqlserver://192.168.21.9;instance=maindb")
.driverClassName("com.microsoft.sqlserver.jdbc.SQLServerDriver")
.build();
this.loadInstance = new Database(ds);
return loadInstance;
}
else {
LOG.debug("Инстанс базы данных уже инициирован, возвращаем существующий");
return loadInstance;}
}
项目:spring-boot-multidatasource
文件:DataSourceInitializer.java
private void runScripts(List<Resource> resources, String username, String password) {
if (resources.isEmpty()) {
return;
}
ResourceDatabasePopulator populator = new ResourceDatabasePopulator();
populator.setContinueOnError(this.properties.isContinueOnError());
populator.setSeparator(this.properties.getSeparator());
if (this.properties.getSqlScriptEncoding() != null) {
populator.setSqlScriptEncoding(this.properties.getSqlScriptEncoding().name());
}
for (Resource resource : resources) {
populator.addScript(resource);
}
DataSource dataSource = this.dataSource;
if (StringUtils.hasText(username) && StringUtils.hasText(password)) {
dataSource = DataSourceBuilder.create(this.properties.getClassLoader())
.driverClassName(this.properties.determineDriverClassName())
.url(this.properties.determineUrl()).username(username)
.password(password).build();
}
DatabasePopulatorUtils.execute(populator, dataSource);
}
项目:micro-service-sample
文件:ReadonlySourceConfiguration.java
@Bean
@ConfigurationProperties(prefix="spring.datasource.readonly")
public DataSource readonlyDataSource() throws SQLException {
DruidDataSource dataSource = (DruidDataSource)DataSourceBuilder
.create()
.type(DruidDataSource.class)
.build();
// dataSource.setFilters("wall");
/*
WallFilter wallFilter = new WallFilter();
wallFilter.setLogViolation(true);
wallFilter.setThrowException(false);
dataSource.getProxyFilters().add(wallFilter);
*/
return dataSource;
}
项目:jhipster-ribbon-hystrix
文件:DatabaseConfiguration.java
@Bean(destroyMethod = "close")
@ConditionalOnExpression("#{!environment.acceptsProfiles('" + Constants.SPRING_PROFILE_CLOUD + "') && !environment.acceptsProfiles('" + Constants.SPRING_PROFILE_HEROKU + "')}")
@ConfigurationProperties(prefix = "spring.datasource.hikari")
public DataSource dataSource(DataSourceProperties dataSourceProperties) {
log.debug("Configuring Datasource");
if (dataSourceProperties.getUrl() == null) {
log.error("Your database connection pool configuration is incorrect! The application" +
" cannot start. Please check your Spring profile, current profiles are: {}",
Arrays.toString(env.getActiveProfiles()));
throw new ApplicationContextException("Database connection pool is not configured correctly");
}
HikariDataSource hikariDataSource = (HikariDataSource) DataSourceBuilder
.create(dataSourceProperties.getClassLoader())
.type(HikariDataSource.class)
.driverClassName(dataSourceProperties.getDriverClassName())
.url(dataSourceProperties.getUrl())
.username(dataSourceProperties.getUsername())
.password(dataSourceProperties.getPassword())
.build();
if (metricRegistry != null) {
hikariDataSource.setMetricRegistry(metricRegistry);
}
return hikariDataSource;
}
项目:jhipster-ribbon-hystrix
文件:DatabaseConfiguration.java
@Bean(destroyMethod = "close")
@ConditionalOnExpression("#{!environment.acceptsProfiles('" + Constants.SPRING_PROFILE_CLOUD + "') && !environment.acceptsProfiles('" + Constants.SPRING_PROFILE_HEROKU + "')}")
@ConfigurationProperties(prefix = "spring.datasource.hikari")
public DataSource dataSource(DataSourceProperties dataSourceProperties) {
log.debug("Configuring Datasource");
if (dataSourceProperties.getUrl() == null) {
log.error("Your database connection pool configuration is incorrect! The application" +
" cannot start. Please check your Spring profile, current profiles are: {}",
Arrays.toString(env.getActiveProfiles()));
throw new ApplicationContextException("Database connection pool is not configured correctly");
}
HikariDataSource hikariDataSource = (HikariDataSource) DataSourceBuilder
.create(dataSourceProperties.getClassLoader())
.type(HikariDataSource.class)
.driverClassName(dataSourceProperties.getDriverClassName())
.url(dataSourceProperties.getUrl())
.username(dataSourceProperties.getUsername())
.password(dataSourceProperties.getPassword())
.build();
if (metricRegistry != null) {
hikariDataSource.setMetricRegistry(metricRegistry);
}
return hikariDataSource;
}
项目:c2mon
文件:ConfigDataSourceConfig.java
@Bean
@org.springframework.boot.context.properties.ConfigurationProperties(prefix = "c2mon.server.configuration.jdbc")
public DataSource configurationDataSource() {
String url = properties.getJdbc().getUrl();
String username = properties.getJdbc().getUsername();
String password = properties.getJdbc().getPassword();
// A simple inspection is done on the JDBC URL to deduce whether to create an in-memory
// in-process database, start a file-based externally visible database or connect to
// an external database.
if (url.contains("hsql")) {
return new HsqlDatabaseBuilder()
.url(url)
.username(username)
.password(password)
.addScript(new ClassPathResource("sql/config-schema-hsqldb.sql")).build();
} else {
return DataSourceBuilder.create().build();
}
}
项目:c2mon
文件:HistoryDataSourceConfig.java
@Bean
@ConfigurationProperties("c2mon.server.history.jdbc")
public DataSource historyDataSource() {
String url = properties.getJdbc().getUrl();
String username = properties.getJdbc().getUsername();
String password = properties.getJdbc().getPassword();
if (url.contains("hsql")) {
return new HsqlDatabaseBuilder()
.url(url)
.username(username)
.password(password)
.addScript(new ClassPathResource("sql/history-schema-hsqldb.sql")).build();
} else {
return DataSourceBuilder.create().build();
}
}
项目:c2mon
文件:HsqlDatabaseBuilder.java
public DataSource build() {
DataSource dataSource;
if (url == null || url.contains("hsqldb:mem")) {
// Start an in-process, in-memory HSQL server
dataSource = new EmbeddedDatabaseBuilder().setType(HSQL).setName("c2mondb").build();
} else if (url.contains("hsql://")) {
// Start an externally visible, file-based HSQL server
HsqlServer.start("file:///tmp/c2mondb", "c2mondb");
url += ";sql.syntax_ora=true;hsqldb.default_table_type=cached;hsqldb.cache_rows=1000;hsqldb.result_max_memory_rows=2000;hsqldb.cache_size=100";
dataSource = DataSourceBuilder.create().url(url).username(username).password(password).build();
} else {
throw new RuntimeException("The given URL was not a valid HSQL JDBC URL!");
}
if (!scripts.isEmpty()) {
ResourceDatabasePopulator populator = new ResourceDatabasePopulator(scripts.toArray(new Resource[scripts.size()]));
populator.setContinueOnError(true);
DatabasePopulatorUtils.execute(populator, dataSource);
}
return dataSource;
}
项目:c2mon
文件:CacheDataSourceConfig.java
@Bean
@ConfigurationProperties(prefix = "c2mon.server.cachedbaccess.jdbc")
public DataSource cacheDataSource() {
String url = properties.getJdbc().getUrl();
String username = properties.getJdbc().getUsername();
String password = properties.getJdbc().getPassword();
// A simple inspection is done on the JDBC URL to deduce whether to create an in-memory
// in-process database, start a file-based externally visible database or connect to
// an external database.
if (url.contains("hsql")) {
return new HsqlDatabaseBuilder()
.url(url)
.username(username)
.password(password)
.addScript(new ClassPathResource("sql/cache-schema-hsqldb.sql")).build();
} else {
return DataSourceBuilder.create().build();
}
}
项目:Dynamic-data-sources
文件:DynamicDataSourceRegister.java
/**
* 创建DataSource
*/
@SuppressWarnings("unchecked")
public DataSource buildDataSource(Map<String, Object> dsMap) {
try {
Object type = dsMap.get("type");
if (type == null)
type = DATASOURCE_TYPE_DEFAULT;// 默认DataSource
Class<? extends DataSource> dataSourceType;
dataSourceType = (Class<? extends DataSource>) Class.forName((String) type);
String driverClassName = dsMap.get("driverClassName").toString();
String url = dsMap.get("url").toString();
String username = dsMap.get("username").toString();
String password = dsMap.get("password").toString();
DataSourceBuilder factory = DataSourceBuilder.create().driverClassName(driverClassName).url(url)
.username(username).password(password).type(dataSourceType);
return factory.build();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
return null;
}
项目:kekoa
文件:DynamicDataSourceRegister.java
/**
* 创建DataSource
*
* @param type
* @param driverClassName
* @param url
* @param username
* @param password
* @return
* @author SHANHY
* @create 2016年1月24日
*/
@SuppressWarnings("unchecked")
public DataSource buildDataSource(Map<String, Object> dsMap) {
try {
Object type = dsMap.get("type");
if (type == null)
type = DATASOURCE_TYPE_DEFAULT;// 默认DataSource
Class<? extends DataSource> dataSourceType;
dataSourceType = (Class<? extends DataSource>) Class.forName((String) type);
String driverClassName = dsMap.get("driver-class-name").toString();
String url = dsMap.get("url").toString();
String username = dsMap.get("username").toString();
String password = dsMap.get("password").toString();
DataSourceBuilder factory = DataSourceBuilder.create().driverClassName(driverClassName).url(url)
.username(username).password(password).type(dataSourceType);
return factory.build();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
return null;
}
项目:apparel
文件:DatabaseConfig.java
@Bean
public DataSource dataSourceProd() {
String databaseUrl = env.getProperty("database.url");
String databaseUsername = env.getProperty("database.username");
String databasePassword = env.getProperty("database.password");
if(databaseUrl == null || databaseUsername == null || databasePassword == null) {
logger.log(Level.ALL, "Using local H2 database");
return new EmbeddedDatabaseBuilder().setType(EmbeddedDatabaseType.H2).build();
}
logger.log(Level.ALL, "Using database " + databaseUrl);
return DataSourceBuilder.create()
.url(databaseUrl)
.username(databaseUsername)
.password(databasePassword)
.build();
}
项目:blackhole
文件:DatabaseConfiguration.java
@Bean(destroyMethod = "close")
@ConditionalOnExpression("#{!environment.acceptsProfiles('" + Constants.SPRING_PROFILE_CLOUD + "') && !environment.acceptsProfiles('" + Constants.SPRING_PROFILE_HEROKU + "')}")
@ConfigurationProperties(prefix = "spring.datasource.hikari")
public DataSource dataSource(DataSourceProperties dataSourceProperties) {
log.debug("Configuring Datasource");
if (dataSourceProperties.getUrl() == null) {
log.error("Your database connection pool configuration is incorrect! The application" +
" cannot start. Please check your Spring profile, current profiles are: {}",
Arrays.toString(env.getActiveProfiles()));
throw new ApplicationContextException("Database connection pool is not configured correctly");
}
HikariDataSource hikariDataSource = (HikariDataSource) DataSourceBuilder
.create(dataSourceProperties.getClassLoader())
.type(HikariDataSource.class)
.driverClassName(dataSourceProperties.getDriverClassName())
.url(dataSourceProperties.getUrl())
.username(dataSourceProperties.getUsername())
.password(dataSourceProperties.getPassword())
.build();
if (metricRegistry != null) {
hikariDataSource.setMetricRegistry(metricRegistry);
}
return hikariDataSource;
}
项目:workflow-catalog-old
文件:Application.java
@Bean
@Profile("default")
public DataSource defaultDataSource() {
String jdbcUrl = dataSourceUrl;
if (jdbcUrl.isEmpty()) {
jdbcUrl = "jdbc:hsqldb:file:" + getDatabaseDirectory() +
";create=true;hsqldb.tx=mvcc;hsqldb.applog=1;hsqldb.sqllog=0;hsqldb.write_delay=false";
}
return DataSourceBuilder.create()
.username(dataSourceUsername)
.password(dataSourcePassword)
.url(jdbcUrl)
.driverClassName(dataSourceDriverClassName)
.build();
}
项目:REST-Web-Services
文件:WebDatasourceConfig.java
/**
* Get data source.
*
* @return Data source
*/
@Primary
@Bean
@ConfigurationProperties(prefix="spring.datasource")
public DataSource getDatasource() {
return DataSourceBuilder.create().build();
}
项目:read-write-sever
文件:DatabaseConfig.java
@Bean(name="writeDataSource", destroyMethod = "close", initMethod="init")
@Primary
@ConfigurationProperties(prefix = "spring.datasource")
public DataSource writeDataSource() {
logger.info("初始化写入数据源……");
return DataSourceBuilder.create().type(dataSourceType).build();
}
项目:read-write-sever
文件:DatabaseConfig.java
/**
* 有多少个从库就要配置多少个
* @return
*/
@Bean(name = "readDataSource")
@ConfigurationProperties(prefix = "custom.datasource.read")
public DataSource readDataSource(){
logger.info("初始化读数据源……");
return DataSourceBuilder.create().type(dataSourceType).build();
}
项目:amv-access-api-poc
文件:SqliteTestDatabaseConfig.java
@Bean
@Primary
public DataSource dataSource() {
DataSourceBuilder dataSourceBuilder = DataSourceBuilder.create();
dataSourceBuilder.driverClassName(org.sqlite.JDBC.class.getName());
dataSourceBuilder.url("jdbc:sqlite:~amv-access-test.db?journal_mode=wal");
return dataSourceBuilder.build();
}
项目:amv-access-api-poc
文件:SwaggerSqliteTestDatabaseConfig.java
@Bean
@Primary
public DataSource dataSource() {
DataSourceBuilder dataSourceBuilder = DataSourceBuilder.create();
dataSourceBuilder.driverClassName(org.sqlite.JDBC.class.getName());
dataSourceBuilder.url("jdbc:sqlite:~amv-access-swagger-docs.db?journal_mode=wal");
return dataSourceBuilder.build();
}
项目:springboot-smart
文件:DataBaseConfigration.java
@Bean(name = "writeDataSource", destroyMethod = "close", initMethod = "init")
@Primary
@ConfigurationProperties(prefix = "spring.datasource")
public DataSource writeDataSource() {
log.info("-------------------- writeDataSource init ---------------------");
return DataSourceBuilder.create().type(dataSourceType).build();
}
项目:druid-spring-boot
文件:DruidDataSourceInitializer.java
private void runScripts(List<Resource> resources, String username, String password) {
if (resources.isEmpty()) {
return;
}
ResourceDatabasePopulator populator = new ResourceDatabasePopulator();
populator.setContinueOnError(this.properties.isContinueOnError());
populator.setSeparator(this.properties.getSeparator());
if (this.properties.getSqlScriptEncoding() != null) {
populator.setSqlScriptEncoding(this.properties.getSqlScriptEncoding().name());
}
for (Resource resource : resources) {
populator.addScript(resource);
}
DataSource dataSource = this.dataSource;
if (StringUtils.hasText(username) && StringUtils.hasText(password)) {
dataSource = DataSourceBuilder.create(this.properties.getClassLoader())
.driverClassName(this.properties.determineDriverClassName())
.url(this.properties.determineUrl()).username(username)
.password(password).build();
}
DatabasePopulatorUtils.execute(populator, dataSource);
}
项目:druid-boot-starter
文件:DruidAutoConfiguration.java
@Bean
@ConfigurationProperties(DruidProperties.DRUID_PREFIX)
public DataSource dataSource(DruidProperties properties) {
DruidDataSource datasource = (DruidDataSource) DataSourceBuilder
.create()
.type(DruidDataSource.class)
.build();
configDruid(datasource, properties);
return datasource;
}
项目:calcite-sql-rewriter
文件:SqlRewriterConfiguration.java
@Bean
@ConfigurationProperties("calcite.datasource")
public DataSource calciteDataSource(@Autowired String inlineModel) {
DataSource dataSource = DataSourceBuilder
.create()
.driverClassName("org.apache.calcite.jdbc.Driver")
.url("jdbc:calcite:lex=JAVA;model=inline:" + inlineModel)
.build();
log.info("Generated Calcite mode: " + inlineModel);
return dataSource;
}
项目:MI-S
文件:DataBaseConfiguration.java
/**
* 主库配置(负责写)
* @return
*/
@Bean(name="masterDataSource")
@Primary
@ConfigurationProperties(prefix = "spring.datasource")
public DataSource writeDataSource() {
log.info("-------------------- Master DataSource init ---------------------");
return DataSourceBuilder.create().type(dataSourceType).build();
}
项目:MI-S
文件:DataBaseConfiguration.java
/**
* 主库配置(负责写)
* @return
*/
@Bean(name="masterDataSource", destroyMethod = "close", initMethod="init")
@Primary
@ConfigurationProperties(prefix = "spring.datasource",locations = "classpath:application.properties")
public DataSource writeDataSource() {
log.info("-------------------- Master DataSource init ---------------------");
return DataSourceBuilder.create().type(dataSourceType).build();
}
项目:MI-S
文件:DataBaseConfiguration.java
/**
* 从库配置(负责读)
* @return
*/
@Bean(name = "slaveDataSourceOne")
@ConfigurationProperties(prefix = "spring.slave",locations = "classpath:application.properties")
public DataSource readDataSourceOne(){
log.info("-------------------- Slave DataSource One init ---------------------");
return DataSourceBuilder.create().type(dataSourceType).build();
}
项目:Building-Web-Apps-with-Spring-5-and-Angular
文件:AppConfig.java
@Bean(name = "dataSource")
public DataSource getDataSource() {
DataSource dataSource = DataSourceBuilder
.create()
.username(username)
.password(password)
.url(url)
.driverClassName(driverClassName)
.build();
return dataSource;
}
项目:Building-Web-Apps-with-Spring-5-and-Angular
文件:AppConfig.java
@Bean(name = "dataSource")
public DataSource getDataSource() {
DataSource dataSource = DataSourceBuilder
.create()
.username(username)
.password(password)
.url(url)
.driverClassName(driverClassName)
.build();
return dataSource;
}
项目:activiti-analytics-spring-boot
文件:AnalyticsConfig.java
@Bean
@Primary
@ConfigurationProperties(prefix = "spring.datasource")
public DataSource activitiDataSource() {
logger.debug("creating activitiDataSource bean");
return DataSourceBuilder.create().build();
}
项目:mybatis-migrations-spring-boot-autoconfigure
文件:MyBatisMigrationsAutoConfiguration.java
private DataSource getDataSource() {
if (this.myBatisMigrationsDataSource != null) {
return this.myBatisMigrationsDataSource;
}
if (this.properties.getUrl() == null) {
return this.dataSource;
}
return DataSourceBuilder.create().url(this.properties.getUrl())
.username(this.properties.getUser())
.password(this.properties.getPassword()).build();
}
项目:participationSystem3a
文件:DataSourceBean.java
@Bean
@Primary
@ConfigurationProperties(prefix = "spring.datasource")
public DataSource dataSource() {
ConnectionData conData = getDbUrl();
return DataSourceBuilder
.create()
.url(conData.getUrl() + "?sslmode=require")
.username(conData.getUser())
.password(conData.getPassword())
.driverClassName("org.postgresql.Driver")
.build();
}
项目:klask-io
文件:DatabaseConfiguration.java
@Bean(destroyMethod = "close")
@ConditionalOnExpression("#{!environment.acceptsProfiles('" + Constants.SPRING_PROFILE_CLOUD + "') && !environment.acceptsProfiles('" + Constants.SPRING_PROFILE_HEROKU + "')}")
@ConfigurationProperties(prefix = "spring.datasource.hikari")
public DataSource dataSource(DataSourceProperties dataSourceProperties) {
log.debug("Configuring Datasource");
if (dataSourceProperties.getUrl() == null) {
log.error("Your database connection pool configuration is incorrect! The application" +
" cannot start. Please check your Spring profile, current profiles are: {}",
Arrays.toString(env.getActiveProfiles()));
throw new ApplicationContextException("Database connection pool is not configured correctly");
}
HikariDataSource hikariDataSource = (HikariDataSource) DataSourceBuilder
.create(dataSourceProperties.getClassLoader())
.type(HikariDataSource.class)
.driverClassName(dataSourceProperties.getDriverClassName())
.url(dataSourceProperties.getUrl())
.username(dataSourceProperties.getUsername())
.password(dataSourceProperties.getPassword())
.build();
if (metricRegistry != null) {
hikariDataSource.setMetricRegistry(metricRegistry);
}
return hikariDataSource;
}
项目:data-migration
文件:DataSourceConfiguration.java
@Bean
@Primary
@Qualifier("jpaDataSource")
@ConfigurationProperties(prefix = "spring.datasource")
public DataSource createJpaDataSource() {
return DataSourceBuilder.create().type(dataSourceType).build();
}
项目:integrate-activiti-with-spring
文件:IntegrateActivitiWithSpringApplication.java
/**
* Activiti's user guide - 5.7.3. Changing the database and connection pool
* https://www.activiti.org/userguide/index.html#_changing_the_database_and_connection_pool
**/
@Bean(name = "datasource.activiti")
public DataSource activitiDataSource() {
return DataSourceBuilder.create(this.dataSourceproperties.getClassLoader())
.url(this.dataSourceproperties.getUrl())
.username(this.dataSourceproperties.getUsername())
.password(this.dataSourceproperties.getPassword())
.driverClassName(this.dataSourceproperties.getDriverClassName())
.build();
}
项目:spring-boot-starter-dynamic-datasource
文件:DynamicDataSourceRegister.java
/**
* @param dataSourceClassType
* @return
* @Title: buildDataSource
* @Description: 根据数据源class类型创建数据源
* @author Kola 6089555
* @date 2017年4月24日 下午6:46:47
*/
@SuppressWarnings("unchecked")
public DataSource buildDataSource(String dataSourceClassType) {
DataSource dataSource = null;
try {
if (StringUtils.isBlank(dataSourceClassType))
dataSourceClassType = DATASOURCE_TYPE_DEFAULT;
Class<? extends DataSource> dataSourceType = (Class<? extends DataSource>) Class.forName(dataSourceClassType);
dataSource = DataSourceBuilder.create().type(dataSourceType).build();
} catch (ClassNotFoundException e) {
LOGGER.error("buildDataSource failure.because {}", e.getMessage());
e.printStackTrace();
}
return dataSource;
}
项目:sample-schedule-job-admin
文件:WebMvc.java
@Bean
public DataSource getDataSource() {
return DataSourceBuilder
.create()
.driverClassName("org.hsqldb.jdbcDriver")
.url("jdbc:hsqldb:file:" + new File(Utils.getBase(), "db").getPath() + "/store")
.username("iisi")
.password("")
.build();
}