yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-12-25 08:58:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(upgrade): Check whether tables exist using findList (#3229)

Browse Source
This commit is contained in:
John Joyce 2021-09-13 14:30:32 -07:00 committed by GitHub
parent 2de4ea9566
commit 05a7939c3a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
metadata-io/src/main/java/com/linkedin/metadata/entity/AspectStorageValidationUtil.java
View File

@ -5,6 +5,7 @@ import com.linkedin.metadata.entity.ebean.EbeanAspectV2;
import io.ebean.EbeanServer;
import io.ebean.SqlQuery;
import io.ebean.SqlRow;
import java.util.List;
public class AspectStorageValidationUtil {
@ -27,8 +28,8 @@ public class AspectStorageValidationUtil {
+ "WHERE TABLE_NAME = 'metadata_aspect_v2'";
final SqlQuery query = server.createSqlQuery(queryStr);
SqlRow row = query.findOne();
return row != null;
final List<SqlRow> rows = query.findList();
return rows.size() > 0;
}
public static boolean checkV1TableExists(EbeanServer server) {
@ -37,7 +38,7 @@ public class AspectStorageValidationUtil {
+ "WHERE TABLE_NAME = 'metadata_aspect'";
final SqlQuery query = server.createSqlQuery(queryStr);
SqlRow row = query.findOne();
return row != null;
final List<SqlRow> rows = query.findList();
return rows.size() > 0;
}
}