honeymoose/hapi-fhir
1
0
Fork 0
mirror of https://github.com/hapifhir/hapi-fhir.git synced 2025-02-27 08:47:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Changed migration test from derby to h2

Browse Source 
Added a new test from 340 to latest version.
This commit is contained in:
Ken Stevens 2019-08-02 16:00:43 -04:00
parent bb03a058bd
commit 48c8497086
4 changed files with 80 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hapi-fhir-base/src/main/java/ca/uhn/fhir/util/VersionEnum.java
View File

@ -31,6 +31,10 @@ public enum VersionEnum {
V3_6_0, V3_6_0,
V3_7_0, V3_7_0,
V3_8_0, V3_8_0,
V4_0_0 V4_0_0;
public static VersionEnum latestVersion() {
VersionEnum[] values = VersionEnum.values();
return values[values.length - 1];
}
} }

5
hapi-fhir-cli/hapi-fhir-cli-api/pom.xml
View File

@ -97,6 +97,11 @@
<groupId>org.apache.derby</groupId> <groupId>org.apache.derby</groupId>
<artifactId>derby</artifactId> <artifactId>derby</artifactId>
</dependency> </dependency>
<dependency>
<groupId>com.h2database</groupId>
<artifactId>h2</artifactId>
<scope>test</scope>
</dependency>
<dependency> <dependency>
<groupId>org.mariadb.jdbc</groupId> <groupId>org.mariadb.jdbc</groupId>
<artifactId>mariadb-java-client</artifactId> <artifactId>mariadb-java-client</artifactId>

96
hapi-fhir-cli/hapi-fhir-cli-api/src/test/java/ca/uhn/fhir/cli/HapiMigrateDatabaseCommandTest.java
View File

