本文整理匯總了Java中com.atomikos.jdbc.AtomikosDataSourceBean.setUniqueResourceName方法的典型用法代碼示例。如果您正苦於以下問題：Java AtomikosDataSourceBean.setUniqueResourceName方法的具體用法？Java AtomikosDataSourceBean.setUniqueResourceName怎麽用？Java AtomikosDataSourceBean.setUniqueResourceName使用的例子？那麽恭喜您, 這裏精選的方法代碼示例或許可以為您提供幫助。您也可以進一步了解該方法所在類com.atomikos.jdbc.AtomikosDataSourceBean的用法示例。

在下文中一共展示了AtomikosDataSourceBean.setUniqueResourceName方法的9個代碼示例，這些例子默認根據受歡迎程度排序。您可以為喜歡或者感覺有用的代碼點讚，您的評價將有助於我們的係統推薦出更棒的Java代碼示例。

示例1: dataSource

​點讚 3

​

import com.atomikos.jdbc.AtomikosDataSourceBean; //導入方法依賴的package包/類

@Bean(initMethod = "init", destroyMethod = "close")

public DataSource dataSource() {

MysqlXADataSource mysqlXaDataSource = new MysqlXADataSource();

mysqlXaDataSource

.setUrl("jdbc:mysql://localhost:3306/flowable?useSSL=false&characterEncoding=UTF-8&serverTimezone=UTC");

mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true);

mysqlXaDataSource.setPassword("flowable");

mysqlXaDataSource.setUser("flowable");

AtomikosDataSourceBean xaDataSource = new AtomikosDataSourceBean();

xaDataSource.setXaDataSource(mysqlXaDataSource);

xaDataSource.setUniqueResourceName("xads");

xaDataSource.setBorrowConnectionTimeout(30000);

xaDataSource.setMinPoolSize(10);

xaDataSource.setPoolSize(20);

xaDataSource.setMaxPoolSize(50);

return xaDataSource;

}

開發者ID:flowable，項目名稱:flowable-examples，代碼行數:19，

示例2: customerDataSource

​點讚 3

​

import com.atomikos.jdbc.AtomikosDataSourceBean; //導入方法依賴的package包/類

@Primary

@Bean(name = "customerDataSource", initMethod = "init", destroyMethod = "close")

//@Qualifier("customerDataSource")

public DataSource customerDataSource() {

MysqlXADataSource mysqlXaDataSource = new MysqlXADataSource();

mysqlXaDataSource.setUrl(customerDatasourceProperties.getUrl());

mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true);

mysqlXaDataSource.setPassword(customerDatasourceProperties.getPassword());

mysqlXaDataSource.setUser(customerDatasourceProperties.getUsername());

mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true);

AtomikosDataSourceBean xaDataSource = new AtomikosDataSourceBean();

xaDataSource.setXaDataSource(mysqlXaDataSource);

xaDataSource.setUniqueResourceName("xads1");

return xaDataSource;

}

開發者ID:YihuaWanglv，項目名稱:spring-boot-jta-atomikos-sample，代碼行數:18，

示例3: dataSource

​點讚 3

​

import com.atomikos.jdbc.AtomikosDataSourceBean; //導入方法依賴的package包/類

@Bean(initMethod = "init", destroyMethod = "close")

public DataSource dataSource() {

AtomikosDataSourceBean ds = new AtomikosDataSourceBean();

ds.setUniqueResourceName(environment.getProperty("jpa.unique.resource.name"));

ds.setXaDataSourceClassName(environment.getProperty("jpa.xa.datasource.classname"));

ds.setMinPoolSize(environment.getProperty("jpa.ds.minpoolsize", Integer.class));

ds.setMaxPoolSize(environment.getProperty("jpa.ds.maxpoolsize", Integer.class));

Properties props = new Properties();

props.put("databaseName", environment.getProperty("jpa.db.name"));

props.put("createDatabase", environment.getProperty("jpa.db.create.strategy"));

ds.setXaProperties(props);

ds.setPoolSize(1);

return ds;

}

開發者ID:bjornharvold，項目名稱:bearchoke，代碼行數:19，

示例4: init

​點讚 3

​

import com.atomikos.jdbc.AtomikosDataSourceBean; //導入方法依賴的package包/類

public static void init() {

utm = new UserTransactionManager();

try {

utm.init();

adsb = new AtomikosDataSourceBean();

adsb.setMaxPoolSize(20);

adsb.setUniqueResourceName("postgres");

adsb.setXaDataSourceClassName("org.postgresql.xa.PGXADataSource");

Properties p = new Properties();

p.setProperty("user", "postgres");

p.setProperty("password", "0");

p.setProperty("serverName", "localhost");

p.setProperty("portNumber", "5432");

p.setProperty("databaseName", "postgres");

adsb.setXaProperties(p);

} catch (SystemException e) {

e.printStackTrace();

throw new RuntimeException(e);

}

}

開發者ID:utluiz，項目名稱:threads-with-transaction，代碼行數:21，

示例5: init

​點讚 2

​

import com.atomikos.jdbc.AtomikosDataSourceBean; //導入方法依賴的package包/類

