icarus/Database/Repositories/AlbumRepository.cs

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

using MySql.Data.MySqlClient;

using Icarus.Models;

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


		#region Properties
		#endregion


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


		#region Methods
		public List<Album> GetAlbumWithoutCount()
		{
			var albums = new List<Album>();

			if (AnyAlbums())
			{
				try
				{
					using (MySqlConnection conn = GetConnection())
					{
						conn.Open();
						var query = "SELECT * FROM Album";
						using (MySqlCommand cmd = new MySqlCommand(query, conn))
						{
							using (var reader = cmd.ExecuteReader())
							{
								albums = ParseData(reader);
							}
						}
					}
				}
				catch (Exception ex)
				{
					var msg = ex.Message;
					_logger.Error(msg, "An error occurred");
				}
			}

			return albums;
		}
		public List<Album> GetAlbums()
		{
			List<Album> albums = new List<Album>();

			try
			{
				using (MySqlConnection conn = GetConnection())
				{
					conn.Open();
					var query = "SELECT alb.*,COUNT(*) AS SongCount FROM Album alb " +
						"LEFT JOIN Song sng ON alb.AlbumId=sng.AlbumId WHERE " +
						"alb.AlbumId=sng.AlbumId GROUP BY alb.AlbumId";
					using (MySqlCommand cmd = new MySqlCommand(query, conn))
					{
						using (var reader = cmd.ExecuteReader())
						{
							albums = ParseData(reader);
						}
					}
				}
			}
			catch (Exception ex)
			{
				var msg = ex.Message;
				_logger.Error(msg, "An error occurred");
			}

			return albums;
		}

		public Album GetAlbum(Album album)
		{

			try
			{
				using (MySqlConnection conn = GetConnection())
				{
					conn.Open();
					var query = "SELECT alb.*, COUNT(*) AS SongCount FROM Album alb " + 
						"LEFT JOIN Song sng ON alb.AlbumId=sng.AlbumId WHERE "+
						"alb.AlbumId=@AlbumId LIMIT 1";
					using (MySqlCommand cmd = new MySqlCommand(query, conn))
					{
						cmd.Parameters.AddWithValue("@AlbumId", album.AlbumId);

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

			return album;
		}
		public Album GetAlbum(Song song)
		{
			var album = new Album();

			try
			{
				using (MySqlConnection conn = GetConnection())
				{
					conn.Open();
					var query = "SELECT alb.*, 0 AS SongCount FROM Album alb " +
						"WHERE alb.Title=@Title LIMIT 1";
					
					using (MySqlCommand cmd = new MySqlCommand(query, conn))
					{
						Console.WriteLine($"Album title {song.AlbumTitle}");
						cmd.Parameters.AddWithValue("@Title", song.AlbumTitle);

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

			return album;
		}
		public Album GetAlbum(Song song, bool retrieveCount)
		{
			var album = new Album();

			try
			{
				using (MySqlConnection conn = GetConnection())
				{
					conn.Open();
					var query = string.Empty;
					if (retrieveCount)
					{
						query = "SELECT alb.*, COUNT(*) AS SongCount FROM Album alb " +
							"LEFT JOIN Song sng ON alb.AlbumId=sng.AlbumId WHERE " +
							"alb.Title=@Title GROUP BY alb.AlbumId LIMIT 1";
					}
					else
					{
						query = "SELECT alb.*, 0 AS SongCount FROM Album alb WHERE " +
							"alb.Title=@Title LIMIT 1";
					}
					
					using (MySqlCommand cmd = new MySqlCommand(query, conn))
					{
						cmd.Parameters.AddWithValue("@Title", song.AlbumTitle);

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

			return album;
		}

		public bool DoesAlbumExist(Album album)
		{
			try
			{
				using (MySqlConnection conn = GetConnection())
				{
					conn.Open();

					var query = "SELECT alb.*, 0 AS SongCount FROM Album alb WHERE alb.AlbumId=@AlbumId";
					using (MySqlCommand cmd = new MySqlCommand(query, conn))
					{
						cmd.Parameters.AddWithValue("@AlbumId", album.AlbumId);
						
						using (var reader = cmd.ExecuteReader())
						{
							album =  ParseSingleData(reader);

							if (album.Title != null)
							{
								_logger.Info($"Album {album.Title} exists");
								return true;
							}
						}
					}
				}
			}
			catch (Exception ex)
			{
				var msg = ex.Message;
				_logger.Error(msg, "An error occurred");
			}
			return false;
		}
		public bool DoesAlbumExist(Song song)
		{
			try
			{
				using (MySqlConnection conn = GetConnection())
				{
					conn.Open();

					var query = "SELECT alb.*, 0 AS SongCount FROM Album alb WHERE alb.Title=@Title";
					using (MySqlCommand cmd = new MySqlCommand(query, conn))
					{
						cmd.Parameters.AddWithValue("@Title", song.AlbumTitle);
						
						using (var reader = cmd.ExecuteReader())
						{
							var album =  ParseSingleData(reader);

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

		public void SaveAlbum(Album album)
		{
			try
			{
				using (MySqlConnection conn = GetConnection())
				{
					conn.Open();
					var query = "INSERT INTO Album(Title, AlbumArtist)" +
						" VALUES (@Title, @AlbumArtist)";
					using (MySqlCommand cmd = new MySqlCommand(query, conn))
					{
						cmd.Parameters.AddWithValue("@Title", album.Title);
						cmd.Parameters.AddWithValue("@AlbumArtist", album.AlbumArtist);

						cmd.ExecuteNonQuery();
					}
				}
			}
			catch (Exception ex)
			{
				var msg = ex.Message;
				_logger.Error(msg, "An error occurred");
			}
		}
		public void UpdateAlbum(Album album)
		{
			try
			{
				using (MySqlConnection conn = GetConnection())
				{
					conn.Open();
					var query = "UPDATE Album SET Title=@Title, AlbumArtist=" +
						"@AlbumArtist WHERE AlbumId=@AlbumId";

					using (MySqlCommand cmd = new MySqlCommand(query, conn))
					{
						cmd.Parameters.AddWithValue("@Title", album.Title);
						cmd.Parameters.AddWithValue("@AlbumArtist", album.AlbumArtist);
						cmd.Parameters.AddWithValue("@AlbumId", album.AlbumId);

						cmd.ExecuteNonQuery();
					}
				}
			}
			catch (Exception ex)
			{
				var msg = ex.Message;
				_logger.Error(msg, "An error occurred");
			}
		}
		public void DeleteAlbum(Album album)
		{
			try
			{
				using (var conn = GetConnection())
				{
					conn.Open();
					var query = "DELETE FROM Album WHERE AlbumId=@AlbumId";

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

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

		private List<Album> ParseData(MySqlDataReader reader)
		{
			List<Album> albums = new List<Album>();
			_logger.Info("Retrieving album records");

			while (reader.Read())
			{
				var id = Convert.ToInt32(reader["AlbumId"]);
				var title = reader["Title"].ToString();
				var albumArtist = reader["AlbumArtist"].ToString();
				var songCount = Convert.ToInt32(reader["SongCount"]);
				albums.Add(new Album
				{
					AlbumId = id,
					Title = title,
					AlbumArtist = albumArtist,
					SongCount = songCount
				});
			}

			_logger.Info("Album records retrieved");

			return albums;
		}
		private Album ParseSingleData(MySqlDataReader reader)
		{
			Album album = new Album();
			_logger.Info("Retrieving single album record");

			while (reader.Read())
			{
				var id = Convert.ToInt32(reader["AlbumId"]);
				var title = reader["Title"].ToString();
				var albumArtist = reader["AlbumArtist"].ToString();
				var songCount = Convert.ToInt32(reader["SongCount"]);
				album = new Album
				{
					AlbumId = id,
					Title = title,
					AlbumArtist = albumArtist,
					SongCount = songCount
				};
			}
			_logger.Info("Single ablum retreived");

			return album;
		}

		private bool AnyAlbums()
		{
			var albums = new List<Album>();

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

				var query = "SELECT * FROM Album";

				using (var cmd = new MySqlCommand(query, conn))
				{
					using (var reader = cmd.ExecuteReader())
					{
						albums = ParseData(reader);
					}
				}
			}

			if (albums.Count > 0)
			{
				return true;
			}

			return false;
		}
		#endregion
	}
}