anchor.diff:          ?assertEqual(ok, insert_range(SKey, 5, def, 'Imem', IsSec)),
           ?assertEqual(5,imem_meta:table_size(def)),
   
  -        Sql3 = "select col1, col2 from def;",
  +        Sql3 = "select col1, col2 from def where col2 <= 5;",
  +        io:format(user, "Query: ~p~n", [Sql3]),
           {ok, _Clm3, _RowFun3, StmtRef3} = imem_sql:exec(SKey, Sql3, 100, 'Imem', IsSec),
           try
               ?assertEqual(ok, imem_statement:fetch_recs_async(SKey, StmtRef3, self(), [{tail_mode,true}], IsSec)),
  
positive.code:         after
              ?assertEqual(ok, close(SKey, StmtRef3))
          end,
          ?assertEqual(ok, close(SKey, StmtRef2)),
          ?assertEqual(ok, imem_sql:exec(SKey, "drop table def;", 0, 'Imem', IsSec)),
  
  
negative.code:         [Guard0] -> [imem_sql:simplify_matchspec(select_bind(MetaRec, Guard0, Binds))]
      end,
      % io:format(user,"Guards after bind : ~p~n", [Guards1]),
      MatchSpec = [{MatchHead, Guards1, [Result]}],
      TailSpec = ets:match_spec_compile(MatchSpec),
      NewFetchCtx = case Pid of
          undefined ->
              case if_call_mfa(IsSec, fetch_start, [SKey, self(), Table, MatchSpec, BlockSize]) of
                  TransPid when is_pid(TransPid) ->
                      MonitorRef = erlang:monitor(process, TransPid),
                      TransPid ! next,
                      #fetchCtx{pid=TransPid, monref=MonitorRef, status=running, metarec=MetaRec, blockSize=BlockSize, remaining=Limit, opts=Opts, tailSpec=TailSpec};
                  Error ->    
                      ?SystemException({"Cannot spawn async fetch process",Error})
              end;
  