anchor.diff:              {MPort, "-1"};
           {Statement, _, _} ->
               {ok, Finished, CacheSize} = Statement:get_buffer_max(),
  -            dderl_session:log(SrvPid, "[~p, ~p] get_buffer_max ~p~n", [SrvPid, StmtKey, CacheSize]),
  +            dderl_session:log(SrvPid, "[~p, ~p] get_buffer_max ~p Fnished ~p~n", [SrvPid, StmtKey, CacheSize, Finished]),
               {MPort, "{\"count\":"++integer_to_list(CacheSize)++", \"finished\":"++atom_to_list(Finished)++"}"}
       end;
   process_cmd({"parse_stmt", BodyJson}, SrvPid, MPort) -> gen_adapter:process_cmd({"parse_stmt", BodyJson}, SrvPid, MPort);
  
positive.code:     %{ok, [ParseTree|_]} = sql_parse:parse(Tokens),
      ParseTree = [],
      dderl_session:log(SrvPid, "[~p] Query ~p~n", [SrvPid, {Session, Query}]),
      
      case Session:execute_sql(Query, [], ?DEFAULT_ROW_SIZE, true) of
          {statement, Statement} ->
              {ok, Clms} = Statement:get_columns(),
  
negative.code:     imem_if:insert_into_table(common, {?MODULE, [
                  #file{name="Users.sql",
                        content="SELECT USERNAME FROM ALL_USERS",
                        posX=0, posY=25, width=200, height=500}
                , #file{name="Tables.sql",
                        content="SELECT CONCAT(OWNER,CONCAT('.', TABLE_NAME)) AS QUALIFIED_TABLE_NAME FROM ALL_TABLES WHERE OWNER=user ORDER BY TABLE_NAME",
                        posX=0, posY=25, width=200, height=500}
                , #file{name="Views.sql",
                        content="SELECT CONCAT(OWNER,CONCAT('.', VIEW_NAME)) AS QUALIFIED_TABLE_NAME FROM ALL_VIEWS WHERE OWNER=user ORDER BY VIEW_NAME",
                        posX=0, posY=25, width=200, height=500}
              ]}).
  
  process_cmd({"connect", BodyJson}, SrvPid, _) ->
  