/* Ċ Ġ* ĠCopyright Ġ 2 0 1 7 ĠPas cal Ċ Ġ* Ċ Ġ* ĠLicensed Ġunder Ġthe ĠApache ĠLicense , ĠVersion Ġ 2 . 0 Ġ( the Ġ" License "); Ċ Ġ* Ġyou Ġmay Ġnot Ġuse Ġthis Ġfile Ġexcept Ġin Ġcompliance Ġwith Ġthe ĠLicense . Ċ Ġ* ĠYou Ġmay Ġobtain Ġa Ġcopy Ġof Ġthe ĠLicense Ġat Ċ Ġ* Ċ Ġ* ĠĠĠĠ Ġhttp :// www . apache . org / licenses / LICENSE - 2 . 0 Ċ Ġ* Ċ Ġ* ĠUnless Ġrequired Ġby Ġapplicable Ġlaw Ġor Ġagreed Ġto Ġin Ġwriting , Ġsoftware Ċ Ġ* Ġdistributed Ġunder Ġthe ĠLicense Ġis Ġdistributed Ġon Ġan Ġ" AS ĠIS " ĠBASIS , Ċ Ġ* ĠWITHOUT ĠWARRANTIES ĠOR ĠCONDITIONS ĠOF ĠANY ĠKIND , Ġeither Ġexpress Ġor Ġimplied . Ċ Ġ* ĠSee Ġthe ĠLicense Ġfor Ġthe Ġspecific Ġlanguage Ġgoverning Ġpermissions Ġand Ċ Ġ* Ġlimitations Ġunder Ġthe ĠLicense . Ċ Ġ*/ Ċ Ċ package Ġcom . github . pas cal gn . db migration . sql Ċ Ċ import Ġcom . github . pas cal gn . db migration . Abstract IT Ċ import Ġcom . github . pas cal gn . db migration . config . Jdbc Ċ import Ġcom . github . pas cal gn . db migration . io . Binary Reader Ċ import Ġorg . junit . Assert . assertTrue Ċ import Ġorg . junit . Ass ume . assume False Ċ import Ġorg . junit . Test Ċ Ċ class ĠSql Server Importer IT Ġ: ĠAbstract IT () Ġ{ ĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġbulk Import () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġhost Ġ= ĠSystem . getProperty (" sql server . host ") ĊĠĠĠĠĠĠĠ Ġval Ġport Ġ= ĠSystem . getProperty (" sql server . port ") ĊĊĠĠĠĠĠĠĠ Ġassume False (" Sql Ġserver Ġhost Ġnot Ġset : Ġ$ host ", Ġhost . isNull Or Blank ()) ĊĠĠĠĠĠĠĠ Ġassume False (" Sql Ġserver Ġport Ġnot Ġset : Ġ$ port ", Ġport . isNull Or Blank ()) ĊĊĠĠĠĠĠĠĠ Ġval Ġurl Ġ= Ġ" jdbc : sql server :// $ host :$ port ; database = db migration " ĊĠĠĠĠĠĠĠ Ġval Ġjdbc Ġ= ĠJdbc ( url , Ġ" db migration ", Ġ" db migration ", Ġ" db migration ", Ġtrue ) ĊĊĠĠĠĠĠĠĠ ĠSession ( jdbc ). use Ġ{ Ġsession Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġopen Resource (" before SqlServer . sql ") Ġ{ Ġinput Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġsql Ġ= Ġinput . buffered Reader (). use Ġ{ Ġit . read Text () Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġsession . with Connection Ġ{ Ġconnection Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġconnection . createStatement (). use Ġ{ Ġstatement Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġstatement . execute ( sql ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġopen Resource (" User - v 2 . bin ") Ġ{ Ġinput Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠBinary Reader ( input ). use Ġ{ Ġreader Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠSql Server Importer ( reader , Ġsession , Ġ" User ", ĠDecimal Handler ()). run () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġsession . with Connection Ġ{ Ġconnection Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġconnection . createStatement (). use Ġ{ Ġstatement Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġstatement . executeQuery (" SELECT Ġ* ĠFROM Ġ[ User ]"). use Ġ{ Ġrs Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠassertTrue ( rs . next ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ } Ċ