Program.cs 1.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. 
  2. using SqlSugar;
  3. using SqlSugarORM;
  4. using System.Collections.Concurrent;
  5. using System.Diagnostics;
  6. using System.Reflection;
  7. using System.Runtime.CompilerServices;
  8. using System.Text;
  9. using System.Text.Json;
  10. using Universal;
  11. using Universal.IO;
  12. namespace Test;
  13. internal class Program
  14. {
  15. static void Main()
  16. {
  17. SqlSugarCustom orm = new();
  18. orm.Initialize(null);
  19. string dbString = "Database=thermaldb;Password=123456;Host=localhost;Username=postgres;Persist Security Info=True";
  20. //string dbString = "Database=Kepler;Password=123456;Host=localhost;Username=postgres;Persist Security Info=True";
  21. if (!orm.Open(dbString, DbType.PostgreSQL, true))
  22. {
  23. Console.WriteLine("Connect Failed");
  24. return;
  25. }
  26. dynamic[] t = orm._Client!.Queryable<dynamic>().AS("\"20250627.PM1\"").Take(10).ToArray();
  27. //dynamic[] t = orm._Client!.Queryable<dynamic>().AS("\"20250626.Data\"").Take(1).ToArray();
  28. //KeplerData processData = new();
  29. GeneralProcessData processData = new();
  30. processData.ToDictionary(t, out Dictionary<string, object>? outputs);
  31. foreach (var item in outputs)
  32. {
  33. string s = JsonSerializer.Serialize(item);
  34. Console.WriteLine(s);
  35. Console.WriteLine();
  36. }
  37. //int totalCount = 0;
  38. //int totalPages = 0;
  39. //dynamic[] page = orm._Client!.Queryable<dynamic>().AS("\"20250626.Data\"").ToPageList(1, 1000, ref totalCount, ref totalPages).ToArray();
  40. }
  41. }