public void init() throws Exception{

System.out.println("**************init");

MicroMetaDao dao=MicroMetaDao.getInstance();

String sql="select * from nh_micro_xadbconf";

List> infoList=dao.queryObjJoinByCondition(sql);

for(Map row:infoList){

//String metaKey=(String) row.get("meta_key");

String uniqueResourceName=(String) row.get("unique_resource_name");

String xaDataSourceClassName=(String) row.get("xa_datasource_classname");

String dbUser=(String) row.get("db_user");

String dbPassWord=(String) row.get("db_password");

if(dbPassWord.startsWith("nhjm-")){

String temp=dbPassWord.substring(5);

dbPassWord=DESUtil.decrypt(temp);

}

String dbUrl=(String) row.get("db_url");

AtomikosDataSourceBean ads=new AtomikosDataSourceBean();

ads.setUniqueResourceName(uniqueResourceName);

ads.setXaDataSourceClassName(xaDataSourceClassName);

ads.setPoolSize(3);

ads.setReapTimeout(10);

Properties xaProperties=new Properties();

xaProperties.setProperty("user", dbUser);

xaProperties.setProperty("password", dbPassWord);

xaProperties.setProperty("url", dbUrl);

ads.setXaProperties(xaProperties);

ads.init();

holderMap.put(uniqueResourceName, ads);

}

}

開發者ID:jeffreyning，項目名稱:nh-micro，代碼行數:31，

示例6: dataSource

​點讚 2

​

import com.atomikos.jdbc.AtomikosDataSourceBean; //導入方法依賴的package包/類

@Bean(initMethod = "init", destroyMethod = "close")

public DataSource dataSource() throws SQLException {

AtomikosDataSourceBean datasource = new AtomikosDataSourceBean();

datasource.setUniqueResourceName("xads");

JDBCXADataSource hsqlDs = new JDBCXADataSource();

hsqlDs.setURL("jdbc:hsqldb:mem:test?hsqldb.applog=3");

hsqlDs.setUser("sa");

hsqlDs.setPassword("");

datasource.setXaDataSource(hsqlDs);

return datasource;

}

開發者ID:Kloudtek，項目名稱:ktspring，代碼行數:12，

示例7: orderDataSource

​點讚 2

​

import com.atomikos.jdbc.AtomikosDataSourceBean; //導入方法依賴的package包/類

@Bean(name = "orderDataSource", initMethod = "init", destroyMethod = "close")

public DataSource orderDataSource() {

MysqlXADataSource mysqlXaDataSource = new MysqlXADataSource();

mysqlXaDataSource.setUrl(orderDatasourceProperties.getUrl());

mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true);

mysqlXaDataSource.setPassword(orderDatasourceProperties.getPassword());

mysqlXaDataSource.setUser(orderDatasourceProperties.getUsername());

mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true);

AtomikosDataSourceBean xaDataSource = new AtomikosDataSourceBean();

xaDataSource.setXaDataSource(mysqlXaDataSource);

xaDataSource.setUniqueResourceName("xads2");

return xaDataSource;

}

開發者ID:YihuaWanglv，項目名稱:spring-boot-jta-atomikos-sample，代碼行數:15，

示例8: dataSource

​點讚 2

​

import com.atomikos.jdbc.AtomikosDataSourceBean; //導入方法依賴的package包/類

@Bean

public DataSource dataSource() {

AtomikosDataSourceBean atomikosDataSourceBean = new AtomikosDataSourceBean();

atomikosDataSourceBean.setXaDataSource(xaDataSource);

atomikosDataSourceBean.setUniqueResourceName("ds");

atomikosDataSourceBean.setMaxPoolSize(50);

return atomikosDataSourceBean;

}

開發者ID:adrobisch，項目名稱:brainslug，代碼行數:11，

示例9: createInstance

​點讚 1

​

import com.atomikos.jdbc.AtomikosDataSourceBean; //導入方法依賴的package包/類

/**

* This method set resources for Atomikos transactions.

*

* Template method that subclasses must override to construct the object

* returned by this factory.

*

* Invoked on initialization of this FactoryBean in case of a singleton;

* else, on each getObject() call.

*

* Overrides: createInstance() in AbstractFactoryBean Returns:

*

* @return The object returned by this factory

*

* @throws Exception

* - if an exception occurred during object creation

*

*/

@Override

protected Object createInstance() throws Exception {

AtomikosDataSourceBean result = new AtomikosDataSourceBean();

result.setXaDataSource(xaDataSource);

result.setUniqueResourceName(uniqueResourceName);

// result.setConnectionPoolSize(connectionPoolSize);

result.setPoolSize(connectionPoolSize);

// result.setExclusiveConnectionMode(exclusiveConnectionMode);

result.init();

return result;

}

開發者ID:M4GiK，項目名稱:Distributed-Transactions，代碼行數:30，

注：本文中的com.atomikos.jdbc.AtomikosDataSourceBean.setUniqueResourceName方法示例整理自Github/MSDocs等源碼及文檔管理平台，相關代碼片段篩選自各路編程大神貢獻的開源項目，源碼版權歸原作者所有，傳播和使用請參考對應項目的License；未經允許，請勿轉載。