1.mql 1.8 KB

1234567891011121314151617181920212223242526272829303132333435
  1. -- MATCH (ptr:/project_1000119_harness_draft/paper_trade_record)
  2. -- -[:project_1000119_harness_draft_trades_on*1..1]->
  3. -- (ti:/project_1000119_harness_draft/trade_instrument
  4. -- WHERE instrument_id in ('INSTRUMENT_000000001', 'INSTRUMENT_000000002', 'INSTRUMENT_000000003', 'INSTRUMENT_000000004', 'INSTRUMENT_000000005', 'INSTRUMENT_000000006', 'INSTRUMENT_000000007', 'INSTRUMENT_000000008', 'INSTRUMENT_000000009', 'INSTRUMENT_000000010'))
  5. -- WITH TIMEOUT = 60m
  6. -- /**
  7. -- match('graph.nodes.len', 284873, 'graph.edges.len', 284863)
  8. -- **/
  9. -- ;
  10. MATCH (ptr:/project_1000119_harness_draft/paper_trade_record)
  11. -[:project_1000119_harness_draft_trades_on*1..1]->
  12. (ti:/project_1000119_harness_draft/trade_instrument
  13. WHERE instrument_id in ('INSTRUMENT_000000001', 'INSTRUMENT_000000002', 'INSTRUMENT_000000003', 'INSTRUMENT_000000004', 'INSTRUMENT_000000005', 'INSTRUMENT_000000006', 'INSTRUMENT_000000007', 'INSTRUMENT_000000008', 'INSTRUMENT_000000009', 'INSTRUMENT_000000010'))
  14. RETURN ti.instrument_id AS "instrument_id", ptr.trade_record_id AS "trade_record_id"
  15. WITH TIMEOUT = 6000m
  16. /**
  17. count(284863)
  18. **/
  19. ;
  20. SELECT temp.instrument_id AS "instrument_id", count(temp.trade_record_id) AS "trade_count" FROM
  21. (MATCH (ptr:/project_1000119_harness_draft/paper_trade_record)
  22. -[:project_1000119_harness_draft_trades_on*1..1]->
  23. (ti:/project_1000119_harness_draft/trade_instrument
  24. WHERE instrument_id in ('INSTRUMENT_000000001', 'INSTRUMENT_000000002', 'INSTRUMENT_000000003', 'INSTRUMENT_000000004', 'INSTRUMENT_000000005', 'INSTRUMENT_000000006', 'INSTRUMENT_000000007', 'INSTRUMENT_000000008', 'INSTRUMENT_000000009', 'INSTRUMENT_000000010'))
  25. RETURN ti.instrument_id AS "instrument_id", ptr.trade_record_id AS "trade_record_id")
  26. temp GROUP BY temp."instrument_id" ORDER BY temp."trade_record_id" DESC WITH TIMEOUT = 6000m
  27. /**
  28. output()
  29. **/
  30. ;