honeymoose
/
hapi-fhir
mirror of https://github.com/hapifhir/hapi-fhir.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix Postgres migration

This commit is contained in:
jamesagnew 2021-10-12 12:00:21 -04:00
parent d2ea4655a7
commit be19acb7c3
2 changed files with 13 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
hapi-fhir-sql-migrate/src/main/java/ca/uhn/fhir/jpa/migrate/taskdef/MigratePostgresTextClobToBinaryClobTask.java
View File

@ -26,6 +26,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.sql.SQLException;
import java.util.Locale;
public class MigratePostgresTextClobToBinaryClobTask extends BaseTableColumnTask {
private static final Logger ourLog = LoggerFactory.getLogger(MigratePostgresTextClobToBinaryClobTask.class);
@ -49,18 +50,22 @@ public class MigratePostgresTextClobToBinaryClobTask extends BaseTableColumnTask
return;
}
JdbcUtils.ColumnType columnType = JdbcUtils.getColumnType(getConnectionProperties(), getTableName(), getColumnName());
String tableName = getTableName();
String columnName = getColumnName();
JdbcUtils.ColumnType columnType = JdbcUtils.getColumnType(getConnectionProperties(), tableName, columnName);
if (columnType.getColumnTypeEnum() == ColumnTypeEnum.LONG) {
ourLog.info("Table {} column {} is already of type LONG, no migration needed", getTableName(), getColumnName());
ourLog.info("Table {} column {} is already of type LONG, no migration needed", tableName, columnName);
return;
}
String tempColumnName = getColumnName() + "_m";
String tempColumnName = columnName + "_m".toLowerCase();
tableName = tableName.toLowerCase();
columnName = columnName.toLowerCase();
executeSql(getTableName(), "alter table ? add column ? oid", getTableName(), tempColumnName);
executeSql(getTableName(), "update ? set ? = cast(? as oid) where ? is not null", getTableName(), tempColumnName, getColumnName(), getColumnName());
executeSql(getTableName(), "alter table ? drop column ?", getTableName(), getColumnName());
executeSql(getTableName(), "alter table ? rename column ? to ?", getTableName(), tempColumnName, getColumnName());
executeSql(tableName, "alter table " + tableName + " add column " + tempColumnName + " oid");
executeSql(tableName, "update " + tableName + " set " + tempColumnName + " = cast(" + columnName + " as oid) where " + columnName + " is not null");
executeSql(tableName, "alter table " + tableName + " drop column " + columnName);
executeSql(tableName, "alter table " + tableName + " rename column " + tempColumnName + " to " + columnName);
}
}

2
hapi-fhir-sql-migrate/src/main/java/ca/uhn/fhir/jpa/migrate/tasks/api/Builder.java
View File

@ -253,7 +253,7 @@ public class Builder {
MigratePostgresTextClobToBinaryClobTask task = new MigratePostgresTextClobToBinaryClobTask(myRelease, theVersion);
task.setTableName(getTableName());
task.setColumnName(theColumnName);
addTask(task);
}
public class BuilderAddIndexWithName {