/****************************************************************************** // Canary Islands Computer Museum Website // ---------------------------------------------------------------------------- // // Filename : News.cs // Author(s) : Natalia Portillo // // --[ Description ] ---------------------------------------------------------- // // Contains operations to manage site news. // // --[ License ] -------------------------------------------------------------- // // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU General Public License as // published by the Free Software Foundation, either version 3 of the // License, or (at your option) any later version. // // This program is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU General Public License for more details. // // You should have received a copy of the GNU General Public License // along with this program. If not, see . // // ---------------------------------------------------------------------------- // Copyright © 2003-2018 Natalia Portillo *******************************************************************************/ using System; using System.Collections.Generic; using System.Data; using Cicm.Database.Schemas; using Console = System.Console; namespace Cicm.Database { public partial class Operations { /// /// Gets all site news /// /// All site news /// true if is correct, false otherwise public bool GetNews(out List entries) { #if DEBUG Console.WriteLine("Getting all news..."); #endif try { const string SQL = "SELECT * from news"; IDbCommand dbCmd = dbCon.CreateCommand(); IDbDataAdapter dataAdapter = dbCore.GetNewDataAdapter(); dbCmd.CommandText = SQL; DataSet dataSet = new DataSet(); dataAdapter.SelectCommand = dbCmd; dataAdapter.Fill(dataSet); entries = NewsFromDataTable(dataSet.Tables[0]); return true; } catch(Exception ex) { Console.WriteLine("Error getting news."); Console.WriteLine(ex); entries = null; return false; } } /// /// Gets the specified number of site news since the specified start /// /// List of site news /// Start of query /// How many entries to retrieve /// true if is correct, false otherwise public bool GetNews(out List entries, ulong start, ulong count) { #if DEBUG Console.WriteLine("Getting {0} news from {1}...", count, start); #endif try { string sql = $"SELECT * FROM news LIMIT {start}, {count}"; IDbCommand dbCmd = dbCon.CreateCommand(); IDbDataAdapter dataAdapter = dbCore.GetNewDataAdapter(); dbCmd.CommandText = sql; DataSet dataSet = new DataSet(); dataAdapter.SelectCommand = dbCmd; dataAdapter.Fill(dataSet); entries = NewsFromDataTable(dataSet.Tables[0]); return true; } catch(Exception ex) { Console.WriteLine("Error getting news."); Console.WriteLine(ex); entries = null; return false; } } /// /// Gets site news by specified id /// /// Id /// Site news with specified id, null if not found or error public News GetNews(int id) { #if DEBUG Console.WriteLine("Getting news with id {0}...", id); #endif try { string sql = $"SELECT * from news WHERE id = '{id}'"; IDbCommand dbCmd = dbCon.CreateCommand(); IDbDataAdapter dataAdapter = dbCore.GetNewDataAdapter(); dbCmd.CommandText = sql; DataSet dataSet = new DataSet(); dataAdapter.SelectCommand = dbCmd; dataAdapter.Fill(dataSet); List entries = NewsFromDataTable(dataSet.Tables[0]); return entries == null || entries.Count == 0 ? null : entries[0]; } catch(Exception ex) { Console.WriteLine("Error getting news."); Console.WriteLine(ex); return null; } } /// /// Counts the number of site news in the database /// /// Entries in database public long CountNews() { #if DEBUG Console.WriteLine("Counting news..."); #endif IDbCommand dbcmd = dbCon.CreateCommand(); dbcmd.CommandText = "SELECT COUNT(*) FROM news"; object count = dbcmd.ExecuteScalar(); dbcmd.Dispose(); try { return Convert.ToInt64(count); } catch { return 0; } } /// /// Adds a new site news to the database /// /// Entry to add /// ID of added entry /// true if added correctly, false otherwise public bool AddNews(News entry, out long id) { #if DEBUG Console.Write("Adding news `{0}`...", entry.Date); #endif IDbCommand dbcmd = GetCommandNews(entry); IDbTransaction trans = dbCon.BeginTransaction(); dbcmd.Transaction = trans; const string SQL = "INSERT INTO news (date, type, added_id)" + " VALUES (@date, @type, @added_id)"; dbcmd.CommandText = SQL; dbcmd.ExecuteNonQuery(); trans.Commit(); dbcmd.Dispose(); id = dbCore.LastInsertRowId; #if DEBUG Console.WriteLine(" id {0}", id); #endif return true; } /// /// Updated a site news in the database /// /// Updated entry /// true if updated correctly, false otherwise public bool UpdateNews(News entry) { #if DEBUG Console.WriteLine("Updating news `{0}`...", entry.Date); #endif IDbCommand dbcmd = GetCommandNews(entry); IDbTransaction trans = dbCon.BeginTransaction(); dbcmd.Transaction = trans; string sql = "UPDATE news SET date = @date, type = @type, added_id = @added_id " + $"WHERE id = {entry.Id}"; dbcmd.CommandText = sql; dbcmd.ExecuteNonQuery(); trans.Commit(); dbcmd.Dispose(); return true; } /// /// Removes a site news entry from the database /// /// ID of entry to remove /// true if removed correctly, false otherwise public bool RemoveNews(long id) { #if DEBUG Console.WriteLine("Removing news widh id `{0}`...", id); #endif IDbCommand dbcmd = dbCon.CreateCommand(); IDbTransaction trans = dbCon.BeginTransaction(); dbcmd.Transaction = trans; string sql = $"DELETE FROM news WHERE id = '{id}';"; dbcmd.CommandText = sql; dbcmd.ExecuteNonQuery(); trans.Commit(); dbcmd.Dispose(); return true; } IDbCommand GetCommandNews(News entry) { IDbCommand dbcmd = dbCon.CreateCommand(); IDbDataParameter param1 = dbcmd.CreateParameter(); IDbDataParameter param2 = dbcmd.CreateParameter(); IDbDataParameter param3 = dbcmd.CreateParameter(); param1.ParameterName = "@date"; param2.ParameterName = "@type"; param3.ParameterName = "@added_id"; param1.DbType = DbType.String; param2.DbType = DbType.Int32; param3.DbType = DbType.Int32; param1.Value = entry.Date; param2.Value = entry.Type; param3.Value = entry.AffectedId; dbcmd.Parameters.Add(param1); dbcmd.Parameters.Add(param2); dbcmd.Parameters.Add(param3); return dbcmd; } static List NewsFromDataTable(DataTable dataTable) { List entries = new List(); foreach(DataRow dataRow in dataTable.Rows) { News entry = new News { Id = int.Parse(dataRow["id"].ToString()), Date = dataRow["date"].ToString(), Type = (NewsType)int.Parse(dataRow["type"].ToString()), AffectedId = int.Parse(dataRow["added_id"].ToString()) }; entries.Add(entry); } return entries; } } }