icarus/Database/Repositories/ArtistRepository.cs

using System;
using System.Collections.Generic;
using System.Globalization;

using Microsoft.Extensions.Logging;
using MySql.Data.MySqlClient;
//using NLog;

using Icarus.Models;

namespace Icarus.Database.Repositories
{
    public class ArtistRepository : BaseRepository
    {
        #region Fields
        #endregion


        #region Properties
        #endregion


        #region Constructors
        public ArtistRepository(string connectionString)
        {
            _connectionString = connectionString;
        }
        #endregion


        #region Methods
        public List<Artist> GetArtists()
        {
            List<Artist> artists = new List<Artist>();
            try
            {
                using (MySqlConnection conn = GetConnection())
                {
                    conn.Open();
                    var query = "SELECT art.*, COUNT(*) AS SongCount FROM Artist " + 
                        "art LEFT JOIN Song sng ON art.ArtistId=sng.ArtistId " +
                        "GROUP BY art.ArtistId";

                    using (MySqlCommand cmd = new MySqlCommand(query, conn))
                        using (var reader = cmd.ExecuteReader())
                            artists = ParseData(reader);
                }
            }
            catch (Exception ex)
            {
                var msg = ex.Message;
                _logger.Error(msg, "An error occurred");
            }

            return artists;
        }

        public Artist GetArtist(Artist artist)
        {
            try
            {
                _logger.Info("Retrieving artist record from the database");
                using (MySqlConnection conn = GetConnection())
                {
                    conn.Open();

                    var query = "SELECT art.*, COUNT(*) AS SongCount FROM Artist " +
                        "art LEFT JOIN Song sng ON art.ArtistId=sng.ArtistId " +
                        "WHERE art.ArtistId=@ArtistId";

                    using (MySqlCommand cmd = new MySqlCommand(query, conn))
                    {
                        cmd.Parameters.AddWithValue("@ArtistId", artist.ArtistId);

                        using (var reader = cmd.ExecuteReader())
                            artist = ParseSingleData(reader);
                    }
                }
            }
            catch (Exception ex)
            {
                var msg = ex.Message;
                _logger.Error(msg, "An error occurred");
            }

            return artist;
        }
        public Artist GetArtist(Song song)
        {
            Artist artist = new Artist();
            try
            {
                _logger.Info("Retrieving artist record from the database");
                using (MySqlConnection conn = GetConnection())
                {
                    conn.Open();

                    var query = "SELECT art.*, 0 AS SongCount FROM Artist " +
                        "art WHERE art.Name=@Name";
                    using (MySqlCommand cmd = new MySqlCommand(query, conn))
                    {
                        cmd.Parameters.AddWithValue("@Name", song.Artist);

                        using (var reader = cmd.ExecuteReader())
                            artist = ParseSingleData(reader);
                    }
                }
            }
            catch (Exception ex)
            {
                var msg = ex.Message;
                _logger.Error(msg, "An error occurred");
            }

            return artist;
        }
        public Artist GetArtist(Song song, bool retrieveCount)
        {
            var artist = new Artist();

            try
            {
                _logger.Info("Retrieving artist record from the database");
                using (MySqlConnection conn = GetConnection())
                {
                    conn.Open();

                    var query = string.Empty;

                    if (retrieveCount)
                        query = "SELECT art.*, COUNT(*) AS SongCount FROM Artist " +
                            "art LEFT JOIN Song sng ON art.ArtistId=sng.ArtistId " +
                            "WHERE art.Name=@Name GROUP BY art.ArtistId LIMIT 1";
                    else
                        query = "SELECT art.*, 0 AS SongCount FROM Artist art " +
                            "WHERE art.Name=@Name LIMIT 1";

                    using (MySqlCommand cmd = new MySqlCommand(query, conn))
                    {
                        cmd.Parameters.AddWithValue("@Name", song.Artist);

                        using (var reader = cmd.ExecuteReader())
                            artist = ParseSingleData(reader);
                    }
                }
            }
            catch (Exception ex)
            {
                var msg = ex.Message;
                _logger.Error(msg, "An error occurred");
            }

            return artist;
        }

