Java 类javax.sql.XADataSource 实例源码

项目：spring-boot-multidatasource 文件：DataSourceAutoConfiguration.java

@Override
public ConditionOutcome getMatchOutcome(ConditionContext context,
        AnnotatedTypeMetadata metadata) {
    ConditionMessage.Builder message = ConditionMessage
            .forCondition("DataSourceAvailable");
    if (hasBean(context, DataSource.class)
            || hasBean(context, XADataSource.class)) {
        return ConditionOutcome
                .match(message.foundExactly("existing data source bean"));
    }
    if (anyMatches(context, metadata, this.pooledCondition,
            this.embeddedCondition)) {
        return ConditionOutcome.match(message
                .foundExactly("existing auto-configured data source bean"));
    }
    return ConditionOutcome
            .noMatch(message.didNotFind("any existing data source bean").atAll());
}

项目：monarch 文件：GemFireTransactionDataSource.java

/**
 * Creates a new instance of GemFireTransactionDataSource
 * 
 * @param xaDS The XADataSource object for the database driver.
 * @param configs - The ConfiguredDataSourceProperties containing the datasource properties.
 * @throws SQLException
 */
public GemFireTransactionDataSource(XADataSource xaDS, ConfiguredDataSourceProperties configs)
    throws SQLException {
  super(configs);
  if ((xaDS == null) || (configs == null)) {
    throw new SQLException(
        LocalizedStrings.GemFireTransactionDataSource_GEMFIRETRANSACTIONDATASOURCEXADATASOURCE_CLASS_OBJECT_IS_NULL_OR_CONFIGUREDDATASOURCEPROPERTIES_OBJECT_IS_NULL
            .toLocalizedString());
  }
  try {
    provider = new GemFireConnectionPoolManager(xaDS, configs, this);
    transManager = JNDIInvoker.getTransactionManager();
  } catch (Exception ex) {
    String exception = "GemFireTransactionDataSource::Exception = " + ex;
    if (logger.isDebugEnabled()) {
      logger.debug(exception, ex);
    }
    throw new SQLException(exception);
  }
}

项目：ByteJTA-sample 文件：ConsumerConfig.java

@Bean(name = "mybatisDataSource")
public DataSource getDataSource(@Autowired XADataSource xaDataSource, @Autowired TransactionManager transactionManager) {
    BasicManagedDataSource bds = new BasicManagedDataSource();
    bds.setXaDataSourceInstance(xaDataSource);
    bds.setTransactionManager(transactionManager);

    bds.setMaxTotal(50);
    bds.setInitialSize(20);
    bds.setMaxWaitMillis(60000);
    bds.setMinIdle(6);
    bds.setLogAbandoned(true);
    bds.setRemoveAbandonedOnBorrow(true);
    bds.setRemoveAbandonedOnMaintenance(true);
    bds.setRemoveAbandonedTimeout(1800);
    bds.setTestWhileIdle(true);
    bds.setTestOnBorrow(false);
    bds.setTestOnReturn(false);
    bds.setValidationQuery("select 'x' ");
    bds.setValidationQueryTimeout(1);
    bds.setTimeBetweenEvictionRunsMillis(30000);
    bds.setNumTestsPerEvictionRun(20);
    return bds;
}

项目：ByteJTA-sample 文件：ProviderConfig.java

@Bean(name = "dataSource")
public DataSource getDataSource(@Autowired XADataSource xaDataSource, @Autowired TransactionManager transactionManager) {
    BasicManagedDataSource bds = new BasicManagedDataSource();
    bds.setXaDataSourceInstance(xaDataSource);
    bds.setTransactionManager(transactionManager);

    bds.setMaxTotal(50);
    bds.setInitialSize(20);
    bds.setMaxWaitMillis(60000);
    bds.setMinIdle(6);
    bds.setLogAbandoned(true);
    bds.setRemoveAbandonedOnBorrow(true);
    bds.setRemoveAbandonedOnMaintenance(true);
    bds.setRemoveAbandonedTimeout(1800);
    bds.setTestWhileIdle(true);
    bds.setTestOnBorrow(false);
    bds.setTestOnReturn(false);
    bds.setValidationQuery("select 'x' ");
    bds.setValidationQueryTimeout(1);
    bds.setTimeBetweenEvictionRunsMillis(30000);
    bds.setNumTestsPerEvictionRun(20);
    return bds;
}

项目：morf 文件：MySql.java

/**
 * Returns a MySQL XA data source. Note that this method may fail at
 * run-time if {@code MysqlXADataSource} is not available on the classpath.
 *
 * @throws IllegalStateException If the data source cannot be created.
 *
 * @see org.alfasoftware.morf.jdbc.DatabaseType#getXADataSource(java.lang.String,
 *      java.lang.String, java.lang.String)
 */
