using System;
using System.Collections.Generic;
using System.Runtime.Serialization;
using MySqlConnector;
using de.hottis.genericdatabaseapiservice.Models;

namespace de.hottis.genericdatabaseapiservice.Services {
    public interface IDbService {
        void JustDoSomething<T>(string msg);
        
    } 

    public class DbService : IDbService {
        async public void JustDoSomething<T>(string msg) {
            Console.WriteLine(msg);

            var item = Activator.CreateInstance<T>();

            using (var conn = new MySqlConnection("Server=172.16.10.18;User ID=apiservicetestdb;Password=geheim123;Database=apiservicetestdb")) {
                await conn.OpenAsync();

                using (var cmd = conn.CreateCommand()) {
                    // cmd.CommandText = "INSERT INTO test1 (txt, nr) VALUES (@txt, @nr)";
                    // cmd.Parameters.AddWithValue("txt", "txt1");
                    // cmd.Parameters.AddWithValue("nr", 12);
                    // await cmd.ExecuteNonQueryAsync();                  
                    cmd.CommandText = "SELECT id, txt, nr FROM test1";
                    using (var reader = await cmd.ExecuteReaderAsync()) {
                        while (await reader.ReadAsync()) {
                            foreach (var propertyInfo in typeof(T).GetProperties()) {
                                Console.WriteLine("Property name: {0}", propertyInfo);
                                var attributes = propertyInfo.GetCustomAttributes(typeof(DataMemberAttribute), true);
                                var dma = (DataMemberAttribute)attributes[0]; 
                                Console.WriteLine("DataMember name: {0} {1} ", dma.Name, dma.TypeId);
                            } 
                            Console.WriteLine(reader.GetString("txt"));
                        } 
                    } 
                } 
            } 
        } 
    } 
}