db.cs 653 B

123456789101112131415161718192021222324252627
  1. using BeetleX;
  2. using BeetleX.Buffers;
  3. using SpanJson;
  4. using System;
  5. using System.Collections.Generic;
  6. using System.Text;
  7. namespace PlatformBenchmarks
  8. {
  9. public partial class HttpHandler
  10. {
  11. public async void db(PipeStream stream, HttpToken token, ISession session)
  12. {
  13. try
  14. {
  15. var data = await token.Db.LoadSingleQueryRow();
  16. await JsonSerializer.NonGeneric.Utf8.SerializeAsync(data, stream);
  17. }
  18. catch(Exception e_)
  19. {
  20. stream.Write(e_.Message);
  21. }
  22. OnCompleted(stream, session, token);
  23. }
  24. }
  25. }