org.sonar.db.Database.getDataSource()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(5.3k)|赞(0)|评价(0)|浏览(155)

本文整理了Java中org.sonar.db.Database.getDataSource()方法的一些代码示例,展示了Database.getDataSource()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Database.getDataSource()方法的具体详情如下:
包路径:org.sonar.db.Database
类名称:Database
方法名:getDataSource

Database.getDataSource介绍

[英]Returns the configured datasource. Null as long as start() is not executed.
[中]返回配置的数据源。只要未执行start(),则为Null。

代码示例

代码示例来源:origin: SonarSource/sonarqube

  1. private static Connection createDdlConnection(Database database) throws SQLException {
  2. Connection res = database.getDataSource().getConnection();
  3. res.setAutoCommit(false);
  4. return res;
  5. }

代码示例来源:origin: SonarSource/sonarqube

  1. private Connection createDdlConnection() throws SQLException {
  2. Connection res = db.getDataSource().getConnection();
  3. res.setAutoCommit(false);
  4. return res;
  5. }

代码示例来源:origin: SonarSource/sonarqube

  1. private Connection createDdlConnection() throws SQLException {
  2. Connection writeConnection = db.getDataSource().getConnection();
  3. writeConnection.setAutoCommit(false);
  4. return writeConnection;
  5. }

代码示例来源:origin: SonarSource/sonarqube

  1. private Connection createReadUncommittedConnection() throws SQLException {
  2. Connection connection = db.getDataSource().getConnection();
  3. connection.setAutoCommit(false);
  4. if (connection.getMetaData().supportsTransactionIsolationLevel(Connection.TRANSACTION_READ_UNCOMMITTED)) {
  5. connection.setTransactionIsolation(Connection.TRANSACTION_READ_UNCOMMITTED);
  6. }
  7. return connection;
  8. }

代码示例来源:origin: SonarSource/sonarqube

  1. @Override
  2. public Optional<Long> getLastMigrationNumber() {
  3. try (Connection connection = database.getDataSource().getConnection()) {
  4. List<Long> versions = selectVersions(connection);
  5. if (!versions.isEmpty()) {
  6. return Optional.of(versions.get(versions.size() - 1));
  7. }
  8. return Optional.empty();
  9. } catch (SQLException e) {
  10. throw new IllegalStateException("Failed to read content of table " + SCHEMA_MIGRATIONS_TABLE, e);
  11. }
  12. }

代码示例来源:origin: SonarSource/sonarqube

  1. private BasicDataSource commonsDbcp() {
  2. return (BasicDataSource) dbClient.getDatabase().getDataSource();
  3. }
  4. }

代码示例来源:origin: SonarSource/sonarqube

  1. private boolean tableExists() throws SQLException {
  2. try (Connection connection = db.getDataSource().getConnection()) {
  3. return DatabaseUtils.tableExists(ORG_QUALITY_GATES, connection);
  4. }
  5. }
  6. }

代码示例来源:origin: SonarSource/sonarqube

  1. private boolean tableExists() throws SQLException {
  2. try (Connection connection = db.getDataSource().getConnection()) {
  3. return DatabaseUtils.tableExists(DEPRECATED_RULE_KEYS, connection);
  4. }
  5. }
  6. }

代码示例来源:origin: SonarSource/sonarqube

  1. @Override
  2. public void start() {
  3. try (Connection connection = database.getDataSource().getConnection()) {
  4. checkState(DatabaseUtils.tableExists(MigrationHistoryTable.NAME, connection), "Migration history table is missing");
  5. } catch (SQLException e) {
  6. Throwables.propagate(e);
  7. }
  8. }

代码示例来源:origin: SonarSource/sonarqube

  1. public boolean tableExists(Database database) throws SQLException {
  2. try (Connection connection = database.getDataSource().getConnection()) {
  3. return DatabaseUtils.tableExists(tableName, connection);
  4. }
  5. }

代码示例来源:origin: SonarSource/sonarqube

  1. private boolean tableExists() throws SQLException {
  2. try (Connection connection = getDatabase().getDataSource().getConnection()) {
  3. return DatabaseUtils.tableExists(TABLE_NAME, connection);
  4. }
  5. }
  6. }

代码示例来源:origin: SonarSource/sonarqube

  1. private boolean tableExists() throws SQLException {
  2. try (Connection connection = getDatabase().getDataSource().getConnection()) {
  3. return DatabaseUtils.tableExists(TABLE_NAME, connection);
  4. }
  5. }
  6. }

代码示例来源:origin: SonarSource/sonarqube

  1. private boolean tableExists() throws SQLException {
  2. try (Connection connection = getDatabase().getDataSource().getConnection()) {
  3. return DatabaseUtils.tableExists(TABLE_NAME, connection);
  4. }
  5. }
  6. }

代码示例来源:origin: SonarSource/sonarqube

  1. private boolean tableExists() throws SQLException {
  2. try (Connection connection = getDatabase().getDataSource().getConnection()) {
  3. return DatabaseUtils.tableExists(TABLE_NAME, connection);
  4. }
  5. }
  6. }

代码示例来源:origin: SonarSource/sonarqube

  1. private boolean tableExists() throws SQLException {
  2. try (Connection connection = getDatabase().getDataSource().getConnection()) {
  3. return DatabaseUtils.tableExists(TABLE_NAME, connection);
  4. }
  5. }
  6. }

代码示例来源:origin: SonarSource/sonarqube

  1. public void check(State state) {
  2. try (Connection connection = db.getDataSource().getConnection()) {
  3. CharsetHandler handler = getHandler(db.getDialect());
  4. if (handler != null) {
  5. handler.handle(connection, state);
  6. }
  7. } catch (SQLException e) {
  8. throw new IllegalStateException(e);
  9. }
  10. }

代码示例来源:origin: SonarSource/sonarqube

  1. @Before
  2. public void setUp() throws Exception {
  3. DataSource dataSource = mock(DataSource.class);
  4. when(database.getDataSource()).thenReturn(dataSource);
  5. Connection connection = mock(Connection.class);
  6. when(dataSource.getConnection()).thenReturn(connection);
  7. when(connection.getMetaData()).thenReturn(mock(DatabaseMetaData.class));
  8. }

代码示例来源:origin: SonarSource/sonarqube

  1. void truncateTables() {
  2. try {
  3. commands.truncateDatabase(db.getDataSource());
  4. } catch (SQLException e) {
  5. throw new IllegalStateException("Fail to truncate db tables", e);
  6. }
  7. }

代码示例来源:origin: SonarSource/sonarqube

  1. @Before
  2. public void setUp() throws Exception {
  3. DataSource dataSource = mock(DataSource.class);
  4. when(database.getDataSource()).thenReturn(dataSource);
  5. Connection connection = mock(Connection.class);
  6. when(dataSource.getConnection()).thenReturn(connection);
  7. when(connection.getMetaData()).thenReturn(mock(DatabaseMetaData.class));
  8. }

代码示例来源:origin: SonarSource/sonarqube

  1. private void insert(int... versions) throws SQLException {
  2. try (Connection connection = dbTester.database().getDataSource().getConnection()) {
  3. Arrays.stream(versions).forEach(version -> insert(connection, version));
  4. }
  5. }

相关文章