@Override
public XADataSource getXADataSource(String jdbcUrl, String username, String password) {
  try {
    log.info("Initialising MySQL XA data source...");
    XADataSource dataSource = (XADataSource) Class.forName("com.mysql.jdbc.jdbc2.optional.MysqlXADataSource").newInstance();
    dataSource.getClass().getMethod("setURL", String.class).invoke(dataSource, jdbcUrl);
    dataSource.getClass().getMethod("setUser", String.class).invoke(dataSource, username);
    dataSource.getClass().getMethod("setPassword", String.class).invoke(dataSource, password);
    //see http://www.atomikos.com/Documentation/KnownProblems#MySQL_XA_bug
    //did not have to set com.atomikos.icatch.serial_jta_transactions=false
    dataSource.getClass().getMethod("setPinGlobalTxToPhysicalConnection", boolean.class).invoke(dataSource, true);
    return dataSource;
  } catch (Exception e) {
    throw new IllegalStateException("Failed to create Oracle XA data source", e);
  }
}

项目：ThriftyPaxos 文件：OsgiDataSourceFactory.java

/**
 * Creates a pooled XA data source.
 *
 * @param properties the properties for the data source.
 * @throws SQLException if unsupported properties are supplied, or if data
 *             source can not be created.
 * @return a new data source.
 */
@Override
public XADataSource createXADataSource(Properties properties)
        throws SQLException {
    // Make copy of properties
    Properties propertiesCopy = new Properties();
    if (properties != null) {
        propertiesCopy.putAll(properties);
    }

    // Verify that no unsupported standard options are used
    rejectUnsupportedOptions(propertiesCopy);

    // The integrated connection pool is H2 is not configurable
    rejectPoolingOptions(propertiesCopy);

    JdbcDataSource dataSource = new JdbcDataSource();

    setupH2DataSource(dataSource, propertiesCopy);

    return dataSource;
}

项目：spring-boot-concourse 文件：NarayanaDataSourceBeanTests.java

@Test
public void shouldGetConnectionAndCommit() throws SQLException {
    Connection mockConnection = mock(Connection.class);
    XAConnection mockXaConnection = mock(XAConnection.class);
    given(mockXaConnection.getConnection()).willReturn(mockConnection);
    given(this.dataSource.getXAConnection()).willReturn(mockXaConnection);

    Properties properties = new Properties();
    properties.put(TransactionalDriver.XADataSource, this.dataSource);

    Connection connection = this.dataSourceBean.getConnection();
    assertThat(connection).isInstanceOf(ConnectionImple.class);

    connection.commit();

    verify(this.dataSource, times(1)).getXAConnection();
    verify(mockXaConnection, times(1)).getConnection();
    verify(mockConnection, times(1)).commit();
}

项目：gemfirexd-oss 文件：XADataSourceConnector.java

public Connection openConnection(String databaseName) throws SQLException {
    JDBCDataSource.setBeanProperty(ds, "databaseName", databaseName);
    try {
        return ds.getXAConnection().getConnection();
    } catch (SQLException e) {
        // Expected state for database not found.
        // For the client the generic 08004 is returned,
        // will just retry on that.
        String expectedState = 
            config.getJDBCClient().isEmbedded() ? "XJ004" : "08004";

        // If there is a database not found exception
        // then retry the connection request with
        // a new DataSource with the createDtabase property set.
        if (!expectedState.equals(e.getSQLState()))
            throw e;
        XADataSource tmpDs = singleUseDS("createDatabase", "create");
        JDBCDataSource.setBeanProperty(tmpDs, "databaseName", databaseName);
        return tmpDs.getXAConnection().getConnection();
   }
}

项目：gemfirexd-oss 文件：PoolXADSCreateShutdownDBTest.java

protected void assertConSetOK(Object ds, String expectedSQLState, 
    String dbName, String connAttrValue, String setter, String setValue) 
throws SQLException {
    JDBCDataSource.setBeanProperty(ds, "databaseName", dbName);
    JDBCDataSource.setBeanProperty(ds, setter, setValue);
    JDBCDataSource.setBeanProperty(
        ds, "ConnectionAttributes", connAttrValue);
    // check that the db exists; execute an unnecessary, but harmless, stmt
    try {
        if (ds instanceof javax.sql.ConnectionPoolDataSource)
            ((ConnectionPoolDataSource)ds).getPooledConnection();
        else
            ((XADataSource)ds).getXAConnection();
        fail("expected an sqlexception " + expectedSQLState);
    } catch (SQLException se) {
        assertSQLState(expectedSQLState, se);
    }
    JDBCDataSource.clearStringBeanProperty(ds, setter);
    JDBCDataSource.clearStringBeanProperty(ds, "ConnectionAttributes");
}