using System.Collections.Generic; using System.Data; using System.Data.OleDb; using System.Runtime.InteropServices; using System.Windows.Forms; namespace AdvertsingProfitControl { internal class DatabaseWriter { private readonly OleDbConnection _oleDbConnection = new OleDbConnection(); private readonly FrmLogConsole _logConsole = FrmLogConsole.GetStaticInstance; public DatabaseWriter(string connectionString) { _oleDbConnection.ConnectionString = connectionString; } #region New Code ///

/// Inserts new records into the specified sales table. /// Supports rolling back the database to prevent corruption. ///

/// The data table that contains the data to be inserted. /// A string pointing to the database. /// A DbWriterStatus object that contains a status, rows added and an error message if necessary. public DbTableWriterStatus InsertIntoSalesTable(DataTable salesTable, string connectionString) { var lastRowProcessed = 0; var writerStatus = new DbTableWriterStatus(); var oleDbConnection = new OleDbConnection(connectionString); var oleDbCommand = new OleDbCommand { Connection = oleDbConnection }; OleDbTransaction oleDbTransaction = null; try { oleDbConnection.Open(); oleDbTransaction = oleDbConnection.BeginTransaction(); oleDbCommand.Transaction = oleDbTransaction; for (var i = 0; i < salesTable.Rows.Count; i++) { oleDbCommand.CommandText = "INSERT INTO " + salesTable.TableName + " (Sold, SalePrice, TotalSales, Cost, ProfitReturn, TotalProfitReturn, FK_AdItemID, RowAttribute, FK_AdSpecialGroupName, RowPosition, FK_DateID) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"; //New Sales Table Layout (Based on the Database's Physical Layout) //0: Sold 1:SalePrice 2:TotalSales 3:cost 4:ProfitReturn 5:TotalProfitReturn //6:FK_AdItemID 7:RowAttribute 8:FK_AdSpecialGroupName (ID) 9:RowPosition (not index based) //10:FK_DateID oleDbCommand.Parameters.AddWithValue("Sold", salesTable.Rows[i][0]); oleDbCommand.Parameters.AddWithValue("SalesPrice", salesTable.Rows[i][1]); oleDbCommand.Parameters.AddWithValue("TotalSales", salesTable.Rows[i][2]); oleDbCommand.Parameters.AddWithValue("Cost", salesTable.Rows[i][3]); oleDbCommand.Parameters.AddWithValue("ProfitReturn", salesTable.Rows[i][4]); oleDbCommand.Parameters.AddWithValue("TotalProfitReturn", salesTable.Rows[i][5]); oleDbCommand.Parameters.AddWithValue("adItemID", int.Parse(salesTable.Rows[i][6].ToString())); oleDbCommand.Parameters.AddWithValue("RowAttribute", int.Parse(salesTable.Rows[i][7].ToString())); oleDbCommand.Parameters.AddWithValue("adSpecialID", int.Parse(salesTable.Rows[i][8].ToString())); oleDbCommand.Parameters.AddWithValue("RowPosition", int.Parse(salesTable.Rows[i][9].ToString())); oleDbCommand.Parameters.AddWithValue("dateID", int.Parse(salesTable.Rows[i][10].ToString())); oleDbCommand.ExecuteNonQuery(); oleDbCommand.Parameters.Clear(); //Row index is only used to keep track of what row failed to update. lastRowProcessed = int.Parse(salesTable.Rows[i][9].ToString()) - 1; } oleDbTransaction.Commit(); foreach (DataRow row in salesTable.Rows) { var rowId = RetrieveRowId(salesTable.TableName, int.Parse(row[6].ToString()), int.Parse(row[10].ToString()), int.Parse(row[8].ToString())); if (int.Parse(row[8].ToString()) != 0) { //Account for the ad special row. //Index 8 of the row indicates that this row is an ad special member row //so we must add one to the row position to offset the fact that a row //is "missing" from this DataTable. //Row[9] is its row position, which is not zero index based. writerStatus.AddRowId(int.Parse(row[9].ToString()) + 1, rowId); } else { //The ad special row doesn't exist so no need to offset it. writerStatus.AddRowId(int.Parse(row[9].ToString()), rowId); } } writerStatus.SetStatus(WritingOperationStatus.InsertionSuccessful); } catch (OleDbException ex) { writerStatus.SetStatus(WritingOperationStatus.Failed); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to write to database: " + ex.Message); if (lastRowProcessed <= 0) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to begin parsing data rows, var dump of erroneous row unavailable."); writerStatus.SetErrorMessage("Failed to begin parsing rows."); } else { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed on row " + (lastRowProcessed + 1) + " due to the above error. Dumping contents of row " + (lastRowProcessed + 1) + " from " + salesTable.TableName + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Ad Item ID: \"" + salesTable.Rows[lastRowProcessed][6] + "\" Sold: \"" + salesTable.Rows[lastRowProcessed][0] + "\""); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Sale Price: \"" + salesTable.Rows[lastRowProcessed][1] + "\" Total Sales: \"" + salesTable.Rows[lastRowProcessed][2] + "\""); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Cost: \"" + salesTable.Rows[lastRowProcessed][3] + "\" Profit Return: \"" + salesTable.Rows[lastRowProcessed][4] + "\""); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Total Profit Return: \"" + salesTable.Rows[lastRowProcessed][5] + "\" Ad Special Group: \"" + salesTable.Rows[lastRowProcessed][8] + "\""); writerStatus.SetErrorMessage("Failed to write to the database on row " + (lastRowProcessed + 1) + "."); } oleDbTransaction?.Rollback(); _logConsole.WriteToLog(FrmLogConsole.Level.Critical, "Rollback completed successfully, " + salesTable.TableName+ " table failed on insertion."); } finally { oleDbConnection.Close(); } return writerStatus; } ///

/// Updates existing records in the database for either the Projections /// table or the Actual Sales table. /// Supports database rollback. ///

/// The data table that contains the data to be inserted. /// A string pointing to the database. /// A DbWriterStatus object that contains a status, rows added and an error message if necessary. public DbTableWriterStatus UpdateSalesTable(DataTable salesTable, string connectionString) { var updateStatus = new DbTableWriterStatus(); var lastRowProccessed = 0; var oleDbConnection = new OleDbConnection(connectionString); var oleDbCommand = new OleDbCommand { Connection = oleDbConnection }; OleDbTransaction oleDbTransaction = null; try { oleDbConnection.Open(); oleDbTransaction = oleDbConnection.BeginTransaction(); oleDbCommand.Transaction = oleDbTransaction; for (var i = 0; i < salesTable.Rows.Count; i++) { oleDbCommand.CommandText = "UPDATE " + salesTable.TableName + " SET Sold = ?, SalePrice = ?, TotalSales = ?, Cost = ?, ProfitReturn = ?, TotalProfitReturn = ?, FK_AdItemID = ?, RowAttribute = ?, FK_AdSpecialGroupName = ?, RowPosition = ? WHERE ID = ?"; //Update Sales Table Layout (Based on the Database's Physical Layout) //0:ID 1:Sold 2:SalePrice 3:TotalSales 4:cost 5:ProfitReturn 6:TotalProfitReturn //7:FK_AdItemID 8:RowAttribute 9:FK_AdSpecialGroupName (ID) 10:RowPosition (not index based) //11:FK_DateID oleDbCommand.Parameters.AddWithValue("Sold", salesTable.Rows[i][1]); oleDbCommand.Parameters.AddWithValue("SalesPrice", salesTable.Rows[i][2]); oleDbCommand.Parameters.AddWithValue("TotalSales", int.Parse(salesTable.Rows[i][3].ToString())); oleDbCommand.Parameters.AddWithValue("Cost", int.Parse(salesTable.Rows[i][4].ToString())); oleDbCommand.Parameters.AddWithValue("ProfitReturn", int.Parse(salesTable.Rows[i][5].ToString())); oleDbCommand.Parameters.AddWithValue("TotalProfitReturn", int.Parse(salesTable.Rows[i][6].ToString())); oleDbCommand.Parameters.AddWithValue("FK_AdItemID", int.Parse(salesTable.Rows[i][7].ToString())); oleDbCommand.Parameters.AddWithValue("RowAttribute", int.Parse(salesTable.Rows[i][8].ToString())); oleDbCommand.Parameters.AddWithValue("adSpecialID", int.Parse(salesTable.Rows[i][9].ToString())); oleDbCommand.Parameters.AddWithValue("RowPosition", int.Parse(salesTable.Rows[i][10].ToString())); oleDbCommand.Parameters.AddWithValue("ID", int.Parse(salesTable.Rows[i][0].ToString())); oleDbCommand.ExecuteNonQuery(); oleDbCommand.Parameters.Clear(); //Row index is only used to keep track of what row failed to update. lastRowProccessed = int.Parse(salesTable.Rows[i][10].ToString()) - 1; } oleDbTransaction.Commit(); foreach (DataRow row in salesTable.Rows) { if (int.Parse(row[9].ToString()) != 0) { //Account for the ad special row. //Index 10 of the row indicates that this row is an ad special member row //so we must add one to the row position to offset the fact that a row //is "missing" from this DataTable. //Row[10] is its row position, which is not zero index based. updateStatus.AddRowId(int.Parse(row[10].ToString()) + 1, int.Parse(row[0].ToString())); } else { //The ad special row doesn't exist so no need to offset it. updateStatus.AddRowId(int.Parse(row[10].ToString()), int.Parse(row[0].ToString())); } } updateStatus.SetStatus(WritingOperationStatus.UpdateSuccessful); } catch (OleDbException ex) { updateStatus.SetStatus(WritingOperationStatus.Failed); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to update the database for " + salesTable.TableName + ": " + ex.Message); if (lastRowProccessed <= 0) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to begin parsing data rows, var dump of erroneous row unavailable."); updateStatus.SetErrorMessage("Failed to begin parsing rows."); } else { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed on row " + (lastRowProccessed + 1) + " due to the above error. Dumping contents of row " + (lastRowProccessed + 1) + " from " + salesTable.TableName + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Ad Item ID: \"" + salesTable.Rows[lastRowProccessed][7] + "\" Sold: \"" + salesTable.Rows[lastRowProccessed][1] + "\""); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Sale Price: \"" + salesTable.Rows[lastRowProccessed][2] + "\" Total Sales: \"" + salesTable.Rows[lastRowProccessed][3] + "\""); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Cost: \"" + salesTable.Rows[lastRowProccessed][4] + "\" Profit Return: \"" + salesTable.Rows[lastRowProccessed][5] + "\""); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Total Profit Return: \"" + salesTable.Rows[lastRowProccessed][6] + "\" Ad Special Group: \"" + salesTable.Rows[lastRowProccessed][9] + "\""); updateStatus.SetErrorMessage("Failed to write to the database on row " + (lastRowProccessed + 1) + "."); } oleDbTransaction?.Rollback(); _logConsole.WriteToLog(FrmLogConsole.Level.Critical, "Rollback completed successfully, " + salesTable.TableName + " table failed on update."); } finally { oleDbConnection.Close(); } return updateStatus; } ///

/// Inserts new records into the Inventory table. /// Supports database rollback. ///

/// The data table that contains the data to be inserted. /// A string pointing to the database. /// A DbWriterStatus object that contains a status, rows added and an error message if necessary. public DbTableWriterStatus InsertIntoInventoryTable(DataTable table, string connectionString) { var status = new DbTableWriterStatus(); var lastRowProcessed = 0; var oleDbConnection = new OleDbConnection(connectionString); var oleDbCommand = new OleDbCommand { Connection = oleDbConnection }; OleDbTransaction oleDbTransaction = null; try { oleDbConnection.Open(); oleDbTransaction = oleDbConnection.BeginTransaction(); oleDbCommand.Transaction = oleDbTransaction; for (var i = 0; i < table.Rows.Count; i++) { oleDbCommand.CommandText = "INSERT INTO " + table.TableName + " (BeginningInventory, Received, TotalInventory, EndingInventory, FK_AdItemID, RowAttribute, FK_AdSpecialGroupName, RowPosition, FK_DateID) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)"; //New inventory Table Layout (Based on the Database's Physical Layout) //0:Beginning Inventory 1:Received 2:Total Inventory 3:Ending Inventory //4:AdItemID 5:RowAttribute 6:GroupID 7:RowPosition 8:DateID oleDbCommand.Parameters.AddWithValue("BegnningInventory", table.Rows[i][0]); oleDbCommand.Parameters.AddWithValue("Received", table.Rows[i][1]); oleDbCommand.Parameters.AddWithValue("TotalInventory", table.Rows[i][2]); oleDbCommand.Parameters.AddWithValue("EndingInventory", table.Rows[i][3]); oleDbCommand.Parameters.AddWithValue("AdItemID", int.Parse(table.Rows[i][4].ToString())); oleDbCommand.Parameters.AddWithValue("RowAttribute", int.Parse(table.Rows[i][5].ToString())); oleDbCommand.Parameters.AddWithValue("FK_AdSpecialGroup", int.Parse(table.Rows[i][6].ToString())); oleDbCommand.Parameters.AddWithValue("RowPosition", int.Parse(table.Rows[i][7].ToString())); oleDbCommand.Parameters.AddWithValue("DateID", int.Parse(table.Rows[i][8].ToString())); oleDbCommand.ExecuteNonQuery(); oleDbCommand.Parameters.Clear(); //Row index is only used to keep track of what row failed to update. lastRowProcessed = int.Parse(table.Rows[i][7].ToString()) - 1; } oleDbTransaction.Commit(); foreach (DataRow row in table.Rows) { var rowId = RetrieveRowId(table.TableName, int.Parse(row[4].ToString()), int.Parse(row[8].ToString()), int.Parse(row[6].ToString())); if (int.Parse(row[6].ToString()) != 0) { //Account for the ad special row. //Index 8 of the row indicates that this row is an ad special member row //so we must add one to the row position to offset the fact that a row //is "missing" from this DataTable. //Row[7] is its row position, which is not zero index based. status.AddRowId(int.Parse(row[7].ToString()) + 1, rowId); } else { //The ad special row doesn't exist so no need to offset it. status.AddRowId(int.Parse(row[7].ToString()), rowId); } } status.SetStatus(WritingOperationStatus.InsertionSuccessful); } catch (OleDbException e) { status.SetStatus(WritingOperationStatus.Failed); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to update the database for " + table.TableName + ": " + e.Message); if (lastRowProcessed <= 0) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to begin parsing data rows, var dump of erroneous row unavailable."); status.SetErrorMessage("Failed to begin parsing rows."); } else { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed on row " + (lastRowProcessed + 1) + " due to the above error. Dumping contents of row " + (lastRowProcessed + 1) + " from " + table.TableName + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Ad Item ID: \"" + table.Rows[lastRowProcessed][4] + "\" Beginning Inventory: \"" + table.Rows[lastRowProcessed][0]); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Received: \"" + table.Rows[lastRowProcessed][1] + "\" Total Inventory: \"" + table.Rows[lastRowProcessed][2] + "\" Ending Inventory: \"" + table.Rows[lastRowProcessed][3] + "\""); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Row Attribute: \"" + table.Rows[lastRowProcessed][5] + "\" Ad Special ID: \"" + table.Rows[lastRowProcessed][7] + "\""); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Date ID: \"" + table.Rows[lastRowProcessed][8] + "\""); status.SetErrorMessage("Failed to write to the database on row " + (lastRowProcessed + 1) + "."); } oleDbTransaction?.Rollback(); _logConsole.WriteToLog(FrmLogConsole.Level.Critical, "Rollback completed successfully, " + table.TableName + " table failed on update."); } finally { oleDbConnection.Close(); } return status; } ///

/// Updates the Inventory table using the supplied DataTable /// Supports rolling back the database. ///

/// The table with the changes to be made. /// A string pointing to the database. /// A DbWriterStatus object that contains a status, rows added and an error message if necessary. public DbTableWriterStatus UpdateInventoryTable(DataTable table, string connectionString) { var status = new DbTableWriterStatus(); var lastRowProcessed = 0; var oleDbConnection = new OleDbConnection(connectionString); var oleDbCommand = new OleDbCommand { Connection = oleDbConnection }; OleDbTransaction oleDbTransaction = null; try { oleDbConnection.Open(); oleDbTransaction = oleDbConnection.BeginTransaction(); oleDbCommand.Transaction = oleDbTransaction; for (var i = 0; i < table.Rows.Count; i++) { oleDbCommand.CommandText = "UPDATE " + table.TableName + " SET BeginningInventory = ?, Received =? , TotalInventory = ?, EndingInventory = ?, FK_AdItemID = ?, RowAttribute = ?, FK_AdSpecialGroupName = ?, RowPosition = ? WHERE ID = ?"; //0:ID 1:BeginningInventory 2:Received 3:TotalInventory 4:EndingInventory //5:AdItemID 6:RowAttribute 7:GroupID 8:RowPosition 9:DateID oleDbCommand.Parameters.AddWithValue("BegnningInventory", table.Rows[i][1]); oleDbCommand.Parameters.AddWithValue("Received", table.Rows[i][2]); oleDbCommand.Parameters.AddWithValue("TotalInventory", table.Rows[i][3]); oleDbCommand.Parameters.AddWithValue("EndingInventory", table.Rows[i][4]); oleDbCommand.Parameters.AddWithValue("AdItemID", int.Parse(table.Rows[i][5].ToString())); oleDbCommand.Parameters.AddWithValue("RowAttribute", int.Parse(table.Rows[i][6].ToString())); oleDbCommand.Parameters.AddWithValue("FK_AdSpecialGroup", int.Parse(table.Rows[i][7].ToString())); oleDbCommand.Parameters.AddWithValue("RowPosition", int.Parse(table.Rows[i][8].ToString())); oleDbCommand.Parameters.AddWithValue("ID", int.Parse(table.Rows[i][0].ToString())); oleDbCommand.ExecuteNonQuery(); oleDbCommand.Parameters.Clear(); //Row index is only used to keep track of what row failed to update. lastRowProcessed = int.Parse(table.Rows[i][8].ToString()) - 1; } oleDbTransaction.Commit(); foreach (DataRow row in table.Rows) { var rowId = RetrieveRowId(table.TableName, int.Parse(row[4].ToString()), int.Parse(row[8].ToString()), int.Parse(row[7].ToString())); if (int.Parse(row[7].ToString()) != 0) { //Account for the ad special row. //Index 8 of the row indicates that this row is an ad special member row //so we must add one to the row position to offset the fact that a row //is "missing" from this DataTable. //Row[8] is its row position, which is not zero index based. status.AddRowId(int.Parse(row[8].ToString()) + 1, rowId); } else { //The ad special row doesn't exist so no need to offset it. status.AddRowId(int.Parse(row[8].ToString()), rowId); } } status.SetStatus(WritingOperationStatus.InsertionSuccessful); } catch (OleDbException e) { status.SetStatus(WritingOperationStatus.Failed); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to update the database for " + table.TableName + ": " + e.Message); if (lastRowProcessed <= 0) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to begin parsing data rows, var dump of erroneous row unavailable."); status.SetErrorMessage("Failed to begin parsing rows."); } else { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed on row " + (lastRowProcessed + 1) + " due to the above error. Dumping contents of row " + (lastRowProcessed + 1) + " from " + table.TableName + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Ad Item ID: \"" + table.Rows[lastRowProcessed][4] + "\" Beginning Inventory: \"" + table.Rows[lastRowProcessed][0]); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Received: \"" + table.Rows[lastRowProcessed][1] + "\" Total Inventory: \"" + table.Rows[lastRowProcessed][2] + "\" Ending Inventory: \"" + table.Rows[lastRowProcessed][3] + "\""); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Row Attribute: \"" + table.Rows[lastRowProcessed][5] + "\" Ad Special ID: \"" + table.Rows[lastRowProcessed][7] + "\""); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Date ID: \"" + table.Rows[lastRowProcessed][8] + "\""); status.SetErrorMessage("Failed to write to the database on row " + (lastRowProcessed + 1) + "."); } oleDbTransaction?.Rollback(); _logConsole.WriteToLog(FrmLogConsole.Level.Critical, "Rollback completed successfully, " + table.TableName + " table failed on update."); } finally { oleDbConnection.Close(); } return status; } public DbTableWriterStatus ProccessInvoiceTable(DataGridView table, int dateId, string connectionString) { var status = new DbTableWriterStatus(); var lastRowProcessed = 0; var rowsAdded = new List(); var oleDbConnection = new OleDbConnection(connectionString); var oleDbCommand = new OleDbCommand { Connection = oleDbConnection }; OleDbTransaction oleDbTransaction = null; try { var dirtyRowsProcessed = 0; oleDbConnection.Open(); oleDbTransaction = oleDbConnection.BeginTransaction(); oleDbCommand.Transaction = oleDbTransaction; for (var i = 0; i < table.Rows.Count - 1; i++) { //Check to see if the row requires processing to start with. if(!(bool) table.Rows[i].Cells[(int)InvoiceTableColumns.IsDirty].Value) { lastRowProcessed = i + 1; continue; } dirtyRowsProcessed++; //Grab the supplier ID number before moving forward. var supplierId = RetrieveSupplierId( table.Rows[i].Cells[(int) InvoiceTableColumns.Supplier].EditedFormattedValue.ToString()); if (supplierId == 0) { status.SetErrorMessage("Failed to obtain supplier ID number for " + table.Rows[i].Cells[(int)InvoiceTableColumns.Supplier].EditedFormattedValue + "."); status.SetStatus(WritingOperationStatus.Failed); oleDbTransaction.Rollback(); return status; } //Check whether or not the row is already in the database by seeing if anything is in the ID number cell. if (table.Rows[i].Cells[(int) InvoiceTableColumns.Id].EditedFormattedValue.ToString() == "") { //If the invoice doesn't exist in the database add it. oleDbCommand.CommandText = "INSERT INTO Invoice (InvoiceDate, InvoiceNumber, InvoiceNetAmountAtCost, InvoiceNetAmount, InvoiceNote, FK_Supplier, FK_DateID) VALUES(?,?,?,?,?,?,?)"; oleDbCommand.Parameters.AddWithValue("InvoiceDate", table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceDate].EditedFormattedValue.ToString()); oleDbCommand.Parameters.AddWithValue("InvoiceNumber", long.Parse(table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNumber].EditedFormattedValue.ToString())); oleDbCommand.Parameters.AddWithValue("InvoiceNetAmountAtCost", table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNetAmountAtCost].EditedFormattedValue.ToString() == "" ? 0 : double.Parse(table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNetAmountAtCost].EditedFormattedValue.ToString())); oleDbCommand.Parameters.AddWithValue("InvoiceNetAmount", table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNetAmount].EditedFormattedValue.ToString() == "" ? 0 : double.Parse(table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNetAmount].EditedFormattedValue.ToString())); oleDbCommand.Parameters.AddWithValue("InvoiceNote", table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNote].EditedFormattedValue.ToString()); oleDbCommand.Parameters.AddWithValue("FK_Supplier", supplierId); oleDbCommand.Parameters.AddWithValue("FK_DateID", dateId); oleDbCommand.ExecuteNonQuery(); oleDbCommand.Parameters.Clear(); rowsAdded.Add(i); } else { //If the invoice already exists in the database then simply update the record. oleDbCommand.CommandText = "UPDATE Invoice SET InvoiceDate = ?, InvoiceNumber = ?, InvoiceNetAmountAtCost = ?, InvoiceNetAmount = ?, InvoiceNote = ?, FK_Supplier = ?, FK_DateID = ? WHERE ID = ?"; oleDbCommand.Parameters.AddWithValue("InvoiceDate", table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceDate].EditedFormattedValue.ToString()); oleDbCommand.Parameters.AddWithValue("InvoiceNumber", long.Parse(table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNumber].EditedFormattedValue.ToString())); oleDbCommand.Parameters.AddWithValue("InvoiceNetAmountAtCost", table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNetAmountAtCost].EditedFormattedValue.ToString() == "" ? 0 : double.Parse(table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNetAmountAtCost].EditedFormattedValue.ToString())); oleDbCommand.Parameters.AddWithValue("InvoiceNetAmount", table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNetAmount].EditedFormattedValue.ToString() == "" ? 0 : double.Parse(table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNetAmount].EditedFormattedValue.ToString())); oleDbCommand.Parameters.AddWithValue("InvoiceNote", table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNote].EditedFormattedValue.ToString()); oleDbCommand.Parameters.AddWithValue("FK_Supplier", supplierId); oleDbCommand.Parameters.AddWithValue("FK_DateID", dateId); oleDbCommand.Parameters.AddWithValue("ID", int.Parse(table.Rows[i].Cells[(int)InvoiceTableColumns.Id].EditedFormattedValue.ToString())); oleDbCommand.ExecuteNonQuery(); oleDbCommand.Parameters.Clear(); } //Row index is only used to keep track of what row failed to update. lastRowProcessed = i + 1; } oleDbTransaction.Commit(); foreach (DataGridViewRow row in table.Rows) { if(row.IsNewRow) continue; if (!rowsAdded.Contains(row.Index)) continue; var supplierId = RetrieveSupplierId(row.Cells[(int)InvoiceTableColumns.Supplier].EditedFormattedValue.ToString()); var invoiceIdNumber = RetrieveInvoiceId( row.Cells[(int)InvoiceTableColumns.InvoiceDate].EditedFormattedValue .ToString(), long.Parse( row.Cells[(int)InvoiceTableColumns.InvoiceNumber].EditedFormattedValue .ToString()), supplierId, dateId); row.Cells[(int)InvoiceTableColumns.Id].Value = invoiceIdNumber; row.Cells[(int)InvoiceTableColumns.IsDirty].Value = false; row.HeaderCell.Style.BackColor = ApplicationColors.EditingSaved; } table.RefreshEdit(); //Set the status. status.SetStatus(WritingOperationStatus.InsertionSuccessful); //Set the message to be used on the calling form since we don't have access to the form's information label. if (dirtyRowsProcessed == 0) { status.SetErrorMessage("No changes to the Invoices table detected."); } else { status.SetErrorMessage("Invoices processed successfully."); } } catch (OleDbException e) { status.SetStatus(WritingOperationStatus.Failed); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to process the Invoice table: " + e.Message); if (lastRowProcessed <= 0) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to begin parsing data rows, var dump of erroneous row unavailable."); status.SetErrorMessage("Failed to begin parsing rows."); } else { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed on row " + (lastRowProcessed + 1) + " due to the above error. Dumping contents of row " + (lastRowProcessed + 1) + " from Invoices."); status.SetErrorMessage("Failed to write to the database on row " + (lastRowProcessed + 1) + "."); } oleDbTransaction?.Rollback(); _logConsole.WriteToLog(FrmLogConsole.Level.Critical, "Rollback completed successfully, Invoice table failed on update."); } finally { oleDbConnection.Close(); } return status; } public DbWriterStatus ProcessComments(string comments, int dateId, string connectionString, int id = 0) { var status = new DbWriterStatus(); var oleDbConnection = new OleDbConnection(connectionString); var oleDbCommand = new OleDbCommand { Connection = oleDbConnection }; try { oleDbConnection.Open(); if (id == 0) { oleDbCommand.CommandText = "INSERT INTO Comment (Comment, FK_DateID) VALUES (?, ?)"; oleDbCommand.Parameters.AddWithValue("Comment", comments); oleDbCommand.Parameters.AddWithValue("DateID", dateId); oleDbCommand.ExecuteNonQuery(); //Now grab the ID number of the comment that was just added. oleDbCommand.CommandText = "SELECT ID FROM Comment WHERE FK_DateID = ?"; oleDbCommand.Parameters.Clear(); oleDbCommand.Parameters.AddWithValue("DateID", dateId); //Now read the ID number and add it to the collection with a default key. var reader = oleDbCommand.ExecuteReader(); while (reader != null && reader.Read()) { status.Id = int.Parse(reader[0].ToString()); } status.Status = status.Id > 0 ? WritingOperationStatus.InsertionSuccessful : WritingOperationStatus.Failed; } else { oleDbCommand.CommandText = "UPDATE Comment SET Comment = ? WHERE ID = ?"; oleDbCommand.Parameters.AddWithValue("Comment", comments); oleDbCommand.Parameters.AddWithValue("ID", id); var rowsEffected = oleDbCommand.ExecuteNonQuery(); status.Status = rowsEffected == 1 ? WritingOperationStatus.UpdateSuccessful : WritingOperationStatus.Failed; } } catch (OleDbException e) { status.Status = WritingOperationStatus.Failed; _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to process the comment(s): " + e.Message); status.ErrorMessage = "Failed to update or insert comments into the database."; } finally { oleDbConnection.Close(); } return status; } public DbWriterStatus ProcessWeeklySales(double[] weeklySales, int dateId, string connectionString, int id = 0) { var status = new DbWriterStatus(); var oleDbConnection = new OleDbConnection(connectionString); var oleDbCommand = new OleDbCommand { Connection = oleDbConnection }; try { oleDbConnection.Open(); if (id == 0) { oleDbCommand.CommandText = "INSERT INTO WeeklySales (Sunday, Monday, Tuesday, Wednesday, Thursday, Friday, Saturday, TotalSales, FK_DateID) VALUES (?,?,?,?,?,?,?,?,?)"; oleDbCommand.Parameters.AddWithValue("Sunday", weeklySales[0]); oleDbCommand.Parameters.AddWithValue("Monday", weeklySales[1]); oleDbCommand.Parameters.AddWithValue("Tuesday", weeklySales[2]); oleDbCommand.Parameters.AddWithValue("Wednesday", weeklySales[3]); oleDbCommand.Parameters.AddWithValue("Thursday", weeklySales[4]); oleDbCommand.Parameters.AddWithValue("Friday", weeklySales[5]); oleDbCommand.Parameters.AddWithValue("Saturday", weeklySales[6]); oleDbCommand.Parameters.AddWithValue("TotalSales", weeklySales[7]); oleDbCommand.Parameters.AddWithValue("DateID", dateId); oleDbCommand.ExecuteNonQuery(); //Now grab the ID number of the comment that was just added. oleDbCommand.CommandText = "SELECT ID FROM WeeklySales WHERE FK_DateID = ?"; oleDbCommand.Parameters.Clear(); oleDbCommand.Parameters.AddWithValue("DateID", dateId); //Now read the ID number and add it to the collection with a default key. var reader = oleDbCommand.ExecuteReader(); while (reader != null && reader.Read()) { status.Id = int.Parse(reader[0].ToString()); } status.Status = status.Id > 0 ? WritingOperationStatus.InsertionSuccessful : WritingOperationStatus.Failed; } else { oleDbCommand.CommandText = "UPDATE WeeklySales SET Sunday = ?, Monday = ?, Tuesday = ?, Wednesday = ?, Thursday = ?, Friday = ?, Saturday = ?, TotalSales = ? WHERE ID = ?"; oleDbCommand.Parameters.AddWithValue("Sunday", weeklySales[0]); oleDbCommand.Parameters.AddWithValue("Monday", weeklySales[1]); oleDbCommand.Parameters.AddWithValue("Tuesday", weeklySales[2]); oleDbCommand.Parameters.AddWithValue("Wednesday", weeklySales[3]); oleDbCommand.Parameters.AddWithValue("Thursday", weeklySales[4]); oleDbCommand.Parameters.AddWithValue("Friday", weeklySales[5]); oleDbCommand.Parameters.AddWithValue("Saturday", weeklySales[6]); oleDbCommand.Parameters.AddWithValue("TotalSales", weeklySales[7]); oleDbCommand.Parameters.AddWithValue("ID", id); var rowsEffected = oleDbCommand.ExecuteNonQuery(); status.Status = rowsEffected == 1 ? WritingOperationStatus.UpdateSuccessful : WritingOperationStatus.Failed; } } catch (OleDbException e) { status.Status = WritingOperationStatus.Failed; _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to process the weekly sales: " + e.Message); status.ErrorMessage = "Failed to update or insert weekly sales into the database."; } finally { oleDbConnection.Close(); } return status; } public DbWriterStatus ProcessTaxable(double[] taxable, int dateId, string connectionString, int id = 0) { var status = new DbWriterStatus(); var oleDbConnection = new OleDbConnection(connectionString); var oleDbCommand = new OleDbCommand { Connection = oleDbConnection }; try { oleDbConnection.Open(); if (id == 0) { oleDbCommand.CommandText = "INSERT INTO Taxable (Sunday, Monday, Tuesday, Wednesday, Thursday, Friday, Saturday, Total, FK_DateID) VALUES (?,?,?,?,?,?,?,?,?)"; oleDbCommand.Parameters.AddWithValue("Sunday", taxable[0]); oleDbCommand.Parameters.AddWithValue("Monday", taxable[1]); oleDbCommand.Parameters.AddWithValue("Tuesday", taxable[2]); oleDbCommand.Parameters.AddWithValue("Wednesday", taxable[3]); oleDbCommand.Parameters.AddWithValue("Thursday", taxable[4]); oleDbCommand.Parameters.AddWithValue("Friday", taxable[5]); oleDbCommand.Parameters.AddWithValue("Saturday", taxable[6]); oleDbCommand.Parameters.AddWithValue("TotalSales", taxable[7]); oleDbCommand.Parameters.AddWithValue("DateID", dateId); oleDbCommand.ExecuteNonQuery(); //Now grab the ID number of the comment that was just added. oleDbCommand.CommandText = "SELECT ID FROM Taxable WHERE FK_DateID = ?"; oleDbCommand.Parameters.Clear(); oleDbCommand.Parameters.AddWithValue("DateID", dateId); //Now read the ID number and add it to the collection with a default key. var reader = oleDbCommand.ExecuteReader(); while (reader != null && reader.Read()) { status.Id = int.Parse(reader[0].ToString()); } status.Status = status.Id > 0 ? WritingOperationStatus.InsertionSuccessful : WritingOperationStatus.Failed; } else { oleDbCommand.CommandText = "UPDATE Taxable SET Sunday = ?, Monday = ?, Tuesday = ?, Wednesday = ?, Thursday = ?, Friday = ?, Saturday = ?, Total = ? WHERE ID = ?"; oleDbCommand.Parameters.AddWithValue("Sunday", taxable[0]); oleDbCommand.Parameters.AddWithValue("Monday", taxable[1]); oleDbCommand.Parameters.AddWithValue("Tuesday", taxable[2]); oleDbCommand.Parameters.AddWithValue("Wednesday", taxable[3]); oleDbCommand.Parameters.AddWithValue("Thursday", taxable[4]); oleDbCommand.Parameters.AddWithValue("Friday", taxable[5]); oleDbCommand.Parameters.AddWithValue("Saturday", taxable[6]); oleDbCommand.Parameters.AddWithValue("TotalSales", taxable[7]); oleDbCommand.Parameters.AddWithValue("ID", id); var rowsEffected = oleDbCommand.ExecuteNonQuery(); status.Status = rowsEffected == 1 ? WritingOperationStatus.UpdateSuccessful : WritingOperationStatus.Failed; } } catch (OleDbException e) { status.Status = WritingOperationStatus.Failed; _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to process the taxable: " + e.Message); status.ErrorMessage = "Failed to update or insert taxable into the database."; } finally { oleDbConnection.Close(); } return status; } public DbWriterStatus ProcessCostAnalysis(double[] costAnalysis, int dateId, string connectionString, int id = 0) { var status = new DbWriterStatus(); var oleDbConnection = new OleDbConnection(connectionString); var oleDbCommand = new OleDbCommand { Connection = oleDbConnection }; try { oleDbConnection.Open(); if (id == 0) { oleDbCommand.CommandText = "INSERT INTO CostOfSalesAnalysis (SalesPerManHour, SalaryPercentage, SalaryDollars, Supplies, FK_dateID) VALUES (?,?,?,?,?)"; oleDbCommand.Parameters.AddWithValue("SalesPerManHour", costAnalysis[0]); oleDbCommand.Parameters.AddWithValue("SalaryPercentage", costAnalysis[1]); oleDbCommand.Parameters.AddWithValue("SalaryDollars", costAnalysis[2]); oleDbCommand.Parameters.AddWithValue("Supplies", costAnalysis[3]); oleDbCommand.Parameters.AddWithValue("DateID", dateId); oleDbCommand.ExecuteNonQuery(); //Now grab the ID number of the comment that was just added. oleDbCommand.CommandText = "SELECT ID FROM CostOfSalesAnalysis WHERE FK_DateID = ?"; oleDbCommand.Parameters.Clear(); oleDbCommand.Parameters.AddWithValue("DateID", dateId); //Now read the ID number and add it to the collection with a default key. var reader = oleDbCommand.ExecuteReader(); while (reader != null && reader.Read()) { status.Id = int.Parse(reader[0].ToString()); } status.Status = status.Id > 0 ? WritingOperationStatus.InsertionSuccessful : WritingOperationStatus.Failed; } else { oleDbCommand.CommandText = "UPDATE CostOfSalesAnalysis SET SalesPerManHour = ?, SalaryPercentage = ?, SalaryDollars = ?, Supplies = ? WHERE ID = ?"; oleDbCommand.Parameters.AddWithValue("SalesPerManHour", costAnalysis[0]); oleDbCommand.Parameters.AddWithValue("SalaryPercentage", costAnalysis[1]); oleDbCommand.Parameters.AddWithValue("SalaryDollars", costAnalysis[2]); oleDbCommand.Parameters.AddWithValue("Supplies", costAnalysis[3]); oleDbCommand.Parameters.AddWithValue("ID", id); var rowsEffected = oleDbCommand.ExecuteNonQuery(); status.Status = rowsEffected == 1 ? WritingOperationStatus.UpdateSuccessful : WritingOperationStatus.Failed; } } catch (OleDbException e) { status.Status = WritingOperationStatus.Failed; _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to process the cost analysis: " + e.Message); status.ErrorMessage = "Failed to update or insert costs analysis."; } finally { oleDbConnection.Close(); } return status; } ///

/// Deletes the contents for the specified table where the date IDs /// match the one sent to this method. ///

/// The name of the table in the database to be trimmed. /// The ID number for the date that is to be dropped. /// The connection info for the database. public void DeleteApcDataEntriesByDate(string tableName, int dateId, string connectionString) { var oleDbConnection = new OleDbConnection(connectionString); var oleDbCommand = new OleDbCommand { Connection = oleDbConnection, CommandText = "DELETE * FROM " + tableName + " WHERE FK_DateID = ?" }; oleDbCommand.Parameters.AddWithValue("DateID", dateId); try { oleDbConnection.Open(); oleDbCommand.ExecuteNonQuery(); } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to delete the entries in " + tableName + " with the date ID of " + dateId + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message); } finally { oleDbConnection.Close(); } } ///

/// Inserts a new ad item into the database and returns the new item's ID number. /// Supports rolling back as to not corrupt the database. ///

/// The ad item's name that is to be added. /// A reference to a command that already has a transaction active. /// The ID number of the ad item that was just added. public int InsertNewAdItem(string adItemName, OleDbCommand oleDbCommand = null) { var adItemId = 0; var needsTransaction = false; if (oleDbCommand == null) { oleDbCommand = new OleDbCommand { Connection = _oleDbConnection }; needsTransaction = true; } oleDbCommand.CommandText = "INSERT INTO AdItem (AdItem) VALUES (?)"; oleDbCommand.Parameters.Clear(); oleDbCommand.Parameters.AddWithValue("AdItem", adItemName); OleDbTransaction oleDbTransaction = null; try { if (needsTransaction) { //If the OleDbCommand object is not supplied, then we'll need to create and assign the transaction object. oleDbCommand.Connection = _oleDbConnection; _oleDbConnection.Open(); oleDbTransaction = _oleDbConnection.BeginTransaction(); oleDbCommand.Transaction = oleDbTransaction; } if (oleDbCommand.ExecuteNonQuery() == 1) { oleDbCommand.CommandText = "SELECT ID FROM AdItem WHERE AdItem.AdItem = ?"; oleDbCommand.Parameters.Clear(); oleDbCommand.Parameters.AddWithValue("AdItem", adItemName); var reader = oleDbCommand.ExecuteReader(); //Get the ID of the new ad item. while (reader != null && reader.Read()) { int.TryParse(reader[0].ToString(), out adItemId); } reader?.Close(); if (adItemId != 0) { //All was successful. oleDbTransaction?.Commit(); } else { // _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Ad item \"" + adItemName + "\" was not found in the database; rolling back changes."); oleDbTransaction?.Rollback(); } } else { //Something failed but wasn't caught. _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to add the ad item \"" + adItemName + "\" into the database."); oleDbTransaction?.Rollback(); } } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to insert ad item " + adItemName + " into the database."); oleDbTransaction?.Rollback(); } finally { if (needsTransaction) { _oleDbConnection.Close(); } } return adItemId; } ///

/// Infrastructure for the DatabaseWriter class, not meant to be used with external code. /// Grabs the ID of the specified row. ///

/// The name of the table to check for the row in. /// The ID of the ad item in the row. /// The ID of the date in the row. /// Ad Special ID of the row. /// The ID of the row, zero(0) if no rows are found. private int RetrieveRowId(string tableName, int adItemId, int dateId, int groupId) { var id = 0; var rowsEffected = 0; var oleDbCommand = new OleDbCommand { CommandText = "SELECT ID FROM " + tableName + " WHERE FK_AdItemID = ? AND FK_DateID = ? AND FK_AdSpecialGroupName = ?", Connection = _oleDbConnection }; oleDbCommand.Parameters.AddWithValue("AdItemID", adItemId); oleDbCommand.Parameters.AddWithValue("DateID", dateId); oleDbCommand.Parameters.AddWithValue("GroupID", groupId); try { _oleDbConnection.Open(); var reader = oleDbCommand.ExecuteReader(); while (reader != null && reader.Read()) { rowsEffected++; int.TryParse(reader[0].ToString(), out id); } reader?.Close(); if (rowsEffected > 1) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Redundancy found row with the ad item ID " + adItemId + " with the date ID " + dateId + " and a group ID of " + groupId + "."); } } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to look up the existence of a row with the ad item ID " + adItemId + " with the date ID " + dateId + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message); } _oleDbConnection.Close(); return id; } ///

/// Attempts to grab the supplier ID from the database. /// If the name is not found it is added to the database /// and the ID of the newly added supplier is returned. ///

/// The name of the supplier from whom the invoice is from. /// private int RetrieveSupplierId(string supplierName) { var id = 0; var rowsEffected = 0; var oleDbCommand = new OleDbCommand { CommandText = "SELECT ID FROM Supplier WHERE SupplierName = ?", Connection = _oleDbConnection }; oleDbCommand.Parameters.AddWithValue("SupplierName", supplierName); try { _oleDbConnection.Open(); var reader = oleDbCommand.ExecuteReader(); while (reader != null && reader.Read()) { rowsEffected++; int.TryParse(reader[0].ToString(), out id); } reader?.Close(); if (rowsEffected == 0) { //Attempt to add the supplier to the database. oleDbCommand.Parameters.Clear(); oleDbCommand.CommandText = "INSERT INTO Supplier (SupplierName) VALUES (?)"; oleDbCommand.Parameters.AddWithValue("SupplierName", supplierName); rowsEffected = oleDbCommand.ExecuteNonQuery(); if (rowsEffected == 1) { _logConsole.WriteToLog(FrmLogConsole.Level.Info, "Added the supplier '" + supplierName + "' to the database."); } //Now try grabbing the ID of the supplier that was just added. oleDbCommand.Parameters.Clear(); oleDbCommand.CommandText = "SELECT ID FROM Supplier WHERE SupplierName = ?"; oleDbCommand.Parameters.AddWithValue("SupplierName", supplierName); reader = oleDbCommand.ExecuteReader(); while (reader != null && reader.Read()) { int.TryParse(reader[0].ToString(), out id); } } if (rowsEffected > 1) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "The supplier " + supplierName + " has multiple entries."); } } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to look up the existence of the supplier " + supplierName + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message); } finally { _oleDbConnection.Close(); } return id; } ///

/// Retrieves the ID number of the invoice with the specified Date, Number and date ID numbers. /// Returns zero if now records are found. ///

/// The date on the invoice. /// The number for the invoice. /// The supplier's ID number. /// The date ID number of the weekending date. /// private int RetrieveInvoiceId(string invoiceDate, long invoiceNumber, int supplierId, int dateId) { var id = 0; var rowsEffected = 0; var oleDbCommand = new OleDbCommand { CommandText = "SELECT ID FROM Invoice WHERE InvoiceDate = ? AND InvoiceNumber = ? AND FK_Supplier = ? AND FK_DateID = ?", Connection = _oleDbConnection }; oleDbCommand.Parameters.AddWithValue("InvoiceDate", invoiceDate); oleDbCommand.Parameters.AddWithValue("InvoiceNumber", invoiceNumber); oleDbCommand.Parameters.AddWithValue("FK_Supplier", supplierId); oleDbCommand.Parameters.AddWithValue("DateID", dateId); try { _oleDbConnection.Open(); var reader = oleDbCommand.ExecuteReader(); while (reader != null && reader.Read()) { rowsEffected++; int.TryParse(reader[0].ToString(), out id); } reader?.Close(); if (rowsEffected > 1) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Redundancy found row with the ad item ID with the date ID " + dateId + "."); } } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to look up the existence of an invoice with the number of " + invoiceNumber + " and a date of " + invoiceDate + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message); } finally { _oleDbConnection.Close(); } return id; } ///

/// Deletes the row with the specified ID number from the provided table. ///

/// The ID number of the row to be deleted. /// The ID number of the row to be deleted. /// The ID number of the row to be deleted. /// True if the operation was successful; false if not. public bool DeleteApcRow(int projectionsRowId, int inventoryRowId, int actualSalesRowId) { var result = false; var tableName = "Projections"; //Starting point. var oleDbCommand = new OleDbCommand { CommandText = "DELETE FROM Projections WHERE ID = ?", Connection = _oleDbConnection }; oleDbCommand.Parameters.AddWithValue("ID", projectionsRowId); OleDbTransaction oleDbTransaction = null; try { _oleDbConnection.Open(); oleDbTransaction = _oleDbConnection.BeginTransaction(); oleDbCommand.Transaction = oleDbTransaction; var rowsEffected = oleDbCommand.ExecuteNonQuery(); if (rowsEffected == 1) { tableName = "Inventory"; oleDbCommand.Parameters.Clear(); oleDbCommand.CommandText = "DELETE FROM Inventory WHERE ID = ?"; oleDbCommand.Parameters.AddWithValue("ID", inventoryRowId); rowsEffected = oleDbCommand.ExecuteNonQuery(); if (rowsEffected == 1) { tableName = "ActualSales"; oleDbCommand.Parameters.Clear(); oleDbCommand.CommandText = "DELETE FROM ActualSales WHERE ID = ?"; oleDbCommand.Parameters.AddWithValue("ID", inventoryRowId); rowsEffected = oleDbCommand.ExecuteNonQuery(); if (rowsEffected == 1) { result = true; } } } if (!result) { oleDbTransaction?.Rollback(); } else { oleDbTransaction.Commit(); } } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to delete row with the ID of " + inventoryRowId + " from " + tableName + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message); oleDbTransaction?.Rollback(); } finally { _oleDbConnection.Close(); } return result; } public bool NormalizeApcTables(int dateId) { var successful = false; var oleDbCommand = new OleDbCommand { CommandText = "SELECT COUNT(*) FROM Projections WHERE FK_DateID = ?", Connection = _oleDbConnection }; oleDbCommand.Parameters.AddWithValue("DateID", dateId); OleDbTransaction oleDbTransaction = null; try { _oleDbConnection.Open(); oleDbTransaction = _oleDbConnection.BeginTransaction(); oleDbCommand.Transaction = oleDbTransaction; var projectionsRowCount = 0; var inventoryRowCount = 0; var actualSalesRowCount = 0; var reader = oleDbCommand.ExecuteReader(); while (reader != null && reader.Read()) { projectionsRowCount = int.Parse(reader[0].ToString()); } oleDbCommand.CommandText = "SELECT COUNT(*) FROM Inventory WHERE FK_DateID = ?"; reader = oleDbCommand.ExecuteReader(); while (reader != null && reader.Read()) { inventoryRowCount = int.Parse(reader[0].ToString()); } oleDbCommand.CommandText = "SELECT COUNT(*) FROM ActualSales WHERE FK_DateID = ?"; reader = oleDbCommand.ExecuteReader(); while (reader != null && reader.Read()) { actualSalesRowCount = int.Parse(reader[0].ToString()); } // if (projectionsRowCount != inventoryRowCount) { } } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message); oleDbTransaction?.Rollback(); } finally { _oleDbConnection.Close(); } return successful; } ///

/// Removes the invoice record with the specified internal ID number. ///

/// The ID of the row to delete. /// Whether or not the removal was a success or not. public bool DeleteInvoiceRow(int rowId) { var result = false; var oleDbCommand = new OleDbCommand { CommandText = "DELETE FROM Invoice WHERE ID = ?", Connection = _oleDbConnection }; oleDbCommand.Parameters.AddWithValue("ID", rowId); OleDbTransaction oleDbTransaction = null; try { _oleDbConnection.Open(); oleDbTransaction = _oleDbConnection.BeginTransaction(); oleDbCommand.Transaction = oleDbTransaction; var rowsEffected = oleDbCommand.ExecuteNonQuery(); if (rowsEffected == 1) { result = true; oleDbTransaction.Commit(); } else { oleDbTransaction?.Rollback(); } } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to delete row with the ID of " + rowId + " from the Invoice table."); _logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message); oleDbTransaction?.Rollback(); } finally { _oleDbConnection.Close(); } return result; } #endregion //10 to 1 ratio of tries to code //http://codebetter.com/karlseguin/2006/04/05/understanding-and-using-exceptions/nfrastructure public bool InsertIntoWeekEnding(string dateString) { //Assume the INSERT operation failed in case anything other error arises. var insertWasSuccessful = false; //Set up the command object, SQL command string and parameters. var oleDbCommand = new OleDbCommand { CommandText = "INSERT INTO WeekEnding(EndOfWeekDate) VALUES ( dateString )" }; oleDbCommand.Parameters.AddWithValue("dateString", dateString); oleDbCommand.Connection = _oleDbConnection; //Try to execute the query try { var numberOfRowsEffected = 0; //Check for the existence of the date string that was provided. oleDbCommand.CommandText = "SELECT ID FROM WeekEnding WHERE EndOfWeekDate = @dateString"; oleDbCommand.Parameters.AddWithValue("@dateString", dateString); oleDbCommand.Connection = _oleDbConnection; _oleDbConnection.Open(); //Execute the SELECT statement and retrieve the row(s) effected. var reader = oleDbCommand.ExecuteReader(); var recordIndex = 0; while (reader != null && reader.Read()) { if (reader[recordIndex].ToString() != "") { numberOfRowsEffected++; } recordIndex++; } reader?.Close(); //IF one row was affected, then return with "True", since the value is already there. if (numberOfRowsEffected == 1) { //Success! Without even lifting a finger, how nice. return true; } //ELSE IF more then one row was effected, then that means we have redundancy... else if (numberOfRowsEffected > 1) { oleDbCommand.CommandText = "DELETE FROM WeekEnding WHERE EndOfWeekDate = @dateString"; oleDbCommand.Parameters.Clear(); oleDbCommand.Parameters.AddWithValue("@dateString", dateString); numberOfRowsEffected = oleDbCommand.ExecuteNonQuery(); if (numberOfRowsEffected > 1) { //Deletion of extra dates has completed successfully so add in the provided date string. oleDbCommand.CommandText = "INSERT INTO WeekEnding(EndOfWeekDate) VALUES(@dateString)"; oleDbCommand.Parameters.Clear(); oleDbCommand.Parameters.AddWithValue("@dateString", dateString); numberOfRowsEffected = oleDbCommand.ExecuteNonQuery(); if (numberOfRowsEffected != 1) { //? _logConsole.WriteToLog(FrmLogConsole.Level.Debug, "An error has occurred attempting to insert the date " + dateString + " into the week ending table."); } } } else if (numberOfRowsEffected == 0) { oleDbCommand.CommandText = "INSERT INTO WeekEnding(EndOfWeekDate) VALUES (?)"; oleDbCommand.Parameters.Clear(); oleDbCommand.Parameters.AddWithValue("dateString", dateString); numberOfRowsEffected = oleDbCommand.ExecuteNonQuery(); if (numberOfRowsEffected == 0) { //? _logConsole.WriteToLog(FrmLogConsole.Level.Debug, "An error has occurred attempting to insert the date " + dateString + " into the week ending table."); } else { insertWasSuccessful = true; } } } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error occurred trying to write a record to the Week Ending table."); _logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message + "\n" + e.StackTrace); } finally { //Make certain that the connection is closed before returning. _oleDbConnection.Close(); } return insertWasSuccessful; } public bool RedundantlessInsertIntoComments(string comments, string dateIdString) { //Again, assume a failed operation so there are no false positives. var insertWasSuccessful = false; var storedComment = ""; //Set up the command object, SQL command string and parameters. var oleDbCommand = new OleDbCommand {Connection = _oleDbConnection}; //Try to execute the query try { int numberOfRowsEffected; //IF one row was affected, then check to see if the comments are the same. //Check to see if the comments already exist. //TODO: Perform a little Reg-ex magic to determine if the comments are just different due to spaces or small word changes. oleDbCommand.CommandText = "SELECT Comment FROM Comment WHERE FK_DateID = dateID"; oleDbCommand.Parameters.Clear(); oleDbCommand.Parameters.AddWithValue("dateID", dateIdString); _oleDbConnection.Open(); //OpenConnection(); var reader = oleDbCommand.ExecuteReader(); var recordIndex = 0; while (reader != null && reader.Read()) { if (recordIndex == 0) { storedComment = reader[0].ToString(); } else { storedComment += reader[0].ToString(); } if (storedComment != "") { recordIndex++; } } reader?.Close(); //IF there is a comment that has the same date then check to see if it is the same as the one entered. if (recordIndex == 1) { if (storedComment == comments) { //The comments match so return true. return true; } else { //ELSE the comments are different, therefore the entry needs to be updated. oleDbCommand.CommandText = "UPDATE Comment SET Comment.Comment = ? WHERE [Comment.FK_DateID] = ?;"; oleDbCommand.Parameters.Clear(); oleDbCommand.Parameters.AddWithValue("comment", storedComment + "\r\n" + comments); oleDbCommand.Parameters.AddWithValue("dateID", dateIdString); numberOfRowsEffected = oleDbCommand.ExecuteNonQuery(); if (numberOfRowsEffected == 1) { //Update was successful, so return true. return true; } else { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error has occurred trying to update a comment with the date ID of " + dateIdString + "."); return false; } } } else if (recordIndex > 1) { //ELSE IF more then one record was found with the same date ID, then clear the redundancy and rewrite to the database. numberOfRowsEffected = 0; oleDbCommand.CommandText = "DELETE FROM Comment WHERE FK_DateID = dateID"; oleDbCommand.Parameters.Clear(); oleDbCommand.Parameters.AddWithValue("dateID", dateIdString); numberOfRowsEffected = oleDbCommand.ExecuteNonQuery(); if (numberOfRowsEffected > 1) { oleDbCommand.CommandText = "INSERT INTO Comment(Comment, FK_DateID) VALUES(comments, dateID)"; oleDbCommand.Parameters.Clear(); oleDbCommand.Parameters.AddWithValue("comments", storedComment + "\r\n" + comments); oleDbCommand.Parameters.AddWithValue("dateID", dateIdString); numberOfRowsEffected = oleDbCommand.ExecuteNonQuery(); if (numberOfRowsEffected == 1) { return true; } else { _logConsole.WriteToLog(FrmLogConsole.Level.Debug, "An error occurred trying to insert a new comment after attempting to delete redundant entries."); return false; } } else { _logConsole.WriteToLog(FrmLogConsole.Level.Debug, "An error occurred trying to delete redundant comments."); return false; } } //Reset the number effected so there is no confusion. numberOfRowsEffected = 0; //Now execute the INSERT statement since no redundancy was found. //The comments are not found to be used in the database anywhere, nor the date ID so add a brand new row. oleDbCommand.CommandText = "INSERT INTO Comment(Comment, FK_DateID) VALUES (comments, dateID)"; oleDbCommand.Parameters.Clear(); oleDbCommand.Parameters.AddWithValue("comments", comments); oleDbCommand.Parameters.AddWithValue("dateID", dateIdString); numberOfRowsEffected = oleDbCommand.ExecuteNonQuery(); if (numberOfRowsEffected == 1) { insertWasSuccessful = true; } else if (numberOfRowsEffected == 0) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to insert new comments into the Comment table."); insertWasSuccessful = false; } } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error occurred trying to write a record to the Comment table."); _logConsole.WriteToLog(FrmLogConsole.Level.Debug, "Message " + e.Message); } finally { //Make certain that the connection is closed before returning. _oleDbConnection.Close(); } return insertWasSuccessful; } ///

/// Inserts the data table provided into the APC table. /// The rows of the table must match the physical layout of the /// APC table. The last column in the table, just before the foreign keys /// is RowAttribute and row position. Then its Fk_AdItem, FK_GroupID and FK_DateID (always the last foreign key). ///

/// /// A list which contains the row numbers of all added rows. public List RedundantlessInsertIntoApc(DataTable parameters) { //Check to see if the DataTable is empty, and if it is one return -1 as the error. if (parameters == null || parameters.Rows.Count == 0) { //Create new List variable and assign it to 0. var noRowsAdded = new List {0}; return noRowsAdded; } _oleDbConnection.Open(); var rowsAdded = new List(); var rowNumber = 0; //DataTable's structure will reflect the APC database table structure. foreach (DataRow row in parameters.Rows) { var adItemId = ReturnAdItemIdFromAdItemString(row[18].ToString()); var dateId = row[20].ToString(); //The nineteenth (19th) entry is the dateID field. var rowsEffected = 0; if (adItemId == "0") { //IF the ad item could not be found in the database, add it in. adItemId = InsertAdItem(row[17].ToString()); //IF the ID is still zero (0), then something went wrong... if (adItemId == "0") { //Add an error code to the end of the array; something went wrong adding the new item to the database. rowsAdded.Add(0); return rowsAdded; } } if (!DoesEntryExist(adItemId, dateId)) { //IF the ad item isn't in the APC table with the specified date, then add it to the database. var oleDbCommand = new OleDbCommand { CommandText = "INSERT INTO APC(ProjectionSold, ProjectionSalePrice, ProjectionTotalSales, ProjectionCost, ProjectionProfitReturn, ProjectionTotalProfitReturn, BeginingInventory, Received, TotalInventory, EndingInventory, ActualSold, ActualSalePrice, ActualTotalSales, ActualCost, ActualProfitReturn, ActualTotalProfitReturn, RowAttribute, RowPosition, FK_AdItemID, FK_GroupID, FK_DateID) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)" }; oleDbCommand.Parameters.AddWithValue("prSold", row[0]); oleDbCommand.Parameters.AddWithValue("prSalesPrice", row[1]); oleDbCommand.Parameters.AddWithValue("prTotalSales", row[2]); oleDbCommand.Parameters.AddWithValue("prCost", row[3]); oleDbCommand.Parameters.AddWithValue("prProfitReturn", row[4]); oleDbCommand.Parameters.AddWithValue("prTotalProfitReturn", row[5]); oleDbCommand.Parameters.AddWithValue("beginingInv", row[6]); oleDbCommand.Parameters.AddWithValue("receivedInv", row[7]); oleDbCommand.Parameters.AddWithValue("totalInv", row[8]); oleDbCommand.Parameters.AddWithValue("endingInv", row[9]); oleDbCommand.Parameters.AddWithValue("acSold", row[10]); oleDbCommand.Parameters.AddWithValue("acSalesPrice", row[11]); oleDbCommand.Parameters.AddWithValue("acTotalSales", row[12]); oleDbCommand.Parameters.AddWithValue("acCost", row[13]); oleDbCommand.Parameters.AddWithValue("acProfitReturn", row[14]); oleDbCommand.Parameters.AddWithValue("acTotalProfitReturn", row[15]); oleDbCommand.Parameters.AddWithValue("RowAttribute", row[16]); oleDbCommand.Parameters.AddWithValue("RowPosition", row[17]); oleDbCommand.Parameters.AddWithValue("AdItemID", adItemId); oleDbCommand.Parameters.AddWithValue("GroupID", row[19]); oleDbCommand.Parameters.AddWithValue("dateID", row[20]); oleDbCommand.Connection = _oleDbConnection; try { var reader = oleDbCommand.ExecuteReader(); while (reader != null && reader.Read()) { rowsEffected++; } reader?.Close(); if (rowsEffected == 1) { rowsAdded.Add(rowNumber); } } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error occurred trying to write a record to the APC table."); _logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message); _oleDbConnection.Close(); //Add an error code at the end of array of rows that were added to show an error occurred. rowsAdded.Add(-1); return rowsAdded; } } else { //Perform an update operation on the row in question. if (!UpdateRow(adItemId, dateId, row)) { //IF the update fails, then return with an error appended to the end of the array. rowsAdded.Add(0); _logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error occurred trying to update a record APC table."); _logConsole.WriteToLog(FrmLogConsole.Level.Debug, "An error occurred trying to update ad item ID " + adItemId + " and dateID " + dateId + "."); _oleDbConnection.Close(); return rowsAdded; } } rowNumber++; } //Close the database connection before returning. _oleDbConnection.Close(); return rowsAdded; } ///

/// Infrastructure for the DatabaseWriter class, not meant to be used with external code; expects an open connection when called. /// Checks to see if an ad item exists based on its end of week date. ///

/// The ID of the item. /// The ID of the end of week date. /// True if the item exists, or false if it doesn't. private bool DoesEntryExist(string adItemId, string dateId) { var exists = false; var oleDbCommand = new OleDbCommand(); var rowsEffected = 0; oleDbCommand.CommandText = "SELECT ID FROM APC WHERE FK_AdItemID = adItemID AND FK_DateID = dateID"; oleDbCommand.Parameters.AddWithValue("adItemID", adItemId); oleDbCommand.Parameters.AddWithValue("dateID", dateId); oleDbCommand.Connection = _oleDbConnection; try { oleDbCommand.Transaction = _oleDbConnection.BeginTransaction(); var reader = oleDbCommand.ExecuteReader(); while (reader != null && reader.Read()) { rowsEffected++; } reader?.Close(); } catch (OleDbException ex) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error occurred trying to check for the existence of an ad item with the ID of " + adItemId + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Debug, ex.Message); } if (rowsEffected == 1) { exists = true; } else if (rowsEffected > 1) { //Throw custom exception, or add a function to correct this issue. _logConsole.WriteToLog(FrmLogConsole.Level.Critical, "A redundant entry has been found with the following values: AdItemID " + adItemId + " and DateID " + dateId + "."); exists = true; } return exists; } ///

/// Infrastructure for the DatabaseWriter class, not meant to be used with external code; expects an open connection when called. /// This method adds a specified ad item to the database's ad item table. ///

/// The name of the ad item. /// The ID number of the ad item, or zero (0) on fail. private string InsertAdItem(string adItemName) { //Remove all nulls from the adItemName and check if it is null. string cleanedAdItemName = adItemName.Replace(" ", ""); if (adItemName == "") { // //throw new System.ArgumentException("Attempted to insert a null ad item name into the database."); return "0"; } else if (cleanedAdItemName.Length == 1) { // //throw new System.ArgumentException("Attempted to insert an ad item name with invalid length."); return "0"; } //Record the number of rows affected when the statement is executed, again assume nothing was affected. var adItemId = "0"; var oleDbCommand = new OleDbCommand { CommandText = "INSERT INTO AdItem (AdItem) VALUES (?)", Connection = _oleDbConnection }; oleDbCommand.Parameters.AddWithValue("adItem", adItemName); //Attempt to execute the INSERT SQL statement. try { var rowsEffected = oleDbCommand.ExecuteNonQuery(); //IF one (1) row was affected, then get the ad item's ID and set it to the return value. if (rowsEffected == 1) { //Modify the OleDbCommand object to query the ad item with the highest ID value since that would be the most recent item added. oleDbCommand.CommandText = "SELECT ID FROM AdItem WHERE ID = (SELECT MAX(AdItem.ID) FROM AdItem)"; var reader = oleDbCommand.ExecuteReader(); while (reader != null && reader.Read()) { adItemId = reader[0].ToString(); } reader?.Close(); } //ELSE IF more then one (1) row was affected... else if (rowsEffected > 1) { //? } //ELSE IF no rows are effected due to an uncaught exception, log it. else if (rowsEffected == 0) { _logConsole.WriteToLog(FrmLogConsole.Level.Critical, "Failed to add " + adItemName + " into the database; zero (0) rows affected."); return "0"; } } catch (OleDbException ex) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error occurred trying to add " + adItemName + " to the database."); _logConsole.WriteToLog(FrmLogConsole.Level.Debug, ex.Message); } return adItemId; } ///

/// Infrastructure for the DatabaseWriter class, not meant to be used with external code; expects an open connection when called. /// Returns the ad item ID from the ad item's name. ///

/// The ID of the specified item. private string ReturnAdItemIdFromAdItemString(string adItemName) { var id = "0"; double parsedName; //Clear all invalid characters and check if its a null entry. if (adItemName.Replace(" " , "") == "") { return id; } if (double.TryParse(adItemName, out parsedName)) { //A number has been found so error out. _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Ad item name cannot be only numeric characters."); return id; } var oleDbCommand = new OleDbCommand {CommandText = "SELECT ID FROM AdItem WHERE UCASE(AdItem.AdItem) = UCASE(adItemName)"}; oleDbCommand.Parameters.AddWithValue("adItemName", adItemName); oleDbCommand.Connection = _oleDbConnection; try { var adItemId = ""; var reader = oleDbCommand.ExecuteReader(); while (reader != null && reader.Read()) { adItemId = reader[0].ToString(); } if (reader != null) reader.Close(); //Grab the ad item's ID. if (adItemId != "0") { id = adItemId; } else { //Return 0 as the ad item doesn't exist. return id; } } catch (OleDbException ex) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error occurred trying to obtain the ad item ID for " + adItemName + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Debug, ex.Message); } return id; } ///

/// Infrastructure for the DatabaseWriter class, not meant to be used with external code; expects an open connection when called. /// Performs an update operation on the row with matching IDs in the ad item and date ID columns. /// This is to be called when an ad item already exists and simply needs updating with new values. ///

/// /// /// /// private bool UpdateRow(string adItemId, string dateId, DataRow parameters) { var updateSuccessful = false; var oleDbCommand = new OleDbCommand { CommandText = "UPDATE APC SET ProjectionSold = ?, ProjectionSalePrice = ?, ProjectionTotalSales = ?, ProjectionCost = ?, ProjectionProfitReturn = ?, ProjectionTotalProfitReturn = ?, BeginingInventory = ?, Received = ?, TotalInventory = ?, EndingInventory = ?, ActualSold = ?, ActualSalePrice = ?, ActualTotalSales = ?, ActualCost = ?, ActualProfitReturn = ?, ActualTotalProfitReturn = ?, RowAttribute = ?, RowPosition = ?, FK_GroupID = ? WHERE FK_DateID = ? AND FK_AdItemID = ?" }; oleDbCommand.Parameters.AddWithValue("prSold", parameters[0]); oleDbCommand.Parameters.AddWithValue("prSalesPrice", parameters[1]); oleDbCommand.Parameters.AddWithValue("prTotalSales", parameters[2]); oleDbCommand.Parameters.AddWithValue("prCost", parameters[3]); oleDbCommand.Parameters.AddWithValue("prProfitReturn", parameters[4]); oleDbCommand.Parameters.AddWithValue("prTotalProfitReturn", parameters[5]); oleDbCommand.Parameters.AddWithValue("beginingInv", parameters[6]); oleDbCommand.Parameters.AddWithValue("receivedInv", parameters[7]); oleDbCommand.Parameters.AddWithValue("totalInv", parameters[8]); oleDbCommand.Parameters.AddWithValue("endingInv", parameters[9]); oleDbCommand.Parameters.AddWithValue("acSold", parameters[10]); oleDbCommand.Parameters.AddWithValue("acSalesPrice", parameters[11]); oleDbCommand.Parameters.AddWithValue("acTotalSales", parameters[12]); oleDbCommand.Parameters.AddWithValue("acCost", parameters[13]); oleDbCommand.Parameters.AddWithValue("acProfitReturn", parameters[14]); oleDbCommand.Parameters.AddWithValue("acTotalProfitReturn", parameters[15]); oleDbCommand.Parameters.AddWithValue("RowAttribute", parameters[16]); oleDbCommand.Parameters.AddWithValue("RowPosition", parameters[17]); oleDbCommand.Parameters.AddWithValue("groupID", parameters[19]); oleDbCommand.Parameters.AddWithValue("dateID", parameters[20]); oleDbCommand.Parameters.AddWithValue("adItemID", adItemId); oleDbCommand.Connection = _oleDbConnection; try { var numberOfRowsEffected = oleDbCommand.ExecuteNonQuery(); if (numberOfRowsEffected == 1) { updateSuccessful = true; } else if (numberOfRowsEffected > 1) //? { _logConsole.WriteToLog(FrmLogConsole.Level.Warning, "Redundancy found: Ad item ID " + parameters[0] + " (" + parameters[17] + ") and date ID " + parameters[18] + "."); updateSuccessful = true; } _logConsole.WriteToLog(FrmLogConsole.Level.Info, "Affected " + numberOfRowsEffected + " updating the ad item " + parameters[17] + "."); } catch (OleDbException ex) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to update ad item with the ID of " + parameters[0] + " (" + parameters[17] + ") and a date ID of " + parameters[18] + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Debug, ex.Message); return false; } return updateSuccessful; } ///

/// ///

/// A copy of the Supplier DataGridView table. /// public List RedundantlessInsertIntoInvoice(DataTable parameters) { //Create an array that hold the indexes of all the rows that were successfully written to the database. var rowsAdded = new List(); var supplierId = ""; //Setup object for each of the three (3) tasks that need to be performed. //Checking for the ID of a particular supplier, by name. var supplierQueryCommand = new OleDbCommand { CommandText = "SELECT ID FROM Supplier WHERE SupplierName = ?", Connection = _oleDbConnection }; //Grabbing the ID of the invoice by the invoice number and the supplier's ID. var invoiceCheckCommand = new OleDbCommand { CommandText = "SELECT ID FROM Invoice WHERE InvoiceNumber = ? AND FK_Supplier = ?", Connection = _oleDbConnection }; //Inserting a new record into the Invoice table. var insertNewInvoice = new OleDbCommand { CommandText = "INSERT INTO Invoice (InvoiceDate, InvoiceNumber, InvoiceNetAmountAtCost, InvoiceNetAmount, InvoiceNote, FK_Supplier, FK_DateID) VALUES (?, ?, ?, ?, ?, ?, ?)", Connection = _oleDbConnection }; _oleDbConnection.Open(); foreach (DataRow row in parameters.Rows) { var itemCount = 0; var index = 0; foreach (var obj in row.ItemArray) { //Check for null objects, row size is 8 on creation for some reason. if (index < 7) { if ((string)obj != "") { itemCount++; } else { row[index] = 0; } } index++; } if (itemCount < 2) { break; } var recordCount = 0; try { //Check for the existence of the supplier to be written. supplierQueryCommand.Parameters.Clear(); supplierQueryCommand.Parameters.AddWithValue("SupplierName", row[1]); var reader = supplierQueryCommand.ExecuteReader(); //Read in the value(s) from the database. while (reader != null && reader.Read()) { if (recordCount == 0) { supplierId = reader[0].ToString(); } recordCount++; } if(reader != null) reader.Close(); //IF no records were pulled, then ad the supplier's name into the database and pull the ID for the new entry. if (recordCount == 0) { supplierId = InsertSupplier(row[1].ToString()); if (supplierId != "0") { recordCount = 1; } //ELSE IF the supplier ID wasn't set, indicting an error, so break out of the loop and add zero (0) to the end of the rows effected array. else { rowsAdded.Add(0); break; } } //IF the supplier exists in the database, then check for the presence of the supplier and the supplied invoice number. if (recordCount == 1) { invoiceCheckCommand.Parameters.Clear(); invoiceCheckCommand.Parameters.AddWithValue("InvoiceNumber", row[2]); invoiceCheckCommand.Parameters.AddWithValue("SupplierID", supplierId); reader = invoiceCheckCommand.ExecuteReader(); recordCount = 0; while (reader != null && reader.Read()) { recordCount++; } if (reader != null) reader.Close(); //IF the entry does exist, then update it with the new information provided. if (recordCount == 1) { //Call the update function and attempt to update the information. if (!UpdateInvoice(row, supplierId)) { //IF the update failed log the failure, add in a failure at the row that failed, and break out. //LOGGING GOES HERE _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to update the record for " + row[1] + "."); rowsAdded.Add(0); break; } } else if (recordCount > 1) { //TODO: Clean up the database's redundant entries. } else if (recordCount == 0) { //ELSE IF no records were found, then insert the new invoice into the Invoice table. insertNewInvoice.Parameters.Clear(); insertNewInvoice.Parameters.AddWithValue("InvoiceDate", row[0]); insertNewInvoice.Parameters.AddWithValue("InvoiceNumber", row[2]); insertNewInvoice.Parameters.AddWithValue("InvoiceNetAmountAtCost", row[3]); insertNewInvoice.Parameters.AddWithValue("InvoiceNetAmount", row[4]); insertNewInvoice.Parameters.AddWithValue("InvoiceNote", row[5]); insertNewInvoice.Parameters.AddWithValue("SupplierID", supplierId); insertNewInvoice.Parameters.AddWithValue("DateID", row[6]); var rowsEffected = insertNewInvoice.ExecuteNonQuery(); if (rowsEffected == 1) continue; _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to write new invoice to the database for supplier " + row[1] + " ID of " + supplierId + "."); rowsAdded.Add(0); break; } } //ELSE IF more then one record was found, clean up the redundancy. else if (recordCount > 1) { _logConsole.WriteToLog(FrmLogConsole.Level.Info, "Redundancy found in the invoices table with supplier " + row[1] + "."); } } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to write supplier " + row[1] + " into the invoice table."); _logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message); _oleDbConnection.Close(); break; } } _oleDbConnection.Close(); return rowsAdded; } ///

/// Infrastructure for the DatabaseWriter class, not meant to be used with external code; expects an open connection when called. /// ///

/// /// private string InsertSupplier(string supplierName) { double doubleParsedValue; if (supplierName == "") { return "0"; } if(double.TryParse(supplierName, out doubleParsedValue)) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Supplier name cannot be only numeric characters."); return "0"; } var supplierNameId = "0"; var oleDbCommand = new OleDbCommand {CommandText = "INSERT INTO Supplier (SupplierName) VALUES (?)"}; oleDbCommand.Parameters.AddWithValue("SupplierName", supplierName); oleDbCommand.Connection = _oleDbConnection; try { var rowsEffected = oleDbCommand.ExecuteNonQuery(); if (rowsEffected == 1) { oleDbCommand.CommandText = "SELECT ID FROM Supplier WHERE ID = (SELECT MAX(Supplier.ID) FROM Supplier)"; var reader = oleDbCommand.ExecuteReader(); while (reader != null && reader.Read()) { supplierNameId = reader[0].ToString(); } if (reader != null) reader.Close(); } else if (rowsEffected > 1) { //TODO: Clean up the database. } else { _logConsole.WriteToLog(FrmLogConsole.Level.Critical, "Failed to write supplier name " + supplierName + " to the suppliers table."); } } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Critical, "Failed to write supplier name " + supplierName + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message); } return supplierNameId; } ///

/// Infrastructure for the DatabaseWriter class, not meant to be used with external code; expects an open connection when called. /// ///

/// /// /// private bool UpdateInvoice(DataRow invoiceField, string supplierId) { var updateSuccessful = false; var oleDbCommand = new OleDbCommand { CommandText = "UPDATE Invoice SET InvoiceDate = ?, InvoiceNetAmountAtCost = ?, InvoiceNetAmount = ?, InvoiceNote = ? WHERE InvoiceNumber = ? AND FK_Supplier = ? AND FK_DateID = ?" }; oleDbCommand.Parameters.AddWithValue("InvoiceDate", invoiceField[0]); oleDbCommand.Parameters.AddWithValue("InvoiceNetAmountAtCost", invoiceField[3]); oleDbCommand.Parameters.AddWithValue("InvoiceNetAmount", invoiceField[4]); oleDbCommand.Parameters.AddWithValue("InvoiceNote", invoiceField[5]); oleDbCommand.Parameters.AddWithValue("InvoiceNumber", invoiceField[2]); oleDbCommand.Parameters.AddWithValue("SupplierID", supplierId); oleDbCommand.Parameters.AddWithValue("DateID", invoiceField[6]); oleDbCommand.Connection = _oleDbConnection; try { var rowsEffected = oleDbCommand.ExecuteNonQuery(); if (rowsEffected == 1) { updateSuccessful = true; } else { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to update record with invoice number " + invoiceField[2] + " for " + invoiceField[1] + "."); } } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to update invoice record invoice number " + invoiceField[2] + " for supplier " + invoiceField[1] + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message); } return updateSuccessful; } ///

/// ///

/// /// public int RedundantlessInsertIntoWeeklySales(DataRow parameters) { var rowsEffected = 0; var recordsRead = 0; //Object to check for the presence of an entry with the supplied date. var weekEndingDateCheck = new OleDbCommand { CommandText = "SELECT ID FROM WeeklySales WHERE FK_DateID = ?" }; weekEndingDateCheck.Parameters.AddWithValue("DateID", parameters[8]); weekEndingDateCheck.Connection = _oleDbConnection; //Object to update a field with the date supplied, assuming an entry was found with the previous object. var updateWeeklySales = new OleDbCommand { CommandText = "UPDATE WeeklySales SET Sunday = ?, Monday = ?, Tuesday = ?, Wednesday = ?, Thursday = ?, Friday = ?, Saturday = ?, TotalSales = ? WHERE FK_DateID = ?" }; updateWeeklySales.Parameters.AddWithValue("Sunday", parameters[0]); updateWeeklySales.Parameters.AddWithValue("Monday", parameters[1]); updateWeeklySales.Parameters.AddWithValue("Tuesday", parameters[2]); updateWeeklySales.Parameters.AddWithValue("Wednesday", parameters[3]); updateWeeklySales.Parameters.AddWithValue("Thursday", parameters[4]); updateWeeklySales.Parameters.AddWithValue("Friday", parameters[5]); updateWeeklySales.Parameters.AddWithValue("Saturday", parameters[6]); updateWeeklySales.Parameters.AddWithValue("TotalSales", parameters[7]); updateWeeklySales.Parameters.AddWithValue("DateID", parameters[8]); updateWeeklySales.Connection = _oleDbConnection; //Object to insert a new field into the database if no entry is present. var insertWeeklySales = new OleDbCommand { CommandText = "INSERT INTO WeeklySales (Sunday, Monday, Tuesday, Wednesday, Thursday, Friday, Saturday, TotalSales, FK_DateID) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)" }; insertWeeklySales.Parameters.AddWithValue("Sunday", parameters[0]); insertWeeklySales.Parameters.AddWithValue("Monday", parameters[1]); insertWeeklySales.Parameters.AddWithValue("Tuesday", parameters[2]); insertWeeklySales.Parameters.AddWithValue("Wednesday", parameters[3]); insertWeeklySales.Parameters.AddWithValue("Thursday", parameters[4]); insertWeeklySales.Parameters.AddWithValue("Friday", parameters[5]); insertWeeklySales.Parameters.AddWithValue("Saturday", parameters[6]); insertWeeklySales.Parameters.AddWithValue("TotalSales", parameters[7]); insertWeeklySales.Parameters.AddWithValue("DateID", parameters[8]); insertWeeklySales.Connection = _oleDbConnection; try { _oleDbConnection.Open(); //Execute the select statement to check for the presence of an entry with the supplied date (parameters[8]). var reader = weekEndingDateCheck.ExecuteReader(); while (reader != null && reader.Read()) { recordsRead++; } if (reader != null) reader.Close(); //IF there are no records with the date ID then add the current sales into the database. if (recordsRead == 0) { rowsEffected = insertWeeklySales.ExecuteNonQuery(); } //ELSE IF one already exists, then update it with the information provided. else if (recordsRead == 1) { rowsEffected = updateWeeklySales.ExecuteNonQuery(); } //ELSE IF more then one entry is detected, remove all redundant entries and insert the current sales into the database. else if (recordsRead > 1) { //TODO: clean up the redundant entries. } } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error has occurred trying to write the weekly sales to the database."); _logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message); } finally { _oleDbConnection.Close(); } return rowsEffected; } public int RedundantlessInsertIntoGroupCategory(string groupName) { // var rowsEffected = 0; //Setup an object to check for the existence of the group name to be added. var categoryDescCheckQueryCommand = new OleDbCommand { CommandText = "SELECT ID FROM GroupCategory WHERE GroupDescription = ?" }; categoryDescCheckQueryCommand.Parameters.AddWithValue("GroupName", groupName); categoryDescCheckQueryCommand.Connection = _oleDbConnection; //Setting up an object to insert a new ad special keyword. var insertNewCategoryDesc = new OleDbCommand { CommandText = "INSERT INTO GroupCategory (GroupDescription) VALUES (?)" }; insertNewCategoryDesc.Parameters.AddWithValue("GroupName", groupName); insertNewCategoryDesc.Connection = _oleDbConnection; try { _oleDbConnection.Open(); var reader = categoryDescCheckQueryCommand.ExecuteReader(); while (reader != null && reader.Read()) { rowsEffected++; } if (reader != null) reader.Close(); if (rowsEffected == 0) { rowsEffected = insertNewCategoryDesc.ExecuteNonQuery(); if (rowsEffected == 0) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error has occurred trying to insert " + groupName + " into the database."); } } } catch (OleDbException ex) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error has occurred trying to write a new ad special key word to the database."); _logConsole.WriteToLog(FrmLogConsole.Level.Debug, ex.Message); } finally { _oleDbConnection.Close(); } return rowsEffected; } public int RemoveAdSpecialMember(string adSpecialName) { var rowsEffected = 0; var oleDbCommand = new OleDbCommand() { CommandText = "DELETE FROM GroupCategory WHERE GroupDescription = ?" }; oleDbCommand.Parameters.AddWithValue("AdSpecialName", adSpecialName); oleDbCommand.Connection = _oleDbConnection; try { _oleDbConnection.Open(); rowsEffected = oleDbCommand.ExecuteNonQuery(); } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to delete the ad special " + adSpecialName + " from the database."); _logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message); } finally { _oleDbConnection.Close(); } return rowsEffected; } public int RemoveRecord(string adItemId, string dateId) { var recordsDeleted = 0; var deleteCommand = new OleDbCommand { CommandText = "DELETE FROM APC WHERE FK_AdItemID = ? AND FK_DateID = ?" }; deleteCommand.Parameters.AddWithValue("AdItemID", adItemId); deleteCommand.Parameters.AddWithValue("DateID", dateId); deleteCommand.Connection = _oleDbConnection; try { _oleDbConnection.Open(); recordsDeleted = deleteCommand.ExecuteNonQuery(); } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to delete the record with an ad item ID of " + adItemId + " and a date ID of " + dateId + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message); } finally { _oleDbConnection.Close(); } return recordsDeleted; } public int RemoveInvoice(string invoiceNumber, string dateId) { var recordsAffected = 0; var oleDbCommand = new OleDbCommand() { CommandText = "DELETE FROM Invoice WHERE InvoiceNumber = ? AND FK_DateID = ?" }; oleDbCommand.Parameters.AddWithValue("InvoiceNumber", invoiceNumber); oleDbCommand.Parameters.AddWithValue("DateID", dateId); oleDbCommand.Connection = _oleDbConnection; try { _oleDbConnection.Open(); recordsAffected = oleDbCommand.ExecuteNonQuery(); } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to delete invoice number " + invoiceNumber + " with the date ID of " + dateId + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message); } finally { _oleDbConnection.Close(); } return recordsAffected; } ///

/// Removes all records by the date ID passed in, and also removes /// the year's entry from the WeekEnding table. ///

/// The ID of the date to be purged. /// The number of records cleared from the database. public int RemoveAllEntriesAndYearById(string dateId) { var recordsRemoved = 0; //Object to clear the APC records associated with the date ID. var clearApCommand = new OleDbCommand() { CommandText = "DELETE FROM APC WHERE FK_DateID = ?" }; clearApCommand.Parameters.AddWithValue("DateID", dateId); clearApCommand.Connection = _oleDbConnection; //Object to clear comments associated with the date ID. var clearCommentsCommand = new OleDbCommand() { CommandText = "DELETE FROM Comment WHERE FK_DateID = ?" }; clearCommentsCommand.Parameters.AddWithValue("DateID", dateId); clearCommentsCommand.Connection = _oleDbConnection; //Object to clear the invoices associated with the date ID. var clearInvoicesCommand = new OleDbCommand() { CommandText = "DELETE FROM Invoice WHERE FK_DateID = ?" }; clearInvoicesCommand.Parameters.AddWithValue("DateID", dateId); clearInvoicesCommand.Connection = _oleDbConnection; //Object to clear the weekly sales associated with the date ID. var clearWeeklySalesCommand = new OleDbCommand() { CommandText = "DELETE FROM WeeklySales WHERE FK_DateID = ?" }; clearWeeklySalesCommand.Parameters.AddWithValue("DateID", dateId); clearWeeklySalesCommand.Connection = _oleDbConnection; //Object to clear the date associated with the ID passed in. var clearEndOfWeekDateCommand = new OleDbCommand() { CommandText = "DELETE FROM WeekEnding WHERE ID = ?" }; clearEndOfWeekDateCommand.Parameters.AddWithValue("DateID", dateId); clearEndOfWeekDateCommand.Connection = _oleDbConnection; try { _oleDbConnection.Open(); recordsRemoved += clearApCommand.ExecuteNonQuery(); recordsRemoved += clearCommentsCommand.ExecuteNonQuery(); recordsRemoved += clearInvoicesCommand.ExecuteNonQuery(); recordsRemoved += clearWeeklySalesCommand.ExecuteNonQuery(); recordsRemoved += clearEndOfWeekDateCommand.ExecuteNonQuery(); } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "And error has occurred attempting to delete all records associated with the date ID of " + dateId + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message); } finally { _oleDbConnection.Close(); } return recordsRemoved; } ///

/// Updates the comments stored in a particular date. /// TODO: Fix this bug... /// IF the delete command deletes more then one row it returns 0. ///

/// /// /// Returns true if the row is deleted and false if a row fails to be deleted. public bool UpdateCommentsByDateId(string comment, string dateId) { var wasSuccessful = false; var oleDbCommand = new OleDbCommand() { CommandText = "UPDATE Comment SET Comment.Comment = ? WHERE FK_DateID = ?" }; oleDbCommand.Parameters.AddWithValue("Comment", comment); oleDbCommand.Parameters.AddWithValue("DateID", dateId); oleDbCommand.Connection = _oleDbConnection; try { //IF the delete command deletes more then one row it returns 0. _oleDbConnection.Open(); var recordsEffected = oleDbCommand.ExecuteNonQuery(); if (recordsEffected == 1) { wasSuccessful = true; } } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "And error has occurred attempting to update the comments for the date ID of " + dateId + "."); _logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message); } finally { _oleDbConnection.Close(); } return wasSuccessful; } public bool RemoveAdItem(string adItemName) { var success = false; var oleDbCommand = new OleDbCommand { CommandText = "DELETE FROM AdItem WHERE AdItem = ?" }; oleDbCommand.Parameters.AddWithValue("AdItemName", adItemName); oleDbCommand.Connection = _oleDbConnection; try { _oleDbConnection.Open(); var rowsEffected = oleDbCommand.ExecuteNonQuery(); if(rowsEffected == 1) { success = true; } else if(rowsEffected > 1) { _logConsole.WriteToLog(FrmLogConsole.Level.Info, "Removed redundant entry " + adItemName + " from the database successfully."); success = true; } else { } } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to delete the ad item " + adItemName + " from the database."); _logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message); } finally { _oleDbConnection.Close(); } return success; } public bool AddNewItem(string adItemName) { var success = false; var oleDbCommand = new OleDbCommand { CommandText = "INSERT INTO AdItem (AdItem) VALUES (?)" }; oleDbCommand.Parameters.AddWithValue("AdItemName", adItemName); oleDbCommand.Connection = _oleDbConnection; var redundantancyCheck = new OleDbCommand { CommandText = "SELECT AdItem FROM AdItem WHERE AdItem = ?" }; redundantancyCheck.Parameters.AddWithValue("AdItemName", adItemName); redundantancyCheck.Connection = _oleDbConnection; try { _oleDbConnection.Open(); using(var reader = redundantancyCheck.ExecuteReader()) { var rows = 0; while(reader != null && reader.Read()) { rows++; } if(rows == 0) { var rowsEffected = oleDbCommand.ExecuteNonQuery(); if (rowsEffected == 1) { success = true; } else { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to insert new ad item " + adItemName + "."); } } else { success = true; _logConsole.WriteToLog(FrmLogConsole.Level.Debug, "Ad Item " + adItemName + " found with " + rows + " row(s)."); } } } catch (OleDbException e) { _logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to add the new ad item " + adItemName + " to the database."); _logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message); } finally { _oleDbConnection.Close(); } return success; } } }