84 lines
3.2 KiB
C#
84 lines
3.2 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using System.Data.SqlClient;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
using HospitalServerManager.InterfacesAndEnums;
|
|
|
|
namespace HospitalServerManager.ViewModel.Controllers
|
|
{
|
|
class DatabaseReader
|
|
{
|
|
// KLASA ZNALAZŁA SIĘ TUTAJ TYLKO DLA POMOCY PRZY TESTOWANIU POCZĄTKOWEJ WERSJI APLIKACJI, NIE PODŁĄCZONEJ JESZCZE DO SIECI.
|
|
// Postanowiłem, że ją zostawię na przyszłość
|
|
private List<ISqlTableModel> _ModelsList { get; set; }
|
|
|
|
public IReadOnlyList<ISqlTableModel> LastReadedModels { get => _ModelsList; }
|
|
public DatabaseReader()
|
|
{
|
|
_ModelsList = new List<ISqlTableModel>();
|
|
|
|
}
|
|
/// <summary>
|
|
/// Reads the data from the database and write models in LastReadedModels. The model have to implements ISqlTableModelable.
|
|
/// </summary>
|
|
/// <param name="connectionString">Connection string</param>
|
|
/// <param name="sqlCommand">Command to execute</param>
|
|
/// <param name="typeOfModel">Type of model</param>
|
|
/// <returns>True if reading ends in right way</returns>
|
|
public async Task<bool> ReadDataFromDatabase(string connectionString, string sqlCommand, Type typeOfModel)
|
|
{
|
|
// TODO: Validate if interface is implemented;
|
|
using (SqlConnection connection = new SqlConnection(connectionString))
|
|
{
|
|
try
|
|
{
|
|
await connection.OpenAsync();
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
throw new Exception("Nie ma możliwości połączyć się z DB.");
|
|
|
|
}
|
|
if (connection.State == ConnectionState.Open)
|
|
{
|
|
|
|
using (SqlCommand cmd = connection.CreateCommand())
|
|
{
|
|
|
|
cmd.CommandText = sqlCommand;
|
|
// TODO: Dodac validator sprawdzajacy komende?
|
|
using (SqlDataReader reader = await cmd.ExecuteReaderAsync())
|
|
{
|
|
|
|
int fieldCount = reader.FieldCount;
|
|
_ModelsList.Clear();
|
|
//List<ISqlTableModelable> sqlTablesModels = new List<ISqlTableModelable>();
|
|
while (await reader.ReadAsync())
|
|
{
|
|
List<string> valueList = new List<string>();
|
|
for (int i = 0; i < fieldCount; i++)
|
|
{
|
|
if (String.IsNullOrEmpty(reader[i].ToString()))
|
|
valueList.Add("NULL");
|
|
else
|
|
valueList.Add(reader[i].ToString());
|
|
}
|
|
var model = Activator.CreateInstance(typeOfModel, valueList);
|
|
|
|
_ModelsList.Add(model as ISqlTableModel);
|
|
}
|
|
return true;
|
|
}
|
|
}
|
|
}
|
|
return false;
|
|
}
|
|
|
|
|
|
}
|
|
}
|
|
}
|