anchor.diff:      {noreply, State};
   
   command({prepared_query, Statement, Parameters}, #state{codec = Codec} = State) ->
  +    %% > Bind
  +    %% < BindComplete
  +    %% > Execute
  +    %% < DataRow*
  +    %% < CommandComplete
  +    %% > Sync
  +    %% < ReadyForQuery
       #statement{name = StatementName, columns = Columns} = Statement,
       Bin1 = epgsql_wire:encode_parameters(Parameters, Codec),
       Bin2 = epgsql_wire:encode_formats(Columns),
  
positive.code:     end;
  
  command({squery, Sql}, State) ->
      send(State, ?SIMPLEQUERY, [Sql, 0]),
      {noreply, State};
  
  
negative.code:     {noreply, State};
  
  command(sync, State) ->
      %% > Sync
      %% < ReadyForQuery
      send(State, ?SYNC, []),
      {noreply, State#state{sync_required = false}};
  
  command({start_replication, ReplicationSlot, Callback, CbInitState, WALPosition, PluginOpts}, State) ->
      %% > SIMPLEQUERY
      %% < CopyBothResponse
      %% < COPY_DATA+
      %% > COPY_DATA?
      Sql1 = ["START_REPLICATION SLOT """, ReplicationSlot, """ LOGICAL ", WALPosition],
      Sql2 =
          case PluginOpts of
  