Просмотр исходного кода

[migration][新增]:flyway java migration 修改

release_toaliyun_real
Stormeye Wu 7 лет назад
Родитель
Сommit
0ef66bfc5f
2 измененных файлов: 49 добавлений и 0 удалений
  1. +1
    -0
      mallinkAdmin/pom.xml
  2. +48
    -0
      mallinkAdmin/src/main/java/com/iformall/migration/V201904271650__Update_User_Role.java

+ 1
- 0
mallinkAdmin/pom.xml Просмотреть файл

@@ -49,6 +49,7 @@
<dependency>
<groupId>org.flywaydb</groupId>
<artifactId>flyway-core</artifactId>
<version>5.2.4</version>
</dependency>

</dependencies>


+ 48
- 0
mallinkAdmin/src/main/java/com/iformall/migration/V201904271650__Update_User_Role.java Просмотреть файл

@@ -0,0 +1,48 @@
package com.iformall.migration;

import org.flywaydb.core.api.migration.BaseJavaMigration;
import org.flywaydb.core.api.migration.Context;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

public class V201904271650__Update_User_Role extends BaseJavaMigration {

private final Logger logger = LoggerFactory.getLogger(this.getClass());

private final String getTenantIdList = "SELECT tenant_id FROM wx_mall WHERE tenant_id like '%100%'";

public void migrate(Context context) throws Exception {
// 获取 tenantId list
// 获取 mall_user_role
/*
try (Statement select = context.getConnection().createStatement()) {
try (ResultSet rows = select.executeQuery(getTenantIdList)) {
while (rows.next()) {
int id = rows.getInt(1);
String anonymizedName = "Anonymous" + id;
try (Statement update = context.getConnection().createStatement()) {
update.execute("UPDATE person SET name='" + anonymizedName + "' WHERE id=" + id);
}
}
}
}
*/
}

private List<String> getTenantList(Context context) throws Exception {
List<String> tlist = new ArrayList<String>();
try (Statement select = context.getConnection().createStatement()) {
try (ResultSet rows = select.executeQuery(getTenantIdList)) {
while (rows.next()) {
tlist.add(rows.getString(0));
}
}
}
return tlist;
}
}

Загрузка…
Отмена
Сохранить