db.cs 806 B

1234567891011121314151617181920212223242526272829
  1. using BeetleX;
  2. using BeetleX.Buffers;
  3. using SpanJson;
  4. using System;
  5. using System.Collections.Generic;
  6. using System.Text;
  7. using System.Threading.Tasks;
  8. namespace PlatformBenchmarks
  9. {
  10. public partial class HttpHandler
  11. {
  12. public async Task db(PipeStream stream, HttpToken token, ISession session)
  13. {
  14. try
  15. {
  16. var data = await token.Db.LoadSingleQueryRow();
  17. await JsonSerializer.NonGeneric.Utf8.SerializeAsync(data, stream);
  18. }
  19. catch(Exception e_)
  20. {
  21. HttpServer.ApiServer.Log(BeetleX.EventArgs.LogType.Error, null, $"db error {e_.Message}@{e_.StackTrace}");
  22. stream.Write(e_.Message);
  23. }
  24. OnCompleted(stream, session, token);
  25. }
  26. }
  27. }