本文整理了Java中org.flywaydb.core.Flyway.migrate()
方法的一些代码示例,展示了Flyway.migrate()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Flyway.migrate()
方法的具体详情如下:
包路径:org.flywaydb.core.Flyway
类名称:Flyway
方法名:migrate
暂无
代码示例来源:origin: jooby-project/jooby
@Override
public void run(final Flyway flyway) {
flyway.migrate();
}
},
代码示例来源:origin: apache/incubator-gobblin
public void migrate() throws FlywayException {
flyway.migrate();
}
代码示例来源:origin: Netflix/conductor
private void flywayMigrate(DataSource dataSource) {
boolean enabled = configuration.isFlywayEnabled();
if (!enabled) {
logger.debug("Flyway migrations are disabled");
return;
}
Flyway flyway = new Flyway();
configuration.getFlywayTable().ifPresent(tableName -> {
logger.debug("Using Flyway migration table '{}'", tableName);
flyway.setTable(tableName);
});
flyway.setDataSource(dataSource);
flyway.setPlaceholderReplacement(false);
flyway.migrate();
}
}
代码示例来源:origin: cloudfoundry/uaa
@Test
public void everyTableShouldHaveAPrimaryKeyColumn() throws Exception {
flyway.migrate();
List<String> tableNames = jdbcTemplate.queryForList(getAllTableNames, String.class, jdbcTemplate.getDataSource().getConnection().getCatalog());
assertThat(tableNames, hasSize(greaterThan(0)));
for (String tableName : tableNames) {
int count = jdbcTemplate.queryForObject(checkPrimaryKeyExists, Integer.class, jdbcTemplate.getDataSource().getConnection().getCatalog(), tableName);
assertThat(format("%s is missing primary key", tableName), count, greaterThanOrEqualTo(1));
}
}
代码示例来源:origin: cloudfoundry/uaa
@Test
public void everyTableShouldHaveAPrimaryKeyColumn() throws Exception {
flyway.migrate();
List<String> tableNames = jdbcTemplate.queryForList(getAllTableNames, String.class, jdbcTemplate.getDataSource().getConnection().getCatalog());
assertThat(tableNames, hasSize(greaterThan(0)));
for (String tableName : tableNames) {
int count = jdbcTemplate.queryForObject(checkPrimaryKeyExists, Integer.class, jdbcTemplate.getDataSource().getConnection().getCatalog(), tableName);
assertThat(format("%s is missing primary key", tableName), count, greaterThanOrEqualTo(1));
}
}
代码示例来源:origin: Netflix/conductor
private void flywayMigrate(Configuration config, DataSource dataSource) {
boolean enabled = getBool(config.getProperty("flyway.enabled", "true"), true);
if(!enabled) {
logger.debug("Flyway migrations are disabled");
return;
}
String migrationTable = config.getProperty("flyway.table", null);
Flyway flyway = new Flyway();
if(null != migrationTable) {
logger.debug("Using Flyway migration table '{}'", migrationTable);
flyway.setTable(migrationTable);
}
flyway.setDataSource(dataSource);
flyway.setPlaceholderReplacement(false);
flyway.migrate();
}
代码示例来源:origin: cloudfoundry/uaa
public void run(MigrationTest... tests) {
final int[] assertionsRan = {0};
flyway.setCallbacks(new BaseFlywayCallback() {
@Override
public void afterEachMigrate(Connection connection, MigrationInfo info) {
super.afterEachMigrate(connection, info);
try {
connection.commit();
} catch (SQLException e) {
Assert.fail(e.getMessage());
}
for (MigrationTest test : tests) {
if (test.getTargetMigration().equals(info.getVersion().getVersion())) {
try {
test.runAssertions();
} catch (Exception e) {
Assert.fail(e.getMessage());
}
assertionsRan[0]++;
}
}
}
});
flyway.migrate();
assertThat("Not every db migration ran", assertionsRan[0], is(tests.length));
}
}
代码示例来源:origin: cloudfoundry/uaa
@Test
public void everyTableShouldHaveAPrimaryKeyColumn() throws Exception {
flyway.migrate();
List<String> tableNames = jdbcTemplate.queryForList(getAllTableNames, String.class, jdbcTemplate.getDataSource().getConnection().getCatalog());
assertThat(tableNames, hasSize(greaterThan(0)));
for (String tableName : tableNames) {
int count = jdbcTemplate.queryForObject(checkPrimaryKeyExists, Integer.class, jdbcTemplate.getDataSource().getConnection().getCatalog(), tableName);
assertThat(format("%s is missing primary key", tableName), count, greaterThanOrEqualTo(1));
}
try {
jdbcTemplate.execute(insertNewOauthCodeRecord);
} catch (Exception _) {
fail("oauth_code table should auto increment primary key when inserting data.");
}
}
代码示例来源:origin: jdbi/jdbi
@Override
public void before() throws Throwable {
if (migration != null) {
final Flyway flyway = new Flyway();
flyway.setDataSource(getDataSource());
flyway.setLocations(migration.paths.toArray(new String[0]));
flyway.setSchemas(migration.schemas.toArray(new String[0]));
flyway.migrate();
}
jdbi = Jdbi.create(getDataSource());
if (installPlugins) {
jdbi.installPlugins();
}
plugins.forEach(jdbi::installPlugin);
handle = jdbi.open();
}
代码示例来源:origin: cloudfoundry/uaa
@Test
public void everyTableShouldHaveAPrimaryKeyColumn() throws Exception {
flyway.migrate();
List<String> tableNames = jdbcTemplate.queryForList(getAllTableNames, String.class, jdbcTemplate.getDataSource().getConnection().getCatalog());
assertThat(tableNames, hasSize(greaterThan(0)));
for (String tableName : tableNames) {
int count = jdbcTemplate.queryForObject(checkPrimaryKeyExists, Integer.class, jdbcTemplate.getDataSource().getConnection().getCatalog(), tableName, "%" + tableName + "_pk%");
assertThat(format("%s is missing primary key", tableName), count, greaterThanOrEqualTo(1));
}
try {
jdbcTemplate.execute(insertNewOauthCodeRecord);
} catch (Exception _) {
fail("oauth_code table should auto increment primary key when inserting data.");
}
}
代码示例来源:origin: Netflix/conductor
private void flywayMigrate(DataSource dataSource) {
Flyway flyway = new Flyway();
flyway.setDataSource(dataSource);
flyway.setPlaceholderReplacement(false);
flyway.migrate();
}
代码示例来源:origin: Netflix/conductor
private synchronized static void flywayMigrate(DataSource dataSource) {
if(EmbeddedDatabase.hasBeenMigrated()) {
return;
}
synchronized (MySQLBaseDAOTest.class) {
Flyway flyway = new Flyway();
flyway.setDataSource(dataSource);
flyway.setPlaceholderReplacement(false);
flyway.migrate();
}
}
代码示例来源:origin: ninjaframework/ninja
@Override
public void migrate() {
// Get the connection credentials from application.conf
String connectionUrl = ninjaProperties.getOrDie(NinjaConstant.DB_CONNECTION_URL);
String connectionUsername = ninjaProperties.getOrDie(NinjaConstant.DB_CONNECTION_USERNAME);
String connectionPassword = ninjaProperties.getOrDie(NinjaConstant.DB_CONNECTION_PASSWORD);
// We migrate automatically => if you do not want that (eg in production)
// set ninja.migration.run=false in application.conf
Flyway flyway = new Flyway();
flyway.setDataSource(connectionUrl, connectionUsername, connectionPassword);
// In testmode we are cleaning the database so that subsequent testcases
// get a fresh database.
if (ninjaProperties.getBooleanWithDefault(NinjaConstant.NINJA_MIGRATION_DROP_SCHEMA,
ninjaProperties.isTest() ? true : false )) {
flyway.clean();
}
flyway.migrate();
}
代码示例来源:origin: yasserg/crawler4j
flyway.migrate();
代码示例来源:origin: cloudfoundry/uaa
if (cleandb) {
context.getBean(Flyway.class).clean();
context.getBean(Flyway.class).migrate();
代码示例来源:origin: cloudfoundry/uaa
@BeforeClass
public static void setUpDatabase() throws Exception {
EmbeddedDatabaseBuilder builder = new EmbeddedDatabaseBuilder();
database = builder.build();
Flyway flyway = new Flyway();
flyway.setBaselineVersion(MigrationVersion.fromVersion("1.5.2"));
flyway.setLocations("classpath:/org/cloudfoundry/identity/uaa/db/hsqldb/");
flyway.setDataSource(database);
flyway.migrate();
}
代码示例来源:origin: cloudfoundry/uaa
@BeforeClass
public static void init() {
EmbeddedDatabaseBuilder builder = new EmbeddedDatabaseBuilder();
database = builder.build();
flyway = new Flyway();
flyway.setBaselineVersion(MigrationVersion.fromVersion("1.5.2"));
flyway.setLocations("classpath:/org/cloudfoundry/identity/uaa/db/hsqldb/");
flyway.setDataSource(database);
flyway.migrate();
}
代码示例来源:origin: rakam-io/rakam
@Inject
public FlywayExecutor(@Named("report.metadata.store.jdbc") JDBCPoolDataSource config) {
Flyway flyway = new Flyway();
flyway.setBaselineOnMigrate(true);
flyway.setDataSource(config);
flyway.setLocations("db/migration/report");
flyway.setTable("schema_version_report");
try {
flyway.migrate();
} catch (FlywayException e) {
flyway.repair();
}
}
}
代码示例来源:origin: tomoya92/pybbs
@PostConstruct
@DependsOn("dataSourceHelper")
public void migrate() {
Flyway flyway = Flyway.configure()
.dataSource(dataSource)
.locations("classpath:db/migration", "filesystem:db/migration")
.baselineOnMigrate(true)
.load();
flyway.migrate();
}
代码示例来源:origin: sixt/ja-micro
@Test
public void sleepAfterFailedMigration() {
props.addProperty("databaseServer", "foo");
Flyway flyway = mock(Flyway.class);
when(flyway.migrate()).thenThrow(new FlywayException());
migrator.flyway = flyway;
migrator.flywayFailedSemaphore.release();
migrator.migrate();
}
}
内容来源于网络,如有侵权,请联系作者删除!