first commit

sql2/Repositories/PaymentRepo.cs

@@ -0,0 +1,59 @@
+using MySql.Data.MySqlClient;
+using PaymentLogs.Domain;
+using PaymentLogs.Utils;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace PaymentLogs.Repositories
+{
+    internal class PaymentRepo : Repo<int, Payment>
+    {
+
+        public override void Load()
+        {
+            DataBase db = new DataBase();
+            db.openConnection();
+            _data.Clear();
+            string sql = " SELECT * FROM payments  ";
+            MySqlCommand cmd = new MySqlCommand(sql, db.getConnection());
+            MySqlDataReader reader = cmd.ExecuteReader();
+
+            while (reader.Read())
+            {
+                Payment payment = new Payment()
+                {
+                    Id = reader.GetInt32("id"),
+                    FCs = reader.GetString("fcs"),
+                    CourseId = reader.GetInt32("course_id"),
+                    CoursePrice = reader.GetInt32("course_price"),
+                    Paid = reader.GetInt32("paid"),
+                    Debt = reader.GetInt32("debt")
+                };
+                _data[payment.Id] = payment;
+
+            }
+            db.closeConnection();
+        }
+
+
+        public override void Save()
+        {
+            DataBase db = new DataBase();
+            db.openConnection();
+            foreach(Payment payment in _data.Values)
+            {
+                string sql = $" INSERT INTO `payments` (`id`, `fcs`, `course_id`, `course_price`, `paid`, `debt`) " +
+                    $"VALUES ('{payment.Id}','{payment.FCs}', '{payment.CourseId}', '{payment.CoursePrice}', '{payment.Paid}', '{payment.Debt}') " +
+                    $"ON DUPLICATE KEY UPDATE `fcs`='{payment.FCs}', `course_id`='{payment.CourseId}', `course_price` = '{payment.CoursePrice}', " +
+                    $"`paid` = '{payment.Paid}', `debt`='{payment.Debt}'";
+                MySqlCommand cmd = new MySqlCommand(sql, db.getConnection());
+                cmd.ExecuteNonQuery();
+                
+            }
+            db.closeConnection();
+        }
+    }
+}