@ -1,6 +1,7 @@
package ca.uhn.fhir.cli; package ca.uhn.fhir.cli;
import ca.uhn.fhir.jpa.migrate.DriverTypeEnum; import ca.uhn.fhir.jpa.migrate.DriverTypeEnum;
import ca.uhn.fhir.util.VersionEnum;
import com.google.common.base.Charsets; import com.google.common.base.Charsets;
import org.apache.commons.io.FileUtils; import org.apache.commons.io.FileUtils;
import org.apache.commons.io.IOUtils; import org.apache.commons.io.IOUtils;
@ -12,6 +13,7 @@ import org.springframework.jdbc.core.support.AbstractLobCreatingPreparedStatemen
import org.springframework.jdbc.support.lob.DefaultLobHandler; import org.springframework.jdbc.support.lob.DefaultLobHandler;
import org.springframework.jdbc.support.lob.LobCreator; import org.springframework.jdbc.support.lob.LobCreator;
import javax.validation.constraints.NotNull;
import java.io.File; import java.io.File;
import java.io.IOException; import java.io.IOException;
import java.sql.PreparedStatement; import java.sql.PreparedStatement;
@ -31,23 +33,21 @@ import static org.junit.Assert.assertTrue;
public class HapiMigrateDatabaseCommandTest { public class HapiMigrateDatabaseCommandTest {
private static final Logger ourLog = LoggerFactory.getLogger(HapiMigrateDatabaseCommandTest.class); private static final Logger ourLog = LoggerFactory.getLogger(HapiMigrateDatabaseCommandTest.class);
public static final String DB_DIRECTORY = "target/h2_test";
static { static {
System.setProperty("test", "true"); System.setProperty("test", "true");
} }
@Test @Test
public void testMigrate_340_370() throws IOException { public void testMigrate_340_current() throws IOException {
File directory = new File("target/migrator_derby_test_340_360"); File location = getLocation("migrator_h2_test_340_current");
if (directory.exists()) {
FileUtils.deleteDirectory(directory);
}
String url = "jdbc:derby:directory:" + directory.getAbsolutePath() + ";create=true"; String url = "jdbc:h2:" + location.getAbsolutePath() + ";create=true";
DriverTypeEnum.ConnectionProperties connectionProperties = DriverTypeEnum.DERBY_EMBEDDED.newConnectionProperties(url, "", ""); DriverTypeEnum.ConnectionProperties connectionProperties = DriverTypeEnum.H2_EMBEDDED.newConnectionProperties(url, "", "");
String initSql = "/persistence_create_derby107_340.sql"; String initSql = "/persistence_create_h2_340.sql";
executeSqlStatements(connectionProperties, initSql); executeSqlStatements(connectionProperties, initSql);
seedDatabase340(connectionProperties); seedDatabase340(connectionProperties);
@ -58,7 +58,57 @@ public class HapiMigrateDatabaseCommandTest {
String[] args = new String[]{ String[] args = new String[]{
"migrate-database", "migrate-database",
"-d", "DERBY_EMBEDDED", "-d", "H2_EMBEDDED",
"-u", url,
"-n", "",
"-p", "",
"-f", "V3_4_0",
"-t", VersionEnum.latestVersion().toString()
};
App.main(args);
connectionProperties.getTxTemplate().execute(t -> {
JdbcTemplate jdbcTemplate = connectionProperties.newJdbcTemplate();
List<Map<String, Object>> values = jdbcTemplate.queryForList("SELECT * FROM hfj_spidx_token");
assertEquals(1, values.size());
assertEquals("identifier", values.get(0).get("SP_NAME"));
assertEquals("12345678", values.get(0).get("SP_VALUE"));
assertTrue(values.get(0).keySet().contains("HASH_IDENTITY"));
assertEquals(7001889285610424179L, values.get(0).get("HASH_IDENTITY"));
return null;
});
}
@NotNull
private File getLocation(String theDatabaseName) throws IOException {
File directory = new File(DB_DIRECTORY);
if (directory.exists()) {
FileUtils.deleteDirectory(directory);
}
return new File(DB_DIRECTORY + "/" + theDatabaseName);
}
@Test
public void testMigrate_340_370() throws IOException {
File location = getLocation("migrator_h2_test_340_360");
String url = "jdbc:h2:" + location.getAbsolutePath() + ";create=true";
DriverTypeEnum.ConnectionProperties connectionProperties = DriverTypeEnum.H2_EMBEDDED.newConnectionProperties(url, "", "");
String initSql = "/persistence_create_h2_340.sql";
executeSqlStatements(connectionProperties, initSql);
seedDatabase340(connectionProperties);
ourLog.info("**********************************************");
ourLog.info("Done Setup, Starting Migration...");
ourLog.info("**********************************************");
String[] args = new String[]{
"migrate-database",
"-d", "H2_EMBEDDED",
"-u", url, "-u", url,
"-n", "", "-n", "",
"-p", "", "-p", "",
@ -83,15 +133,12 @@ public class HapiMigrateDatabaseCommandTest {
@Test @Test
public void testMigrate_340_350() throws IOException { public void testMigrate_340_350() throws IOException {
File directory = new File("target/migrator_derby_test_340_350"); File location = getLocation("migrator_h2_test_340_350");
if (directory.exists()) {
FileUtils.deleteDirectory(directory);
}
String url = "jdbc:derby:directory:" + directory.getAbsolutePath() + ";create=true"; String url = "jdbc:h2:" + location.getAbsolutePath() + ";create=true";
DriverTypeEnum.ConnectionProperties connectionProperties = DriverTypeEnum.DERBY_EMBEDDED.newConnectionProperties(url, "", ""); DriverTypeEnum.ConnectionProperties connectionProperties = DriverTypeEnum.H2_EMBEDDED.newConnectionProperties(url, "", "");
String initSql = "/persistence_create_derby107_340.sql"; String initSql = "/persistence_create_h2_340.sql";
executeSqlStatements(connectionProperties, initSql); executeSqlStatements(connectionProperties, initSql);
seedDatabase340(connectionProperties); seedDatabase340(connectionProperties);
@ -102,7 +149,7 @@ public class HapiMigrateDatabaseCommandTest {
String[] args = new String[]{ String[] args = new String[]{
"migrate-database", "migrate-database",
"-d", "DERBY_EMBEDDED", "-d", "H2_EMBEDDED",
"-u", url, "-u", url,
"-n", "", "-n", "",
"-p", "", "-p", "",
@ -125,7 +172,7 @@ public class HapiMigrateDatabaseCommandTest {
args = new String[]{ args = new String[]{
"migrate-database", "migrate-database",
"-d", "DERBY_EMBEDDED", "-d", "H2_EMBEDDED",
"-u", url, "-u", url,
"-n", "", "-n", "",
"-p", "", "-p", "",
@ -263,15 +310,12 @@ public class HapiMigrateDatabaseCommandTest {
@Test @Test
public void testMigrate_340_350_NoMigrateHashes() throws IOException { public void testMigrate_340_350_NoMigrateHashes() throws IOException {
File directory = new File("target/migrator_derby_test_340_350_nmh"); File location = getLocation("migrator_h2_test_340_350_nmh");
if (directory.exists()) {
FileUtils.deleteDirectory(directory);
}
String url = "jdbc:derby:directory:" + directory.getAbsolutePath() + ";create=true"; String url = "jdbc:h2:" + location.getAbsolutePath() + ";create=true";
DriverTypeEnum.ConnectionProperties connectionProperties = DriverTypeEnum.DERBY_EMBEDDED.newConnectionProperties(url, "", ""); DriverTypeEnum.ConnectionProperties connectionProperties = DriverTypeEnum.H2_EMBEDDED.newConnectionProperties(url, "", "");
String initSql = "/persistence_create_derby107_340.sql"; String initSql = "/persistence_create_h2_340.sql";
executeSqlStatements(connectionProperties, initSql); executeSqlStatements(connectionProperties, initSql);
seedDatabase340(connectionProperties); seedDatabase340(connectionProperties);
@ -282,7 +326,7 @@ public class HapiMigrateDatabaseCommandTest {
String[] args = new String[]{ String[] args = new String[]{
"migrate-database", "migrate-database",
"-d", "DERBY_EMBEDDED", "-d", "H2_EMBEDDED",
"-u", url, "-u", url,
"-n", "", "-n", "",
"-p", "", "-p", "",

0
hapi-fhir-cli/hapi-fhir-cli-api/src/test/resources/persistence_create_derby107_340.sql → hapi-fhir-cli/hapi-fhir-cli-api/src/test/resources/persistence_create_h2_340.sql
View File