db.cs 776 B

12345678910111213141516171819202122232425262728
  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. HttpServer.ApiServer.Log(BeetleX.EventArgs.LogType.Error, null, $"db error {e_.Message}@{e_.StackTrace}");
  21. stream.Write(e_.Message);
  22. }
  23. OnCompleted(stream, session, token);
  24. }
  25. }
  26. }