|
@@ -1,4 +1,6 @@
|
|
|
using System;
|
|
|
+using System.Collections.Generic;
|
|
|
+using System.Threading.Tasks;
|
|
|
using MySql.Data.MySqlClient;
|
|
|
|
|
|
namespace HyperCube
|
|
@@ -56,6 +58,44 @@ namespace HyperCube
|
|
|
return lastID;
|
|
|
}
|
|
|
|
|
|
+ public async Task<Dictionary<int, Models.ArticleModel>> SQLSelectArticles(string sql)
|
|
|
+ {
|
|
|
+ Dictionary<int, Models.ArticleModel> articleModels = new();
|
|
|
+ Models.ArticleModel articleModel;
|
|
|
+
|
|
|
+ bool connected = IsConnect();
|
|
|
+ if (connected)
|
|
|
+ {
|
|
|
+ SQLcom = new(sql, Connection);
|
|
|
+
|
|
|
+ MySqlDataReader rdr = SQLcom.ExecuteReader();
|
|
|
+
|
|
|
+ while (rdr.Read())
|
|
|
+ {
|
|
|
+ Console.WriteLine("{0} {1} {2} {3} {4}", rdr.GetInt32(0), rdr.GetString(1),
|
|
|
+ rdr.GetString(2), rdr.GetDateTime(3), rdr.GetString(4));
|
|
|
+
|
|
|
+ articleModel = new();
|
|
|
+ articleModel.Filename = rdr.GetString(1);
|
|
|
+ articleModel.Name = rdr.GetString(2);
|
|
|
+ articleModel.PublishDate = rdr.GetDateTime(3);
|
|
|
+ articleModel.Authors = rdr.GetString(4);
|
|
|
+
|
|
|
+ articleModels.Add(rdr.GetInt32(0), articleModel);
|
|
|
+ }
|
|
|
+
|
|
|
+ await Task.WhenAll();
|
|
|
+
|
|
|
+ Console.WriteLine("End reading DB");
|
|
|
+
|
|
|
+ return articleModels;
|
|
|
+ }
|
|
|
+ else
|
|
|
+ Console.WriteLine("Not connected to DB.");
|
|
|
+
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
public uint SQLGetID(string sql)
|
|
|
{
|
|
|
bool connected = IsConnect();
|