2727import org .labkey .remoteapi .Connection ;
2828import org .labkey .remoteapi .SimplePostCommand ;
2929import org .labkey .remoteapi .query .Filter ;
30+ import org .labkey .remoteapi .query .ImportDataCommand ;
3031import org .labkey .remoteapi .query .InsertRowsCommand ;
3132import org .labkey .remoteapi .query .SaveRowsResponse ;
3233import org .labkey .remoteapi .query .SelectRowsCommand ;
@@ -218,11 +219,6 @@ protected File getStudyPolicyXML()
218219 return TestFileUtils .getSampleData ("wnprc_ehr/wnprcEhrTestStudyPolicy.xml" );
219220 }
220221
221- private static void folderSetup ()
222- {
223-
224- }
225-
226222 @ BeforeClass @ LogMethod
227223 public static void doSetup () throws Exception
228224 {
@@ -1928,40 +1924,39 @@ private void truncateBillingTables(Connection connection) throws IOException, Co
19281924 private void uploadData () throws IOException , CommandException
19291925 {
19301926 Connection connection = createDefaultConnection ();
1931- Map <String , Object > responseMap = new HashMap <>();
1932-
19331927 truncateBillingTables (connection );
19341928
19351929 //upload Tier Rates
1936- List <Map <String , Object >> tsv = loadTsv (TIER_RATES_TSV );
1937- insertTsvData (connection , "wnprc_billing" , "tierrates" , tsv , PRIVATE_FOLDER_PATH )
1938- .forEach (row -> responseMap .put (row .get ("tierRateType" ).toString (),row .get ("rowid" )));
1930+ insertTsvData (connection , "wnprc_billing" , "tierrates" , TIER_RATES_TSV , PRIVATE_FOLDER_PATH );
19391931
19401932 //upload Grant Accounts
1941- tsv = loadTsv (ALIASES_TSV );
1933+ List < Map < String , Object >> tsv = loadTsv (ALIASES_TSV );
19421934 insertTsvData (connection , "ehr_billing" , "aliases" , tsv , PRIVATE_FOLDER_PATH )
19431935 .forEach (row -> aliasesMap .put (row .get ("alias" ).toString (),row .get ("rowid" )));
19441936
19451937 //upload Charge Units
1946- tsv = loadTsv (CHARGE_UNITS_TSV );
1947- insertTsvData (connection , "ehr_billing" , "chargeUnits" , tsv , PRIVATE_FOLDER_PATH )
1948- .forEach (row -> responseMap .put (row .get ("groupName" ).toString (),row .get ("active" )));
1938+ insertTsvData (connection , "ehr_billing" , "chargeUnits" , CHARGE_UNITS_TSV , PRIVATE_FOLDER_PATH );
19491939
19501940 //upload Chargeable Item Categories
1951- tsv = loadTsv (CHARGEABLE_ITEM_CATEGORIES_TSV );
1952- insertTsvData (connection , "ehr_billing" , "chargeableItemCategories" , tsv , PRIVATE_FOLDER_PATH )
1953- .forEach (row -> responseMap .put (row .get ("name" ).toString (),row .get ("rowId" )));
1941+ insertTsvData (connection , "ehr_billing" , "chargeableItemCategories" , CHARGEABLE_ITEM_CATEGORIES_TSV , PRIVATE_FOLDER_PATH );
19541942
19551943 //upload Group-Category Associations
1956- tsv = loadTsv (GROUP_CATEGORY_ASSOCIATIONS_TSV );
1957- insertTsvData (connection , "wnprc_billing" , "groupCategoryAssociations" , tsv , PRIVATE_FOLDER_PATH )
1958- .forEach (row -> responseMap .put (row .get ("chargeGroupName" ).toString (),row .get ("rowid" )));
1944+ insertTsvData (connection , "wnprc_billing" , "groupCategoryAssociations" , GROUP_CATEGORY_ASSOCIATIONS_TSV , PRIVATE_FOLDER_PATH );
19591945
19601946 //upload Chargeable Items and Charge Rates
19611947 uploadChargeRates (CHARGEABLE_ITEMS_RATES_TSV , CHARGE_RATES_NUM_ROWS , CHARGEABLE_ITEMS_NUM_ROWS );
19621948
19631949 }
19641950
1951+ private void insertTsvData (Connection connection , String schemaName , String queryName , File tsvFile , String folderPath ) throws IOException , CommandException
1952+ {
1953+ log ("Loading tsv data: " + schemaName + "." + queryName + " from file " + tsvFile .getPath ());
1954+ ImportDataCommand command = new ImportDataCommand (schemaName ,queryName );
1955+ command .setImportLookupByAlternateKey (true );
1956+ command .setFile (tsvFile );
1957+ command .execute (connection , folderPath );
1958+ }
1959+
19651960 private List <Map <String , Object >> insertTsvData (Connection connection , String schemaName , String queryName , List <Map <String , Object >> tsv , String folderPath ) throws IOException , CommandException
19661961 {
19671962 log ("Loading tsv data: " + schemaName + "." + queryName );
@@ -4692,4 +4687,4 @@ public void activateDumbster(WebDriverWrapper myDriver) {
46924687
46934688 }
46944689
4695- }
4690+ }
0 commit comments