OpenMRS

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.io.PrintStream;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.Properties;
import org.apache.log4j.Logger;
import org.openmrs.Location;
import org.openmrs.Patient;
import org.openmrs.PatientIdentifier;
import org.openmrs.PatientIdentifierType;
import org.openmrs.PersonAddress;
import org.openmrs.PersonAttribute;
import org.openmrs.PersonAttributeType;
import org.openmrs.PersonName;
import org.openmrs.Privilege;
import org.openmrs.User;
import org.openmrs.api.APIException;
import org.openmrs.api.LocationService;
import org.openmrs.api.PatientService;
import org.openmrs.api.PersonService;
import org.openmrs.api.context.Context;
import org.openmrs.util.OpenmrsUtil;

public class PatientDataLoader
{
  protected static Logger logger = Logger.getLogger(PatientDataLoader.class);

  public static void main(String[] args)
  {
    try
    {
      logger.info("Started on: " + new Date(System.currentTimeMillis()));

      String filename = "openmrs-runtime.properties";
      String filepath = OpenmrsUtil.getApplicationDataDirectory() + filename;

      FileInputStream propertyStream = new FileInputStream(filepath);

      Properties properties = new Properties();
      properties.load(propertyStream);

      Context.startup("jdbc:mysql://localhost:3306/openmrs?autoReconnect=true", args[1], args[2], properties);
      Context.authenticate(args[3], args[4]);
      User user = Context.getAuthenticatedUser();

      for (Privilege privilege : user.getPrivileges()) {
        Context.addProxyPrivilege(privilege.getPrivilege());
      }

      String[] attributes = { "Credit Card", "CVC Code", "Country", "Email", "Phone", "Mother's Name", "CC Exp", "UID", "SSN" };
      String[] locations = { "LOCAL" };
      String[] identifiers = { "UID" };

      PatientService patientService = Context.getPatientService();
      PersonService personService = Context.getPersonService();
      LocationService locationService = Context.getLocationService();

      for (String attribute : attributes) {
        PersonAttributeType attributeType = personService.getPersonAttributeTypeByName(attribute);
        if (attributeType == null) {
          attributeType = new PersonAttributeType();
          attributeType.setName(attribute);
          attributeType.setFormat("java.lang.String");
          attributeType.setDescription("Description of : " + attribute);
        }
        personService.savePersonAttributeType(attributeType);
      }

      for (String identifier : identifiers) {
        PatientIdentifierType identifierType = patientService.getPatientIdentifierTypeByName(identifier);
        if (identifierType == null) {
          identifierType = new PatientIdentifierType();
          identifierType.setName(identifier);
          identifierType.setDescription("Description of : " + identifier);
          identifierType.setCheckDigit(new Boolean(false));
          identifierType.setRequired(new Boolean(false));
        }
        patientService.savePatientIdentifierType(identifierType);
      }

      for (String location : locations) {
        Location locationName = locationService.getLocation(location);
        if (locationName == null) {
          locationName = new Location();
          locationName.setName(location);
        }
        locationService.saveLocation(locationName);
      }

      PersonAttributeType attributeTypeCC = personService.getPersonAttributeTypeByName("Credit Card");
      PersonAttributeType attributeTypeCVCCode = personService.getPersonAttributeTypeByName("CVC Code");
      PersonAttributeType attributeTypeCountry = personService.getPersonAttributeTypeByName("Country");
      PersonAttributeType attributeTypeEmail = personService.getPersonAttributeTypeByName("Email");
      PersonAttributeType attributeTypePhone = personService.getPersonAttributeTypeByName("Phone");
      PersonAttributeType attributeTypeMothersName = personService.getPersonAttributeTypeByName("Mother's Name");
      PersonAttributeType attributeTypeCCExp = personService.getPersonAttributeTypeByName("CC Exp");
      PersonAttributeType attributeTypeUID = personService.getPersonAttributeTypeByName("UID");
      PersonAttributeType attributeTypeSSN = personService.getPersonAttributeTypeByName("SSN");

      PatientIdentifierType identType = patientService.getPatientIdentifierTypeByName("UID");
      Location patientLocation = locationService.getLocation("LOCAL");

      int counter = patientService.getAllPatients().size();

      SimpleDateFormat format = new SimpleDateFormat("MM/dd/yyyy");

      BufferedReader reader = new BufferedReader(new FileReader(new File(args[0])));
      String s = null;
      while ((s = reader.readLine()) != null) {
        String[] element = s.split("[|]", -1);

        Patient patient = new Patient();

        PersonAddress address = new PersonAddress();
        address.setCityVillage(element[6]);
        address.setStateProvince(element[7]);
        address.setAddress1(element[5]);
        address.setAddress2("");
        address.setPostalCode(element[8]);
        patient.addAddress(address);

        PersonName name = new PersonName();
        name.setGivenName(element[2]);
        name.setMiddleName(element[3]);
        name.setFamilyName(element[4]);
        patient.addName(name);

        PersonAttribute attribute = new PersonAttribute();
        attribute.setAttributeType(attributeTypeCC);
        attribute.setValue(element[15]);
        patient.addAttribute(attribute);

        attribute = new PersonAttribute();
        attribute.setAttributeType(attributeTypeCVCCode);
        attribute.setValue(element[16]);
        patient.addAttribute(attribute);

        attribute = new PersonAttribute();
        attribute.setAttributeType(attributeTypeCountry);
        attribute.setValue(element[9]);
        patient.addAttribute(attribute);

        attribute = new PersonAttribute();
        attribute.setAttributeType(attributeTypeEmail);
        attribute.setValue(element[10]);
        patient.addAttribute(attribute);

        attribute = new PersonAttribute();
        attribute.setAttributeType(attributeTypePhone);
        attribute.setValue(element[11]);
        patient.addAttribute(attribute);

        attribute = new PersonAttribute();
        attribute.setAttributeType(attributeTypeMothersName);
        attribute.setValue(element[12]);
        patient.addAttribute(attribute);

        attribute = new PersonAttribute();
        attribute.setAttributeType(attributeTypeCCExp);
        attribute.setValue(element[17]);
        patient.addAttribute(attribute);

        attribute = new PersonAttribute();
        attribute.setAttributeType(attributeTypeUID);
        attribute.setValue(element[0]);
        patient.addAttribute(attribute);

        attribute = new PersonAttribute();
        attribute.setAttributeType(attributeTypeSSN);
        attribute.setValue(element[18]);
        patient.addAttribute(attribute);

        ++counter;
        if (counter % 100 == 0) {
          Context.clearSession();
        }

        PatientIdentifier patientIdentifier = new PatientIdentifier(
          String.valueOf(counter), identType, 
          patientLocation);
        patient.addIdentifier(patientIdentifier);

        Date dateOfBirth = format.parse(element[13]);
        patient.setBirthdate(dateOfBirth);
        patient.setGender(element[1]);
        patient.setCreator(user);
        patientService.savePatient(patient);
        System.out.println("Saved patient: " + patient.getGivenName() + " " + patient.getFamilyName());
        logger.info("Ended on: " + new Date(System.currentTimeMillis()));
      }
    }
    catch (APIException e)
    {
      e.printStackTrace();
    }
    catch (FileNotFoundException e) {
      e.printStackTrace();
    }
    catch (IOException e) {
      e.printStackTrace();
    }
    catch (ParseException e) {
      e.printStackTrace();
    }
  }
}