package Ġcom . github . ays nc . sql . db . postgresql . en coders Ċ Ċ import Ġcom . github . j async . sql . db . postgresql . column . PostgreSQL Column Encoder Registry Ċ import Ġcom . github . j async . sql . db . postgresql . en coders . Execute PreparedStatement Encoder Ċ import Ġcom . github . j async . sql . db . postgresql . messages . frontend . PreparedStatement Execute Message Ċ import Ġio . netty . util . Charset Util Ċ import Ġorg . assertj . core . api . Assertions . assertThat Ċ import Ġorg . junit . Test ĊĊ Ċ class ĠExecute PreparedStatement Encoder Spec Ġ{ ĊĊĠĠĠ Ġval Ġregistry Ġ= ĠPostgreSQL Column Encoder Registry () ĊĠĠĠ Ġval Ġencoder Ġ= ĠExecute PreparedStatement Encoder ( Charset Util . UTF _ 8 , Ġregistry ) ĊĠĠĠ Ġval Ġsample Message Ġ= Ġbyte ArrayOf ( ĊĠĠĠĠĠĠĠĠ 6 6 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 1 8 , ĊĠĠĠĠĠĠĠĠ 4 9 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 4 9 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 1 , ĊĠĠĠĠĠĠĠ Ġ- 1 , ĊĠĠĠĠĠĠĠ Ġ- 1 , ĊĠĠĠĠĠĠĠ Ġ- 1 , ĊĠĠĠĠĠĠĠ Ġ- 1 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 6 9 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 1 0 , ĊĠĠĠĠĠĠĠĠ 4 9 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 8 3 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 4 , ĊĠĠĠĠĠĠĠĠ 6 7 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 0 , ĊĠĠĠĠĠĠĠĠ 7 , ĊĠĠĠĠĠĠĠĠ 8 0 , ĊĠĠĠĠĠĠĠĠ 4 9 , ĊĠĠĠĠĠĠĠĠ 0 ĊĠĠĠ Ġ) ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġ` encoder Ġshould Ġcorrectly Ġhandle Ġthe Ġcase Ġwhere Ġan Ġencoder Ġreturns Ġnull `() Ġ{ ĊĊĊĠĠĠĠĠĠĠ Ġval Ġmessage Ġ= ĠPreparedStatement Execute Message ( 1 , Ġ" select Ġ* Ġfrom Ġusers ", ĠlistOf ( null ), Ġregistry ) ĊĊĠĠĠĠĠĠĠ Ġval Ġresult Ġ= Ġencoder . encode ( message ) ĊĊĠĠĠĠĠĠĠ Ġval Ġbytes Ġ= ĠByteArray ( result . readable Bytes ()) Ġ{ Ġ 0 Ġ} ĊĠĠĠĠĠĠĠ Ġresult . read Bytes ( bytes ) ĊĊĠĠĠĠĠĠĠ ĠassertThat ( bytes ). isEqualTo ( sample Message ) ĊĊĊĠĠĠ Ġ} Ċ Ċ } Ċ