        public bool DoesArtistExist(Artist artist)
        {
            try
            {
                _logger.Info("Checking to see if Artist exists");
                using (MySqlConnection conn = GetConnection())
                {
                    conn.Open();

                    var query = "SELECT art.*, 0 AS SongCount FROM Artist art WHERE art.ArtistId=@ArtistId";

                    using (MySqlCommand cmd = new MySqlCommand(query, conn))
                    {
                        cmd.Parameters.AddWithValue("@ArtistId", artist.ArtistId);
                        
                        using (var reader = cmd.ExecuteReader())
                        {
                            artist =  ParseSingleData(reader);

                            if (artist.Name != null)
                            {
                                _logger.Info($"Artist {artist.Name} exists");
                                return true;
                            }
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                var msg = ex.Message;
                _logger.Error(msg, "An error occurred");
            }
            
            _logger.Info("Could not successfully retrieve Artist");

            return false;
        }
        public bool DoesArtistExist(Song song)
        {
            try
            {
                _logger.Info("Checking to see if Artist exists");
                using (MySqlConnection conn = GetConnection())
                {
                    conn.Open();

                    var query = "SELECT art.*, 0 AS SongCount FROM Artist art WHERE art.Name=@Name";
                    using (MySqlCommand cmd = new MySqlCommand(query, conn))
                    {
                        cmd.Parameters.AddWithValue("@Name", song.Artist);
                        
                        using (var reader = cmd.ExecuteReader())
                        {
                            var artist =  ParseSingleData(reader);

                            if (!String.IsNullOrEmpty(artist.Name))
                            {
                                _logger.Info($"Artist {artist.Name} exists");
                                return true;
                            }
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                var msg = ex.Message;
                _logger.Error(msg, "An error occurred");
            }

            _logger.Info("Could not successfully retrieve Artist");

            return false;
        }


        public void SaveArtist(Artist artist)
        {
            try
            {
                _logger.Info("Saving artist record");
                using (MySqlConnection conn = GetConnection())
                {
                    conn.Open();
                    var query = "INSERT INTO Artist(Name) VALUES(@Name)";

                    using (MySqlCommand cmd = new MySqlCommand(query, conn))
                    {
                        cmd.Parameters.AddWithValue("@Name", artist.Name);

                        cmd.ExecuteNonQuery();
                    }
                }

                _logger.Info("Artist record has successfully been saved");
            }
            catch (Exception ex)
            {
                var msg = ex.Message;
                _logger.Error(msg, "An error occurred");
            }
        }
        public void UpdateArtist(Artist artist)
        {
            try
            {
                _logger.Info("Updating artist record");
                using (MySqlConnection conn = GetConnection())
                {
                    conn.Open();
                    var query = "UPDATE Artist SET Name=@Name WHERE ArtistId=@ArtistId";

                    using (MySqlCommand cmd = new MySqlCommand(query, conn))
                    {
                        cmd.Parameters.AddWithValue("@Name", artist.Name);
                        cmd.Parameters.AddWithValue("@ArtistId", artist.ArtistId);

                        cmd.ExecuteNonQuery();
                    }
                }

                _logger.Info("Artist record has successfully been saved");
            }
            catch (Exception ex)
            {
                var msg = ex.Message;
                _logger.Error(msg, "An error occurred");
            }
        }
        public void DeleteArtist(Artist artist)
        {
            try
            {
                _logger.Info("Deleting artist record");

                using (var conn = GetConnection())
                {
                    conn.Open();

                    var query = "DELETE FROM Artist WHERE ArtistId=@ArtistId";

                    using (var cmd = new MySqlCommand(query, conn))
                    {
                        cmd.Parameters.AddWithValue("@ArtistId", artist.ArtistId);

                        cmd.ExecuteNonQuery();
                    }
                }
            }
            catch (Exception ex)
            {
                var msg = ex.Message;
                _logger.Error(msg, "An error occurred");
            }
        }

        private List<Artist> ParseData(MySqlDataReader reader)
        {
            List<Artist> artists = new List<Artist>();

            while (reader.Read())
            {
                var id = Convert.ToInt32(reader["ArtistId"]);
                var name = reader["Name"].ToString();
                var songCount = Convert.ToInt32(reader["SongCount"].ToString());
                artists.Add(new Artist
                {
                    ArtistId = id,
                    Name = name,
                    SongCount = songCount
                });
            }

            _logger.Info("Artist records retrieved");

            return artists;
        }

        private Artist ParseSingleData(MySqlDataReader reader)
        {
            Artist artist = new Artist();

            while (reader.Read())
            {
                var id = Convert.ToInt32(reader["ArtistId"]);
                var name = reader["Name"].ToString();
                var songCount = Convert.ToInt32(reader["SongCount"].ToString());
                artist.ArtistId = id;
                artist.Name = name;
                artist.SongCount = songCount;
            }

            _logger.Info("Single artist record retrieved");

            return artist;
        }
        #endregion
    }
}