package Ġcz . enc irc led . join er . reactive Ċ Ċ import Ġcz . enc irc led . join er . exception . Join er Exception Ċ import Ġcz . enc irc led . join er . exception . Join er Exceptions Ċ import Ġcz . enc irc led . join er . kotlin . Join er Kt QueryBuilder . count Of Ċ import Ġcz . enc irc led . join er . kotlin . Join er Kt QueryBuilder . from Ċ import Ġcz . enc irc led . join er . model . Q Status Ċ import Ġcz . enc irc led . join er . model . Q User . user 1 Ċ import Ġcz . enc irc led . join er . model . User Ċ import Ġorg . junit . jupiter . api . Nested Ċ import Ġreactor . test . Step Verifier Ċ import Ġkotlin . test . Test ĊĊ Ċ class ĠRe actor Join er Test Ġ: ĠAbstract Reactor Test () Ġ{ ĊĊĠĠĠ Ġ@ Nested ĊĠĠĠ Ġinner Ġclass ĠPers ist Ġ{ ĊĊĠĠĠĠĠĠĠ Ġ@ Test ĊĠĠĠĠĠĠĠ Ġfun Ġ` persist Ġnew Ġentity `() Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġentity Ġ= ĠUser (" Test ĠName ") ĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . persist ( entity )) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Next Matches Ġ{ Ġexpect Pers isted User ( it , Ġ" Test ĠName ") Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Complete () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify () ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġ@ Test ĊĠĠĠĠĠĠĠ Ġfun Ġ` persist Ġentity Ġhi bernate Ġexception `() Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġentity Ġ= ĠUser (" Test ĠName "). apply Ġ{ Ġid Ġ= Ġ 3 Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . persist ( entity )) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Error Matches Ġ{ Ġit . message !!. contains (" det ached Ġentity Ġpassed ") Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify () ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġassert Users Are Empty () ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġ@ Test ĊĠĠĠĠĠĠĠ Ġfun Ġ` persist Ġmultiple Ġentities `() Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . persist ( listOf ( User (" Test ĠName "), ĠUser (" Test ĠName Ġ 2 ")) )) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Next Matches Ġ{ Ġexpect Pers isted User ( it , Ġ" Test ĠName ") Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Next Matches Ġ{ Ġexpect Pers isted User ( it , Ġ" Test ĠName Ġ 2 ") Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Complete () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify () ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġ@ Test ĊĠĠĠĠĠĠĠ Ġfun Ġ` persist Ġmultiple Ġentities Ġexception `() Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġreactor Join er . persist ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠlistOf ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠUser (" 1 "), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠUser (" 2 "). apply Ġ{ Ġid Ġ= Ġ 1 Ġ}, ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠUser (" 3 "), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Error Matches Ġ{ Ġit . message !!. contains (" det ached Ġentity Ġpassed ") Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify () ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġassert Users Are Empty () ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Nested ĊĠĠĠ Ġinner Ġclass ĠFind One Ġ{ ĊĊĠĠĠĠĠĠĠ Ġ@ Test ĊĠĠĠĠĠĠĠ Ġfun Ġ` find Ġone Ġsuccess `() Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreactor Join er . persist ( User (" Test ĠName ")). block () ĊĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . findOne ( user 1 . name Ġfrom Ġuser 1 Ġwhere Ġ{ Ġit . name Ġeq Ġ" Test ĠName " Ġ})) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Next (" Test ĠName ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Complete () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify () ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġ@ Test ĊĠĠĠĠĠĠĠ Ġfun Ġ` find Ġone Ġexecution Ġexception `() Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreactor Join er . persist ( User (" Test ĠName ")). block () ĊĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . findOne ( user 1 . name Ġfrom ĠQ Status . status )) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Error Matches Ġ{ Ġit . message !!. contains (" Query Syntax Exception ") Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify () ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġ@ Test ĊĠĠĠĠĠĠĠ Ġfun Ġ` find Ġone Ġempty `() Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . findOne ( user 1 . name Ġfrom Ġuser 1 )) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Error Matches Ġ{ Ġit . has Cause ( Join er Exceptions . entity NotFound (). message !! ) Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify () ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġ@ Test ĊĠĠĠĠĠĠĠ Ġfun Ġ` find Ġone Ġmultiple Ġresults `() Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreactor Join er . persist ( User (" Test ĠName ")). block () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreactor Join er . persist ( User (" Test ĠName Ġ 2 ")). block () ĊĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . findOne ( user 1 . name Ġfrom Ġuser 1 )) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Error ( Join er Exception :: class . java ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify () ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġ@ Test ĊĠĠĠĠĠĠĠ Ġfun Ġ` count Ġquery Ġsuccess `() Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . findOne ( user 1 . count Of ())) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Next ( 0 ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify Complete () ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġreactor Join er . persist ( listOf ( User (" 1 "), ĠUser (" 2 ")) ). collect List (). block () ĊĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . findOne ( user 1 . count Of ())) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Next ( 2 ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify Complete () ĊĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . findOne ( user 1 . count Of () Ġwhere Ġ{ Ġit . name Ġne Ġ" 1 " Ġ})) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Next ( 1 ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify Complete () ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Nested ĊĠĠĠ Ġinner Ġclass ĠFind One Optional Ġ{ ĊĊĠĠĠĠĠĠĠ Ġ@ Test ĊĠĠĠĠĠĠĠ Ġfun Ġ` find Ġone Ġsuccess `() Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreactor Join er . persist ( User (" Test ĠName ")). block () ĊĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . findOne Optional ( user 1 . name Ġfrom Ġuser 1 Ġwhere Ġ{ Ġit . name Ġeq Ġ" Test ĠName " Ġ})) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Next (" Test ĠName ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Complete () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify () ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġ@ Test ĊĠĠĠĠĠĠĠ Ġfun Ġ` find Ġone Ġempty `() Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . findOne Optional ( user 1 . name Ġfrom Ġuser 1 )) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Complete () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify () ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġ@ Test ĊĠĠĠĠĠĠĠ Ġfun Ġ` find Ġone Ġmultiple Ġresults `() Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreactor Join er . persist ( User (" Test ĠName ")). block () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreactor Join er . persist ( User (" Test ĠName Ġ 2 ")). block () ĊĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . findOne Optional ( user 1 . name Ġfrom Ġuser 1 )) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Error ( Join er Exception :: class . java ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify () ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġ@ Test ĊĠĠĠĠĠĠĠ Ġfun Ġ` count Ġquery Ġsuccess `() Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . findOne Optional ( user 1 . count Of ())) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Next ( 0 ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify Complete () ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġreactor Join er . persist ( listOf ( User (" 1 "), ĠUser (" 2 ")) ). collect List (). block () ĊĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . findOne Optional ( user 1 . count Of ())) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Next ( 2 ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify Complete () ĊĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . findOne Optional ( user 1 . count Of () Ġwhere Ġ{ Ġit . name Ġne Ġ" 1 " Ġ})) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Next ( 1 ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify Complete () ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Nested ĊĠĠĠ Ġinner Ġclass ĠFind Multiple Ġ{ ĊĊĠĠĠĠĠĠĠ Ġ@ Test ĊĠĠĠĠĠĠĠ Ġfun Ġ` find Ġmultiple Ġsuccess Ġwith Ġlimit Ġand Ġoffset `() Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreactor Join er . persist ( User (" Limit And Offset ")). block () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreactor Join er . persist ( User (" Limit And Offset Ġ 2 ")). block () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreactor Join er . persist ( User (" Limit And Offset Ġ 3 ")). block () ĊĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . find ( user 1 . name Ġfrom Ġuser 1 Ġwhere Ġ{ Ġit . name Ġcontains Ġ" Limit And Offset " Ġ} Ġlimit Ġ 1 Ġoffset Ġ 1 )) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Next (" Limit And Offset Ġ 2 ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Complete () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify () ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġ@ Test ĊĠĠĠĠĠĠĠ Ġfun Ġ` find Ġmultiple Ġsuccess `() Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreactor Join er . persist ( User (" Test ĠName ")). block () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreactor Join er . persist ( User (" Test ĠName Ġ 2 ")). block () ĊĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . find ( user 1 . name Ġfrom Ġuser 1 Ġwhere Ġ{ Ġit . name Ġeq Ġ" Test ĠName " Ġor Ġit . name Ġeq Ġ" Test ĠName Ġ 2 " Ġ})) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Next (" Test ĠName ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Next (" Test ĠName Ġ 2 ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Complete () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify () ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġ@ Test ĊĠĠĠĠĠĠĠ Ġfun Ġ` find Ġmultiple Ġexception `() Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠStep Verifier . create ( reactor Join er . find ( user 1 . name Ġfrom ĠQ Status . status )) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. expect Error Matches Ġ{ Ġit . message !!. contains (" Query Syntax Exception ") Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. verify () ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠ Ġ} ĊĊĠĠĠ Ġprivate Ġfun Ġexpect Pers isted User ( user : ĠUser , Ġname : ĠString ): ĠBoolean Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġuser . id Ġ!= Ġnull Ġ&& Ġuser . name . equals ( name ) Ġ&& ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġreactor Join er . findOne ( user 1 Ġfrom Ġuser 1 Ġwhere Ġ{ Ġit . id Ġeq Ġuser . id Ġ}). block () Ġ!= Ġnull ĊĠĠĠ Ġ} Ċ Ċ } Ċ