/* Ċ Ġ* Ġ* Ċ Ġ* Ġ Ġ* ĠCreated Ġby ĠS ina ĠD al v and Ġon Ġ 1 2 / 2 2 / 2 0 Ġ 1 1 : 3 4 ĠPM Ċ Ġ* Ġ Ġ* ĠCopyright Ġ( c ) Ġ 2 0 2 0 Ġ. ĠAll Ġrights Ġreserved . Ċ Ġ* Ġ Ġ* ĠLast Ġmodified Ġ 1 2 / 2 2 / 2 0 Ġ 1 1 : 3 4 ĠPM Ċ Ġ* Ċ Ġ*/ Ċ Ċ package Ġir . sin ad al v and . projects . baz aar project . data . local Ċ Ċ import Ġandroidx . paging . Paging Source Ċ import Ġandroidx . room .* Ċ import Ġio . reactivex . Comp letable Ċ import Ġio . reactivex . Flow able Ċ import Ġir . sin ad al v and . projects . baz aar project . data . model . Venue ĊĊ Ċ @ Dao Ċ interface ĠV en ue Dao Ġ{ ĊĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* Ġinsert Ġlist Ġof Ġven ues Ġinto Ġdatabase ĊĠĠĠĠ Ġ* Ġ@ param Ġusers ĠList < Venue ?> ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġ@ Insert ( on Conflict Ġ= ĠOn Conflict Strategy . REPLACE ) ĊĠĠĠ Ġfun Ġinsert Ven ues ( venue : ĠList < Venue >): ĠComp letable ĊĊĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* Ġinsert Ġven ue Ġinto Ġdatabase ĊĠĠĠĠ Ġ* Ġ@ param Ġusers ĠV en ue ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġ@ Update ĊĠĠĠ Ġfun Ġinsert Venue ( venue : ĠV en ue ) ĊĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* Ġget Ġspecific Ġven ue Ġfrom Ġdatabase ĊĠĠĠĠ Ġ* Ġ@ param Ġid ĠString ĊĠĠĠĠ Ġ* Ġ@ return ĠFlow able < Venue ?> ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġ@ Query (" SELECT Ġ* Ġfrom ĠV en ue ĠWHERE Ġid =: id Ġ") ĊĠĠĠ Ġfun Ġget Venue ( id : ĠString ): ĠFlow able < Venue ?> ĊĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* Ġselect Ġand Ġretrieve Ġven ues Ġfrom Ġdatabase ĊĠĠĠĠ Ġ* Ġ@ return ĠFlow able < List < Venue ?> ?> ? ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġ@ Query (" select Ġ* Ġfrom ĠV en ue ") ĊĠĠĠ Ġfun Ġget Ven ues (): ĠP aging Source < Int , ĠV en ue > ĊĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* Ġget Ġrecords Ġcount Ġin Ġven ue Ġtable Ġfor Ġpagination ĊĠĠĠĠ Ġ* Ġ@ return ĠFlow able < Int ?> ? ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġ@ Query (" SELECT ĠCOUNT (*) ĠFROM ĠV en ue ") ĊĠĠĠ Ġfun Ġget Ven ues Count (): ĠFlow able < Int ?> ? ĊĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* Ġdelete Ġall Ġrecords Ġin Ġven us Ġtable ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġ@ Query (" DELETE ĠFROM ĠV en ue ") ĊĠĠĠ Ġfun Ġdelete All Ven ues (): ĠComp letable Ċ Ċ }