Java 类org.jooq.conf.Settings 实例源码

项目：AdvancedDataProfilingSeminar 文件：TestDatabase.java

public void setUp() throws Exception {
  connection = DriverManager.getConnection("jdbc:hsqldb:mem:myDb");
  context = DSL.using(connection, SQLDialect.HSQLDB, new Settings().withRenderNameStyle(
      RenderNameStyle.AS_IS));

  final List<Field<String>> fields = getFields();

  context.createTable(relationName)
      .columns(fields)
      .execute();

  try (InputStream in = resourceClass.getResourceAsStream(csvPath)) {
    final Loader<Record> loader = context.loadInto(table(name(relationName)))
        .loadCSV(in)
        .fields(fields)
        .execute();

    assertThat(loader.errors()).isEmpty();
  }
}

项目：curiostack 文件：DatabaseModule.java

@Provides
@Singleton
static DSLContext dbContext(
    DataSource dataSource, @ForDatabase ListeningExecutorService dbExecutor) {
  Configuration configuration =
      new DefaultConfiguration()
          .set(dbExecutor)
          .set(SQLDialect.MYSQL)
          .set(new Settings().withRenderSchema(false))
          .set(new DataSourceConnectionProvider(dataSource))
          .set(DatabaseUtil.sfmRecordMapperProvider());
  DSLContext ctx = DSL.using(configuration);
  // Eagerly trigger JOOQ classinit for better startup performance.
  ctx.select().from("curio_server_framework_init").getSQL();
  return ctx;
}

项目：steve-plugsurfing 文件：BeanConfiguration.java

/**
 * Can we re-use DSLContext as a Spring bean (singleton)? Yes, the Spring tutorial of
 * Jooq also does it that way, but only if we do not change anything about the
 * config after the init (which we don't do anyways) and if the ConnectionProvider
 * does not store any shared state (we use DataSourceConnectionProvider of Jooq, so no problem).
 *
 * Some sources and discussion:
 * - http://www.jooq.org/doc/3.6/manual/getting-started/tutorials/jooq-with-spring/
 * - http://jooq-user.narkive.com/2fvuLodn/dslcontext-and-threads
 * - https://groups.google.com/forum/#!topic/jooq-user/VK7KQcjj3Co
 * - http://stackoverflow.com/questions/32848865/jooq-dslcontext-correct-autowiring-with-spring
 */
@Bean
public DSLContext dslContext() {
    initDataSource();

    Settings settings = new Settings()
            // Normally, the records are "attached" to the Configuration that created (i.e. fetch/insert) them.
            // This means that they hold an internal reference to the same database connection that was used.
            // The idea behind this is to make CRUD easier for potential subsequent store/refresh/delete
            // operations. We do not use or need that.
            .withAttachRecords(false)
            // To log or not to log the sql queries, that is the question
            .withExecuteLogging(CONFIG.getDb().isSqlLogging());

    // Configuration for JOOQ
    org.jooq.Configuration conf = new DefaultConfiguration()
            .set(SQLDialect.MYSQL)
            .set(new DataSourceConnectionProvider(dataSource))
            .set(settings);

    return DSL.using(conf);
}

项目：https-github.com-g0t4-jenkins2-course-spring-boot 文件：JooqAutoConfiguration.java

public DslContextConfiguration(JooqProperties properties,
        ConnectionProvider connectionProvider,
        ObjectProvider<TransactionProvider> transactionProviderProvider,
        ObjectProvider<RecordMapperProvider> recordMapperProviderProvider,
        ObjectProvider<Settings> settingsProvider,
        ObjectProvider<RecordListenerProvider[]> recordListenerProvidersProvider,
        ExecuteListenerProvider[] executeListenerProviders,
        ObjectProvider<VisitListenerProvider[]> visitListenerProvidersProvider) {
    this.properties = properties;
    this.connectionProvider = connectionProvider;
    this.transactionProvider = transactionProviderProvider.getIfAvailable();
    this.recordMapperProvider = recordMapperProviderProvider.getIfAvailable();
    this.settings = settingsProvider.getIfAvailable();
    this.recordListenerProviders = recordListenerProvidersProvider
            .getIfAvailable();
    this.executeListenerProviders = executeListenerProviders;
    this.visitListenerProviders = visitListenerProvidersProvider.getIfAvailable();
}

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

public DslContextConfiguration(JooqProperties properties,
        ConnectionProvider connectionProvider,
        ObjectProvider<TransactionProvider> transactionProviderProvider,
        ObjectProvider<RecordMapperProvider> recordMapperProviderProvider,
        ObjectProvider<Settings> settingsProvider,
        ObjectProvider<RecordListenerProvider[]> recordListenerProvidersProvider,
        ExecuteListenerProvider[] executeListenerProviders,
        ObjectProvider<VisitListenerProvider[]> visitListenerProvidersProvider) {
    this.properties = properties;
    this.connectionProvider = connectionProvider;
    this.transactionProvider = transactionProviderProvider.getIfAvailable();
    this.recordMapperProvider = recordMapperProviderProvider.getIfAvailable();
    this.settings = settingsProvider.getIfAvailable();
    this.recordListenerProviders = recordListenerProvidersProvider
            .getIfAvailable();
    this.executeListenerProviders = executeListenerProviders;
    this.visitListenerProviders = visitListenerProvidersProvider.getIfAvailable();
}

