yi lu 6 years ago
parent
commit
1fca713c6c

+ 0 - 2
frameworks/CSharp/zysocket-v/PlatformBenchmarks/HttpHandler.cs

@@ -45,12 +45,10 @@ namespace PlatformBenchmarks
 
         private static byte _question = 63;
 
-        private RawDb mPgsql;
 
         public HttpHandler()
         {
 
-            mPgsql = new RawDb(new ConcurrentRandom(), Npgsql.NpgsqlFactory.Instance);
         }
 
         public void Default(IFiberRw<HttpToken> fiberRw,ref WriteBytes write)

+ 3 - 3
frameworks/CSharp/zysocket-v/PlatformBenchmarks/fortunes.cs

@@ -10,7 +10,7 @@ namespace PlatformBenchmarks
     public partial class HttpHandler
     {
 
-        private readonly static AsciiString _fortunesTableStart = "<!DOCTYPE html><html><head><title>Fortunes</title></head><body><table><tr><th>id</th><th>message</th></tr>";
+        private readonly static AsciiString _fortunesTableStart = "<!DOCTYPE html><html><head><title>Fortunes</title></head><body><table><tr><th>id</th><th>message</th></tr>";     
         private readonly static AsciiString _fortunesRowStart = "<tr><td>";
         private readonly static AsciiString _fortunesColumn = "</td><td>";
         private readonly static AsciiString _fortunesRowEnd = "</td></tr>";
@@ -18,11 +18,11 @@ namespace PlatformBenchmarks
 
         public async void fortunes(IFiberRw<HttpToken> fiberRw, WriteBytes write)
         {
-            List<Fortune> data = null;
+         
 
             try
             {
-                data = await mPgsql.LoadFortunesRows();
+                var data = await fiberRw.UserToken.Db.LoadFortunesRows();
 
                 Task<int> WSend()
                 {

+ 1 - 1
frameworks/CSharp/zysocket-v/PlatformBenchmarks/queries.cs

@@ -27,7 +27,7 @@ namespace PlatformBenchmarks
                 count = 1;
             try
             {
-                var data = await mPgsql.LoadMultipleQueriesRows(count);
+                var data = await fiberRw.UserToken.Db.LoadMultipleQueriesRows(count);
                 await JsonSerializer.NonGeneric.Utf8.SerializeAsync(data, write.Stream);
             }
             catch (Exception e_)