package Ġcom . bn orm . pg kotlin . internal . msg Ċ Ċ import Ġcom . bn orm . pg kotlin . internal . ok io . Buffered Source Ċ Ċ /** Ċ Ġ* ĠSee Ġ[ PostgreSQL Ġmessage Ġformats ]( https :// www . postgresql . org / docs / current / static / protocol - message - formats . html ) Ċ Ġ* Ċ Ġ* Ġ< pre > Ċ Ġ* ĠCommand Complete Ġ( B ) Ċ Ġ* ĠĠ ĠByte 1 (' C ') Ċ Ġ* ĠĠĠĠĠ ĠIdent ifies Ġthe Ġmessage Ġas Ġa Ġcommand - completed Ġresponse . Ċ Ġ* ĠĠ ĠInt 3 2 Ċ Ġ* ĠĠĠĠĠ ĠLength Ġof Ġmessage Ġcontents Ġin Ġbytes , Ġincluding Ġself . Ċ Ġ* ĠĠ ĠString Ċ Ġ* ĠĠĠĠĠ ĠThe Ġcommand Ġtag . ĠThis Ġis Ġusually Ġa Ġsingle Ġword Ġthat Ġidentifies Ġwhich ĠSQL Ġcommand Ġwas Ġcompleted . Ċ Ġ* ĠĠĠĠĠ ĠFor Ġan ĠINSERT Ġcommand , Ġthe Ġtag Ġis ĠINSERT Ġoid Ġrows , Ġwhere Ġrows Ġis Ġthe Ġnumber Ġof Ġrows Ġinserted . Ġoid Ġis Ġthe Ġobject ĠID Ġof Ġthe Ġinserted Ġrow Ġif Ġrows Ġis Ġ 1 Ġand Ġthe Ġtarget Ġtable Ġhas ĠO IDs ; Ġotherwise Ġoid Ġis Ġ 0 . Ċ Ġ* ĠĠĠĠĠ ĠFor Ġa ĠDELETE Ġcommand , Ġthe Ġtag Ġis ĠDELETE Ġrows Ġwhere Ġrows Ġis Ġthe Ġnumber Ġof Ġrows Ġdeleted . Ċ Ġ* ĠĠĠĠĠ ĠFor Ġan ĠUPDATE Ġcommand , Ġthe Ġtag Ġis ĠUPDATE Ġrows Ġwhere Ġrows Ġis Ġthe Ġnumber Ġof Ġrows Ġupdated . Ċ Ġ* ĠĠĠĠĠ ĠFor Ġa ĠSELECT Ġor ĠCREATE ĠTABLE ĠAS Ġcommand , Ġthe Ġtag Ġis ĠSELECT Ġrows Ġwhere Ġrows Ġis Ġthe Ġnumber Ġof Ġrows Ġretrieved . Ċ Ġ* ĠĠĠĠĠ ĠFor Ġa ĠMOVE Ġcommand , Ġthe Ġtag Ġis ĠMOVE Ġrows Ġwhere Ġrows Ġis Ġthe Ġnumber Ġof Ġrows Ġthe Ġcursor 's Ġposition Ġhas Ġbeen Ġchanged Ġby . Ċ Ġ* ĠĠĠĠĠ ĠFor Ġa ĠFETCH Ġcommand , Ġthe Ġtag Ġis ĠFETCH Ġrows Ġwhere Ġrows Ġis Ġthe Ġnumber Ġof Ġrows Ġthat Ġhave Ġbeen Ġretrieved Ġfrom Ġthe Ġcursor . Ċ Ġ* ĠĠĠĠĠ ĠFor Ġa ĠCOPY Ġcommand , Ġthe Ġtag Ġis ĠCOPY Ġrows Ġwhere Ġrows Ġis Ġthe Ġnumber Ġof Ġrows Ġcopied . Ġ( Note : Ġthe Ġrow Ġcount Ġappears Ġonly Ġin ĠPostgreSQL Ġ 8 . 2 Ġand Ġlater .) Ċ Ġ* Ġ</ pre > Ċ Ġ*/ Ċ internal Ġdata Ġclass ĠCommand Complete ( ĊĠ Ġval Ġrows : ĠInt Ċ ) Ġ: ĠMessage Ġ{ ĊĠ Ġoverride Ġval Ġid : ĠInt Ġ= ĠComp anion . id ĊĊĠ Ġcompanion Ġobject Ġ: ĠMessage . Factory < Command Complete > Ġ{ ĊĠĠĠ Ġoverride Ġval Ġid : ĠInt Ġ= Ġ' C '. toInt () ĊĠĠĠ Ġoverride Ġfun Ġdecode ( source : ĠBuffered Source ): ĠCommand Complete Ġ{ ĊĠĠĠĠĠ Ġval Ġquery Ġ= Ġsource . read Utf 8 Terminated () ĊĠĠĠĠĠ Ġreturn ĠCommand Complete ( ĊĠĠĠĠĠĠĠ Ġquery . split (" Ġ". to Regex ()). last (). toInt OrNull () Ġ?: Ġ 0 ĊĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} ĊĠ Ġ} Ċ } Ċ