项目：waltz 文件：DIConfiguration.java

@Bean
@Autowired
public DSLContext dsl(DataSource dataSource) {
    try {
        SQLDialect.valueOf(dialect);
    } catch (IllegalArgumentException iae) {
        System.err.println("Cannot parse sql dialect: "+dialect);
        throw iae;
    }

    Settings dslSettings = null;
    if ("true".equals(System.getProperty(JOOQ_DEBUG_PROPERTY))) {
        dslSettings = new Settings()
                .withRenderFormatted(true)
                .withExecuteLogging(true);
    }

    return DSL.using(
            dataSource,
            SQLDialect.valueOf(dialect),
            dslSettings);
}

项目：high-performance-java-persistence 文件：AbstractJOOQIntegrationTest.java

protected <T> T doInJOOQ(DSLContextCallable<T> callable, Settings settings) {
    Session session = null;
    Transaction txn = null;
    try {
        session = sessionFactory().openSession();
        txn = session.beginTransaction();
        T result = session.doReturningWork(connection -> {
            DSLContext sql = settings != null ?
                DSL.using(connection, sqlDialect(), settings) :
                DSL.using(connection, sqlDialect());
            return callable.execute(sql);
        });
        txn.commit();
        return result;
    } catch (Throwable e) {
        if ( txn != null ) txn.rollback();
        throw e;
    } finally {
        if (session != null) {
            session.close();
        }
    }
}

项目：high-performance-java-persistence 文件：AbstractJOOQIntegrationTest.java

protected void doInJOOQ(DSLContextVoidCallable callable, Settings settings) {
    Session session = null;
    Transaction txn = null;
    try {
        session = sessionFactory().openSession();
        txn = session.beginTransaction();
        session.doWork(connection -> {
            DSLContext sql = settings != null ?
                DSL.using(connection, sqlDialect(), settings) :
                DSL.using(connection, sqlDialect());
            callable.execute(sql);
        });
        txn.commit();
    } catch (Throwable e) {
        if ( txn != null ) txn.rollback();
        throw e;
    } finally {
        if (session != null) {
            session.close();
        }
    }
}

项目：cattle 文件：Bootstrap.java

private void setupDatabase() {
    System.setProperty("org.jooq.no-logo", "true");

    dataSource = dataSourceFactory.createDataSource("cattle");

    DataSourceConnectionProvider dscp = new DataSourceConnectionProvider(dataSource);
    ThreadLocalTransactionProvider tp = new ThreadLocalTransactionProvider(dscp, false);

    LoggerListener logger = new LoggerListener();
    logger.setMaxLength(1000);

    ExecuteListener[] listeners = new ExecuteListener[] { logger, new StopWatchListener() };
    Settings settings = dbSetting("cattle");
    jooqConfig = new DefaultConfiguration()
            .set(getSQLDialect("cattle"))
            .set(settings)
            .set(dscp)
            .set(tp)
            .set(DefaultExecuteListenerProvider.providers(listeners));
}

项目：club-tracker 文件：BrokerTestUtil.java

static Connector mockConnector(MockDataProvider provider) {
    // Put your provider into a MockConnection and use that connection
    // in your application. In this case, with a jOOQ DSLContext:
    Connection connection = new MockConnection(provider);

    return new Connector() {

        @Override
        public Connection connect() throws SQLException {
            return connection;
        }

        @Override
        public SQLDialect getDialect() {
            return SQLDialect.HSQLDB;
        }

        @Override
        public Settings getSettings() {
            return new Settings();
        }
    };
}

项目：killbill-analytics-plugin 文件：SqlReportDataExtractor.java

public SqlReportDataExtractor(final String tableName,
                              final ReportSpecification reportSpecification,
                              @Nullable final DateTime startDate,
                              @Nullable final DateTime endDate,
                              final SQLDialect sqlDialect,
                              final Long tenantRecordId) {
    this.tableName = tableName;
    this.reportSpecification = reportSpecification;
    this.startDate = startDate;
    this.endDate = endDate;
    this.tenantRecordId = tenantRecordId;

    final Settings settings = new Settings();
    settings.withStatementType(StatementType.STATIC_STATEMENT);
    settings.withRenderFormatted(true);
    if (SQLDialect.H2.equals(sqlDialect)) {
        settings.withRenderNameStyle(RenderNameStyle.AS_IS);
    }
    this.context = DSL.using(sqlDialect, settings);

    setup();
}