|
@@ -34,7 +34,7 @@ namespace HyperCube
|
|
|
string connstring = $"Server={Server}; database={DatabaseName}; UID={UserName}; password={Password}";
|
|
|
if (Connection != null)
|
|
|
{
|
|
|
- Console.WriteLine($"IsConnect {Connection.State}");
|
|
|
+ //Console.WriteLine($"IsConnect {Connection.State}");
|
|
|
//try
|
|
|
//{
|
|
|
await SQLSelectComplex("select COUNT(*) from accounts", false);
|
|
@@ -182,7 +182,7 @@ namespace HyperCube
|
|
|
//return null;
|
|
|
Console.WriteLine($"SQLSelectArticles {sql}");
|
|
|
Dictionary<int, ArticleModel> articleModels = new();
|
|
|
- Models.ArticleModel articleModel;
|
|
|
+ ArticleModel articleModel;
|
|
|
|
|
|
bool connected = await IsConnect();
|
|
|
if (connected)
|
|
@@ -193,6 +193,7 @@ namespace HyperCube
|
|
|
bool stop = false;
|
|
|
while (rdr.Read()) ///id, filename, article_name, date_publish, action_type/status
|
|
|
{
|
|
|
+ /// tmp
|
|
|
for (int i = 0; i < rdr.FieldCount; i++)
|
|
|
{
|
|
|
if (rdr.IsDBNull(i))
|
|
@@ -207,26 +208,26 @@ namespace HyperCube
|
|
|
stop = false;
|
|
|
continue;
|
|
|
}
|
|
|
+
|
|
|
articleModel = new();
|
|
|
articleModel.ID = rdr.GetInt32(0);
|
|
|
articleModel.Filename = rdr.GetString(1);
|
|
|
- articleModel.Name = rdr.GetString(2);
|
|
|
+ if (!rdr.IsDBNull(2)) articleModel.Name = rdr.GetString(2); else articleModel.Name = "NULL";
|
|
|
articleModel.PublishDate = rdr.GetDateTime(3);
|
|
|
articleModel.Authors = rdr.GetString(4);
|
|
|
- articleModel.Status = (ArticleStatus)rdr.GetInt32(5);
|
|
|
+ if (!rdr.IsDBNull(5)) articleModel.Status = (ArticleStatus)rdr.GetInt32(5); else articleModel.Status = ArticleStatus.New;
|
|
|
|
|
|
if (articleModels.ContainsKey(articleModel.ID))
|
|
|
continue;
|
|
|
-
|
|
|
- Console.WriteLine($"SQLSelectArticles count {count} model id {articleModel.ID}");
|
|
|
+
|
|
|
count++;
|
|
|
|
|
|
articleModels.Add(articleModel.ID, articleModel);
|
|
|
-
|
|
|
}
|
|
|
- Console.WriteLine($"SQLSelectArticles2");
|
|
|
+
|
|
|
+ Console.WriteLine($"SQLSelectArticles count: {count}");
|
|
|
rdr.Close();
|
|
|
- //await Task.WhenAll();
|
|
|
+
|
|
|
return articleModels;
|
|
|
}
|
|
|
else
|
|
@@ -242,22 +243,22 @@ namespace HyperCube
|
|
|
bool connected = true;
|
|
|
if (check)
|
|
|
{
|
|
|
- Console.WriteLine($"SQLSelectComplex check");
|
|
|
+ //Console.WriteLine($"SQLSelectComplex check");
|
|
|
connected = await IsConnect();
|
|
|
}
|
|
|
if (connected)
|
|
|
{
|
|
|
- Console.WriteLine($"SQLSelectComplex connected");
|
|
|
+ //Console.WriteLine($"SQLSelectComplex connected");
|
|
|
List<Dictionary<string, object>> retval = new List<Dictionary<string, object>>();
|
|
|
MySqlCommand SQLcom2 = new(request, Connection);
|
|
|
- Console.WriteLine($"SQLSelectComplex new SQLcom");
|
|
|
+ //Console.WriteLine($"SQLSelectComplex new SQLcom");
|
|
|
//try
|
|
|
//{
|
|
|
var Reader = await SQLcom2.ExecuteReaderAsync();
|
|
|
- Console.WriteLine($"SQLSelectComplex ExecuteReader");
|
|
|
+ //Console.WriteLine($"SQLSelectComplex ExecuteReader");
|
|
|
while (Reader.Read())
|
|
|
{
|
|
|
- Console.WriteLine($"SQLSelectComplex Reader.Read");
|
|
|
+ //Console.WriteLine($"SQLSelectComplex Reader.Read");
|
|
|
Dictionary<string, object> data = new Dictionary<string, object>();
|
|
|
|
|
|
for (int i = 0; i < Reader.FieldCount; i++)
|
|
@@ -286,7 +287,7 @@ namespace HyperCube
|
|
|
retval.Add(data);
|
|
|
}
|
|
|
|
|
|
- Console.WriteLine($"SQLSelectComplex Reader.Close");
|
|
|
+ //Console.WriteLine($"SQLSelectComplex Reader.Close");
|
|
|
Reader.Close();
|
|
|
await Task.WhenAll();
|
|
|
//}
|