anchor.diff:      %{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(),
  
positive.code:             {MPort, "-1"};
          {Statement, _, _} ->
              {ok, Finished, CacheSize} = Statement:get_buffer_max(),
              dderl_session:log(SrvPid, "[~p, ~p] get_buffer_max ~p~n", [SrvPid, StmtKey, CacheSize]),
              {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);
  
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, _) ->
  