Files
PaymentLogs/sql2/Repositories/CourseRepo.cs
T
2024-05-23 23:21:24 +03:00

58 lines
1.6 KiB
C#

using MySql.Data.MySqlClient;
using PaymentLogs.Domain;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace PaymentLogs.Repositories
{
internal class CourseRepo : Repo<int, Course>
{
public override void Load()
{
DataBase db = new DataBase();
db.openConnection();
_data.Clear();
string sql = " SELECT * FROM courses ";
MySqlCommand cmd = new MySqlCommand(sql, db.getConnection());
MySqlDataReader reader = cmd.ExecuteReader();
while (reader.Read())
{
Course course = new Course() {
Id = reader.GetInt32("id"),
Name = reader.GetString("name"),
Type = reader.GetString("type"),
Cost = reader.GetInt32("cost"),
Duration = reader.GetInt32("duration"),
StudentsCount = reader.GetInt32("students_count")
};
_data[course.Id] = course;
}
db.closeConnection();
}
public override void Save()
{
throw new NotImplementedException();
}
public Course ByName(string name)
{
foreach (var course in _data.Values)
{
if (course.Name.ToLower().Equals(name.ToLower()))
{
return course;
}
}
return _data.Values.FirstOrDefault();
}
}
}